84 lines
2.4 KiB
TypeScript
84 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: [],
|
|
};
|
|
}
|
|
|
|
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,
|
|
};
|
|
}
|
|
};
|