Files

86 lines
2.4 KiB
TypeScript

import { eq, sql } from "drizzle-orm";
import { db } from "../../../../database/dbclient.js";
import { ocmeData } from "../../../../database/schema/ocme.js";
import { createLog, logLevel } from "../../logger/logger.js";
export const pickedup = async (data: any) => {
if (data.sscc && !data.runningNr) {
data.runningNr = data.sscc.slice(10, -1);
}
if (!data.sscc && !data.runningNr) {
// data.runningNr = data.sscc.slice(10, -1);
return {
success: false,
message: "Missing data please try again",
data: [],
};
}
console.log(data);
if (data.areaFrom) {
try {
const updateRn = await db
.update(ocmeData)
.set({ pickedUp: true, upd_date: sql`NOW()` })
.where(eq(ocmeData.areaFrom, data.areaFrom))
.returning({ runningNr: ocmeData.runningNr });
createLog(
"info",
"ocme",
"ocme",
`Pending pallets were just cleared out.`
);
return {
success: true,
message: `Pending pallets were just cleared out.`,
data: updateRn,
};
} catch (error) {
createLog(
"error",
"ocme",
"ocme",
`Error clearing out the pallets.`
);
return {
success: false,
message: `Error clearing out the pallets.`,
error,
};
}
}
try {
const updateRn = await db
.update(ocmeData)
.set({ pickedUp: true, upd_date: sql`NOW()` })
.where(eq(ocmeData.runningNr, data.runningNr))
.returning({ runningNr: ocmeData.runningNr });
createLog(
"info",
"ocme",
"ocme",
`${parseInt(data.runningNr)} was just pickedup`
);
return {
success: true,
message: `${parseInt(data.runningNr)} was just pickedup`,
data: updateRn,
};
} catch (error) {
createLog(
"error",
"ocme",
"ocme",
`${parseInt(data.runningNr)} was just pickedup`
);
return {
success: false,
message: `${parseInt(data.runningNr)} was not pickedup`,
error,
};
}
};