import {
	addDays,
	format,
	formatISO,
	isBefore,
	parseISO,
	startOfWeek,
} from "date-fns";
import { db } from "../../../../../database/dbclient.js";
import { invHistoricalData } from "../../../../../database/schema/historicalINV.js";
import { tryCatch } from "../../../../globalUtils/tryCatch.js";
import { query } from "../../../sqlServer/prodSqlServer.js";
import {
	materialPerDay,
	materialPurchasesPerDay,
} from "../../../sqlServer/querys/dataMart/materialPerDay.js";
import { materialPurchases } from "./materialPurchases.js";
import { buildInventoryTimeline } from "./materialWithInv.js";

const getInv = async () => {
	const { data, error } = await tryCatch(db.select().from(invHistoricalData));

	if (error) {
		return [];
	}

	return data;
};

function toDate(val: any) {
	if (val instanceof Date) return val;
	if (typeof val === "string") return parseISO(val.replace(" ", "T"));
	return new Date(val);
}

function sumByMaterialAndWeek(data: any) {
	/** @type {Record<string, Record<string, number>>} */
	const grouped: any = {};

	for (const r of data) {
		const mat = String(r.MaterialHumanReadableId);
		const d = toDate(r.CalDate);
		const week = formatISO(startOfWeek(d, { weekStartsOn: 1 }), {
			representation: "date",
		});

		grouped[mat] ??= {};
		grouped[mat][week] ??= 0;
		grouped[mat][week] += Number(r.DailyMaterialDemand) || 0;
	}

	const result = [];
	for (const [mat, weeks] of Object.entries(grouped)) {
		// @ts-ignore
		for (const [week, total] of Object.entries(weeks)) {
			result.push({
				MaterialHumanReadableId: mat,
				WeekStart: week,
				WeeklyDemand: Number(total).toFixed(2),
			});
		}
	}

	return result;
}

export default async function materialPerDayCheck() {
	/**
	 * getting the shipped pallets
	 */

	const startDate = format(new Date(Date.now()), "yyyy-MM-dd");
	const endDate = format(addDays(new Date(Date.now()), 90), "yyyy-MM-dd");

	const { data, error } = (await tryCatch(
		query(
			materialPerDay
				.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: [],
		};
	}

	// 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 openingInventory: Record<string, number> = {};
	const inventoryRows = await getInv();
	for (const row of inventoryRows) {
		openingInventory[row.article] = Number(row.total_QTY) || 0;
	}

	return {
		success: true,
		message: "material data",
		data: buildInventoryTimeline(
			sumByMaterialAndWeek(data.data) as any,
			openingInventory,
		),
	};
}