feat: implement dynamic budget category creation based on program names during data ingestion

app.py

@@ -528,7 +528,9 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
         tiempos_db = {t.id_tiempo for t in 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()}
-        categorias_db = {c.id_categoria for c in db.query(DimCategoriaFinanciera).all()}
+        
+        existing_categorias = {c.nombre_categoria: c.id_categoria for c in db.query(DimCategoriaFinanciera).all()}
+        categorias_db = set(existing_categorias.values())
 
         nuevos_estudiantes = []
         nuevos_docentes = []
@@ -574,9 +576,13 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
             # Para presupuestos asumimos categoría base por defecto (ID 1) si no existe
             area_check = getattr(payload, 'tipo_fuente', 'ACADEMIC')
             if not area_check: area_check = 'ACADEMIC'
-            if area_check == 'BUDGET' and 1 not in categorias_db:
-                nuevas_categorias.append(DimCategoriaFinanciera(id_categoria=1, nombre_categoria="Presupuesto General", tipo="EGRESO"))
-                categorias_db.add(1)
+            if area_check == 'BUDGET':
+                cat_name = payload.programa.strip() if getattr(payload, 'programa', None) else "Presupuesto General"
+                if cat_name not in existing_categorias:
+                    new_id = max(existing_categorias.values() or [0]) + 1
+                    nuevas_categorias.append(DimCategoriaFinanciera(id_categoria=new_id, nombre_categoria=cat_name, tipo="EGRESO"))
+                    existing_categorias[cat_name] = new_id
+                    categorias_db.add(new_id)
 
         # Insertar nuevas dimensiones en bloque si existen
         if nuevos_docentes: db.add_all(nuevos_docentes)
@@ -628,9 +634,10 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
                     puntuacion=getattr(payload, 'puntuacion', 5.0), comentario=nombre_resuelto
                 ))
             elif area == "BUDGET":
+                cat_name = payload.programa.strip() if getattr(payload, 'programa', None) else "Presupuesto General"
                 hechos_budget.append(FactRentabilidadPresupuesto(
                     id_modulo=payload.id_modulo, id_tiempo=payload.id_tiempo,
-                    id_categoria=1,
+                    id_categoria=existing_categorias.get(cat_name, 1),
                     monto_ejecutado=getattr(payload, 'monto_ejecutado', getattr(payload, 'costo', 0)),
                     monto_meta=getattr(payload, 'monto_meta', getattr(payload, 'costo', 0))
                 ))