feat: implement automatic creation of default financial category for budget payloads in app sync process

app.py

@@ -512,6 +512,7 @@ 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()}
 
         nuevos_estudiantes = []
         nuevos_docentes = []
@@ -519,6 +520,7 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
         nuevos_tiempos = []
         nuevos_docs = []
         nuevos_users = []
+        nuevas_categorias = []
 
         hechos_marketing = []
         hechos_surveys = []
@@ -542,6 +544,13 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
             if payload.id_usuario not in users_db:
                 nuevos_users.append(Users(id=payload.id_usuario, username=f"sistema_{payload.id_usuario}", hashed_password="$placeholder$", role="admin"))
                 users_db.add(payload.id_usuario)
+            
+            # 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)
 
         # Insertar nuevas dimensiones en bloque si existen
         if nuevos_docentes: db.add_all(nuevos_docentes)
@@ -549,6 +558,7 @@ def procesar_lote_tabular(payloads: List[ProcessSheetPayload], db: Session = Dep
         if nuevos_tiempos: db.add_all(nuevos_tiempos)
         if nuevos_docs: db.add_all(nuevos_docs)
         if nuevos_users: db.add_all(nuevos_users)
+        if nuevas_categorias: db.add_all(nuevas_categorias)
         db.flush()
 
         for payload in payloads: