src/Controller/CronController.php line 97

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\HttpFoundation\Request;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Symfony\Component\Routing\Annotation\Route;
  10. use Doctrine\Persistence\ManagerRegistry;
  11. use Symfony\Component\Mailer\MailerInterface;
  12. use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
  13. use Symfony\Component\Mime\Email;
  14. use Symfony\Component\Mime\Address;
  15. use Symfony\Component\Mime\Crypto\DkimSigner;
  16. use Symfony\Component\Mime\Crypto\DkimOptions;
  17. use Symfony\Component\String\Slugger\SluggerInterface;
  19. use App\Service\EvenementInfo;
  22. use App\Entity\Envoi;
  23. use App\Entity\Evenement;
  24. use App\Entity\Message;
  25. use App\Entity\EvenementIntervenant;
  26. use App\Entity\Inscription;
  29. /**
  30.  * @Route("/cron", name="app_cron_")
  31.  */
  32. class CronController extends AbstractController
  33. {
  35.     private $doctrine;
  36.     private $mailer;
  37.     private $slugger;
  38.     private $evtInfo;
  40.     public function __construct(ManagerRegistry $doctrine, MailerInterface $mailer, SluggerInterface $slugger, EvenementInfo $evtInfo)
  41.     {
  42.         $this->doctrine = $doctrine;
  43.         $this->mailer = $mailer;
  44.         $this->slugger = $slugger;
  45.         $this->evtInfo = $evtInfo;
  47.     }
  49.     
  50.     /**
  51.      * @Route("/testics", name="testics")
  52.      */
  53.     public function testics(): Response
  54.     {
  55.         $evenement = $this->doctrine->getRepository(Evenement::class)->find(4);
  56.         $dateStartEnd = $this->evtInfo->getStartEndEvt($evenement);
  58.         $ics = $this->evtInfo->createIcs($evenement, $dateStartEnd);
  60.         return new Response(
  61.             '<html><body>-OK-</body></html>'
  62.         );
  63.     }
  65.     /**
  66.      * @Route("/envoi", name="cronenvoi")
  67.      */
  68.     public function cronenvoi(): Response
  69.     {
  70.         //$response = $this->envoi();
  71.         $response = null;
  72.         for ($i=0; $i < 5 ; $i++) { 
  73.             $response = $this->envoi();
  74.             
  75.             if($response == "error") break;
  76.             else {
  77.                 sleep(9);
  78.             }
  79.         }
  81.         return $this->redirectToRoute("app_cron_cronsatisfaction");
  83.         // dd($response)
  84.         // if($response == "error") {
  85.         // }
  87.         
  88.         return new Response(
  89.             '<html><body>-'.$response.'-</body></html>'
  90.         );
  91.     }
  92.     
  94.     /**
  95.      * @Route("/recap", name="cronrecap")
  96.      */
  97.     public function cronrecap(): Response
  98.     {
  99.         $inscriptions = $this->doctrine->getRepository(Inscription::class)->findRecap();
  101.         $em = $this->doctrine->getManager();
  103.         //dump($inscriptions);
  104.         if(!empty($inscriptions) && $inscription = $inscriptions[0]) {
  105.             $message = $this->doctrine->getRepository(Message::class)->findOneBy(
  106.                 [
  107.                     'evenement' => $inscription->getEvenement(),
  108.                     'type' => 'j-1'
  109.                 ]
  110.             );
  111.             $titre = $this->slugger->slug(strtolower($message->getEvenement()->getTitre()));
  113.             $html = $this->renderView('email/email.html.twig', [
  114.                 'message' => $message,
  115.                 'titre' => $titre,
  116.             ]);
  118.             $email = (new Email())
  119.                 ->from(new Address('noreply@evenements.engie-solutions.com ', 'Invitation ENGIE Solutions'))
  120.                 ->subject($message->getObjet())
  121.                 ->replyTo('evenements.engiesolutions@engie.com')
  122.                 ->to(new Address($inscription->getContact()->getEmail(), $inscription->getContact()->getPrenom().' '.$inscription->getContact()->getNom()))
  123.                 ->html($html)
  124.                 ->text(strip_tags($html))
  125.             ;
  127.             if($message->getPiecejointe() != null) {
  128.                 $email->attachFromPath($this->getParameter('folder.uploadsite').$message->getPiecejointe());
  129.             }
  132.             //$signer = new DkimSigner('file:///'.$this->getParameter('folder.key').'/dkimkey.key', 'plusvertmoinscherevent.engie.fr', 'mail');
  133.             //$signedEmail = $signer->sign($email);
  134.             $signedEmail =$email;
  136.             
  137.             try {
  138.                 $this->mailer->send($signedEmail);
  140.                 $inscription->setEnvoiRecap(new \DateTime);
  142.                 $em->persist($inscription);
  143.                 $em->flush();
  145.             } catch (TransportExceptionInterface $e) {
  146.                 $date = \DateTime::createFromFormat('YmdHis', '20000101000000');
  147.                 $inscription->setEnvoiRecap($date);
  148.                 $em->persist($inscription);
  149.                 $em->flush();
  150.             }
  151.         }
  153.         
  155.         return new Response(
  156.             '<html><body></body></html>'
  157.         );
  158.     }
  163.     /**
  164.      * @Route("/satisfaction", name="cronsatisfaction")
  165.      */
  166.     public function cronsatisfaction(): Response
  167.     {
  168.         $inscriptions = $this->doctrine->getRepository(Inscription::class)->findSatisfaction();
  169.         //dump($inscriptions);
  171.         if(!empty($inscriptions) && $inscription = $inscriptions[0]) {
  172.             $message = $this->doctrine->getRepository(Message::class)->findOneBy(
  173.                 [
  174.                     'evenement' => $inscription->getEvenement(),
  175.                     'type' => 'j+1'
  176.                 ]
  177.             );
  179.             if($message) {
  180.                 $response = $this->envoiSatisfaction($message, $inscription, "setEnvoiSatisfaction");
  182.                 if($response) {
  183.                     return new Response(
  184.                         '<html><body>*'.$response.'*</body></html>'
  185.                     );
  186.                 } 
  187.             }                        
  188.         }
  190.         return $this->redirectToRoute("app_cron_cronrecap");
  192.         return new Response(
  193.             '<html><body></body></html>'
  194.         );
  195.     }
  200.     private function envoiSatisfaction($message, $inscription, $methode) {
  201.         $em = $this->doctrine->getManager();
  202.         $titre = $this->slugger->slug(strtolower($message->getEvenement()->getTitre()));
  203.         
  204.         $html = $this->renderView('email/email.html.twig', [
  205.             'message'     => $message,
  206.             'inscription' => $inscription,
  207.             'titre'       => $titre,
  208.         ]);
  210.         $email = (new Email())
  211.             ->from(new Address('contact@evenements.engie-solutions.com ', 'Invitation ENGIE Solutions'))
  212.             ->subject($message->getObjet())
  213.             ->replyTo('evenements.engiesolutions@engie.com')
  214.             ->to(new Address($inscription->getContact()->getEmail(), $inscription->getContact()->getPrenom().' '.$inscription->getContact()->getNom()))
  215.             ->html($html)
  216.             ->text(strip_tags($html))
  217.         ;
  219.         if($message->getPiecejointe() != null) {
  220.             $email->attachFromPath($this->getParameter('folder.uploadsite').$message->getPiecejointe());
  221.         }
  224.         // $signer = new DkimSigner('file:///'.$this->getParameter('folder.key').'/dkimkey.key', 'plusvertmoinscherevent.engie.fr', 'mail');
  225.         // $signedEmail = $signer->sign($email);
  226.         $signedEmail =$email;
  228.         
  229.         try {
  230.             $this->mailer->send($signedEmail);
  232.             $inscription->{$methode}(new \DateTime);
  234.             $em->persist($inscription);
  235.             $em->flush();
  237.             return $inscription->getId();
  239.         } catch (TransportExceptionInterface $e) {
  240.             $date = \DateTime::createFromFormat('YmdHis', '20000101000000');
  241.             $inscription->{$methode}($date);
  242.             $em->persist($inscription);
  243.             $em->flush();
  245.             return false;
  246.         }
  248.     }
  253.     public function envoi()
  254.     {
  255.         
  256.         $envoi = $this->doctrine->getRepository(Envoi::class)->findNextToSend();
  258.         
  259.         if($envoi) {
  260.             $titre = $this->slugger->slug(strtolower($envoi->getMessage()->getEvenement()->getTitre()));
  262.             
  264.             $html = $this->renderView('email/email.html.twig', [
  265.                 'message' => $envoi->getMessage(),
  266.                 'envoi' => $envoi,
  267.                 'titre' => $titre,
  268.                 'intervenants' => $this->doctrine->getRepository(EvenementIntervenant::class)->findBy(['evenement' => $envoi->getMessage()->getEvenement()]),
  269.             ]);
  271.             $email = (new Email())
  272.                 ->from(new Address('contact@evenements.engie-solutions.com ', 'Invitation ENGIE Solutions'))
  273.                 ->subject($envoi->getMessage()->getObjet())
  274.                 ->replyTo('evenements.engiesolutions@engie.com')
  275.                 ->to(new Address($envoi->getContact()->getEmail(), $envoi->getContact()->getPrenom().' '.$envoi->getContact()->getNom()))
  276.                 ->html($html)
  277.                 ->text(strip_tags($html))
  278.             ;
  280.            
  282.             if($envoi->getMessage()->getPiecejointe() != null) {
  283.                 $email->attachFromPath($this->getParameter('folder.uploadsite').$envoi->getMessage()->getPiecejointe());
  284.             }
  287.             // AJOUT DU ICS
  288.             if($envoi->getMessage()->getType() == "savethedate" || $envoi->getMessage()->getType() == "invitation") {
  289.                 $dateStartEnd = $this->evtInfo->getStartEndEvt($envoi->getMessage()->getEvenement());
  291.                 $ics = $this->evtInfo->createIcs($envoi->getMessage()->getEvenement(), $dateStartEnd);
  292.                 
  293.                 $email->attachFromPath($this->getParameter('folder.uploadsite').$ics);
  294.             }
  297.             // $signer = new DkimSigner('file:///'.$this->getParameter('folder.key').'/dkimkey.key', 'plusvertmoinscherevent.engie.fr', 'mail');
  298.             // $signedEmail = $signer->sign($email);
  300.             // $signedEmail = $signer->sign($email, (new DkimOptions())
  301.             //     ->bodyCanon('relaxed')
  302.             //     ->headerCanon('relaxed')
  303.             //     ->headersToIgnore(['Message-ID'])
  304.             //     ->toArray()
  305.             // );
  307.             $signedEmail = $email;
  309.             $em = $this->doctrine->getManager();
  311.             try {
  312.                 $this->mailer->send($signedEmail);
  314.                 $envoi->setDateEnvoi(new \DateTime);
  316.                 $em->persist($envoi);
  317.                 $em->flush();
  319.                 return $envoi->getId();
  321.             } catch (TransportExceptionInterface $e) {
  322.                 $date = \DateTime::createFromFormat('YmdHis', '20000101000000');
  323.                 $envoi->setDateEnvoi($date);
  324.                 $em->persist($envoi);
  325.                 $em->flush();
  326.             }            
  327.         } else {
  328.             return "error";
  329.         }
  331.     }
  333.     /**
  334.      * @Route("/envoitest-{messageId<\d+>}", name="envoitest")
  335.      */
  336.     public function envoiTest($messageId, Request $request)
  337.     {
  338.         
  339.         $message = $this->doctrine->getRepository(Message::class)->find($messageId);
  340.         
  341.         if($message) {
  342.             $titre = $this->slugger->slug(strtolower($message->getEvenement()->getTitre()));
  346.             $html = $this->renderView('email/email.html.twig', [
  347.                 'message' => $message,
  348.                 'titre' => $titre,
  349.                 'intervenants' => $this->doctrine->getRepository(EvenementIntervenant::class)->findBy(['evenement' => $message->getEvenement()]),
  350.             ]);
  352.             $email = (new Email())
  353.                 ->from(new Address('contact@evenements.engie-solutions.com ', 'Invitation ENGIE Solutions'))
  354.                 ->subject($message->getObjet())
  355.                 ->replyTo('evenements.engiesolutions@engie.com')
  356.                 ->to(new Address($request->request->get('email'), "Prénom Nom" ))
  357.                 ->html($html)
  358.                 ->text(strip_tags($html))
  359.             ;
  361.             if($message->getPiecejointe() != null) {
  362.                 $email->attachFromPath($this->getParameter('folder.uploadsite').$message->getPiecejointe());
  363.             }
  366.             // $signer = new DkimSigner('file:///'.$this->getParameter('folder.key').'/dkimkey.key', 'plusvertmoinscherevent.engie.fr', 'mail');
  367.             // $email = $signer->sign($email);
  369.             try {
  370.                 $this->mailer->send($email);
  372.             } catch (TransportExceptionInterface $e) {
  374.             }     
  375.             return $this->redirectToRoute('app_evenement', ['idevenement' => $message->getEvenement()->getId()]);
  377.         } else {
  378.             return "error";
  379.         }
  381.     }
  383.     
  384.     /**
  385.      * @Route("/cleandoublons", name="cleandoublons")
  386.      */
  387.     public function cleandoublons() {
  388.         
  389.         // Modif du 17/05/2023
  390.         // Finalement c'est plus une liste unique par event, on avait pas dit jacadi
  391.         // Aled, il y a des doublons dans tous les sens
  392.         $emailsEnvoi = [];
  393.         $doublons = [];
  394.         $envoiProgrammes = $this->doctrine->getRepository(Envoi::class)->findForEvent(6, true);
  395.         $toRemove = [];
  396.         $toKeep = [];
  397.         $em = $this->doctrine->getManager();
  398.         foreach ($envoiProgrammes as $envoi) {
  399.             // Si l'email du contact de l'envoi est déjà dans la liste pour ce message, on vire l'envoi qui est un doublon
  400.             if(
  401.                 isset($emailsEnvoi[$envoi->getMessage()->getId()]) 
  402.                 && in_array($envoi->getContact()->getEmail(), $emailsEnvoi[$envoi->getMessage()->getId()])
  403.                 && $envoi->getDateEnvoi() == null
  404.             ) {
  405.                 //if($envoi->getDateEnvoi() == null) $em->remove($envoi);
  406.                 
  407.                 
  408.                 $doublons[$envoi->getContact()->getId()] = ($envoi->getMessage()->getId()." / ".$envoi->getContact()->getEmail());
  409.                 $inscription = $this->doctrine->getRepository(Inscription::class)->findOneBy(
  410.                     ['contact' => $envoi->getContact()]
  411.                 );
  412.                 if($inscription) {
  413.                     //dump($inscription);
  414.                     $toKeep[$envoi->getContact()->getId()] = $envoi->getContact();
  415.                 } else {
  416.                     //$toRemove[$envoi->getContact()->getId()] = $envoi->getContact();
  417.                     $em->remove($envoi->getContact());
  418.                 }
  421.             } else {
  422.                 $emailsEnvoi[$envoi->getMessage()->getId()][] = trim($envoi->getContact()->getEmail());
  423.             }
  424.         }
  426.         $em->flush();
  428.         // dump($toKeep);
  429.         // dump($toRemove);
  431.         // $emailInscrit = [];
  432.         // $dejaListes = [];
  433.         // $caDegage = [];
  434.         // foreach($doublons as $idcontact=>$email) {
  435.         //     $inscription = $this->doctrine->getRepository(Inscription::class)->findOneBy(
  436.         //         ['contact' => $idcontact, 'evenement' => 6]
  437.         //     );
  439.         //     if($inscription) {
  440.         //         dump($inscription);
  441.         //         $emailInscrit[] = $email;
  442.         //     } else {
  444.         //         if(in_array($email, $dejaListes) && !in_array($email, $emailInscrit)) {
  445.         //             $caDegage[] = $idcontact;
  446.         //         }
  448.         //     }
  450.         //     $dejaListes[] = $email;
  451.         // }
  452.         
  453.         // dump($caDegage);
  454.         dd($doublons);
  457.         
  458.         //$em->flush();
  459.     }
  461. }