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();
  22.         $entityManager = $this->getContainer()->get('doctrine')->getManager();
  24.         $rows = $conn->fetchAll("SELECT * FROM lead_queue WHERE status = 'pendente'");
  26.         foreach ($rows as $row) {
  27.             $mailer1 = $this->getContainer()->get('admin.mail.service');
  28.             $mailer2 = $this->getContainer()->get('admin.mail.service2');
  30.             $lead = $entityManager->getRepository('ApplicationInternitLeadBundle:Lead')->find($row['lead_id']);
  31.             $copyEmails = explode(',', $row['copy_emails']);
  33.             try {
  35.                 if (!$lead) {
  36.                     $conn->update('lead_queue', ['status' => 'falhou', 'updated_at' => date('Y-m-d H:i:s')], ['id' => $row['id']]);
  37.                     continue;
  38.                 }
  40.                 $html = $this->getContainer()->get('templating')->render(
  41.                     '@ApplicationInternit/SettingBundle/Resources/views/Mail/emailLead.html.twig',
  42.                     ['data' => $lead, 'corretor' => $row['broker_name']]
  43.                 );
  45.                 $enviado = false;
  47.                 // Primeira tentativa
  48.                 try {
  49.                     $mailer1->setMessage()
  50.                         ->setTo($row['broker_email'] ?? $lead->getProduct()->getEmail())
  51.                         ->setCC($copyEmails)
  52.                         ->setSubject("[leadcalper] " . $lead->getProduct()->getName() .  ' - ' . $lead->getGroup() . ' - ' . $row['broker_name'])
  53.                         ->setBody(
  54.                             $html,
  55.                             'text/html'
  56.                         );
  58.                     $mailer1->send();
  60.                     $lead->setSendStatus('Sim 1');
  61.                     $entityManager->persist($lead);
  62.                     $entityManager->flush();
  64.                     $enviado = true;
  66.                 } catch (\Exception $e1) {
  67.                     // Segunda tentativa
  69.                     try {
  70.                         $mailer2->setMessage()
  71.                             ->setTo($row['broker_email'] ?? $lead->getProduct()->getEmail())
  72.                             ->setCc($copyEmails)
  73.                             ->setSubject("[leadcalper] " . $lead->getProduct()->getName() . ' - ' . $lead->getGroup() . ' - ' . $row['broker_name'])
  74.                             ->setBody($html, 'text/html')
  75.                             ->send();
  77.                         $lead->setSendStatus('Sim 2');
  78.                         $entityManager->persist($lead);
  79.                         $entityManager->flush();
  81.                         $enviado = true;
  83.                     } catch (\Exception $e2) {
  84.                         // Ambos falharam
  85.                         $lead->setSendStatus('Não');
  87.                         $conn->update('lead_queue', [
  88.                             'status' => 'falhou',
  89.                             'updated_at' => date('Y-m-d H:i:s')
  90.                         ], ['id' => $row['id']]);
  92.                             $log = new LeadErrorLog();
  93.                             $log->setLead($lead ?? null);
  94.                             $entityManager->persist($lead);
  96.                             $log->setErrorMessage('Falha na tentativa de reenvio de lead, os 2 emails falharam.');
  97.                             $log->setErrorType('Erro de envio de email');
  98.                             $log->setCreatedAt(new \DateTime());
  100.                             $entityManager->persist($log);
  101.                             $entityManager->flush();
  103.                         $output->writeln("Lead {$row['lead_id']} falhou nos dois envios.");
  104.                         continue;
  105.                     }
  106.                 }
  108.                 if ($enviado) {
  109.                     $conn->delete('lead_queue', ['id' => $row['id']]);
  110.                     $output->writeln("Lead {$row['lead_id']} enviado com sucesso.");
  111.                 }
  113.             } catch (\Exception $e) {
  114.                 $lead->setSendStatus('Não');
  115.                 $entityManager->persist($lead);
  116.                 $entityManager->flush();
  118.                 $conn->update('lead_queue', ['status' => 'falhou', 'updated_at' => date('Y-m-d H:i:s')], ['id' => $row['id']]);
  119.                 $output->writeln("Erro inesperado no lead ID {$row['lead_id']}");
  120.             }
  121.         }
  123.         $output->writeln("Processamento finalizado.");
  124.     }
  126. }