src/Application/Internit/LeadBundle/Controller/ProductFrontController.php line 46

Open in your IDE?
  1. <?php
  3. namespace App\Application\Internit\LeadBundle\Controller;
  5. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  6. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
  7. use Symfony\Component\HttpFoundation\Request;
  8. use Symfony\Component\HttpFoundation\Response;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  11. use App\Application\Internit\LeadBundle\Entity\Lead;
  12. use App\Application\Internit\LeadBundle\Entity\LeadErrorLog;
  13. use App\Application\Internit\LeadBundle\Entity\ChatbotLead;
  14. use Symfony\Component\HttpKernel\Exception\HttpException;
  15. use Swift_SmtpTransport;
  16. use Swift_Mailer;
  17. use Swift_Message;
  19. /**
  20.  * Product Front controller.
  21.  *
  22.  * @Route("/api/leads")
  23.  */
  24. class ProductFrontController extends Controller
  25. {
  27.     public function getBundleName()
  28.     {
  29.         return 'ApplicationInternitLeadBundle';
  30.     }
  32.     public function getEntityName()
  33.     {
  34.         return 'Product';
  35.     }
  37.     public function getFormType()
  38.     {
  39.         return 'App\Application\Internit\LeadBundle\Form\ProductType';
  40.     }
  42.     /**
  43.      * @Route("/send", name="front_product_lead_send")
  44.      * @Method("POST")
  45.      */
  46.     public function send(Request $request)
  47.     {
  48.         $entityManager = $this->getDoctrine()->getManager();
  49.         $data = json_decode($request->getContent());
  50.         $statusCode = 400;
  51.         $result = [];
  52.         if (!$data) {
  53.             // $this->handleLeadError(null, null, null, 'Novo Lead não é válido.');
  54.             return $this->sendStatus(400, "New Lead is not valid");
  55.         }
  57.         if (isset($data->token)) {
  58.             $product = $this->getDoctrine()->getRepository('ApplicationInternitLeadBundle:Product')->findOneByToken($data->token);
  60.             if (!$product) {
  61.                 // $this->handleLeadError(null, null, null, 'ID da campanha não encontrado.');
  62.                 return $this->sendStatus(404, "Product not found");
  63.             }
  66.             if (
  67.                 !empty($data->name) &&
  68.                 !empty($data->origem) &&
  69.                 !empty($data->group)
  70.             ) {
  71.                 // form de whatsapp não traz e-mail
  72.                 $emailLead = isset($data->email) ? $data->email : '';
  73.                 $phoneLead = isset($data->phone) ? $data->phone : '';
  74.                 $extraInfo = array();
  75.                 $to = $this->get('tupi.caster.service')->next($product, $emailLead, $phoneLead);
  77.                 //dd($to);
  79.                 // dump($to);exit;
  80.                 $newLead = new Lead();
  81.                 //Obrigatórios
  82.                 $newLead->setName($data->name);
  83.                 $newLead->setGroup($data->group);
  84.                 $newLead->setOrigem($data->origem);
  85.                 $newLead->setProduct($product);
  86.                 $newLead->setEmail($emailLead);
  87.                 $newLead->setPhone($phoneLead);
  89.                 if (!empty($this->getDoctrine()->getRepository("ApplicationInternitLeadBundle:Lead")->attended($emailLead, $phoneLead, $product->getCorretores()))) {
  90.                     $newLead->setLoyalty(true);
  91.                 }
  94.                 //Opcionais
  95.                 if (isset($data->fixedPhone)) {
  96.                     $newLead->setFixedPhone(($data->fixedPhone ? $data->fixedPhone : ''));
  97.                 }
  98.                 if (isset($data->empreendimento))
  99.                     $newLead->setEmpreendimento(($data->empreendimento ? $data->empreendimento : ''));
  100.                 if (isset($data->utm_source))
  101.                     $newLead->setUtm_source(($data->utm_source ? $data->utm_source : ''));
  102.                 if (isset($data->utm_medium))
  103.                     $newLead->setUtm_medium(($data->utm_medium ? $data->utm_medium : ''));
  104.                 if (isset($data->utm_campaign))
  105.                     $newLead->setUtm_campaign(($data->utm_campaign ? $data->utm_campaign : ''));
  106.                 if (isset($data->message))
  107.                     $newLead->setMessage(($data->message ? $data->message : ''));
  109.                 // e-mail que a construtora configura para receber os leads deste produto.
  110.                 $productEmail = $product->getEmail();
  113.                 if (!empty($productEmail) || !is_null($to)) {
  115.                     // obter e-mails de lead da imobiliária da vez
  116.                     $realEstateLeadEmails = $this->getDoctrine()
  117.                         ->getRepository('ApplicationInternitLeadBundle:RealEstateEmail')
  118.                         ->findRealEstateLeadEmails($to['imob']);
  120.                     $realEstate = $this->getDoctrine()
  121.                         ->getRepository('ApplicationInternitRealEstateBundle:RealEstate')
  122.                         ->findOneBy(['name' => $to['imob']]);
  124.                     //Chamar service de disparo para corretor
  125.                     $email1 = $this->get('admin.mail.service');
  126.                     //$email2 = $this->get('admin.mail.service');
  129.                     // EMAILS COPY
  130.                     $emailCopySend = [];
  131.                     $emailToSend = [];
  133.                     if ($realEstate) {
  134.                         if ($realEstate->getReceiveLead()) {
  135.                             $emailCopySend[] = $realEstate->getEmail();
  136.                             //$email->setMessage()->setBCC($realEstate->getEmail());
  137.                         }
  138.                     }
  140.                     if (! empty($productEmail)) {
  141.                         $emailsSend = explode(',', str_replace(' ', '', $productEmail));
  142.                         foreach ($emailsSend as $sendMail) {
  143.                             $emailCopySend[] = $sendMail;
  144.                             //$email->setMessage()->setBCC($sendMail);
  145.                         }
  146.                     }
  149.                     // se houver o e-mail do corretor, ele é o destinatário principal e
  150.                     // o e-mail padrão da campanha é cópia oculta
  151.                     if (!empty($to['email'])) {
  153.                         // $email1->setMessage()->setTo($to['email']);
  154.                         $emailToSend[] = $to['email'];
  156.                         //dd($realEstate);
  158.                         // if (!empty($emailCopySend)) {
  159.                         //     $email1->setMessage()->setCC($emailCopySend);
  160.                         // }
  161.                     }
  162.                     // se não houver nenhum corretor para receber e-mail, o e-mail padrão
  163.                     // da campanha é o destinatário principal
  164.                     else if (! empty($productEmail)) {
  166.                         $emailsSend = explode(',', str_replace(' ', '', $productEmail));
  167.                         foreach ($emailsSend as $sendMail) {
  168.                             $emailCopySend[] = $sendMail;
  169.                             //$email->setMessage()->setBCC($sendMail);
  170.                         }
  171.                         // $email1->setMessage()->setTo($emailsSend);
  172.                         $emailToSend[] = $emailsSend;
  174.                         // if (!empty($emailCopySend)) {
  175.                         //     $email1->setMessage()->setCC($emailCopySend);
  176.                         // }
  177.                     }
  179.                     // if (!empty($realEstateLeadEmails)) {
  180.                     //     $email->setMessage()->setCC($realEstateLeadEmails);
  181.                     // }
  183.                     $newLead->setBrokerEmail(! empty($to['email']) ? $to['email'] : $productEmail); //Seta email do corretor que recebeu o lead
  184.                     $newLead->setBrokerRealState($to['imob']); //Seta Imobiliaria do corretor que recebeu o lead
  185.                     $extraInfo['broker_name'] = $to['name'];
  186.                     //if($to['phone'])
  187.                     //    $extraInfo['broker_phone'] = preg_replace('/[^0-9]/', '', $to['phone']);
  189.                     $extraInfo['realstate_name'] = $to['imob']; //strtoupper()
  191.                     $newLead->setSendStatus('Enviando');
  192.                     $entityManager->persist($newLead);
  193.                     $entityManager->flush();
  194.                     
  195.                     $this->get('tupi.caster.service')->gerarLogDistribuicao($product);
  197.                     // Insere na fila
  198.                     $conn = $this->getDoctrine()->getConnection();
  199.                     $conn->insert('lead_queue', [
  200.                         'lead_id' => $newLead->getId(),
  201.                         'broker_name' => $to['name'],
  202.                         'broker_email' => $to['email'] ?? $productEmail,
  203.                         'copy_emails' => implode(',', $emailCopySend),
  204.                         'status' => 'pendente',
  205.                         'created_at' => date('Y-m-d H:i:s'),
  206.                     ]);
  208.                     // Inicia o worker em background (se quiser garantir que ele esteja rodando)
  209.                     $projectRoot = $this->get('kernel')->getProjectDir();
  210.                     $phpPath = '/usr/local/bin/php';
  211.                     exec("nohup $phpPath $projectRoot/bin/console resend:lead:worker > $projectRoot/var/log/worker.log 2>&1 &");
  213.                     return $this->sendStatus(200, "Lead criado ", $extraInfo);
  215.                     // try {
  217.                     //     $this->get('tupi.caster.service')->gerarLogDistribuicao($product);
  219.                     //     $email1
  220.                     //         ->setMessage()
  221.                     //         ->setSubject("[leadcalper] " . $product->getName() . ' - ' . $newLead->getGroup() . ' - ' . $to['name'])
  222.                     //         ->setBody($this->renderView("@ApplicationInternit/SettingBundle/Resources/views/Mail/emailLead.html.twig", array(
  223.                     //             'data' => $newLead,
  224.                     //             'corretor' => $to['name'],
  225.                     //         )), 'text/html');
  227.                     //     $email1->send();
  229.                     //     $newLead->setSendStatus('Sim 1');
  230.                     //     $entityManager->persist($newLead);
  231.                     //     $entityManager->flush();
  233.                     // } catch (\Exception $e) {
  234.                     //     $this->handleLeadError($newLead, $to['name'], $to['email'], 'Erro ao enviar o e-mail: ');
  235.                     //     $entityManager->flush();
  236.                     //     return $this->sendStatus(200, "Lead created", $extraInfo);
  237.                     // }
  239.                     /*   $email2
  240.                         ->setMessage()
  241.                         ->setSubject("[Lead] ".$product->getName() . ' - ' . $newLead->getGroup())
  242.                         ->setBody($this->renderView("@ApplicationInternit/SettingBundle/Resources/views/Mail/emailLead.html.twig", array(
  243.                             'data' => $newLead,
  244.                         )), 'text/html');
  245.                     $email2->send();*/
  246.                 }
  248.                 // dump($newLead);
  250.                 // return $this->sendStatus(200, "Lead created", $extraInfo);
  251.             } else {
  252.                 // $this->handleLeadError(null, null, null, 'Conteúdo inválido, preencha os campos obrigatórios.');
  253.                 return $this->sendStatus(400, "Invalid content");
  254.             }
  255.         }
  256.         // $this->handleLeadError(null, null, null, 'O token é obrigatório.');
  257.         return $this->sendStatus(400, "Token is required");
  258.     }
  261.     public function sendLast(Request $request)
  262.     {
  264.         $data = json_decode($request->getContent());
  265.         $statusCode = 400;
  266.         $result = [];
  267.         if (!$data)
  268.             return $this->sendStatus(400, "New Lead is not valid");
  270.         if (isset($data->token)) {
  271.             $product = $this->getDoctrine()->getRepository('ApplicationInternitLeadBundle:Product')->findOneByToken($data->token);
  273.             // dump($product); exit;
  274.             if (!$product)
  275.                 return $this->sendStatus(404, "Product not found");
  278.             if (
  279.                 !empty($data->name) &&
  280.                 !empty($data->origem) &&
  281.                 !empty($data->group)
  282.             ) {
  283.                 // form de whatsapp não traz e-mail
  284.                 $emailLead = isset($data->email) ? $data->email : '';
  285.                 $phoneLead = isset($data->phone) ? $data->phone : '';
  286.                 $extraInfo = array();
  287.                 $to = $this->get('tupi.caster.service')->next($product, $emailLead, $phoneLead);
  289.                 //dd($to);
  291.                 // dump($to);exit;
  292.                 $newLead = new Lead();
  293.                 //Obrigatórios
  294.                 $newLead->setName($data->name);
  295.                 $newLead->setGroup($data->group);
  296.                 $newLead->setOrigem($data->origem);
  297.                 $newLead->setProduct($product);
  298.                 $newLead->setEmail($emailLead);
  299.                 $newLead->setPhone($phoneLead);
  301.                 //Opcionais
  302.                 if (isset($data->fixedPhone)) {
  303.                     $newLead->setFixedPhone(($data->fixedPhone ? $data->fixedPhone : ''));
  304.                 }
  305.                 if (isset($data->empreendimento))
  306.                     $newLead->setEmpreendimento(($data->empreendimento ? $data->empreendimento : ''));
  307.                 if (isset($data->utm_source))
  308.                     $newLead->setUtm_source(($data->utm_source ? $data->utm_source : ''));
  309.                 if (isset($data->utm_medium))
  310.                     $newLead->setUtm_medium(($data->utm_medium ? $data->utm_medium : ''));
  311.                 if (isset($data->utm_campaign))
  312.                     $newLead->setUtm_campaign(($data->utm_campaign ? $data->utm_campaign : ''));
  313.                 if (isset($data->message))
  314.                     $newLead->setMessage(($data->message ? $data->message : ''));
  316.                 // e-mail que a construtora configura para receber os leads deste produto.
  317.                 $productEmail = $product->getEmail();
  320.                 if (!empty($productEmail) || !is_null($to)) {
  322.                     // obter e-mails de lead da imobiliária da vez
  323.                     $realEstateLeadEmails = $this->getDoctrine()
  324.                         ->getRepository('ApplicationInternitLeadBundle:RealEstateEmail')
  325.                         ->findRealEstateLeadEmails($to['imob']);
  327.                     $realEstate = $this->getDoctrine()
  328.                         ->getRepository('ApplicationInternitRealEstateBundle:RealEstate')
  329.                         ->findOneBy(['name' => $to['imob']]);
  331.                     //Chamar service de disparo para corretor
  332.                     $email1 = $this->get('admin.mail.service');
  333.                     $email2 = $this->get('admin.mail.service');
  336.                     // EMAILS COPY
  337.                     $emailCopySend = [];
  339.                     if ($realEstate) {
  340.                         if ($realEstate->getReceiveLead()) {
  341.                             $emailCopySend[] = $realEstate->getEmail();
  342.                             //$email->setMessage()->setBCC($realEstate->getEmail());
  343.                         }
  344.                     }
  346.                     if (! empty($productEmail)) {
  347.                         $emailsSend = explode(',', str_replace(' ', '', $productEmail));
  348.                         foreach ($emailsSend as $sendMail) {
  349.                             $emailCopySend[] = $sendMail;
  350.                             //$email->setMessage()->setBCC($sendMail);
  351.                         }
  352.                     }
  355.                     // se houver o e-mail do corretor, ele é o destinatário principal e
  356.                     // o e-mail padrão da campanha é cópia oculta
  357.                     if (!empty($to['email'])) {
  359.                         $email1->setMessage()->setTo($to['email']);
  361.                         //dd($realEstate);
  363.                         if (!empty($emailCopySend)) {
  364.                             $email2->setMessage()->setTo($emailCopySend);
  365.                         }
  366.                     }
  367.                     // se não houver nenhum corretor para receber e-mail, o e-mail padrão
  368.                     // da campanha é o destinatário principal
  369.                     else if (! empty($productEmail)) {
  371.                         $emailsSend = explode(',', str_replace(' ', '', $productEmail));
  372.                         foreach ($emailsSend as $sendMail) {
  373.                             $emailCopySend[] = $sendMail;
  374.                             //$email->setMessage()->setBCC($sendMail);
  375.                         }
  376.                         $email1->setMessage()->setTo($emailsSend);
  378.                         if (!empty($emailCopySend)) {
  379.                             $email2->setMessage()->setTo($emailCopySend);
  380.                         }
  381.                     }
  384.                     // if (!empty($realEstateLeadEmails)) {
  385.                     //     $email->setMessage()->setCC($realEstateLeadEmails);
  386.                     // }
  389.                     $newLead->setBrokerEmail(! empty($to['email']) ? $to['email'] : $productEmail); //Seta email do corretor que recebeu o lead
  390.                     $newLead->setBrokerRealState($to['imob']); //Seta Imobiliaria do corretor que recebeu o lead
  391.                     $extraInfo['broker_name'] = $to['name'];
  392.                     if ($to['phone'])
  393.                         $extraInfo['broker_phone'] = preg_replace('/[^0-9]/', '', $to['phone']);
  397.                     $entityManager = $this->getDoctrine()->getManager();
  398.                     $entityManager->persist($newLead);
  399.                     $entityManager->flush();
  404.                     $email1
  405.                         ->setMessage()
  406.                         ->setSubject("[Lead] " . $product->getName() . ' - ' . $newLead->getGroup())
  407.                         ->setBody($this->renderView("@ApplicationInternit/SettingBundle/Resources/views/Mail/emailLead.html.twig", array(
  408.                             'data' => $newLead,
  409.                         )), 'text/html');
  410.                     $email1->send();
  413.                     $email2
  414.                         ->setMessage()
  415.                         ->setSubject("[Lead] " . $product->getName() . ' - ' . $newLead->getGroup())
  416.                         ->setBody($this->renderView("@ApplicationInternit/SettingBundle/Resources/views/Mail/emailLead.html.twig", array(
  417.                             'data' => $newLead,
  418.                         )), 'text/html');
  419.                     $email2->send();
  420.                 }
  422.                 // dump($newLead);
  424.                 return $this->sendStatus(200, "Lead created", $extraInfo);
  425.             } else {
  426.                 return $this->sendStatus(400, "Invalid content");
  427.             }
  428.         }
  429.         return $this->sendStatus(400, "Token is required");
  430.     }
  432.     private function sendStatus($code = 401, $message = "Requisição não autorizada", $extra = array())
  433.     {
  434.         $array = array('message' => $message);
  435.         $array = array_merge($array, $extra);
  436.         $response = new Response(json_encode($array), $code);
  437.         $response->headers->set('Content-Type', 'application/json');
  438.         return $response;
  439.     }
  441.     private function handleBodyView($lead = null, $brokerName = null)
  442.     {
  443.         return $this->renderView('@ApplicationInternit/SettingBundle/Resources/views/Mail/emailLead.html.twig', [
  444.             'data' => $lead ?? '',
  445.             'corretor' => $brokerName ?? '',
  446.         ]);
  447.     }
  449.     private function handleLeadError($lead = null, $brokerName = null, $brokerEmail = null, $errorMessage = null)
  450.     {
  451.         $entityManager = $this->getDoctrine()->getManager();
  452.         $html = $this->handleBodyView($lead, $brokerName);
  454.         if (empty($lead) && empty($brokerEmail)) {
  455.             $log = new LeadErrorLog();
  456.             $log->setLead($lead ?? null);
  457.             $log->setErrorMessage($errorMessage);
  458.             $log->setErrorType('Server Error');
  459.             $log->setCreatedAt(new \DateTime());
  461.             $entityManager->persist($log);
  463.             $lead->setSendStatus('Não');
  464.             $entityManager->persist($lead);
  465.             $entityManager->flush();
  467.             return;
  468.         }
  470.         // // Tentativa 1
  471.         try {
  473.             $mailer1 = $this->get('admin.mail.service');
  475.             $mailer1->setMessage()
  476.                 ->setTo($brokerEmail ?? $lead->getProduct()->getEmail())
  477.                 ->setSubject("[leadcalper] " . $lead->getProduct()->getName() .  ' -' . $lead->getGroup() . ' - ' . $brokerName)
  478.                 ->setBody(
  479.                     $html,
  480.                     'text/html'
  481.                 );
  483.             $mailer1->send();
  485.             $lead->setSendStatus('Sim 1');
  486.             $entityManager->persist($lead);
  488.         } catch (\Exception $e) {
  490.             // Tentativa 2
  491.             try{
  492.                 
  493.                 $mailer2 = $this->get('admin.mail.service2');
  494.                 $mailer2->setMessage()
  495.                     ->setTo($brokerEmail ?? $lead->getProduct()->getEmail()) 
  496.                     ->setSubject("[leadcalper] " . $lead->getProduct()->getName() . $lead->getGroup() . ' - ' . $brokerName)
  497.                     ->setBody($html, 'text/html')
  498.                     ->send();
  500.                 $lead->setSendStatus('Sim 2');
  501.                 $entityManager->persist($lead);
  503.             }catch(\Exception $e){
  504.                 
  505.                 $log = new LeadErrorLog();
  506.                 $log->setLead($lead ?? null);
  507.                 $log->setErrorMessage($errorMessage);
  508.                 $log->setErrorType('Email');
  509.                 $log->setCreatedAt(new \DateTime());
  511.                 $entityManager->persist($log);
  513.                 $lead->setSendStatus('Não');
  514.                 $entityManager->persist($lead);
  515.             }
  516.         }
  517.     }
  519.     /**
  520.      * @Route("/resend", name="front_product_lead_resend")
  521.      * @Method("POST")
  522.      */
  523.     public function resendLead(Request $request)
  524.     {
  525.         $entityManager = $this->getDoctrine()->getManager();
  526.         $data = json_decode($request->getContent(), true);
  528.         $leadsNotSent = $this->getDoctrine()->getRepository('ApplicationInternitLeadBundle:Lead')->findBySendStatusAndProduct('Não', $data['productId']);
  530.         foreach ($leadsNotSent as $lead) {
  532.             $lead->setSendStatus('Enviando');
  533.             $entityManager->flush();
  535.             $brokerEmail = $lead->getBrokerEmail();
  536.             $broker = $this->getDoctrine()->getRepository('ApplicationSonataUserBundle:User')->findByEmail($brokerEmail);
  537.             $realEstate = $this->getDoctrine()
  538.                         ->getRepository('ApplicationInternitRealEstateBundle:RealEstate')
  539.                         ->findOneBy(['name' => $lead->getBrokerRealState()]);
  541.             $product = $this->getDoctrine()->getRepository('ApplicationInternitLeadBundle:Product')->find($data['productId']);
  542.             $productEmail = $product->getEmail();
  544.             // COPY EMAILS
  545.             $emailCopySend = [];
  547.             if ($realEstate) {
  548.                 if ($realEstate->getReceiveLead()) {
  549.                     $emailCopySend[] = $realEstate->getEmail();
  550.                 }
  551.             }
  553.             if (! empty($productEmail)) {
  554.                 $emailsSend = explode(',', str_replace(' ', '', $productEmail));
  555.                 foreach ($emailsSend as $sendMail) {
  556.                     $emailCopySend[] = $sendMail;
  557.                 }
  558.             }
  560.             // se não houver nenhum corretor para receber e-mail, o e-mail padrão
  561.             // da campanha é o destinatário principal
  562.             else if (! empty($productEmail)) {
  564.                 $emailsSend = explode(',', str_replace(' ', '', $productEmail));
  565.                 foreach ($emailsSend as $sendMail) {
  566.                     $emailCopySend[] = $sendMail;
  567.                 }
  568.             }
  570.             $conn = $this->getDoctrine()->getConnection();
  571.             $conn->insert('lead_queue', [
  572.                 'lead_id' => $lead->getId(),
  573.                 'broker_name' => $broker['firstname'],
  574.                 'broker_email' => $brokerEmail,
  575.                 'copy_emails' => implode(',', $emailCopySend),
  576.                 'status' => 'pendente',
  577.                 'created_at' => date('Y-m-d H:i:s'),
  578.             ]);
  579.         }
  581.         $projectRoot = $this->get('kernel')->getProjectDir();
  582.         $phpPath = '/usr/local/bin/php';
  583.         exec("nohup $phpPath $projectRoot/bin/console resend:lead:worker > $projectRoot/var/log/worker.log 2>&1 &");
  585.         $entityManager->flush();
  587.         return $this->sendStatus(200, "Leads Enviados");
  588.     }
  590.     /**
  591.      * @Route("/resend/cronjob1", name="front_product_lead_resend_cronjob1")
  592.      * @Method("POST")
  593.      */
  594.     public function resendLeadCron1()
  595.     {
  596.         $entityManager = $this->getDoctrine()->getManager();
  598.         $leadsNotSent = $this->getDoctrine()->getRepository('ApplicationInternitLeadBundle:Lead')->findBy(['send_status' => 'Não']);
  600.         foreach ($leadsNotSent as $lead) {
  602.             $lead->setSendStatus('Enviando');
  603.             $entityManager->flush();
  605.             $brokerEmail = $lead->getBrokerEmail();
  606.             $broker = $this->getDoctrine()->getRepository('ApplicationSonataUserBundle:User')->findByEmail($brokerEmail);
  608.             $conn = $this->getDoctrine()->getConnection();
  609.             $conn->insert('lead_queue_cron', [
  610.                 'lead_id' => $lead->getId(),
  611.                 'broker_name' => $broker['firstname'],
  612.                 'broker_email' => $brokerEmail,
  613.                 'status' => 'pendente',
  614.                 'created_at' => date('Y-m-d H:i:s'),
  615.             ]);
  616.         }
  618.         $projectRoot = $this->get('kernel')->getProjectDir();
  619.         $phpPath = '/usr/local/bin/php';
  620.         exec("nohup $phpPath $projectRoot/bin/console resend:lead:workerCron1 > $projectRoot/var/log/worker.log 2>&1 &");
  622.         $entityManager->flush();
  624.         return $this->sendStatus(200, "Leads Enviados");
  625.     }
  627.     /**
  628.      * @Route("/resend/cronjob2", name="front_product_lead_resend_cronjob2")
  629.      * @Method("POST")
  630.      */
  631.     public function resendLeadCron2()
  632.     {
  633.         $projectRoot = $this->get('kernel')->getProjectDir();
  634.         $phpPath = '/usr/local/bin/php';
  635.         exec("nohup $phpPath $projectRoot/bin/console resend:lead:workerCron2 > $projectRoot/var/log/worker.log 2>&1 &");
  637.         return $this->sendStatus(200, "Notificações Enviadas");
  638.     }
  639. }