test(materials per day): work on getting this running better

LogisticsSupportTool_API_DOCS/environments/lst.bru

@@ -1,7 +1,7 @@
 vars {
   url: http://localhost:4200
   session_cookie: 
-  urlv2: http://localhost:3000
+  urlv2: http://usmcd1vms036:3000
   jwtV2: 
   userID: 
 }

frontend/src/lib/authClient.ts

@@ -26,7 +26,8 @@ export type UserRoles = {
 		| "supervisor"
 		| "manager"
 		| "admin"
-		| "systemAdmin";
+		| "systemAdmin"
+		| "user";
 };
 
 type UserRoleState = {

frontend/src/lib/tableStuff/TableNoExpand.tsx

@@ -42,8 +42,8 @@ export default function TableNoExpand({
 	});
 	return (
 		<div className="p-4">
-			<ScrollArea className="w-11/12 rounded-md border whitespace-nowrap">
-				<Table>
+			<Table className="table-fixed w-full">
+				<ScrollArea className="w-full rounded-md border whitespace-nowrap">
 					<TableHeader>
 						{table.getHeaderGroups().map((headerGroup) => (
 							<TableRow key={headerGroup.id}>
@@ -89,7 +89,10 @@ export default function TableNoExpand({
 							</React.Fragment>
 						))}
 					</TableBody>
+					<ScrollBar orientation="horizontal" />
+				</ScrollArea>
 			</Table>
+
 			<div className="flex items-center justify-end space-x-2 py-4">
 				<Button
 					variant="outline"
@@ -108,8 +111,6 @@ export default function TableNoExpand({
 					Next
 				</Button>
 			</div>
-				<ScrollBar orientation="horizontal" />
-			</ScrollArea>
 		</div>
 	);
 }

frontend/src/routes/_old/old/(logistics)/siloAdjustments/index.tsx

@@ -7,7 +7,13 @@ export const Route = createFileRoute("/_old/old/(logistics)/siloAdjustments/")({
 	component: RouteComponent,
 	beforeLoad: async () => {
 		const auth = await checkUserAccess({
-			allowedRoles: ["systemAdmin", "technician", "admin", "manager"],
+			allowedRoles: [
+				"systemAdmin",
+				"technician",
+				"admin",
+				"manager",
+				"supervisor",
+			],
 			moduleName: "siloAdjustments", // optional
 		});
 

frontend/src/routes/_old/old/-components/logistics/warehouse/PPOOCard.tsx

@@ -1,9 +1,10 @@
 //import { LstCard } from "@/components/extendedUI/LstCard";
 
 import { useQuery } from "@tanstack/react-query";
+import { LstCard } from "@/components/ui/lstCard";
+import TableNoExpand from "@/lib/tableStuff/TableNoExpand";
 import { getPPOO } from "../../../-utils/querys/logistics/getPPOO";
 import { columns } from "../../../-utils/tableData/ppoo/ppooColumns";
-import { PPOOTable } from "../../../-utils/tableData/ppoo/ppooData";
 //import { CircleX } from "lucide-react";
 //import { Suspense } from "react";
 //import { toast } from "sonner";
@@ -12,7 +13,7 @@ export default function PPOO() {
 	//{ style = {} }
 	const { data, isError, isLoading } = useQuery(getPPOO());
 
-	if (isLoading) return <div>Loading adjustmnet data...</div>;
+	if (isLoading) return <div>Loading adjustments data...</div>;
 	if (isError) {
 		return (
 			<div>
@@ -28,11 +29,15 @@ export default function PPOO() {
 	// };
 
 	return (
-		<PPOOTable
+		<>
+			<LstCard className="">
+				<TableNoExpand
 					columns={columns}
 					data={data}
 					//style={style}
 				/>
+			</LstCard>
+		</>
 	);
 	// return (
 	//     <div style={style}>

frontend/src/routes/_old/old/quality/-components/QualityRequest.tsx

@@ -2,14 +2,16 @@ import { useQuery } from "@tanstack/react-query";
 import { useNavigate, useRouterState } from "@tanstack/react-router";
 import { createColumnHelper } from "@tanstack/react-table";
 import axios from "axios";
-import { ArrowDown, ArrowUp } from "lucide-react";
+import { ArrowDown, ArrowUp, Trash2 } from "lucide-react";
 import { useState } from "react";
 import { toast } from "sonner";
 import { Button } from "@/components/ui/button";
 import {
 	Select,
 	SelectContent,
+	SelectGroup,
 	SelectItem,
+	SelectLabel,
 	SelectTrigger,
 	SelectValue,
 } from "@/components/ui/select";
@@ -30,7 +32,6 @@ type Pallets = {
 	durationToMove: null;
 	qualityDurationToInspect: number;
 	returnDurationToInspect: number;
-	locationMovesTo: string;
 	locationDropOff: string;
 	palletStatus: number;
 	palletStatusText: string;
@@ -40,6 +41,8 @@ type Pallets = {
 	add_user: string;
 	upd_date: Date;
 	upd_user: string;
+	palletComplete: string;
+	canceled: string;
 };
 
 export default function QualityRequest() {
@@ -50,35 +53,35 @@ export default function QualityRequest() {
 	const router = useRouterState();
 	const currentPath = router.location.href;
 
-	const palletCompleted = async (e: any) => {
-		if (!session || !session.user) {
-			toast.error("You are allowed to do this unless you are logged in");
-			navigate({ to: "/login", search: { redirect: currentPath } });
-			return;
-		}
-		const data = {
-			username: session?.user.username,
-			runningNr: Number(e.original.runningNr),
-			palletStatusText: "return",
-		};
-		try {
-			const res = await axios.post("/lst/old/api/quality/newrequest", data);
+	// const palletCompleted = async (e: any) => {
+	// 	if (!session || !session.user) {
+	// 		toast.error("You are allowed to do this unless you are logged in");
+	// 		navigate({ to: "/login", search: { redirect: currentPath } });
+	// 		return;
+	// 	}
+	// 	const data = {
+	// 		username: session?.user.username,
+	// 		runningNr: Number(e.original.runningNr),
+	// 		palletStatusText: "return",
+	// 	};
+	// 	try {
+	// 		const res = await axios.post("/lst/old/api/quality/newrequest", data);
 
-			//console.log(res.data);
+	// 		//console.log(res.data);
 
-			if (res.data.success) {
-				toast.success(res.data.message);
-				refetch();
-			}
+	// 		if (res.data.success) {
+	// 			toast.success(res.data.message);
+	// 			refetch();
+	// 		}
 
-			if (!res.data.success) {
-				toast.error(res.data.message);
-			}
-		} catch (error) {
-			console.log(error);
-			toast.error("Encountered and error please try again");
-		}
-	};
+	// 		if (!res.data.success) {
+	// 			toast.error(res.data.message);
+	// 		}
+	// 	} catch (error) {
+	// 		console.log(error);
+	// 		toast.error("Encountered and error please try again");
+	// 	}
+	// };
 
 	const columns = [
 		columnHelper.accessor("article", {
@@ -166,14 +169,14 @@ export default function QualityRequest() {
 				);
 			},
 		}),
-		columnHelper.accessor("locationMovesTo", {
+		columnHelper.accessor("locationMovedTo", {
 			header: ({ column }) => {
 				return (
 					<Button
 						variant="ghost"
 						onClick={() => column.toggleSorting(column.getIsSorted() === "asc")}
 					>
-						<span className="flex flex-row gap-2">Location At Request</span>
+						<span className="flex flex-row gap-2">Location Moved to</span>
 						{column.getIsSorted() === "asc" ? (
 							<ArrowUp className="ml-2 h-4 w-4" />
 						) : (
@@ -227,7 +230,7 @@ export default function QualityRequest() {
 				);
 			},
 		}),
-		columnHelper.accessor("palletRequest", {
+		columnHelper.accessor("palletComplete", {
 			header: ({ column }) => {
 				return (
 					<Button
@@ -245,15 +248,78 @@ export default function QualityRequest() {
 			},
 			cell: ({ row }) => {
 				// if pending
+
+				//const [p, setP] = useState(`${getValue()}`);
 				const okToCompleteStats = [2, 4, 5];
 				return (
 					<>
 						{okToCompleteStats.includes(row.original.palletStatus) ? (
-							<Button variant="outline" onClick={() => palletCompleted(row)}>
-								Check Complete
-							</Button>
+							<Select
+								//value={"return to warehouse"}
+								onValueChange={async (value) => {
+									if (!session || !session.user) {
+										toast.error(
+											"You are allowed to do this unless you are logged in",
+										);
+										navigate({
+											to: "/login",
+											search: { redirect: currentPath },
+										});
+										return;
+									}
+
+									const data = {
+										username: session?.user.username,
+										runningNr: Number(row.original.runningNr),
+										palletStatusText: value,
+									};
+
+									try {
+										const res = await axios.post(
+											"/lst/old/api/quality/newrequest",
+											data,
+										);
+
+										//console.log(res.data);
+
+										if (res.data.success) {
+											toast.success(res.data.message);
+											refetch();
+										}
+
+										if (!res.data.success) {
+											toast.error(res.data.message);
+										}
+									} catch (error) {
+										console.log(error);
+										toast.error("Encountered and error please try again");
+									}
+								}}
+							>
+								<SelectTrigger
+								// className={cn(
+								// 	"w-[100px]",
+								// 	active
+								// 		? "border-green-500 text-green-600"
+								// 		: "border-gray-400 text-gray-500",
+								// )}
+								>
+									<SelectValue placeholder="Complete Selection" />
+								</SelectTrigger>
+								<SelectContent>
+									<SelectGroup>
+										<SelectLabel>Location to drop off</SelectLabel>
+										<SelectItem value="return to warehouse">
+											Return to Warehouse
+										</SelectItem>
+										<SelectItem value="rework">Rework</SelectItem>
+										<SelectItem value="grind">Grind</SelectItem>
+										<SelectItem value="scrap">Scrap</SelectItem>
+									</SelectGroup>
+								</SelectContent>
+							</Select>
 						) : (
-							<span>Pending to be completed</span>
+							<span>Pending move</span>
 						)}
 					</>
 				);
@@ -262,7 +328,9 @@ export default function QualityRequest() {
 	];
 
 	let adminColumns: any = [];
-	if (userAccess("quality", ["systemAdmin", "admin", "supervisor"])) {
+	if (
+		userAccess("quality", ["systemAdmin", "admin", "supervisor", "manager"])
+	) {
 		adminColumns = [
 			...columns,
 			columnHelper.accessor("priority", {
@@ -287,7 +355,6 @@ export default function QualityRequest() {
 					// if pending
 
 					const [p, setP] = useState(`${getValue()}`);
-					console.log(getValue());
 					return (
 						<>
 							<Select
@@ -343,6 +410,78 @@ export default function QualityRequest() {
 					);
 				},
 			}),
+			columnHelper.accessor("palletComplete", {
+				header: ({ column }) => {
+					return (
+						<Button
+							variant="ghost"
+							onClick={() =>
+								column.toggleSorting(column.getIsSorted() === "asc")
+							}
+						>
+							<span className="flex flex-row gap-2">Cancel</span>
+							{column.getIsSorted() === "asc" ? (
+								<ArrowUp className="ml-2 h-4 w-4" />
+							) : (
+								<ArrowDown className="ml-2 h-4 w-4" />
+							)}
+						</Button>
+					);
+				},
+				cell: ({ row }) => {
+					return (
+						<>
+							<Button
+								//value={"return to warehouse"}
+								variant="destructive"
+								onClick={async () => {
+									if (!session || !session.user) {
+										toast.error(
+											"You are allowed to do this unless you are logged in",
+										);
+										navigate({
+											to: "/login",
+											search: { redirect: currentPath },
+										});
+										return;
+									}
+
+									const data = {
+										username: session?.user.username,
+										runningNr: Number(row.original.runningNr),
+										palletStatusText: "canceled",
+									};
+
+									try {
+										const res = await axios.post(
+											"/lst/old/api/quality/newrequest",
+											data,
+										);
+
+										//console.log(res.data);
+
+										if (res.data.success) {
+											toast.success(
+												`${row.original.runningNr} was just canceled`,
+											);
+											refetch();
+										}
+
+										if (!res.data.success) {
+											toast.error(res.data.message);
+										}
+									} catch (error) {
+										console.log(error);
+										toast.error("Encountered and error please try again");
+									}
+								}}
+							>
+								<Trash2 className="w-[24px] h-[24px]" />
+							</Button>
+						</>
+					);
+				},
+			}),
 		];
 	}
 	if (isLoading) {

frontend/src/routes/_old/old/quality/-components/WarehouseCard.tsx

@@ -46,6 +46,7 @@ export default function PPOO() {
 					<Button
 						variant="ghost"
 						onClick={() => column.toggleSorting(column.getIsSorted() === "asc")}
+						className="w-16 ml-1"
 					>
 						<span className="flex flex-row gap-2">Article</span>
 						{column.getIsSorted() === "asc" ? (
@@ -63,6 +64,7 @@ export default function PPOO() {
 					<Button
 						variant="ghost"
 						onClick={() => column.toggleSorting(column.getIsSorted() === "asc")}
+						className="w-16 ml-1"
 					>
 						<span className="flex flex-row gap-2">Running Number</span>
 						{column.getIsSorted() === "asc" ? (
@@ -80,6 +82,7 @@ export default function PPOO() {
 					<Button
 						variant="ghost"
 						onClick={() => column.toggleSorting(column.getIsSorted() === "asc")}
+						className="w-16 ml-1"
 					>
 						<span className="flex flex-row gap-2">Location</span>
 						{column.getIsSorted() === "asc" ? (
@@ -97,8 +100,9 @@ export default function PPOO() {
 					<Button
 						variant="ghost"
 						onClick={() => column.toggleSorting(column.getIsSorted() === "asc")}
+						className="w-16 ml-1"
 					>
-						<span className="flex flex-row gap-2">Drop off at</span>
+						<span className="flex flex-row gap-1">Drop off at</span>
 						{column.getIsSorted() === "asc" ? (
 							<ArrowUp className="ml-2 h-4 w-4" />
 						) : (
@@ -111,7 +115,7 @@ export default function PPOO() {
 	];
 
 	return (
-		<LstCard className="w-fit">
+		<LstCard className="w-5/6">
 			<CardHeader>
 				Quality Request Card Total Pallets {filteredData.length}
 			</CardHeader>

frontend/src/routes/_old/old/quality/index.tsx

@@ -13,6 +13,7 @@ export const Route = createFileRoute("/_old/old/quality/")({
 				"admin",
 				"manager",
 				"supervisor",
+				"user",
 			],
 			moduleName: "quality", // optional
 		});

lstV2/server/services/notifications/controller/materialsPerDay/materialPerDay.ts

@@ -9,11 +9,14 @@ import {
 import { db } from "../../../../../database/dbclient.js";
 import { invHistoricalData } from "../../../../../database/schema/historicalINV.js";
 import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { createLog } from "../../../logger/logger.js";
 import { query } from "../../../sqlServer/prodSqlServer.js";
 import {
 	materialPerDay,
 	materialPurchasesPerDay,
 } from "../../../sqlServer/querys/dataMart/materialPerDay.js";
+import { singleArticle } from "../../../sqlServer/querys/misc/singleArticle.js";
+import { sendEmail } from "../sendMail.js";
 import { materialPurchases } from "./materialPurchases.js";
 import { buildInventoryTimeline } from "./materialWithInv.js";
 
@@ -99,43 +102,77 @@ export default async function materialPerDayCheck() {
 
 	// purchases
 
-	const { data: p, error: pe } = (await tryCatch(
-		query(
-			materialPurchasesPerDay
-				.replace("[startDate]", startDate)
-				.replace("[endDate]", endDate),
-			"material check",
-		),
-	)) as any;
-
-	if (error) {
-		return {
-			success: false,
-			message: "Error getting the material data",
-			error,
-		};
-	}
-
-	if (!data.success) {
-		return {
-			success: false,
-			message: data.message,
-			data: [],
-		};
-	}
+	const pOrders = (await materialPurchases({ startDate, endDate })) as any;
 
+	//console.log(pOrders);
 	const openingInventory: Record<string, number> = {};
 	const inventoryRows = await getInv();
 	for (const row of inventoryRows) {
 		openingInventory[row.article] = Number(row.total_QTY) || 0;
 	}
 
+	const materialsDemand = buildInventoryTimeline(
+		sumByMaterialAndWeek(data.data) as any,
+		openingInventory,
+		pOrders,
+	);
+
+	const { data: av, error: eav } = await tryCatch(
+		query(singleArticle.replace("[av]", "107"), "single article"),
+	);
+
+	const formattedMaterials = materialsDemand
+		.filter((n) => n.MaterialHumanReadableId === `${av?.data[0].article}`)
+		.map((i) => ({
+			...i,
+			OpeningInventory: i.OpeningInventory?.toLocaleString("en-US", {
+				minimumFractionDigits: 2,
+				maximumFractionDigits: 2,
+			}),
+			Purchases: i.Purchases?.toLocaleString("en-US", {
+				minimumFractionDigits: 2,
+				maximumFractionDigits: 2,
+			}),
+			Consumption: i.Consumption?.toLocaleString("en-US", {
+				minimumFractionDigits: 2,
+				maximumFractionDigits: 2,
+			}),
+			ClosingInventory: i.ClosingInventory?.toLocaleString("en-US", {
+				minimumFractionDigits: 2,
+				maximumFractionDigits: 2,
+			}),
+		}));
+
+	// send the email stuff
+	const emailSetup = {
+		email: "blake.matthes@alpla.com",
+		subject: `Material Week.`,
+		template: "materialPerDay",
+		context: {
+			items: formattedMaterials,
+			article: av?.data[0].combined,
+		},
+	};
+
+	const { data: sentEmail, error: sendEmailError } = await tryCatch(
+		sendEmail(emailSetup),
+	);
+	if (sendEmailError) {
+		createLog(
+			"error",
+			"blocking",
+			"notify",
+			"Failed to send email, will try again on next interval",
+		);
+		return {
+			success: false,
+			message: "Failed to send email, will try again on next interval",
+		};
+	}
+
 	return {
 		success: true,
 		message: "material data",
-		data: buildInventoryTimeline(
-			sumByMaterialAndWeek(data.data) as any,
-			openingInventory,
-		),
+		data: formattedMaterials,
 	};
 }

lstV2/server/services/notifications/controller/materialsPerDay/materialPurchases.ts

@@ -1,4 +1,7 @@
 import { formatISO, parseISO, startOfWeek } from "date-fns";
+import { tryCatch } from "../../../../globalUtils/tryCatch.js";
+import { query } from "../../../sqlServer/prodSqlServer.js";
+import { materialPurchasesPerDay } from "../../../sqlServer/querys/dataMart/materialPerDay.js";
 
 function toDate(val: any) {
 	if (val instanceof Date) return val;
@@ -6,20 +9,52 @@ function toDate(val: any) {
 	return new Date(val);
 }
 
-export const materialPurchases = async (data: any) => {
+export const materialPurchases = async ({
+	startDate,
+	endDate,
+}: {
+	startDate: string;
+	endDate: string;
+}) => {
 	/** @type {Record<string, Record<string, number>>} */
 	const grouped: any = {};
 
-	for (const r of data) {
+	const { data: p, error } = (await tryCatch(
+		query(
+			materialPurchasesPerDay
+				.replace("[startDate]", startDate)
+				.replace("[endDate]", endDate),
+			"material check",
+		),
+	)) as any;
+
+	if (error) {
+		return {
+			success: false,
+			message: "Error getting the material data",
+			error,
+		};
+	}
+
+	if (!p.success) {
+		return {
+			success: false,
+			message: p.message,
+			data: [],
+		};
+	}
+
+	for (const r of p.data) {
+		const pOrder = String(r.purhcaseOrder);
 		const mat = String(r.MaterialHumanReadableId);
-		const d = toDate(r.CalDate);
+		const d = toDate(r.deliveryDate);
 		const week = formatISO(startOfWeek(d, { weekStartsOn: 1 }), {
 			representation: "date",
 		});
 
 		grouped[mat] ??= {};
 		grouped[mat][week] ??= 0;
-		grouped[mat][week] += Number(r.DailyMaterialDemand) || 0;
+		grouped[mat][week] += Number(r.qty) || 0;
 	}
 
 	const result = [];
@@ -29,7 +64,7 @@ export const materialPurchases = async (data: any) => {
 			result.push({
 				MaterialHumanReadableId: mat,
 				WeekStart: week,
-				WeeklyDemand: Number(total).toFixed(2),
+				WeeklyPurchase: Number(total).toFixed(2),
 			});
 		}
 	}

lstV2/server/services/notifications/controller/materialsPerDay/materialWithInv.ts

@@ -5,25 +5,51 @@ export const buildInventoryTimeline = (
 		WeeklyDemand: number;
 	}>,
 	opening: Record<string, number>,
+	weeklyPurchases?: Array<{
+		MaterialHumanReadableId: string;
+		WeekStart: string;
+		WeeklyPurchase: number;
+	}>,
 ) => {
 	// group weekly demand by material
-	const grouped: Record<
+	const groupedDemand: Record<
 		string,
 		Array<{ WeekStart: string; Demand: number }>
 	> = {};
-
 	for (const d of weeklyDemand) {
 		const mat = d.MaterialHumanReadableId;
-		grouped[mat] ??= [];
-		grouped[mat].push({
+		groupedDemand[mat] ??= [];
+		groupedDemand[mat].push({
 			WeekStart: d.WeekStart,
 			Demand: Number(d.WeeklyDemand),
 		});
 	}
 
-	// sort weeks chronologically per material
-	for (const mat of Object.keys(grouped)) {
-		grouped[mat].sort(
+	// group weekly purchases by material
+	const groupedPurchases: Record<
+		string,
+		Array<{ WeekStart: string; Purchase: number }>
+	> = {};
+	if (weeklyPurchases) {
+		for (const p of weeklyPurchases) {
+			const mat = p.MaterialHumanReadableId;
+			groupedPurchases[mat] ??= [];
+			groupedPurchases[mat].push({
+				WeekStart: p.WeekStart,
+				Purchase: Number(p.WeeklyPurchase),
+			});
+		}
+	}
+
+	// sort both chronologically
+	for (const mat of Object.keys(groupedDemand)) {
+		groupedDemand[mat].sort(
+			(a, b) =>
+				new Date(a.WeekStart).getTime() - new Date(b.WeekStart).getTime(),
+		);
+	}
+	for (const mat of Object.keys(groupedPurchases)) {
+		groupedPurchases[mat].sort(
 			(a, b) =>
 				new Date(a.WeekStart).getTime() - new Date(b.WeekStart).getTime(),
 		);
@@ -33,25 +59,30 @@ export const buildInventoryTimeline = (
 		MaterialHumanReadableId: string;
 		WeekStart: string;
 		OpeningInventory: number;
+		Purchases: number;
 		Consumption: number;
 		ClosingInventory: number;
 	}> = [];
 
-	for (const [mat, weeks] of Object.entries(grouped)) {
-		// get starting inventory from the ERP result
+	for (const [mat, weeks] of Object.entries(groupedDemand)) {
 		let inv = opening[mat] ?? 0;
+		const purchasesForMaterial = groupedPurchases[mat] ?? [];
 
-		for (const w of weeks) {
-			const week = w.WeekStart;
-			const demand = Number(w.Demand);
+		for (const week of weeks) {
+			const demand = Number(week.Demand);
+			const purchase =
+				purchasesForMaterial.find((p) => p.WeekStart === week.WeekStart)
+					?.Purchase ?? 0;
 
 			const openingInv = inv;
-			const closingInv = openingInv - demand;
+			const adjustedInv = openingInv + purchase;
+			const closingInv = adjustedInv - demand;
 
 			result.push({
 				MaterialHumanReadableId: mat,
-				WeekStart: week,
+				WeekStart: week.WeekStart,
 				OpeningInventory: Number(openingInv.toFixed(2)),
+				Purchases: Number(purchase.toFixed(2)),
 				Consumption: Number(demand.toFixed(2)),
 				ClosingInventory: Number(closingInv.toFixed(2)),
 			});

lstV2/server/services/notifications/controller/sendMail.ts

@@ -1,17 +1,18 @@
-import { tryCatch } from "../../../globalUtils/tryCatch.js";
-import { db } from "../../../../database/dbclient.js";
-import { settings } from "../../../../database/schema/settings.js";
-import nodemailer from "nodemailer";
+import Handlebars from "handlebars";
 import type { Transporter } from "nodemailer";
-import type SMTPTransport from "nodemailer/lib/smtp-transport/index.js";
+import nodemailer from "nodemailer";
 import type Mail from "nodemailer/lib/mailer/index.js";
 import type { Address } from "nodemailer/lib/mailer/index.js";
+import type SMTPTransport from "nodemailer/lib/smtp-transport/index.js";
+import hbs from "nodemailer-express-handlebars";
 import path from "path";
 import { fileURLToPath } from "url";
-import hbs from "nodemailer-express-handlebars";
 import { promisify } from "util";
-import { createLog } from "../../logger/logger.js";
+import { db } from "../../../../database/dbclient.js";
+import { settings } from "../../../../database/schema/settings.js";
+import { tryCatch } from "../../../globalUtils/tryCatch.js";
 import { installed } from "../../../index.js";
+import { createLog } from "../../logger/logger.js";
 
 interface HandlebarsMailOptions extends Mail.Options {
 	template: string;
@@ -33,7 +34,7 @@ export const sendEmail = async (data: any): Promise<any> => {
 	let transporter: Transporter;
 	let fromEmail: string | Address;
 	const { data: settingData, error: settingError } = await tryCatch(
-        db.select().from(settings)
+		db.select().from(settings),
 	);
 
 	if (settingError) {
@@ -47,12 +48,14 @@ export const sendEmail = async (data: any): Promise<any> => {
 	const server = settingData.filter((n) => n.name === "server");
 
 	if (
-        server[0].value === "localhost" &&
+		server[0].value === "localhostx" &&
 		process.env.EMAIL_USER &&
 		process.env.EMAIL_PASSWORD
 	) {
 		transporter = nodemailer.createTransport({
 			service: "gmail",
+			host: "smtp.gmail.com",
+			port: 465,
 			auth: {
 				user: process.env.EMAIL_USER,
 				pass: process.env.EMAIL_PASSWORD,
@@ -97,7 +100,7 @@ export const sendEmail = async (data: any): Promise<any> => {
 	// creating the handlbar options
 	const viewPath = path.resolve(
 		path.dirname(fileURLToPath(import.meta.url)),
-        "../utils/views/"
+		"../utils/views/",
 	);
 
 	const handlebarOptions = {
@@ -133,7 +136,7 @@ export const sendEmail = async (data: any): Promise<any> => {
 			"info",
 			"notification",
 			"system",
-            `Email was sent to: ${data.email}`
+			`Email was sent to: ${data.email}`,
 		);
 		return { success: true, message: "Email sent.", data: info };
 	} catch (err) {
@@ -142,7 +145,7 @@ export const sendEmail = async (data: any): Promise<any> => {
 			"error",
 			"notification",
 			"system",
-            `Error sending Email: ${JSON.stringify(err)}`
+			`Error sending Email: ${JSON.stringify(err)}`,
 		);
 		return { success: false, message: "Error sending email.", error: err };
 	}

lstV2/server/services/notifications/routes/manualTiggerMaterials.ts

@@ -0,0 +1,28 @@
+// an external way to creating logs
+import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
+import { apiHit } from "../../../globalUtils/apiHits.js";
+import { responses } from "../../../globalUtils/routeDefs/responses.js";
+import materialPerDayCheck from "../controller/materialsPerDay/materialPerDay.js";
+import runTiImport from "../controller/notifications/tiIntergration.js";
+
+const app = new OpenAPIHono({ strict: false });
+
+app.openapi(
+	createRoute({
+		tags: ["notify"],
+		summary: "Manually trigger TI intergrations.",
+		method: "get",
+		path: "/materialPerDayCheck",
+		//middleware: authMiddleware,
+		responses: responses(),
+	}),
+	async (c) => {
+		apiHit(c, { endpoint: "/materialPerDayCheck" });
+		const tiImport = await materialPerDayCheck();
+		return c.json({
+			success: tiImport?.success,
+			message: tiImport?.message,
+		});
+	},
+);
+export default app;

lstV2/server/services/notifications/routes/manualTiggerTi.ts

@@ -1,9 +1,8 @@
 // an external way to creating logs
 import { createRoute, OpenAPIHono, z } from "@hono/zod-openapi";
-import { responses } from "../../../globalUtils/routeDefs/responses.js";
-
-import runTiImport from "../controller/notifications/tiIntergration.js";
 import { apiHit } from "../../../globalUtils/apiHits.js";
+import { responses } from "../../../globalUtils/routeDefs/responses.js";
+import runTiImport from "../controller/notifications/tiIntergration.js";
 
 const app = new OpenAPIHono({ strict: false });
 
@@ -23,6 +22,6 @@ app.openapi(
 			success: tiImport?.success,
 			message: tiImport?.message,
 		});
-    }
+	},
 );
 export default app;

lstV2/server/services/notifications/utils/views/materialPerDay.hbs

@@ -0,0 +1,44 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    {{!-- <link rel="stylesheet" href="styles/styles.css" /> --}}
+    {{> styles}}
+</head>
+<body>
+        <p>All,</p> 
+        <p>Below is the weekly material demand for Article: {{article}}.</p>        
+        <table > 
+        <thead> 
+            <tr> 
+            <th>AV</th> 
+            <th>Week</th> 
+            <th>Opening Inventory</th> 
+            <th>Purchases</th> 
+            <th>Consumption</th> 
+            <th>Closing Inventory</th> 
+            </tr> 
+        </thead> 
+
+        <tbody>
+            {{#each items}}
+                    <tr>
+                        <td>{{MaterialHumanReadableId}}</td>
+                        <td>{{WeekStart}}</td>
+                        <td>{{OpeningInventory}}</td>
+                        <td>{{Purchases}}</td>
+                        <td>{{Consumption}}</td>
+                        <td>{{ClosingInventory}}</td>
+                    </tr>
+                {{/each}}
+        </tbody>
+        </table>
+
+        <div>
+           <p>Thank you,</p>
+        <p>LST Team</p> 
+        </div>
+
+</body>
+</html>

lstV2/server/services/quality/controller/addNewPallet.ts

@@ -13,6 +13,10 @@ export const addNewPallet = async (data: any) => {
 	 * Post new pallets
 	 */
 
+	const returnLabels = ["return to warehouse", "rework", "grind", "scrap"];
+
+	console.log(data, returnLabels.includes(data.palletStatusText));
+
 	if (parseInt(data.runningNr) <= 0) {
 		return {
 			success: false,
@@ -40,7 +44,7 @@ export const addNewPallet = async (data: any) => {
 	const palletData: any = c;
 	// if the pallet exist then tell the user to check on it
 	const pStatus = [1, 4, 6];
-	if (!data.priority) {
+	if (!data.priority && data.palletStatusText !== "canceled") {
 		if (palletData && pStatus.includes(palletData[0]?.palletStatus)) {
 			return {
 				success: false,
@@ -73,22 +77,39 @@ export const addNewPallet = async (data: any) => {
 					upd_user: data.user,
 					upd_date: sql`NOW()`,
 				};
-			} else {
+			} else if (data.palletStatusText === "canceled") {
 				pData = {
-					warehouseAtRequest: p[0].warehouseAtRequest,
-					locationAtRequest: p[0].locationAtRequest,
+					warehouseAtRequest: null,
+					locationAtRequest: null,
 					warehouseMovedTo: null,
 					locationMovedTo: null,
-					palletStatus: data.palletStatusText === "return" ? 6 : 4,
+					palletStatus: 5,
 					//durationToMove: 0,
-					palletStatusText:
-						data.palletStatusText === "return" ? "return" : "reactivated",
-					qualityDurationToInspect:
-						data.palletStatusText === "return"
+					palletStatusText: "canceled",
+					qualityDurationToInspect: 0,
+					locationDropOff: "canceled",
+					palletRequest: palletData[0].palletStatus + 1,
+					upd_user: data.user,
+					upd_date: sql`NOW()`,
+				};
+			} else {
+				pData = {
+					warehouseAtRequest: p[0].warehouseAtRequest || "no longer on stock",
+					locationAtRequest: p[0].locationAtRequest || "no longer on stock",
+					warehouseMovedTo: null,
+					locationMovedTo: null,
+					palletStatus: returnLabels.includes(data.palletStatusText) ? 6 : 4,
+					//durationToMove: 0,
+					palletStatusText: returnLabels.includes(data.palletStatusText)
+						? data.palletStatusText
+						: "reactivated",
+
+					qualityDurationToInspect: returnLabels.includes(data.palletStatusText)
 						? differenceInMinutes(new Date(Date.now()), p[0].lastMove)
 						: 0,
-					locationDropOff:
-						data.palletStatusText === "return" ? "Return to warhouse" : "",
+					locationDropOff: returnLabels.includes(data.palletStatusText)
+						? data.palletStatusText
+						: "No location Checked",
 					palletRequest: palletData[0].palletStatus + 1,
 					upd_user: data.user,
 					upd_date: sql`NOW()`,

lstV2/server/services/quality/controller/qualityCycle.ts

@@ -71,21 +71,21 @@ export const qualityCycle = async () => {
 						const qDataPost = {
 							warehouseMovedTo: prodData[0]?.warehouseAtRequest,
 							locationMovedTo: prodData[0]?.locationAtRequest,
-							// how ling did it take the warhouse to originally move the pallet
+							// how ling did it take the warehouse to originally move the pallet
 							durationToMove: warehouse.includes(lstQData[i].palletStatus)
 								? differenceInMinutes(
 										new Date(Date.now()),
 										lstQData[i].upd_date,
 									)
 								: lstQData[i].durationToMove,
-							// how long did it take warehouse to move the pallet back agian
+							// how long did it take warehouse to move the pallet back again
 							returnDurationToInspect:
 								lstQData[i].palletStatus === 7
 									? differenceInMinutes(
 											new Date(Date.now()),
 											lstQData[i].upd_date,
 										)
-									: lstQData[i].qualityDurationToInspect,
+									: lstQData[i].returnDurationToInspect,
 							palletStatus: 2,
 							palletStatusText: "moved",
 							upd_date: sql`NOW()`,

lstV2/server/services/sqlServer/querys/dataMart/materialPerDay.ts

@@ -3,7 +3,7 @@
  * startdate and end date should be passed over
  */
 export const materialPerDay = `
-use [test3_AlplaPROD2.0_Read]
+use [test1_AlplaPROD2.0_Read]
 
 DECLARE @ShiftStartHour INT = 6
 declare @startDate nvarchar(max) = '[startDate]'
@@ -121,7 +121,7 @@ declare @endDate nvarchar(max) = '[endDate]'
 SELECT 
       [IdBestellung] as purhcaseOrder
      
-      ,[IdArtikelVarianten]
+      ,[IdArtikelVarianten] as MaterialHumanReadableId
       ,convert(date, [BestellDatum], 120) as orderDate
       ,convert(date, [Lieferdatum], 120) as deliveryDate
       ,[BestellMenge] as qty

lstV2/server/services/sqlServer/querys/misc/singleArticle.ts

@@ -0,0 +1,10 @@
+export const singleArticle = `
+use AlplaPROD_test1
+
+select 
+idartikelvarianten as article,
+CONCAT(idartikelvarianten , ' - '  , Alias) as combined
+
+from V_Artikel (nolock)
+where idartikelvarianten = '[av]'
+`;