Fix: Alinear modelos SQLAlchemy con DDL real de Supabase

app.py

@@ -1,10 +1,18 @@
 import datetime
 import logging
-from typing import List
 from fastapi import FastAPI, Depends, HTTPException, status
 from pydantic import BaseModel
 from sqlalchemy.orm import Session
-from database import get_db, DimEstudiante, DimDocente, DimModulo, DimTiempo, DimDocumento, DimUsuario, FactRendimientoAcademico
+from database import (
+    get_db,
+    DimEstudiante,
+    DimDocente,
+    DimModulo,
+    DimTiempo,
+    DimOrigenDocumental,
+    Users,
+    FactRendimientoAcademico,
+)
 from ner_engine import ner_engine
 
 logging.basicConfig(level=logging.INFO)
@@ -16,6 +24,10 @@ app = FastAPI(
     version="1.0.0"
 )
 
+# El nombre del comment en el esquema DDL de Supabase indica que el CHECK de
+# tipo_documento es: ('SHEET', 'FORM', 'MOODLE', 'XLSX')
+TIPO_DOC_VALIDO = "SHEET"
+
 class ProcessSheetPayload(BaseModel):
     texto_celda: str
     nota_detectada: float
@@ -37,42 +49,78 @@ def read_root():
 
 @app.post("/api/v1/ingesta/tabular", status_code=status.HTTP_201_CREATED)
 def procesar_registro_tabular(payload: ProcessSheetPayload, db: Session = Depends(get_db)):
-    try: # Todo envuelto en un try-except
+    try:
+        # 1. NLP con BETO
         entidades = ner_engine.extract_entities(payload.texto_celda)
         confianza_ia = sum([e["score"] for e in entidades]) / len(entidades) if entidades else 1.0
         forzar_revision = confianza_ia < 0.60
 
+        # 2. Dimensión Estudiante
         nombre_resuelto = payload.texto_celda.strip()
-        estudiante = db.query(DimEstudiante).filter(DimEstudiante.nombre_completo == nombre_resuelto).first()
-        
+        estudiante = db.query(DimEstudiante).filter(
+            DimEstudiante.nombre_completo == nombre_resuelto
+        ).first()
         if not estudiante:
             estudiante = DimEstudiante(nombre_completo=nombre_resuelto)
             db.add(estudiante)
-            db.flush() # Importante: Usar flush para obtener el ID sin confirmar transacción final
+            db.flush()
 
+        # 3. Dimensión Docente — columnas reales: nombre_completo, area_especialidad
         if not db.query(DimDocente).filter(DimDocente.id_docente == payload.id_docente).first():
-            db.add(DimDocente(id_docente=payload.id_docente, nombre="Docente Generico", especialidad="Generico"))
-            
+            db.add(DimDocente(
+                id_docente=payload.id_docente,
+                nombre_completo="Docente Generico",
+                area_especialidad="Generico"
+            ))
+
+        # 4. Dimensión Módulo — columnas reales: nombre_modulo, nombre_institucion, programa
         if not db.query(DimModulo).filter(DimModulo.id_modulo == payload.id_modulo).first():
-            db.add(DimModulo(id_modulo=payload.id_modulo, nombre_modulo="Modulo Generico", version="1.0"))
-            
+            db.add(DimModulo(
+                id_modulo=payload.id_modulo,
+                nombre_modulo="Modulo Generico",
+                nombre_institucion="GiraGroup",
+                programa="General"
+            ))
+
+        # 5. Dimensión Tiempo — columnas reales: gestion, semestre, mes
         if not db.query(DimTiempo).filter(DimTiempo.id_tiempo == payload.id_tiempo).first():
-            db.add(DimTiempo(id_tiempo=payload.id_tiempo, anio=2026, mes=5, dia=30, trimestre=2))
-            
-        if not db.query(DimDocumento).filter(DimDocumento.id_documento == payload.id_documento).first():
-            db.add(DimDocumento(id_documento=payload.id_documento, tipo_documento="Consolidado Generico"))
-            
-        if not db.query(DimUsuario).filter(DimUsuario.id_usuario == payload.id_usuario).first():
-            db.add(DimUsuario(id_usuario=payload.id_usuario, rol="Sistema", nombre="Admin"))
-            
-        db.flush() # Confirmamos la creación de las dimensiones
+            db.add(DimTiempo(
+                id_tiempo=payload.id_tiempo,
+                gestion=2026,
+                semestre=1,
+                mes="Mayo"
+            ))
+
+        # 6. Dimensión Origen Documental — tabla real: dim_origen_documental
+        #    CHECK: tipo_documento IN ('SHEET', 'FORM', 'MOODLE', 'XLSX')
+        if not db.query(DimOrigenDocumental).filter(
+            DimOrigenDocumental.id_documento == payload.id_documento
+        ).first():
+            db.add(DimOrigenDocumental(
+                id_documento=payload.id_documento,
+                tipo_documento=TIPO_DOC_VALIDO,
+                nombre_archivo="carga_automatica"
+            ))
 
+        # 7. Usuario — tabla real: users (id, username, hashed_password, role)
+        if not db.query(Users).filter(Users.id == payload.id_usuario).first():
+            db.add(Users(
+                id=payload.id_usuario,
+                username=f"sistema_{payload.id_usuario}",
+                hashed_password="$placeholder$",
+                role="admin"
+            ))
+
+        db.flush()
+
+        # 8. Alertas estratégicas
         alertas_disparadas = []
         if payload.nota_detectada <= 70.0:
             alertas_disparadas.append("RIESGO_ACADEMICO_CRITICO")
         if payload.asistencia < 70.0 or payload.incumplimiento_tareas > 30.0:
             alertas_disparadas.append("RIESGO_DESERCION_ALTA")
 
+        # 9. Insertar hecho con las FK correctas
         nuevo_hecho = FactRendimientoAcademico(
             id_estudiante=estudiante.id_estudiante,
             id_docente=payload.id_docente,
@@ -87,10 +135,8 @@ def procesar_registro_tabular(payload: ProcessSheetPayload, db: Session = Depend
             requiere_revision=forzar_revision
         )
         db.add(nuevo_hecho)
-        
-        # Una vez que todo está correcto, hacemos el commit final
-        db.commit() 
-        
+        db.commit()
+
         return {
             "status": "processed",
             "id_estudiante_asignado": estudiante.id_estudiante,
@@ -99,39 +145,37 @@ def procesar_registro_tabular(payload: ProcessSheetPayload, db: Session = Depend
             "alertas_estrategicas": alertas_disparadas
         }
     except Exception as err:
-        db.rollback() # Si falla, deshacemos todo para mantener la integridad
+        db.rollback()
         logger.error(f"Error crítico en backend 500: {err}")
-        # Enviar el error real al frontend para depurar
         raise HTTPException(status_code=500, detail=str(err))
 
+
 @app.get("/api/v1/riesgos/cruzado")
 def obtener_riesgos_cruzados(limite_nota: float = 70.0, min_cuotas: int = 2, db: Session = Depends(get_db)):
     try:
-        # Inner Join vectorial entre la dimensión y la tabla de hechos
         resultados = db.query(DimEstudiante, FactRendimientoAcademico).\
             join(FactRendimientoAcademico, DimEstudiante.id_estudiante == FactRendimientoAcademico.id_estudiante).\
             filter(FactRendimientoAcademico.nota_final <= limite_nota).\
             all()
-        
+
         data = []
         for est, fact in resultados:
-            # Serialización estricta bajo el contrato JSON esperado por AlertDashboard.jsx
             data.append({
                 "estudiante": est.nombre_completo,
                 "codigo": f"EST-{est.id_estudiante:06d}",
                 "rendimiento": {
-                    "nota_actual": fact.nota_final,
-                    "estado_academico": "CRÍTICO"
+                    "nota_actual": float(fact.nota_final),
+                    "estado_academico": "CRÍTICO" if fact.nota_final <= 70 else "REGULAR"
                 },
                 "finanzas": {
-                    "cuotas_mora": min_cuotas, 
-                    "deuda_total": 350.0 * min_cuotas, # Proyección estática hasta integrar fact_situacion_financiera
+                    "cuotas_mora": min_cuotas,
+                    "deuda_total": 350.0 * min_cuotas,
                     "estado_cartera": "MORA"
                 },
                 "nivel_riesgo_global": "ALTO - CRÍTICO"
             })
-        
+
         return {"status": "success", "data": data}
     except Exception as e:
         logger.error(f"Fallo en la resolución del query OLAP: {e}")
-        raise HTTPException(status_code=500, detail="Error de lectura en el esquema estrella.")
+        raise HTTPException(status_code=500, detail=str(e))

database.py

@@ -1,6 +1,7 @@
 import os
+import datetime
 from dotenv import load_dotenv
-from sqlalchemy import create_engine
+from sqlalchemy import create_engine, Column, Integer, String, Numeric, Boolean, DateTime, ForeignKey, CheckConstraint
 from sqlalchemy.orm import declarative_base, sessionmaker
 
 # Load environment variables from .env file
@@ -9,7 +10,6 @@ load_dotenv()
 DATABASE_URL = os.getenv("DATABASE_URL")
 
 if not DATABASE_URL:
-    # Fallback to local postgres if not set for safety, or raise a warning
     DATABASE_URL = "postgresql://postgres:postgres@localhost:5432/postgres"
 
 # For Supabase, pool_pre_ping=True is highly recommended to handle stale connections
@@ -21,63 +21,93 @@ engine = create_engine(
 
 SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
 
-from sqlalchemy import Column, Integer, String, Numeric, Boolean, DateTime, ForeignKey
-import datetime
-
 Base = declarative_base()
 
+
+# =============================================================================
+# DIMENSIONES — mapeadas exactamente al DDL de Supabase
+# =============================================================================
+
+class DimTiempo(Base):
+    __tablename__ = "dim_tiempo"
+    id_tiempo   = Column(Integer, primary_key=True)
+    gestion     = Column(Integer, nullable=False, default=2026)
+    semestre    = Column(Integer, default=1)
+    mes         = Column(String(20), default="Mayo")
+
+
 class DimEstudiante(Base):
     __tablename__ = "dim_estudiante"
-    id_estudiante = Column(Integer, primary_key=True, index=True)
-    nombre_completo = Column(String(200), nullable=False)
+    id_estudiante     = Column(Integer, primary_key=True, index=True)
+    nombre_completo   = Column(String(200), nullable=False)
     codigo_estudiante = Column(String(50))
 
+
 class DimDocente(Base):
     __tablename__ = "dim_docente"
-    id_docente = Column(Integer, primary_key=True)
-    nombre = Column(String(200), nullable=False, default="Docente Generico")
-    especialidad = Column(String(100), default="Generico")
+    id_docente        = Column(Integer, primary_key=True)
+    nombre_completo   = Column(String(200), nullable=False, default="Docente Generico")
+    area_especialidad = Column(String(200), default="Generico")
+
 
 class DimModulo(Base):
     __tablename__ = "dim_modulo"
-    id_modulo = Column(Integer, primary_key=True)
-    nombre_modulo = Column(String(200), nullable=False, default="Modulo Generico")
-    version = Column(String(50), default="1.0")
+    id_modulo           = Column(Integer, primary_key=True)
+    nombre_modulo       = Column(String(200), nullable=False, default="Modulo Generico")
+    nombre_institucion  = Column(String(200), nullable=False, default="GiraGroup")
+    programa            = Column(String(200), default="General")
 
-class DimTiempo(Base):
-    __tablename__ = "dim_tiempo"
-    id_tiempo = Column(Integer, primary_key=True)
-    anio = Column(Integer, nullable=False, default=2026)
-    mes = Column(Integer, nullable=False, default=5)
-    dia = Column(Integer, nullable=False, default=30)
-    trimestre = Column(Integer, nullable=False, default=2)
-
-class DimDocumento(Base):
-    __tablename__ = "dim_documento"
-    id_documento = Column(Integer, primary_key=True)
-    tipo_documento = Column(String(100), nullable=False, default="Consolidado Generico")
-
-class DimUsuario(Base):
-    __tablename__ = "dim_usuario"
-    id_usuario = Column(Integer, primary_key=True)
-    rol = Column(String(50), nullable=False, default="Sistema")
-    nombre = Column(String(100), nullable=False, default="Admin")
+
+class DimOrigenDocumental(Base):
+    """Mapeada a la tabla dim_origen_documental en Supabase."""
+    __tablename__ = "dim_origen_documental"
+    id_documento        = Column(Integer, primary_key=True)
+    tipo_documento      = Column(String(10), default="SHEET")
+    nombre_archivo      = Column(String(500), default="archivo_generico")
+    fecha_procesamiento = Column(DateTime, default=datetime.datetime.utcnow)
+
+
+class Users(Base):
+    """Tabla de usuarios/autenticación en Supabase."""
+    __tablename__ = "users"
+    id              = Column(Integer, primary_key=True)
+    username        = Column(String(100), unique=True, nullable=False, default="sistema")
+    hashed_password = Column(String(255), nullable=False, default="$placeholder$")
+    role            = Column(String(20), default="admin")
+    created_at      = Column(DateTime, default=datetime.datetime.utcnow)
+
+
+# =============================================================================
+# TABLAS DE HECHOS
+# =============================================================================
 
 class FactRendimientoAcademico(Base):
     __tablename__ = "fact_rendimiento_academico"
-    id_hecho_aca = Column(Integer, primary_key=True, index=True)
-    id_estudiante = Column(Integer, ForeignKey("dim_estudiante.id_estudiante"))
-    id_docente = Column(Integer)
-    id_modulo = Column(Integer)
-    id_tiempo = Column(Integer)
-    id_documento = Column(Integer)
-    id_usuario_carga = Column(Integer)
-    nota_final = Column(Numeric(5,2))
-    asistencia_pct = Column(Numeric(5,2))
-    incumplimiento_actividades_pct = Column(Numeric(5,2))
-    nivel_confianza_ia = Column(Numeric(5,4))
-    requiere_revision = Column(Boolean, default=False)
-    created_at = Column(DateTime, default=datetime.datetime.utcnow)
+    id_hecho_aca                   = Column(Integer, primary_key=True, index=True)
+    id_estudiante                  = Column(Integer, ForeignKey("dim_estudiante.id_estudiante"))
+    id_docente                     = Column(Integer, ForeignKey("dim_docente.id_docente"))
+    id_modulo                      = Column(Integer, ForeignKey("dim_modulo.id_modulo"))
+    id_tiempo                      = Column(Integer, ForeignKey("dim_tiempo.id_tiempo"))
+    id_documento                   = Column(Integer, ForeignKey("dim_origen_documental.id_documento"))
+    id_usuario_carga               = Column(Integer, ForeignKey("users.id"))
+    nota_final                     = Column(Numeric(5, 2))
+    asistencia_pct                 = Column(Numeric(5, 2))
+    incumplimiento_actividades_pct = Column(Numeric(5, 2), default=0.00)
+    nivel_confianza_ia             = Column(Numeric(5, 4))
+    requiere_revision              = Column(Boolean, default=False)
+    created_at                     = Column(DateTime, default=datetime.datetime.utcnow)
+
+
+class FactSituacionFinanciera(Base):
+    __tablename__ = "fact_situacion_financiera"
+    id_hecho_fin   = Column(Integer, primary_key=True)
+    id_estudiante  = Column(Integer, ForeignKey("dim_estudiante.id_estudiante"))
+    id_tiempo      = Column(Integer, ForeignKey("dim_tiempo.id_tiempo"))
+    monto_deuda    = Column(Numeric(10, 2))
+    cuotas_impagas = Column(Integer)
+    estado_cartera = Column(String(20))
+    tipo_alerta    = Column(String(20))
+    fecha_registro = Column(DateTime, default=datetime.datetime.utcnow)
 
 
 def get_db():