src/Application/Internit/LeadBundle/Service/ResendLeadWorkerCommand.php line 10

Open in your IDE?
  1. <?php
  3. namespace App\Application\Internit\LeadBundle\Service;
  5. use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
  6. use Symfony\Component\Console\Input\InputInterface;
  7. use Symfony\Component\Console\Output\OutputInterface;
  8. use App\Application\Internit\LeadBundle\Entity\LeadErrorLog;
  10. class ResendLeadWorkerCommand extends ContainerAwareCommand
  11. {
  12.     protected function configure()
  13.     {
  14.         $this
  15.             ->setName('resend:lead:worker')
  16.             ->setDescription('Consome fila de leads e envia e-mail');
  17.     }
  19.    protected function execute(InputInterface $input, OutputInterface $output)
  20.     {
  21.         $conn = $this->getContainer()->get('doctrine')->getConnection();
  23.         $entityManager = $this->getContainer()->get('doctrine')->getManager();
  25.         $rows = $conn->fetchAllAssociative("SELECT * FROM lead_queue WHERE status = 'pendente'");
  27.         foreach ($rows as $row) {
  28.             
  29.             $entityManager->beginTransaction(); // Inicia a transação
  30.             
  31.             try {
  32.                 // 1. LIMPEZA DOS EMAILS DE CÓPIA
  33.                 $copyEmailsRaw = explode(',', $row['copy_emails']);
  34.                 // Filtra e-mails vazios ou nulos (soluciona o Address in mailbox given [] error)
  35.                 $copyEmails = array_filter($copyEmailsRaw, function($email) {
  36.                     return !empty(trim($email));
  37.                 });
  39.                 $lead = $entityManager->getRepository('ApplicationInternitLeadBundle:Lead')->find($row['lead_id']);
  41.                 if (!$lead) {
  42.                     $conn->update('lead_queue', ['status' => 'falhou', 'updated_at' => date('Y-m-d H:i:s')], ['id' => $row['id']]);
  43.                     $entityManager->commit(); 
  44.                     continue;
  45.                 }
  47.                 $html = $this->getContainer()->get('templating')->render(
  48.                     '@ApplicationInternit/SettingBundle/Resources/views/Mail/emailLead.html.twig',
  49.                     ['data' => $lead, 'corretor' => $row['broker_name']]
  50.                 );
  52.                 $enviado = false;
  54.                 // Primeira tentativa
  55.                 try {
  56.                     $mailer1 = $this->getContainer()->get('admin.mail.service');
  58.                     $mailer1->setMessage()
  59.                         ->setTo($row['broker_email'] ?? $lead->getProduct()->getEmail())
  60.                         ->setCC($copyEmails) // Array filtrado!
  61.                         // ... (restante do setSubject e setBody) ...
  62.                         ->setSubject("[leadcalper] " . $lead->getProduct()->getName() . ' - ' . $lead->getGroup() . ' - ' . $row['broker_name'])
  63.                         ->setBody($html, 'text/html');
  65.                     $mailer1->send();
  66.                     $lead->setSendStatus('Sim 1');
  67.                     $enviado = true;
  69.                 } catch (\Exception $e1) {
  70.                     // ... (log de erro 1) ...
  71.                     try {
  72.                         $mailer2 = $this->getContainer()->get('admin.mail.service2');
  73.                         $mailer2->setMessage()
  74.                             ->setTo($row['broker_email'] ?? $lead->getProduct()->getEmail())
  75.                             ->setCc($copyEmails) // Array filtrado!
  76.                             // ... (restante do setSubject e setBody) ...
  77.                             ->setSubject("[leadcalper] " . $lead->getProduct()->getName() . ' - ' . $lead->getGroup() . ' - ' . $row['broker_name'])
  78.                             ->setBody($html, 'text/html')
  79.                             ->send();
  81.                         $lead->setSendStatus('Sim 2');
  82.                         $enviado = true;
  84.                     } catch (\Exception $e2) {
  85.                         // Ambos falharam
  86.                         $lead->setSendStatus('Não');
  87.                         $output->writeln("Lead {$row['lead_id']} falhou nos dois envios.");
  88.                         $output->writeln($e2); // Log da última exceção
  89.                     }
  90.                 }
  91.                 
  92.                 // Persiste o status final do Lead
  93.                 $entityManager->persist($lead);
  95.                 if ($enviado) {
  96.                     $conn->delete('lead_queue', ['id' => $row['id']]);
  97.                     $output->writeln("Lead {$row['lead_id']} enviado com sucesso. Status: {$lead->getSendStatus()}");
  98.                 } else {
  99.                      // Atualiza o status da fila como falhou
  100.                     $conn->update('lead_queue', [
  101.                         'status' => 'falhou',
  102.                         'updated_at' => date('Y-m-d H:i:s')
  103.                     ], ['id' => $row['id']]);
  104.                 }
  106.                 // Finaliza a transação e salva Lead e Fila
  107.                 $entityManager->flush();
  108.                 $entityManager->commit();
  109.                 
  110.             } catch (\Exception $e) {
  111.                 // Em caso de qualquer erro inesperado, faça rollback
  112.                 if ($entityManager->getConnection()->isTransactionActive()) {
  113.                     $entityManager->rollback();
  114.                 }
  115.                 
  116.                 // Atualiza a fila como falha
  117.                 $conn->update('lead_queue', ['status' => 'falhou', 'updated_at' => date('Y-m-d H:i:s')], ['id' => $row['id']]);
  118.                 $output->writeln("Erro inesperado no lead ID {$row['lead_id']}: " . $e->getMessage());
  119.             }
  120.         }
  122.         $output->writeln("Processamento finalizado.");
  123.         
  124.         return 0; 
  125.     }
  127. }