WebSVN – LeadersLinked - Services – Diff – /module/LeadersLinked/src/Command/ProcessQueueEmailCommand.php

 declare(strict_types = 1);
 namespace LeadersLinked\Command;
 use Symfony\Component\Console\Command\Command;
-use Symfony\Component\Console\Input\InputInterface;
-// use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 use Laminas\Db\Adapter\AdapterInterface;
 use Laminas\Log\LoggerInterface;
 use LeadersLinked\Mapper\EmailMapper;
 use PHPMailer\PHPMailer\PHPMailer;
 use LeadersLinked\Model\Email;
 use Laminas\Mvc\I18n\Translator;
+use LeadersLinked\Cache\CacheInterface;
-use LeadersLinked\Cache\CacheInterface;
+use Laminas\Db\Adapter\Exception\InvalidQueryException; // Importar para manejar excepciones de BD
-class ProcessQueueEmailCommand extends Command
 class ProcessQueueEmailCommand extends Command
+{
     /**
+     *
      * @var \Laminas\Db\Adapter\AdapterInterface
     /**
+     *
      * @param \Laminas\Db\Adapter\AdapterInterface $adapter
-     * @param \LeadersLinked\Cache\CacheInterface $cache
-     * @param
+     * @param \LeadersLinked\Cache\CacheInterface $cache
-     *            \Laminas\Log\LoggerInterface
+     * @param \Laminas\Log\LoggerInterface $logger
      * @param array $config
      * @param \Laminas\Mvc\I18n\Translator $translator
      */
     public function __construct($adapter, $cache, $logger, $config, $translator)
         $this->translator = $translator;
         parent::__construct();
     }
-    protected function execute(InputInterface $input, OutputInterface $output): int
+    protected function execute($input, $output)
+    {
         $sandbox = $this->config['leaderslinked.runmode.sandbox'];
         if ($sandbox) {
             $port = $this->config['leaderslinked.email.production_port'];
             $username = $this->config['leaderslinked.email.production_username'];
             $password = $this->config['leaderslinked.email.production_password'];
+        }
-        echo 'Username : ' . $username . PHP_EOL;
-        echo 'Password : ' . $password . PHP_EOL;
-        echo 'Host : ' . $host . PHP_EOL;
-        echo 'Port : ' . $port . PHP_EOL;
+        $this->logger->info('Inicio del proceso de la cola de Email');
-        $this->logger->info('Inicio del proceso de la cola de Email');
+        $output->writeln('<info>Iniciando el procesamiento de la cola de emails...</info>');
+        $emailCompleted = 0;
-        $emailCompleted = 0;
+        $emailError = 0; // Para correos con errores que se descartan
-        $emailError = 0;
+        $emailRetried = 0; // Para correos que se reintentan
+        $emailMapper = EmailMapper::getInstance($this->adapter);
+        $emails = $emailMapper->fetchBatch($batch_size);
+        if (!$emails) {
+            $this->logger->info('No hay emails en la cola');
-        $emailMapper = EmailMapper::getInstance($this->adapter);
+            $output->writeln('<comment>No hay emails en la cola para procesar.</comment>');
+            return Command::SUCCESS;
+        }
-        $emails = $emailMapper->fetchBatch($batch_size);
+        foreach ($emails as $email) {
+            // Iniciar transacción para cada email para asegurar atomicidad
+            $this->adapter->getDriver()->getConnection()->beginTransaction();
+            try {
+                $content = json_decode($email->content, true);
+                // Validación básica de los datos del email
+                if (json_last_error() !== JSON_ERROR_NONE) {
+                    throw new \RuntimeException('Error al decodificar el contenido JSON del email: ' . json_last_error_msg());
+                }
-        if ($emails) {
+                if (!isset($content['to_address'], $content['subject'], $content['message'])) {
-            foreach ($emails as $email) {
+                    throw new \RuntimeException('Contenido del email JSON incompleto: faltan datos esenciales.');
-                $content = json_decode($email->content, true);
+                }
                 $to_address = $content['to_address'];
-                $to_name = $content['to_name'];
-                $cc = $content['cc'];
+                $to_name = $content['to_name'] ?? ''; // Valor por defecto
-                $bcc = $content['bcc'];
+                $cc = $content['cc'] ?? []; // Valor por defecto
-                $subject = $content['subject'];
-                $message = $content['message'];
+                $bcc = $content['bcc'] ?? []; // Valor por defecto
-                $encoding = mb_detect_encoding($subject);
-                if ($encoding != 'UTF-8') {
-                    $subject = mb_convert_encoding($subject, 'UTF-8', $encoding);
-                }
+                $subject = $content['subject'];
                 $message = $content['message'];
+                // Normalización de codificación
+                $subject = $this->normalizeEncoding($subject);
+                $message = $this->normalizeEncoding($message);
+                $phpMailer = new PHPMailer(true); // true para habilitar excepciones
+                $phpMailer->isSMTP();
+                $phpMailer->SMTPDebug = 0; // 0 para no depurar, 2 para mensajes detallados en desarrollo
+                $phpMailer->Host = $host;
-                $encoding = mb_detect_encoding($message);
+                $phpMailer->SMTPAuth = true;
-                if ($encoding != 'UTF-8') {
+                $phpMailer->SMTPSecure = 'tls'; // o 'ssl' si el puerto es 465
-                    $message = mb_convert_encoding($message, 'UTF-8', $encoding);
+                $phpMailer->Username = $username;
-                }
+                $phpMailer->Password = $password;
-                $phpMailer = new PHPMailer();
+                $phpMailer->Port = $port;
-                $phpMailer->isSMTP();
+                $phpMailer->CharSet = 'UTF-8';
-                $phpMailer->addAddress($to_address, $to_name);
-                if ($cc) {
-                    foreach ($cc as $address => $name) {
+                $phpMailer->setFrom($from_address, $from_name);
-                        $phpMailer->addCC($address, $name);
-                    }
-                }
-                if ($bcc) {
-                    foreach ($bcc as $address => $name) {
+                $phpMailer->addAddress($to_address, $to_name);
-                        $phpMailer->addBCC($address, $name);
-                    }
-                }
-                $phpMailer->setFrom($from_address, $from_name);
                 $phpMailer->SMTPDebug = false;
-                $phpMailer->Host = $host;
+                foreach ($cc as $address => $name) {
-                $phpMailer->Port = $port;
+                    $phpMailer->addCC($address, $name);
-                $phpMailer->IsHTML(true);
-                $phpMailer->SMTPAuth = true;
+                }
+                foreach ($bcc as $address => $name) {
-                $phpMailer->SMTPSecure = 'tls';
+                    $phpMailer->addBCC($address, $name);
-                $phpMailer->SMTPAuth = true;
+                }
-                $phpMailer->Username = $username;
+                $phpMailer->IsHTML(true);
-                $phpMailer->Password = $password;
+                $phpMailer->Subject = $subject;
-                $phpMailer->Subject = $subject;
+                $phpMailer->Body = $message;
+                $phpMailer->AltBody = strip_tags($message); // Versión de texto plano
+                $phpMailer->send();
-                $phpMailer->Body = $message;
+                // Si el envío es exitoso
+                $emailCompleted++;
+                $email->status = Email::STATUS_COMPLETED;
+                $email->tried = $email->tried + 1; // Aunque exitoso, es bueno registrar el intento
+                $this->logger->info('Email enviado correctamente: ' . $email->id);
+                $output->writeln("  <info>✔ Email #{$email->id} enviado a {$to_address}</info>");
+                // Actualizar el estado del email en la BD y confirmar la transacción
-                $phpMailer->AltBody = $message;
+                $emailMapper->update($email);
-                $phpMailer->CharSet = 'UTF-8';
+                $this->adapter->getDriver()->getConnection()->commit();
+            } catch (\Exception $e) {
-                try{
+                $error_message = 'Error de PHPMailer al enviar email ' . $email->id . ': ' . $e->getMessage() . ' Debug: ' . $phpMailer->ErrorInfo;
-                    $result = $phpMailer->send();
-                } catch (\Exception $e) {
+                $this->logger->error($error_message);
-                    $this->logger->info('Error al enviar el email: ' . $e->getMessage());
+                $output->writeln("  <error>✗ Error al enviar email #{$email->id}: {$e->getMessage()}</error>");
-                    $result = false;
+                $email->tried = $email->tried + 1;
-                }
+                if ($email->tried >= $this->config['leaderslinked.email.max_retries']) { // Usar una configuración para el número máximo de reintentos
+                    $emailError++;
+                    $email->status = Email::STATUS_ERROR;
+                    $this->logger->info('Email descartado después de ' . $email->tried . ' intentos fallidos: ' . $email->id);
+                    $output->writeln("    <error>Email #{$email->id} descartado (máx. reintentos alcanzado).</error>");
+                } else {
+                    $emailRetried++;
-                if ($result) {
+                    $email->status = Email::STATUS_PENDING; // Mantener como pendiente para reintentar
+                    $this->logger->warning('Email ' . $email->id . ' falló. Intentos: ' . $email->tried . '. Reintentando más tarde.');
+                }
+                // Actualizar el estado del email en la BD y revertir si algo sale mal con la actualización (raro en este punto)
+                try {
+                    $emailMapper->update($email);
+                    $this->adapter->getDriver()->getConnection()->commit(); // Confirmar la transacción
+                } catch (\Exception $dbE) {
+                    $this->adapter->getDriver()->getConnection()->rollback();
+                    $this->logger->critical('Error CRÍTICO al actualizar el estado del email #'.$email->id.' en la BD después de fallo de envío: ' . $dbE->getMessage());
+                    $output->writeln("<error>    ERROR CRÍTICO: No se pudo actualizar el estado del email #{$email->id} en la BD.</error>");
+                }
-                    $emailCompleted ++;
+            } catch (\RuntimeException $e) {
+                // Errores de lógica de negocio o validación (ej. JSON malformado)
+                $error_message = 'Error de lógica/validación para email ' . $email->id . ': ' . $e->getMessage();
+                $this->logger->error($error_message);
+                $output->writeln("  <error>✗ Error de procesamiento interno para email #{$email->id}: {$e->getMessage()}</error>");
+                $emailError++; // Generalmente estos errores son irrecuperables por reintentos
+                $email->status = Email::STATUS_ERROR;
+                $email->tried = $email->tried + 1; // Registrar el intento fallido
+                try {
+                    $emailMapper->update($email);
+                    $this->adapter->getDriver()->getConnection()->commit(); // Confirmar la transacción
+                } catch (\Exception $dbE) {
+                    $this->adapter->getDriver()->getConnection()->rollback();
+                    $this->logger->critical('Error CRÍTICO al actualizar el estado del email #'.$email->id.' en la BD después de error de procesamiento: ' . $dbE->getMessage());
+                    $output->writeln("<error>    ERROR CRÍTICO: No se pudo actualizar el estado del email #{$email->id} en la BD.</error>");
+                }
+            }
+             catch (\Exception $e) {
+                // Cualquier otra excepción no capturada
+                $error_message = 'Error desconocido al procesar email ' . $email->id . ': ' . $e->getMessage();
+                $this->logger->critical($error_message);
+                $output->writeln("  <error>✗ Error inesperado al procesar email #{$email->id}: {$e->getMessage()}</error>");
-                    $email->status = Email::STATUS_COMPLETED;
+                $emailError++;
-                    $this->logger->info('Email enviado correctamente: ' . $email->id . ' Resultado: ' . $result);
+                $email->status = Email::STATUS_ERROR; // Marcar como error irrecuperable
-                } else {
+                $email->tried = $email->tried + 1;
-                    if ($email->tried == 2) {
+                try {
-                        $emailError ++;
-                        $email->status = Email::STATUS_ERROR;
+                    $emailMapper->update($email);
+                    $this->adapter->getDriver()->getConnection()->commit(); // Confirmar la transacción
+                } catch (\Exception $dbE) {
+                    $this->adapter->getDriver()->getConnection()->rollback();
+                    $this->logger->critical('Error CRÍTICO al actualizar el estado del email #'.$email->id.' en la BD después de error desconocido: ' . $dbE->getMessage());
+                    $output->writeln("<error>    ERROR CRÍTICO: No se pudo actualizar el estado del email #{$email->id} en la BD.</error>");
+                }
+            }
+        }
+        $this->logger->info('Email con Errores descartados: ' . $emailError);
+        $this->logger->info('Email pendientes para reintento: ' . $emailRetried);
+        $this->logger->info('Email enviados correctamente: ' . $emailCompleted);
+        $this->logger->info('Fin del proceso de la cola de Email');
+        $output->writeln('');
+        $output->writeln("<info>Resumen de la ejecución:</info>");
+        $output->writeln("  - Correos enviados: <info>{$emailCompleted}</info>");
+        $output->writeln("  - Correos con error y descartados: <error>{$emailError}</error>");
+        $output->writeln("  - Correos a reintentar: <comment>{$emailRetried}</comment>");
+        $output->writeln('<info>Proceso de la cola de emails finalizado.</info>');
+        return Command::SUCCESS; // Usar constantes de Symfony para el código de salida
-                        $this->logger->info('Email descartado: ' . $email->id . ' Resultado: ' . $result);
+    }
-                    $email->tried ++;
+    /**
      * Normaliza la codificación de una cadena a UTF-8.

Proyectos de Subversion LeadersLinked - Services

(root)/module/LeadersLinked/src/Command/ProcessQueueEmailCommand.php – Rev 612 → 613