AI-Powered Alerts

// tamboEngineService.ts:47-64
static async analizarSiCorresponde(idEstablecimiento: string) {
  const fechaLimite = new Date();
  fechaLimite.setDate(fechaLimite.getDate() - 15);
  
  // Fetch completed batches from last 15 days
  const lotes = await prisma.loteProduccion.findMany({
    where: {
      idEstablecimiento,
      estado: true,  // Only completed batches
      fechaProduccion: { gte: fechaLimite }
    },
    include: { producto: true, mermas: true, costosDirectos: true, establecimiento: true }
  });
  
  // Minimum 15 batches required for analysis
  if (lotes.length < MINIMO_LOTES) return;
}

// tamboEngineService.ts:67-89
const payload = {
  idEstablecimiento,
  nombreEstablecimiento: lotes[0].establecimiento?.nombre || idEstablecimiento,
  periodo: new Date().toLocaleString("es-AR", { month: "long", year: "numeric" }),
  lotes: lotes.map(l => ({
    idLote: l.idLote,
    fechaProduccion: l.fechaProduccion.toISOString().split("T")[0],
    producto: l.producto.nombre,
    categoria: l.producto.categoria,
    cantidad: Number(l.cantidad),
    unidad: l.unidad,
    mermas: l.mermas.map(m => ({
      descripcion: m.observacion || m.tipo,
      cantidad: Number(m.cantidad),
      unidad: l.unidad,
    })),
    costosDirectos: l.costosDirectos.map(c => ({
      concepto: c.concepto,
      monto: Number(c.monto),
      moneda: "ARS",
    })),
  }))
};

// Get alerts (alertController.ts:7-21)
GET /api/alertas/:idEstablecimiento?rango=30
Authorization: Bearer <jwt-token>

// Query parameters:
// - rango (optional): number of days to look back (default varies by AI)

// Response
{
  "success": true,
  "message": "Alertas obtenidas correctamente",
  "data": [
    {
      "idAlerta": "alert-uuid",
      "tipo": "merma_elevada",
      "severidad": "alta",
      "titulo": "Mermas elevadas en producción de queso",
      "descripcion": "Se detectó un incremento del 15% en mermas naturales comparado con el promedio histórico",
      "idLote": "lote-uuid",
      "numeroLote": 1247,
      "visto": false,
      "fechaCreacion": "2026-03-08T10:30:00.000Z"
    }
  ]
}

// Get latest alerts (alertController.ts:23-33)
GET /api/alertas/:idEstablecimiento/ultimas
Authorization: Bearer <jwt-token>

// Returns a limited set of the most recent alerts

// Get unseen count (alertController.ts:46-56)
GET /api/alertas/:idEstablecimiento/no-vistas
Authorization: Bearer <jwt-token>

// Response
{
  "success": true,
  "message": "Conteo de alertas no vistas obtenido correctamente",
  "data": {
    "cantidad": 3
  }
}

// Mark as seen (alertController.ts:35-45)
PUT /api/alertas/:idAlerta/visto
Authorization: Bearer <jwt-token>

// No body required

// Response
{
  "success": true,
  "message": "Alerta marcada como vista correctamente",
  "data": {
    "idAlerta": "alert-uuid",
    "visto": true,
    ...
  }
}

// tamboEngineService.ts:28-45
private static async _enriquecerAlertasConNumeroLote(alertas: any[]) {
  if (!alertas || alertas.length === 0) return [];
  
  const idsLotes = alertas.map(a => a.idLote).filter(Boolean);
  if (idsLotes.length === 0) return alertas;
  
  // Fetch batch numbers
  const lotesDb = await prisma.loteProduccion.findMany({
    where: { idLote: { in: idsLotes } },
    select: { idLote: true, numeroLote: true }
  });
  
  const lotesMap = new Map(lotesDb.map(l => [l.idLote, l.numeroLote]));
  
  // Add numeroLote to each alert
  return alertas.map(a => ({
    ...a,
    numeroLote: lotesMap.get(a.idLote) || null
  }));
}

// Dashboard.tsx:114
<aside className="w-full lg:w-80 shrink-0">
  <AlertsSection />
</aside>

// tamboEngineService.ts:8-26
private static async fetchWithTimeout(url: string, options: RequestInit = {}, timeout = 15000) {
  const controller = new AbortController();
  const id = setTimeout(() => controller.abort(), timeout);
  
  try {
    const response = await fetch(url, {
      ...options,
      signal: controller.signal
    });
    clearTimeout(id);
    return response;
  } catch (error: any) {
    clearTimeout(id);
    if (error.name === 'AbortError') {
      throw new AppError("Timeout: La IA tardó demasiado en responder", 504);
    }
    throw new AppError("Error de red: No se pudo conectar con la IA", 503);
  }
}

// tamboEngineService.ts:109-130
static async getAlertas(idEstablecimiento: string, rangoDias?: number) {
  try {
    const response = await this.fetchWithTimeout(url, {}, 15000);
    
    if (!response.ok) {
      if (response.status === 404) return []; // No alerts yet
      throw new AppError(`Error interno en la IA (Status: ${response.status})`, response.status);
    }
    
    const alertas = await response.json();
    return await this._enriquecerAlertasConNumeroLote(alertas);
  } catch (error: any) {
    console.error("[TamboEngine] Error consultando alertas:", error);
    if (error instanceof AppError) throw error;
    throw new AppError("El servicio de Inteligencia Artificial devolvió una respuesta inesperada.", 502);
  }
}