From 1bcb4db32878d5f270197791782b43d277c58158 Mon Sep 17 00:00:00 2001
From: Blake Matthes <cowchmonkey@gmail.com>
Date: Mon, 10 Mar 2025 16:33:24 -0500
Subject: [PATCH] feat(ocme): added in picked up and included a all function to
 reduce endpoints

---
 server/services/ocme/controller/pickedup.ts | 42 +++++++++++++++++++++
 1 file changed, 42 insertions(+)
 create mode 100644 server/services/ocme/controller/pickedup.ts

diff --git a/server/services/ocme/controller/pickedup.ts b/server/services/ocme/controller/pickedup.ts
new file mode 100644
index 0000000..2fddf40
--- /dev/null
+++ b/server/services/ocme/controller/pickedup.ts
@@ -0,0 +1,42 @@
+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};
+    }
+};