Fix: Autogeneración de Dimensiones Maestras para evitar Error 500 por Foreign Keys

app.py

@@ -4,7 +4,7 @@ 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, FactRendimientoAcademico
+from database import get_db, DimEstudiante, DimDocente, DimModulo, DimTiempo, DimDocumento, DimUsuario, FactRendimientoAcademico
 from ner_engine import ner_engine
 
 logging.basicConfig(level=logging.INFO)
@@ -16,8 +16,6 @@ app = FastAPI(
     version="1.0.0"
 )
 
-# El resto del código de ProcessSheetPayload y endpoints se mantiene exactamente igual...
-
 class ProcessSheetPayload(BaseModel):
     texto_celda: str
     nota_detectada: float
@@ -39,6 +37,7 @@ 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)):
+    # 1. Extracción con BETO NLP
     entidades = ner_engine.extract_entities(payload.texto_celda)
     confianza_ia = sum([e["score"] for e in entidades]) / len(entidades) if entidades else 1.0
 
@@ -46,21 +45,42 @@ def procesar_registro_tabular(payload: ProcessSheetPayload, db: Session = Depend
     if confianza_ia < 0.60:
         forzar_revision = True
 
+    # 2. Resolución de Estudiante
     nombre_resuelto = payload.texto_celda.strip()
     estudiante = db.query(DimEstudiante).filter(DimEstudiante.nombre_completo == nombre_resuelto).first()
-    
     if not estudiante:
         estudiante = DimEstudiante(nombre_completo=nombre_resuelto)
         db.add(estudiante)
         db.commit()
         db.refresh(estudiante)
 
+    # 3. Control de Dimensiones (Evitar violación de Foreign Keys)
+    # Autogenerar IDs por defecto si no existen
+    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"))
+    
+    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"))
+         
+    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.commit() # Asegurar que las FK existan antes del INSERT principal
+
+    # 4. 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")
 
+    # 5. Persistencia del Hecho (Fact)
     try:
         nuevo_hecho = FactRendimientoAcademico(
             id_estudiante=estudiante.id_estudiante,
@@ -88,7 +108,8 @@ def procesar_registro_tabular(payload: ProcessSheetPayload, db: Session = Depend
     except Exception as err:
         db.rollback()
         logger.error(f"Fallo en persistencia: {err}")
-        raise HTTPException(status_code=500, detail="Error al escribir en Supabase.")
+        # Retornar detalles del error en consola puede ser útil para ti, aunque en producción no se expone el log del motor
+        raise HTTPException(status_code=500, detail=f"Error al escribir en Supabase: {str(err)}")
 
 @app.get("/api/v1/riesgos/cruzado")
 

database.py

@@ -32,6 +32,37 @@ class DimEstudiante(Base):
     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)
+    especialidad = Column(String(100))
+
+class DimModulo(Base):
+    __tablename__ = "dim_modulo"
+    id_modulo = Column(Integer, primary_key=True)
+    nombre_modulo = Column(String(200), nullable=False)
+    version = Column(String(50))
+
+class DimTiempo(Base):
+    __tablename__ = "dim_tiempo"
+    id_tiempo = Column(Integer, primary_key=True)
+    anio = Column(Integer, nullable=False)
+    mes = Column(Integer, nullable=False)
+    dia = Column(Integer, nullable=False)
+    trimestre = Column(Integer, nullable=False)
+
+class DimDocumento(Base):
+    __tablename__ = "dim_documento"
+    id_documento = Column(Integer, primary_key=True)
+    tipo_documento = Column(String(100), nullable=False)
+
+class DimUsuario(Base):
+    __tablename__ = "dim_usuario"
+    id_usuario = Column(Integer, primary_key=True)
+    rol = Column(String(50), nullable=False)
+    nombre = Column(String(100), nullable=False)
+
 class FactRendimientoAcademico(Base):
     __tablename__ = "fact_rendimiento_academico"
     id_hecho_aca = Column(Integer, primary_key=True, index=True)