chore: remove debug _debug_default_recipient script and finalize email services unification

Author: DysTelefonica-legacy

README.md

@@ -310,8 +310,7 @@ scripts-python/
 │   │   ├── __init__.py
 │   │   ├── agedys/              # Integración del sistema AGEDYS
 │   │   ├── brass/               # Integración del sistema brass
-│   │   ├── correo_tareas/       # Integración del sistema de correo tareas
-│   │   ├── correos/             # Integración del sistema de correos
+│   │   ├── email_services/      # Integración del servicio unificado de correos
 │   │   ├── database/            # Integración con bases de datos
 │   │   ├── expedientes/         # Integración del sistema de expedientes
 │   │   ├── no_conformidades/    # Integración no conformidades
@@ -321,7 +320,7 @@ scripts-python/
 │       ├── agedys/              # Tests específicos AGEDYS
 │       ├── brass/               # Tests específicos BRASS
 │       ├── common/              # Tests módulos comunes
-│       ├── correos/             # Tests del módulo de correos
+│       ├── email_services/      # Tests del servicio unificado de correos
 │       ├── expedientes/         # Tests del módulo de expedientes
 │       ├── no_conformidades/    # Tests no conformidades
 │       └── riesgos/             # Tests del módulo de riesgos
@@ -722,7 +721,7 @@ El sistema soporta dos configuraciones SMTP:
 | `src/common/task_registry.py` | 64% | ✅ |
 | `src/common/notifications.py` | 100% | ✅ |
 | `src/common/utils.py` | 49% | ✅ |
-| `src/correos/correos_manager.py` | 91% | ✅ |
+| `src/email_services/email_manager.py` | 91% | ✅ |
 | `src/expedientes/expedientes_manager.py` | 98% | ✅ |
 | `src/riesgos/riesgos_manager.py` | 90% | ✅ |
 
@@ -1076,6 +1075,9 @@ python scripts/run_riesgos.py --force           # Fuerza ejecución
 python scripts/run_riesgos.py --dry-run         # Modo simulación
 
 # Email Services - Servicio unificado de correo (remplaza correos y correo_tareas)
+
+### Manejo de errores transitorios SMTP (Refactor 2025)
+Los errores de conexión SMTP (p.ej. desconexión inesperada, `SMTPConnectError`, `ConnectionRefusedError`) ahora se consideran **transitorios** y no marcan el correo como fallido en la base de datos. El registro permanece pendiente para reintentos en futuros ciclos. Sólo errores definitivos (credenciales inválidas, destinatario rechazado, formato de mensaje inválido) marcan el correo como fallido. Esto incrementa la resiliencia ante caídas puntuales del servidor de correo.
 python scripts/run_email_services.py            # Ejecución normal
 python scripts/run_email_services.py --force    # (Reservado) Fuerza ejecución
 

scripts/README.md

@@ -7,7 +7,7 @@ Este directorio contiene los scripts de producción del sistema de monitoreo con
 ```
 scripts/
 ├── run_master.py              # 🎯 Script maestro - daemon principal del sistema
-├── run_correos.py             # 📧 Gestión y envío de correos electrónicos
+├── run_email_services.py      # 📧 Servicios unificados de envío de correos
 ├── run_brass.py               # 🔧 Procesamiento de datos BRASS
 ├── run_expedientes.py         # 📋 Gestión de expedientes y ofertas
 ├── run_riesgos.py             # ⚠️  Análisis y gestión de riesgos
@@ -31,18 +31,18 @@ El **Master Runner** es el corazón del sistema de monitoreo continuo. Ejecuta d
 - **Configuración flexible**: Variables de entorno para todos los parámetros
 
 ### Scripts Gestionados:
-1. **correos** → `run_correos.py` (continuo)
+1. **email_services** → `run_email_services.py` (continuo unificado)
 2. **riesgos** → `run_riesgos.py` (diario)
 3. **brass** → `run_brass.py` (diario)
 4. **expedientes** → `run_expedientes.py` (diario)
 5. **no_conformidades** → `run_no_conformidades.py` (diario)
 
 ## 📧 Scripts de Producción
 
-### run_correos.py
-- **Función**: Gestión y envío de correos electrónicos
+### run_email_services.py
+- **Función**: Gestión unificada de servicios de correo (reemplaza correos y correo_tareas)
 - **Tipo**: Tarea continua (ejecutada en cada ciclo)
-- **Descripción**: Procesa colas de correo y envía notificaciones
+- **Descripción**: Procesa colas de correo de múltiples orígenes (correos, tareas) y envía notificaciones
 
 ### run_brass.py
 - **Función**: Procesamiento de datos BRASS
@@ -89,7 +89,7 @@ python run_master.py --dry-run
 ### Ejecución Individual de Scripts:
 ```bash
 # Ejecutar script específico
-python run_correos.py
+python run_email_services.py
 python run_brass.py
 python run_expedientes.py
 python run_riesgos.py

src/email_services/email_manager.py

@@ -25,6 +25,11 @@
 logger = logging.getLogger(__name__)
 
 
+class TransientEmailSendError(Exception):
+    """Error transitorio (p.ej. fallo de conexión SMTP) que NO debe marcar el correo como no enviado aún."""
+    pass
+
+
 class EmailManager:
     """Gestor unificado para envío de correos pendientes.
 
@@ -69,12 +74,19 @@ def process_pending_emails(self) -> int:
             logger.info("%s correos pendientes (%s)", len(rows), self.email_source)
             for correo in rows:
                 try:
-                    if self._enviar_correo_individual(correo):
+                    resultado = self._enviar_correo_individual(correo)
+                    if resultado is True:
                         self._marcar_correo_enviado(correo['IDCorreo'], datetime.now())
                         enviados += 1
-                    else:
+                    elif resultado is False:
+                        # Fallo definitivo en construcción o envío (no transitorio)
                         self._marcar_correo_no_enviado(correo['IDCorreo'], 'Error envío')
-                except Exception as e:  # pragma: no cover - path de error
+                except TransientEmailSendError as e:  # fallo transitorio -> reintentar en ciclo futuro
+                    logger.warning(
+                        "Fallo transitorio SMTP para correo ID %s: %s (se reintentará sin marcar)",
+                        correo.get('IDCorreo'), e
+                    )
+                except Exception as e:  # pragma: no cover - path de error inesperado
                     logger.error("Error procesando correo ID %s: %s", correo.get('IDCorreo'), e)
                     self._marcar_correo_no_enviado(correo.get('IDCorreo', -1), str(e))
             return enviados
@@ -84,6 +96,7 @@ def process_pending_emails(self) -> int:
 
     # ------------------ Lógica interna ------------------
     def _enviar_correo_individual(self, correo: Dict[str, Any]) -> bool:
+        """Devuelve True si enviado, False si fallo definitivo, o levanta TransientEmailSendError."""
         try:
             msg = MIMEMultipart()
             aplicacion = correo.get('Aplicacion', 'Sistema')
@@ -109,6 +122,8 @@ def _enviar_correo_individual(self, correo: Dict[str, Any]) -> bool:
                 logger.warning("Correo ID %s sin destinatarios", correo.get('IDCorreo'))
                 return False
             return self._enviar_smtp(msg, destinatarios)
+        except TransientEmailSendError:
+            raise
         except Exception as e:
             logger.error("Error en _enviar_correo_individual: %s", e)
             return False
@@ -162,6 +177,9 @@ def _enviar_smtp(self, msg: MIMEMultipart, destinatarios: List[str]) -> bool:
                     servidor.login(self.smtp_user, self.smtp_password)
                 servidor.sendmail(self.smtp_user, destinatarios, msg.as_string())
             return True
+        except (ConnectionRefusedError, smtplib.SMTPConnectError, smtplib.SMTPServerDisconnected) as e:
+            logger.error("Fallo conexión SMTP: %s", e)
+            raise TransientEmailSendError(str(e))
         except Exception as e:
             logger.error("Error enviando correo SMTP: %s", e)
             return False