feat: add dynamic DimTiempo resolution and support for projected collections in financial processing

app.py

@@ -149,9 +149,13 @@ class ProcessSheetPayload(BaseModel):
     inscritos: Optional[int] = 0
     costo: Optional[float] = 0.0
     
-    # Survey fields
     pregunta: Optional[str] = None
     puntuacion: Optional[float] = 0.0
+    
+    # Custom fields for specific processing logic
+    gestion: Optional[int] = None
+    mes: Optional[str] = None
+    proyecciones_mensuales: Optional[Dict[str, float]] = None
 
     @field_validator('texto_celda')
     @classmethod
@@ -525,7 +529,7 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
         # For default/generic fallback
         docentes_db = set(existing_docentes.values())
         modulos_db = {m.id_modulo for m in db.query(DimModulo).all()}
-        tiempos_db = {t.id_tiempo for t in db.query(DimTiempo).all()}
+        tiempos_db_list = db.query(DimTiempo).all()
         docs_db = {d.id_documento for d in db.query(DimOrigenDocumental).all()}
         users_db = {u.id for u in db.query(Users).all()}
         
@@ -545,6 +549,7 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
         hechos_academic = []
         hechos_budget = []
         hechos_finance = []
+        hechos_cobranzas = []
 
         for payload in payloads:
             # Dimensiones requeridas
@@ -563,9 +568,18 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
             if payload.id_modulo not in modulos_db:
                 nuevos_modulos.append(DimModulo(id_modulo=payload.id_modulo, nombre_modulo=payload.modulo or "Modulo Generico", nombre_institucion=payload.institucion or "GiraGroup", programa=payload.programa or "General"))
                 modulos_db.add(payload.id_modulo)
-            if payload.id_tiempo not in tiempos_db:
-                nuevos_tiempos.append(DimTiempo(id_tiempo=payload.id_tiempo, gestion=2026, semestre=1, mes="Mayo"))
-                tiempos_db.add(payload.id_tiempo)
+                
+            # Resolución dinámica de DimTiempo
+            gestion_val = int(payload.gestion) if getattr(payload, 'gestion', None) else 2026
+            mes_val = str(payload.mes).capitalize() if getattr(payload, 'mes', None) else "Mayo"
+            tiempo_obj = next((t for t in tiempos_db_list if t.gestion == gestion_val and t.mes.lower() == mes_val.lower()), None)
+            if not tiempo_obj:
+                new_id = max((t.id_tiempo for t in tiempos_db_list), default=0) + 1
+                tiempo_obj = DimTiempo(id_tiempo=new_id, gestion=gestion_val, semestre=1, mes=mes_val)
+                nuevos_tiempos.append(tiempo_obj)
+                tiempos_db_list.append(tiempo_obj)
+            payload.id_tiempo = tiempo_obj.id_tiempo
+
             if payload.id_documento not in docs_db:
                 nuevos_docs.append(DimOrigenDocumental(id_documento=payload.id_documento, tipo_documento="SHEET", nombre_archivo="carga_automatica"))
                 docs_db.add(payload.id_documento)
@@ -642,14 +656,35 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
                     monto_meta=getattr(payload, 'monto_meta', getattr(payload, 'costo', 0))
                 ))
             elif area == "FINANCE":
-                hechos_finance.append(FactSituacionFinanciera(
-                    id_estudiante=estudiante.id_estudiante,
-                    id_tiempo=payload.id_tiempo,
-                    monto_deuda=getattr(payload, 'monto_deuda', 0),
-                    cuotas_impagas=getattr(payload, 'cuotas_impagas', 0),
-                    estado_cartera=getattr(payload, 'estado_cartera', 'PENDIENTE'),
-                    tipo_alerta=getattr(payload, 'tipo_alerta', 'NINGUNA')
-                ))
+                if getattr(payload, 'proyecciones_mensuales', None):
+                    for mes_key, monto_esp in payload.proyecciones_mensuales.items():
+                        parts = str(mes_key).upper().replace('MONTO', '').strip().split()
+                        mes_str = parts[0] if len(parts) > 0 else 'ENERO'
+                        gestion_val = int(parts[1]) if len(parts) > 1 and parts[1].isdigit() else getattr(payload, 'gestion', 2024)
+                        if not gestion_val: gestion_val = 2024
+                        
+                        tiempo_proj = next((t for t in tiempos_db_list if t.gestion == gestion_val and t.mes.lower() == mes_str.lower()), None)
+                        if not tiempo_proj:
+                            new_id = max((t.id_tiempo for t in tiempos_db_list), default=0) + 1
+                            tiempo_proj = DimTiempo(id_tiempo=new_id, gestion=gestion_val, semestre=1, mes=mes_str.capitalize())
+                            nuevos_tiempos.append(tiempo_proj)
+                            tiempos_db_list.append(tiempo_proj)
+                            
+                        hechos_cobranzas.append(FactCobranzasProyectadas(
+                            id_estudiante=estudiante.id_estudiante,
+                            id_tiempo=tiempo_proj.id_tiempo,
+                            monto_esperado=float(monto_esp),
+                            estado_cobro="PENDIENTE"
+                        ))
+                else:
+                    hechos_finance.append(FactSituacionFinanciera(
+                        id_estudiante=estudiante.id_estudiante,
+                        id_tiempo=payload.id_tiempo,
+                        monto_deuda=getattr(payload, 'monto_deuda', 0),
+                        cuotas_impagas=getattr(payload, 'cuotas_impagas', 0),
+                        estado_cartera=getattr(payload, 'estado_cartera', 'PENDIENTE'),
+                        tipo_alerta=getattr(payload, 'tipo_alerta', 'NINGUNA')
+                    ))
             else: # ACADEMIC
                 hechos_academic.append(FactRendimientoAcademico(
                     id_estudiante=estudiante.id_estudiante, id_docente=payload.id_docente,
@@ -664,6 +699,7 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
         if hechos_surveys: db.add_all(hechos_surveys)
         if hechos_budget: db.add_all(hechos_budget)
         if hechos_finance: db.add_all(hechos_finance)
+        if hechos_cobranzas: db.add_all(hechos_cobranzas)
         if hechos_academic: db.add_all(hechos_academic)
 
         db.commit()