73 lines
2.0 KiB
TypeScript
73 lines
2.0 KiB
TypeScript
import { OpenAPIHono } from "@hono/zod-openapi";
|
|
|
|
const app = new OpenAPIHono();
|
|
|
|
import { tryCatch } from "../../globalUtils/tryCatch.js";
|
|
import { createLog } from "../logger/logger.js";
|
|
import { createJob } from "../notifications/utils/processNotifications.js";
|
|
import { query } from "../sqlServer/prodSqlServer.js";
|
|
import { shiftChange } from "../sqlServer/querys/misc/shiftChange.js";
|
|
import gpData from "./route/getGpData.js";
|
|
import lastPurch from "./route/getLastPurchPrice.js";
|
|
import lastSales from "./route/getLastSalesPrice.js";
|
|
import consumptionData from "./route/getProductionConsumption.js";
|
|
import purchased from "./route/getPurchased.js";
|
|
import regrind from "./route/getregrind.js";
|
|
import soldItems from "./route/getSoldItems.js";
|
|
import history from "./route/invHistory.js";
|
|
import stats from "./route/stats.js";
|
|
import { historicalInvIMmport } from "./utils/historicalInv.js";
|
|
|
|
const routes = [
|
|
stats,
|
|
history,
|
|
lastPurch,
|
|
lastSales,
|
|
gpData,
|
|
consumptionData,
|
|
regrind,
|
|
soldItems,
|
|
purchased,
|
|
] as const;
|
|
|
|
const appRoutes = routes.forEach((route) => {
|
|
app.route("/eom", route);
|
|
});
|
|
|
|
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
|
|
|
|
if (process.env.NODE_ENV?.trim() !== "production") {
|
|
setTimeout(() => {
|
|
historicalInvIMmport();
|
|
}, 15 * 1000);
|
|
}
|
|
|
|
export default app;
|