import { db, ia, schedule } from "@ck/core";

// Triple cruce financiero por obra
export async function controlObra(id: string) {
  const partidas = await db.partidas
    .where({ obra: id, activa: true })
    .all();

  return partidas.map(p => {
    const desviacion = (p.committed - p.budget) / p.budget;
    return {
      partida: p.codigo,
      presupuestado: p.budget,
      comprometido: p.committed,
      pagado: p.paid,
      desviacion,
      estado: desviacion > 0.03 ? "alerta" : "ok",
    };
  });
}

// Antifraude
export async function analizarFactura(file: File) {
  const data = await ia.ocr(file);
  const riesgos = await Promise.all([
    detectarDuplicado(data),
    detectarProveedorNuevo(data),
    detectarSobrecompra(data),
  ]);

  return {
    factura: data,
    riesgo: Math.max(...riesgos.map(r => r.score)),
    motivos: riesgos.filter(r => r.score > 0.5),
  };
}

// Cada 15 min, monitorear todas las obras activas
schedule.every("15m", async () => {
  const obras = await db.obras.activas();
  for (const o of obras) {
    const alertas = await controlObra(o.id);
    if (alertas.some(a => a.estado === "alerta")) {
      await notify({ to: o.admin, alertas });
    }
  }
});