43 lines
1.8 KiB
TypeScript
43 lines
1.8 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.all) {
|
|
try {
|
|
const updateRn = await db
|
|
.update(ocmeData)
|
|
.set({pickedUp: true, upd_date: sql`NOW()`})
|
|
.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};
|
|
}
|
|
};
|