feat(new command): helper command to remove as non reusable pallets

server/services/logistics/controller/commands/removeAsNonReusable.ts

@@ -0,0 +1,120 @@
+import axios from "axios";
+import { commandLog } from "../../../../../database/schema/commandLog.js";
+import { prodEndpointCreation } from "../../../../globalUtils/createUrl.js";
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { lstAuth } from "../../../../index.js";
+import { createSSCC } from "../../../../globalUtils/createSSCC.js";
+import { db } from "../../../../../database/dbclient.js";
+import net from "net";
+import { query } from "../../../sqlServer/prodSqlServer.js";
+import { labelInfo } from "../../../sqlServer/querys/warehouse/labelInfo.js";
+import { settings } from "../../../../../database/schema/settings.js";
+import { eq } from "drizzle-orm";
+import { serverData } from "../../../../../database/schema/serverData.js";
+export const removeAsNonReusable = async (data: any) => {
+    // const removalUrl = await prodEndpointCreation(
+    //     "/public/v1.0/Warehousing/RemoveAsNonReusableMaterial"
+    // );
+
+    // const sscc = await createSSCC(data.runningNr);
+
+    // const { data: remove, error } = await tryCatch(
+    //     axios.post(
+    //         removalUrl,
+    //         { scannerId: "500", sscc: sscc.slice(2) },
+    //         {
+    //             headers: { Authorization: `Basic ${lstAuth}` },
+    //         }
+    //     )
+    // );
+
+    // use a scanner tcp connection to trigger this process
+    const STX = "\x02";
+    const ETX = "\x03";
+    const scanner = new net.Socket();
+    let stage = 0;
+    // get the label info
+    const { data: label, error: labelError } = (await tryCatch(
+        query(labelInfo.replaceAll("[runningNr]", data.runningNr), "Label Info")
+    )) as any;
+
+    if (label.data[0].stockStatus === "notOnStock") {
+        return {
+            success: false,
+            message: `The label: ${data.runningNr} is not currently in stock`,
+            data: [],
+        };
+    }
+
+    // get the server ip based on the token.
+    const setting = await db.select().from(settings);
+
+    const plantInfo = await db.select().from(serverData);
+    const plantToken = setting.filter((n: any) => n.name === "plantToken");
+    const scannerID = setting.filter((n: any) => n.name === "scannerID");
+    const scannerPort = setting.filter((n: any) => n.name === "scannerPort");
+    const plantData = plantInfo.filter(
+        (p: any) => p.plantToken === plantToken[0].value
+    );
+
+    scanner.connect(
+        parseInt(scannerPort[0].value),
+        plantData[0].idAddress!,
+        async () => {
+            // need to get the ip from the server data and scanner port
+            //console.log(`connected to scanner`);
+            scanner.write(`${STX}${scannerID[0].value}@AlplaPRODcmd23${ETX}`);
+        }
+    );
+    scanner.on("data", (data) => {
+        const response = data.toString();
+        //console.log("Received:", response.trimStart());
+        if (stage === 0) {
+            stage = 1;
+            scanner.write(
+                `${STX}${scannerID[0].value}${label.data[0].Barcode}${ETX}`
+            );
+        } else if (stage === 1) {
+            scanner.end();
+        }
+    });
+    scanner.on("close", () => {
+        //console.log("Connection closed");
+        scanner.destroy();
+    });
+    scanner.on("error", (err) => {
+        //console.error("Scanner error:", err);
+        scanner.destroy();
+        return {
+            success: false,
+            message: `The label: ${data.runningNr} encountering an error while being removed, please try again`,
+            data: [],
+        };
+    });
+
+    // if (error) {
+    //     //console.log(error);
+    //     return {
+    //         success: false,
+    //         message: `There was an error removing ${data.runningNr}`,
+    //         data: [],
+    //     };
+    // }
+
+    let reason = data.reason || "";
+    delete data.reason;
+
+    const { data: commandL, error: ce } = await tryCatch(
+        db.insert(commandLog).values({
+            commandUsed: "removeAsNonReusable",
+            bodySent: data,
+            reasonUsed: reason,
+        })
+    );
+
+    return {
+        success: true,
+        message: `The label: ${data.runningNr}, was removed`,
+        data: [],
+    };
+};

server/services/logistics/logisticsService.ts

@@ -19,6 +19,7 @@ import outbound from "./route/getOutbound.js";
 import { runHistoricalData } from "./controller/eom/historicalInv.js";
 import intervalChecks from "./route/getActiveLogistics.js";
 import getActiveLanes from "./route/getActiveLanes.js";
+import removeAsNonReable from "./route/removeAsNonReusable.js";
 
 const app = new OpenAPIHono();
 
@@ -45,6 +46,9 @@ const routes = [
     // outbound deliveries
     outbound,
     intervalChecks,
+
+    // logisitcs
+    removeAsNonReable,
 ] as const;
 
 // app.route("/server", modules);

server/services/ocp/routes/labeling/bookIn.ts

@@ -6,6 +6,8 @@ import { labelingProcess } from "../../controller/labeling/labelProcess.js";
 import { bookInLabel } from "../../controller/labeling/bookIn.js";
 import { createSSCC } from "../../../../globalUtils/createSSCC.js";
 import { apiHit } from "../../../../globalUtils/apiHits.js";
+import { db } from "../../../../../database/dbclient.js";
+import { commandLog } from "../../../../../database/schema/commandLog.js";
 
 const app = new OpenAPIHono({ strict: false });
 
@@ -49,6 +51,13 @@ app.openapi(
         const newLabel: any = bookinLabel;
         //console.log(newLabel);
 
+        const { data: commandL, error: ce } = await tryCatch(
+            db.insert(commandLog).values({
+                commandUsed: "bookin",
+                bodySent: bodyData,
+            })
+        );
+
         return c.json({
             success: newLabel.success,
             message: newLabel.message,

server/services/server/utils/settingsCheck.ts

@@ -222,6 +222,20 @@ const newSettings = [
         serviceBelowsTo: "dm",
         roleToChange: "admin",
     },
+    {
+        name: "scannerID",
+        value: `500`,
+        description: "What scanner id will we be using for the app",
+        serviceBelowsTo: "logistics",
+        roleToChange: "admin",
+    },
+    {
+        name: "scannerPort",
+        value: `50002`,
+        description: "What port instance will we be using?",
+        serviceBelowsTo: "logistics",
+        roleToChange: "admin",
+    },
     // temp settings can be deleted at a later date once that code is removed
     {
         name: "siloAdjMigrations",

server/services/sqlServer/querys/warehouse/labelInfo.ts

@@ -0,0 +1,20 @@
+export const labelInfo = `
+select top(500) e.Barcode, 
+e.IdArtikelvarianten as av,
+e.lfdnr as rn,
+IdEtikettenLayout as labelLayout,
+AnzStkJePalette,
+Sonstiges_9,AnzStkJeKarton
+,case when EinlagerungsMengeSum IS NULL then 'notOnStock' else 'onStock' end as stockStatus
+,EinlagerungsMengeSum
+--,*
+from [AlplaPROD_test1].dbo.[T_EtikettenGedruckt] e (nolock)
+
+left join
+[AlplaPROD_test1].dbo.V_LagerPositionenBarcodes as l on
+e.LfdNr = l.Lfdnr
+
+where e.LfdNr in ([runningNr])
+
+order by add_date desc
+`;