fix(eom stats): corrections to the eom inv stuff to be proper tiems

server/services/eom/eomService.ts

@@ -6,17 +6,43 @@ import stats from "./route/stats.js";
 import history from "./route/invHistory.js";
 import { createJob } from "../notifications/utils/processNotifications.js";
 import { historicalInvIMmport } from "./utils/historicalInv.js";
+import { tryCatch } from "../../globalUtils/tryCatch.js";
+import { query } from "../sqlServer/prodSqlServer.js";
+import { shiftChange } from "../sqlServer/querys/misc/shiftChange.js";
+import { createLog } from "../logger/logger.js";
 const routes = [stats, history] as const;
 
 const appRoutes = routes.forEach((route) => {
     app.route("/eom", route);
 });
 
-// setTimeout(() => {
-//     historicalInvIMmport();
-// }, 5 * 1000);
+setTimeout(async () => {
+    const { data: shift, error: shiftError } = (await tryCatch(
+        query(shiftChange, "shift change from material.")
+    )) as any;
+
+    if (shiftError) {
+        createLog(
+            "error",
+            "eom",
+            "eom",
+            "There was an error getting the shift times will use fallback times"
+        );
+    }
+
+    // shift split
+    const shiftTimeSplit = shift?.data[0]?.shiftChange.split(":");
+
+    const cronSetup = `${
+        shiftTimeSplit.length > 0 ? `${parseInt(shiftTimeSplit[1])}` : "0"
+    } ${
+        shiftTimeSplit.length > 0 ? `${parseInt(shiftTimeSplit[0])}` : "7"
+    } * * *`;
+
+    //console.log(cronSetup);
+    createJob("eom_historical_inv", cronSetup, historicalInvIMmport);
+}, 5 * 1000);
 // the time we want to run the hostircal data should be  the same time the historical data run on the server
 // getting this from the shift time
-createJob("eom_historical_inv", "0 7 * * *", historicalInvIMmport);
 
 export default app;