Merge feature/brass-refactor-2: DB unification, TaskRegistry, simple mode improvements, legacy cleanup

Author: DysTelefonica-legacy

.gitignore

@@ -52,7 +52,6 @@ coverage.xml
 # Logs
 logs/
 *.log
-setup_local_environment.log
 
 # Database files
 *.accdb

README.md

@@ -28,6 +28,76 @@ El **script maestro (`run_master.py`)** es el corazón del sistema y reemplaza a
 6. **Correos** (`run_correos.py`): Sistema de envío de correos
 7. **Correo Tareas** (`run_correo_tareas.py`): Sistema de gestión de correos que interactúa con la base de datos de tareas
 
+### 🆕 Cambios Arquitectónicos Recientes (Refactor 2025)
+
+Refactor integral para simplificar arquitectura, mejorar testabilidad y eliminar código legacy.
+
+Principales mejoras:
+1. Capa de datos unificada:
+   - Eliminados `AccessAdapter` y `DemoDatabase`.
+   - Nueva clase única `AccessDatabase` con soporte opcional de pool.
+   - Introducido `AccessConnectionPool` (gestiona instancias reutilizables por cadena de conexión).
+2. Gestión de tareas:
+   - Reemplazo de funciones globales por clase `TaskRegistry` (extensible, inyectable, test-friendly).
+   - API: `get_daily_tasks()`, `get_continuous_tasks()`, `get_all_tasks()`, `summary()`, filtros y extensión por parámetros `extra_daily/extra_continuous`.
+   - Backwards compatibility: funciones wrapper conservadas para código legado.
+3. Script maestro (`run_master.py`):
+   - Consolidado antiguo `run_master_new.py` (eliminado).
+   - Añadido modo `--simple` sobre `TaskRegistry` con resumen estructurado.
+   - Fast-path en tests (`MASTER_DRY_SUBPROCESS=1`) evitando importaciones pesadas.
+4. Riesgos y No Conformidades: parametrización explícita de frecuencias vía variables de entorno para subtareas.
+5. Limpieza y cobertura:
+   - Eliminado definitivamente archivo legacy `database_adapter.py` y su test.
+   - Stub ligero de `RiesgosTask` para unit tests cuando el módulo completo no es necesario.
+6. Documentación actualizada: ejemplos de extensión de tareas, uso de pools y guía de migración.
+
+Pendiente futuro (no implementado aún):
+- Sistema de plugins de tareas (descubrimiento dinámico).
+- Persistencia de métricas de ejecución (duración/estado) para observabilidad.
+- Reducción selectiva de coste de importación en módulos grandes (lazy loading adicional).
+
+### Uso de TaskRegistry
+
+```python
+from common.task_registry import TaskRegistry
+
+registry = TaskRegistry()
+for task in registry.get_daily_tasks():
+   if task.debe_ejecutarse():
+      task.ejecutar()
+      task.marcar_como_completada()
+```
+
+Extender con tareas personalizadas:
+
+```python
+from common.base_task import TareaDiaria
+from common.task_registry import TaskRegistry
+
+class MiTarea(TareaDiaria):
+   def __init__(self):
+      super().__init__(name="MiTarea", script_filename="run_mi_tarea.py", task_names=["MiTareaDiaria"], frequency_days=1)
+   def debe_ejecutarse(self):
+      return True
+   def marcar_como_completada(self):
+      pass
+
+registry = TaskRegistry(extra_daily=[MiTarea()])
+```
+
+### Acceso unificado a BD
+
+```python
+from common.database import AccessDatabase
+from common.access_connection_pool import get_tareas_connection_pool
+from common.config import config
+
+conn_str = config.get_db_tareas_connection_string()
+pool = get_tareas_connection_pool(conn_str)
+db = AccessDatabase(conn_str, pool=pool)
+rows = db.execute_query("SELECT TOP 1 * FROM TbTareas")
+```
+
 ### 🚀 Modo Verbose del Script Maestro
 
 El script maestro incluye un **modo verbose** para debugging y monitoreo detallado:
@@ -135,7 +205,6 @@ scripts-python/
 │   ├── run_correos.py           # Script para módulo correos
 │   ├── run_expedientes.py       # Script para módulo expedientes
 │   ├── run_master.py            # Script maestro - daemon principal con modo verbose
-│   ├── run_master_new.py        # Nueva versión del script maestro
 │   ├── run_no_conformidades.py  # Script para no conformidades
 │   └── run_riesgos.py           # Script para módulo de riesgos
 ├── src/                         # Código fuente
@@ -155,12 +224,11 @@ scripts-python/
 │   │   ├── base_email_manager.py # Gestor base para emails
 │   │   ├── base_task.py         # Clase base para tareas
 │   │   ├── config.py            # Configuración multi-entorno
-│   │   ├── database.py          # Capa abstracción bases datos Access
-│   │   ├── database_adapter.py  # Adaptador de bases de datos
+│   │   ├── database.py          # Capa unificada Access (AccessDatabase + pools)
 │   │   ├── html_report_generator.py # Generador reportes HTML
 │   │   ├── logger.py            # Sistema de logging
 │   │   ├── notifications.py     # Sistema de notificaciones
-│   │   ├── task_registry.py     # Registro de tareas
+│   │   ├── task_registry.py     # Registro de tareas (TaskRegistry OO)
 │   │   ├── user_adapter.py      # Adaptador de usuarios
 │   │   └── utils.py             # Utilidades HTML, logging, fechas
 │   ├── correo_tareas/           # Módulo de gestión de correos que interactúa con la base de datos de tareas
@@ -611,7 +679,7 @@ El sistema soporta dos configuraciones SMTP:
 |--------|-----------|-------|
 | `src/common/config.py` | 88% | ✅ |
 | `src/common/database.py` | 55% | ✅ |
-| `src/common/database_adapter.py` | 95% | ✅ |
+| `src/common/task_registry.py` | 64% | ✅ |
 | `src/common/notifications.py` | 100% | ✅ |
 | `src/common/utils.py` | 49% | ✅ |
 | `src/correos/correos_manager.py` | 91% | ✅ |
@@ -1015,7 +1083,7 @@ python tools/setup_local_environment.py --empty-correos
 
 4. **Actualización de Vínculos**: Actualiza automáticamente todas las tablas vinculadas para que apunten a las bases de datos locales
 
-5. **Logging Detallado**: Genera un log completo del proceso en `setup_local_environment.log`
+5. **Logging Detallado**: Genera un log completo del proceso en `logs/setup_local_environment.log` (directorio de logs central). Si usas stack Grafana/Loki, puedes desactivar este archivo estableciendo la variable de entorno `SETUP_LOCAL_FILE_LOG=0` y capturando stdout.
 
 **📋 Casos de Uso Típicos:**
 
@@ -1430,7 +1498,7 @@ docker-compose down -v
 
 - **config.py**: Gestión centralizada de configuración
 - **database.py**: Abstracción para bases de datos Access con ODBC  
-- **database_adapter.py**: Adaptador de conexiones de base de datos
+- (Eliminado) `database_adapter.py` sustituido por `AccessDatabase`
 - **utils.py**: Utilidades compartidas (HTML, fechas, logging)
 
 ### Mejoras vs VBS Original

legacy/script-continuo.vbs.txt

@@ -0,0 +1,164 @@
+Option Explicit
+
+
+Public Function EsNoche()
+    Dim Hora
+    Dim HoraCompleta
+    HoraCompleta = Now()
+    Hora = Hour(HoraCompleta)
+    If Hora >= 20 And Hora <= 24 Then
+        EsNoche = True
+    ElseIf Hora >= 0 And Hora < 7 Then
+        EsNoche = True
+    Else
+        EsNoche = False
+    End If
+End Function
+Function EsLaborable(fecha)
+    Dim fso, archivo, linea,rutaScript, dirPadre, rutaFestivos
+
+
+    
+    
+    ' Si es s�bado o domingo, no es laborable
+    If Weekday(fecha, vbMonday) > 5 Then
+        EsLaborable = False
+        Exit Function
+    End If
+    
+    Set fso = CreateObject("Scripting.FileSystemObject")
+    rutaScript = fso.GetParentFolderName(WScript.ScriptFullName)
+    dirPadre = fso.GetParentFolderName(rutaScript)  ' Un directorio atrás
+    rutaFestivos = fso.BuildPath(dirPadre, "herramientas\\Festivos.txt")
+
+
+    Set archivo = fso.OpenTextFile(rutaFestivos, 1)
+    
+    Do While Not archivo.AtEndOfStream
+        linea = archivo.ReadLine
+        ' Busca la fecha al principio de la línea (puede estar entre paréntesis)
+        ' Extrae solo la parte de la fecha
+        If InStr(1, linea, fecha) <> 0 Then
+            archivo.Close
+            Set archivo = Nothing
+            Set fso = Nothing
+            EsLaborable = False
+            Exit Function
+        End If
+       
+    Loop
+    archivo.Close
+    Set archivo = Nothing
+    Set fso = Nothing
+    
+    EsLaborable = True
+End Function
+Public Function getTiempo(m_EsNoche, EsLaborableDia)
+    Dim minutosLaborablesDia
+    Dim minutosNoLaborablesDia
+    Dim minutosLaborablesNoche
+    Dim minutosNoLaborablesNoche
+    Dim minutos
+    Dim segundos
+
+    minutosNoLaborablesDia = 60
+    minutosLaborablesDia = 5
+    minutosLaborablesNoche = 60
+    minutosNoLaborablesNoche = 120
+
+    If EsLaborableDia Then
+        If m_EsNoche Then
+            minutos = minutosLaborablesNoche
+        Else
+            minutos = minutosLaborablesDia
+        End If
+    Else
+        If m_EsNoche Then
+            minutos = minutosNoLaborablesNoche
+        Else
+            minutos = minutosNoLaborablesDia
+        End If
+    End If
+    segundos = minutos * 60
+    getTiempo = minutos & "|" & segundos * 1000
+End Function
+
+Public Function main()
+    Dim objShell
+    Dim minutos
+    Dim flag
+    Dim Tiempo
+    Dim dato
+    Dim DiaActual
+    Dim DiaRealizacionTareas
+    Dim TiempotareaNC
+    Dim TiempoTareaBrass
+    Dim TiempoTareaTareas
+    Dim TiempoTareaRiesgos
+    Dim EsLaborableHoy
+	Dim TareasHechas
+	Dim fso, scriptDir
+
+    TiempotareaNC = 30000
+    TiempoTareaBrass = 30000
+    TiempoTareaTareas = 120000
+    TiempoTareaRiesgos = 60000
+    Set objShell = WScript.CreateObject("WScript.Shell")
+    DiaRealizacionTareas = Date
+
+    EsLaborableHoy = EsLaborable(Date)
+    TareasHechas = False
+    Set fso = CreateObject("Scripting.FileSystemObject")
+    scriptDir = fso.GetParentFolderName(WScript.ScriptFullName)
+    Do While True
+        objShell.CurrentDirectory =scriptDir
+        DiaActual = Date
+
+        ' Verificar si la fecha ha cambiado para recalcular EsLaborableHoy
+        If DiaActual <> DiaRealizacionTareas Then
+            EsLaborableHoy = EsLaborable(DiaActual) ' Recalcular solo si el día ha cambiado
+            TareasHechas = False
+        End If
+
+        flag = getTiempo(EsNoche(), EsLaborableHoy)
+        dato = Split(flag, "|")
+        minutos = dato(0)
+        Tiempo = dato(1)
+
+        If EsLaborableHoy And TareasHechas = False Then
+            If Hour(Now()) > 6 Then
+                debug.WriteLine "1/7 Iniciando NoConformidades "  & Now()
+                objShell.Run "NoConformidades.vbs"
+                WScript.Sleep TiempotareaNC
+                
+                debug.WriteLine "2/7 Iniciando GestionRiesgos_bat "  & Now()
+                objShell.Run "GestionRiesgos.vbs"
+                WScript.Sleep TiempoTareaRiesgos
+  
+                debug.WriteLine "3/7 Iniciando BRASS.vbs "  & Now()
+                objShell.Run "BRASS.vbs"
+                WScript.Sleep TiempoTareaBrass
+                debug.WriteLine "4/7 Iniciando Expedientes.vbs "  & Now()
+                objShell.Run "Expedientes.vbs"
+                WScript.Sleep TiempoTareaBrass
+                debug.WriteLine "5/7 Iniciando AGEDYS "  & Now()
+                objShell.Run "AGEDYS.VBS"
+                WScript.Sleep TiempoTareaTareas
+                debug.WriteLine "Pasa Por tareas diarias"
+                DiaRealizacionTareas = Date ' Actualizar la fecha de última ejecución de las tareas diarias
+                TareasHechas=true
+            End If
+        Else
+            debug.WriteLine "No Pasa Por tareas diarias"
+        End If
+        
+        debug.WriteLine "6/7 Iniciando Correos de Tareas "  & Now()
+        objShell.Run "EnviarCorreoTareas.vbs"
+        debug.WriteLine "7/7 Iniciando Correos Resto "  & Now()
+        objShell.Run "EnviarCorreoNoEnviado.vbs"
+        debug.WriteLine "Próximo ciclo en " &  minutos & " minutos" & " " & DateAdd("n", minutos, Now())
+        debug.WriteLine "--------------------------------------------------------------------------"
+        WScript.Sleep Tiempo
+    Loop
+End Function
+main

scripts/run_brass.py

@@ -9,11 +9,15 @@
 
 # Añadir el directorio raíz del proyecto al path para importaciones
 project_root = Path(__file__).parent.parent
-sys.path.insert(0, str(project_root))
+src_dir = project_root / 'src'
+if str(project_root) not in sys.path:
+    sys.path.insert(0, str(project_root))
+if str(src_dir) not in sys.path:
+    sys.path.insert(0, str(src_dir))
 
 from src.common.config import config
 from src.common.utils import setup_logging
-from src.brass.brass_manager import BrassManager
+from src.brass.brass_task import BrassTask
 
 def main():
     """Función principal"""
@@ -26,33 +30,31 @@ def main():
     args = parser.parse_args()
 
     # Configurar logging
-    setup_logging(config.log_level, config.log_file)
+    # setup_logging espera primero el archivo y luego el nivel
+    setup_logging(log_file=config.log_file, level=config.log_level)
 
     try:
-        # Crear instancia del gestor BRASS
-        brass_manager = BrassManager()
-        
-        if args.dry_run:
-            print("Modo simulación - verificando si la tarea debe ejecutarse...")
-            should_run = brass_manager.should_execute_task()
-            print(f"¿Debe ejecutarse la tarea BRASS? {'Sí' if should_run else 'No'}")
-            return 0
-        
-        if args.force:
-            print("Modo forzado - ejecutando tarea BRASS...")
-            success = brass_manager.ejecutar_logica_especifica()
+        with BrassTask() as task:
+            if args.dry_run:
+                print("Modo simulación - verificando si la tarea debe ejecutarse...")
+                should_run = task.debe_ejecutarse()
+                print(f"¿Debe ejecutarse la tarea BRASS? {'Sí' if should_run else 'No'}")
+                return 0
+
+            if args.force:
+                print("Modo forzado - ejecutando tarea BRASS...")
+                success = task.execute_specific_logic()
+                if success:
+                    task.marcar_como_completada()
+            else:
+                success = task.run()
+
             if success:
-                brass_manager.marcar_como_completada()
-        else:
-            # Ejecución normal con verificación de horarios
-            success = brass_manager.run()
-        
-        if success:
-            print("Tarea BRASS ejecutada exitosamente")
-            return 0
-        else:
-            print("Error en la ejecución de la tarea BRASS")
-            return 1
+                print("Tarea BRASS ejecutada exitosamente")
+                return 0
+            else:
+                print("Error en la ejecución de la tarea BRASS")
+                return 1
 
     except Exception as e:
         print(f"Error crítico: {e}")