From 353960bd267e55b24c59a4a654cc37411c9986c7 Mon Sep 17 00:00:00 2001
From: Blake Matthes <cowchmonkey@gmail.com>
Date: Wed, 11 Jun 2025 20:50:43 -0500
Subject: [PATCH] feat(new command): helper command to remove as non reusable
 pallets

---
 .../commands/RemoveAsNonReusable.tsx          | 138 ++++++++++++++++++
 .../logistics/helperCommands/helperPage.tsx   |  11 +-
 .../commands/removeAsNonReusable.ts           | 120 +++++++++++++++
 server/services/logistics/logisticsService.ts |   4 +
 server/services/ocp/routes/labeling/bookIn.ts |   9 ++
 server/services/server/utils/settingsCheck.ts |  14 ++
 .../sqlServer/querys/warehouse/labelInfo.ts   |  20 +++
 7 files changed, 314 insertions(+), 2 deletions(-)
 create mode 100644 frontend/src/components/logistics/helperCommands/commands/RemoveAsNonReusable.tsx
 create mode 100644 server/services/logistics/controller/commands/removeAsNonReusable.ts
 create mode 100644 server/services/sqlServer/querys/warehouse/labelInfo.ts

diff --git a/frontend/src/components/logistics/helperCommands/commands/RemoveAsNonReusable.tsx b/frontend/src/components/logistics/helperCommands/commands/RemoveAsNonReusable.tsx
new file mode 100644
index 0000000..67a825f
--- /dev/null
+++ b/frontend/src/components/logistics/helperCommands/commands/RemoveAsNonReusable.tsx
@@ -0,0 +1,138 @@
+import { LstCard } from "@/components/extendedUI/LstCard";
+import { Button } from "@/components/ui/button";
+import { CardContent, CardHeader } from "@/components/ui/card";
+import { Input } from "@/components/ui/input";
+import { Label } from "@/components/ui/label";
+import { Textarea } from "@/components/ui/textarea";
+import { useForm } from "@tanstack/react-form";
+import axios from "axios";
+import { useState } from "react";
+import { toast } from "sonner";
+
+export default function RemoveAsNonReusable() {
+    const [stockOut, setStockOut] = useState(false);
+    const form = useForm({
+        defaultValues: { runningNr: " ", reason: " " },
+        onSubmit: async ({ value }) => {
+            // Do something with form data
+            setStockOut(true);
+
+            //console.log(value);
+
+            try {
+                const res = await axios.post(
+                    "/api/logistics/removeasreusable",
+
+                    value // this is basically the data field
+                );
+
+                if (res.data.success) {
+                    toast.success(res.data.message);
+                    form.reset();
+                    setStockOut(false);
+                } else {
+                    console.log(res.data);
+                    toast.error(res.data?.message);
+                    form.reset();
+                    setStockOut(false);
+                }
+            } catch (error: any) {
+                console.log(error);
+                toast.error(error.message);
+                setStockOut(false);
+            }
+        },
+    });
+    return (
+        <LstCard>
+            <CardHeader>
+                <p>Remove a pallet as non reusable</p>
+            </CardHeader>
+            <form
+                onSubmit={(e) => {
+                    e.preventDefault();
+                    e.stopPropagation();
+                }}
+            >
+                <CardContent>
+                    <form.Field
+                        name="runningNr"
+                        validators={{
+                            // We can choose between form-wide and field-specific validators
+                            onChange: ({ value }) =>
+                                value.length > 2
+                                    ? undefined
+                                    : "Please enter a valid running number",
+                        }}
+                        children={(field) => {
+                            return (
+                                <div className="w-96">
+                                    <Label htmlFor="runningNr" className="mb-2">
+                                        Runnning Number
+                                    </Label>
+                                    <Input
+                                        name={field.name}
+                                        value={field.state.value}
+                                        onBlur={field.handleBlur}
+                                        required
+                                        type="number"
+                                        onChange={(e) =>
+                                            field.handleChange(e.target.value)
+                                        }
+                                    />
+                                    {field.state.meta.errors.length ? (
+                                        <em>
+                                            {field.state.meta.errors.join(",")}
+                                        </em>
+                                    ) : null}
+                                </div>
+                            );
+                        }}
+                    />
+                    <form.Field
+                        name="reason"
+                        validators={{
+                            // We can choose between form-wide and field-specific validators
+                            onChange: ({ value }) =>
+                                value.length > 10
+                                    ? undefined
+                                    : "Please enter a valid reason on why you needed to remove this pallet",
+                        }}
+                        children={(field) => {
+                            return (
+                                <div className="">
+                                    <Label htmlFor="reason" className="mb-2">
+                                        Reason for removing
+                                    </Label>
+                                    <Textarea
+                                        name={field.name}
+                                        value={field.state.value}
+                                        onBlur={field.handleBlur}
+                                        //type="number"
+                                        onChange={(e) =>
+                                            field.handleChange(e.target.value)
+                                        }
+                                    />
+                                    {field.state.meta.errors.length ? (
+                                        <div className="text-pretty max-w-96">
+                                            <em>
+                                                {field.state.meta.errors.join(
+                                                    ","
+                                                )}
+                                            </em>
+                                        </div>
+                                    ) : null}
+                                </div>
+                            );
+                        }}
+                    />
+                    <div className="flex mt-2 justify-end">
+                        <Button onClick={form.handleSubmit} disabled={stockOut}>
+                            Remove
+                        </Button>
+                    </div>
+                </CardContent>
+            </form>
+        </LstCard>
+    );
+}
diff --git a/frontend/src/components/logistics/helperCommands/helperPage.tsx b/frontend/src/components/logistics/helperCommands/helperPage.tsx
index b46de24..d403a11 100644
--- a/frontend/src/components/logistics/helperCommands/helperPage.tsx
+++ b/frontend/src/components/logistics/helperCommands/helperPage.tsx
@@ -1,9 +1,16 @@
 import Bookin from "./commands/Bookin";
+import RemoveAsNonReusable from "./commands/RemoveAsNonReusable";
 
 export default function HelperPage() {
     return (
-        <div>
-            <Bookin />
+        <div className="flex flex-wrap m-2 justify-center">
+            <div className="m-1">
+                <Bookin />
+            </div>
+
+            <div className="m-1">
+                <RemoveAsNonReusable />
+            </div>
         </div>
     );
 }
diff --git a/server/services/logistics/controller/commands/removeAsNonReusable.ts b/server/services/logistics/controller/commands/removeAsNonReusable.ts
new file mode 100644
index 0000000..cc0d570
--- /dev/null
+++ b/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: [],
+    };
+};
diff --git a/server/services/logistics/logisticsService.ts b/server/services/logistics/logisticsService.ts
index c4dc6af..a42ec0b 100644
--- a/server/services/logistics/logisticsService.ts
+++ b/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);
diff --git a/server/services/ocp/routes/labeling/bookIn.ts b/server/services/ocp/routes/labeling/bookIn.ts
index 903d4f3..4e61879 100644
--- a/server/services/ocp/routes/labeling/bookIn.ts
+++ b/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,
diff --git a/server/services/server/utils/settingsCheck.ts b/server/services/server/utils/settingsCheck.ts
index abb3be1..245da17 100644
--- a/server/services/server/utils/settingsCheck.ts
+++ b/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",
diff --git a/server/services/sqlServer/querys/warehouse/labelInfo.ts b/server/services/sqlServer/querys/warehouse/labelInfo.ts
new file mode 100644
index 0000000..cb07a53
--- /dev/null
+++ b/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
+`;