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};
    }
};