refactor(ocme): changes in the pickup to no longer handle all but specific area

server/services/ocme/controller/pickedup.ts

@@ -10,20 +10,43 @@ export const pickedup = async (data: any) => {
 
     if (!data.sscc && !data.runningNr) {
         // data.runningNr = data.sscc.slice(10, -1);
-        return {success: false, message: "Missing data please try again", data: []};
+        return {
+            success: false,
+            message: "Missing data please try again",
+            data: [],
+        };
     }
 
-    if (data.all) {
+    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.`);
+            createLog(
-            return {success: true, message: `Pending pallets were just cleared out.`, data: updateRn};
+                "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.`);
+            createLog(
-            return {success: false, message: `Error clearing out the pallets.`, error};
+                "error",
+                "ocme",
+                "ocme",
+                `Error clearing out the pallets.`
+            );
+            return {
+                success: false,
+                message: `Error clearing out the pallets.`,
+                error,
+            };
         }
     }
 
@@ -33,10 +56,28 @@ export const pickedup = async (data: any) => {
             .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`);
+        createLog(
-        return {success: true, message: `${parseInt(data.runningNr)} was just pickedup`, data: updateRn};
+            "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`);
+        createLog(
-        return {success: false, message: `${parseInt(data.runningNr)} was not pickedup`, error};
+            "error",
+            "ocme",
+            "ocme",
+            `${parseInt(data.runningNr)} was just pickedup`
+        );
+        return {
+            success: false,
+            message: `${parseInt(data.runningNr)} was not pickedup`,
+            error,
+        };
     }
 };