src/Controller/MaillingController.php line 363

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: anthony
  5.  * Date: 25/05/18
  6.  * Time: 10:45
  7.  */
  9. namespace App\Controller;
  12. use App\Entity\Auth\AuthUser;
  13. use App\Entity\Client;
  14. use App\Entity\ClientRoleUser;
  15. use App\Entity\Coupure;
  16. use App\Entity\Mailling;
  17. use App\Entity\PieceJointeMailling;
  18. use App\Ovh\OvhSend;
  19. use App\Service\Coupure\GenerateCoupureInterface;
  20. use App\Service\MaillingEnCour\MaillingEnCour;
  21. use Doctrine\ORM\EntityManagerInterface;
  22. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  23. use Spipu\Html2Pdf\Html2Pdf;
  24. use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  25. use Symfony\Component\HttpFoundation\JsonResponse;
  26. use Symfony\Component\HttpFoundation\Request;
  27. use Symfony\Component\HttpFoundation\Response;
  28. use Symfony\Component\HttpKernel\KernelInterface;
  29. use Symfony\Component\Serializer\Mapping\Factory\ClassMetadataFactory;
  30. use Symfony\Component\Serializer\Mapping\Loader\AnnotationLoader;
  31. use Symfony\Component\Serializer\Normalizer\DateTimeNormalizer;
  32. use Symfony\Component\Serializer\Normalizer\PropertyNormalizer;
  33. use Symfony\Component\Serializer\Serializer;
  34. use Symfony\Component\Serializer\Encoder\XmlEncoder;
  35. use Symfony\Component\Serializer\Encoder\JsonEncoder;
  36. use Doctrine\Common\Annotations\AnnotationReader;
  38. class MaillingController extends Controller
  39. {
  43.     /**
  44.      * @Route("api/maillings/maillings/getErreur/{idMailling}", methods={"GET"}, name="get.erreur.mailling.en.cours")
  45.      */
  46.     public function getErreurMaillingEnCourAction($idMailling, EntityManagerInterface $em, MaillingEnCour $maillingEnCour){
  47.         $maillingEnCoursErreur = $maillingEnCour->getMaillingErreur($idMailling);
  48.         $encoders = array(new XmlEncoder(), new JsonEncoder());
  49.         $classMetadataFactory = new ClassMetadataFactory(new AnnotationLoader(new AnnotationReader()));
  50.         $normalizer = new PropertyNormalizer($classMetadataFactory);
  51.         $dateTimeNormalizer = new DateTimeNormalizer('d-m-y H:i');
  52.         $serializer = new Serializer([$normalizer,$dateTimeNormalizer], $encoders);
  53.         $jsonContent = $serializer->normalize($maillingEnCoursErreur, null, array('groups' => array('email_retour')));
  54.         $response = new JsonResponse($jsonContent);
  55.         $response->headers->set('Content-Type', 'application/json');
  56.         return $response;
  57.     }
  59.     /**
  60.      * @Route("/maillings/content/{id}",methods={"GET"},name="get.mailling.content")
  61.      */
  62.     public function getMaillingContentAction($id, Request $request, KernelInterface $kernel)
  63.     {
  64.         $em = $this->get('doctrine.orm.entity_manager');
  65.         $mailling = $em->getRepository('App\Entity\Mailling')
  66.             ->find($request->get('id'));
  67.         $path = $kernel->getRootDir() . '/../public/maillings/' . $mailling->getAncienId() . '.html';
  68.         $read = file_get_contents($path);
  69.         return new JsonResponse(utf8_encode($read));
  70.     }
  72.     /**
  73.      * @Route("/maillings/getNbEnvoyer/{id}",methods={"GET"},name="get.mailling.nb.envoyer")
  74.      */
  75.     public function getMaillingNbEnvoyer($id)
  76.     {
  77.         $em = $this->get('doctrine.orm.entity_manager');
  78.         $mailling = $em->getRepository('App\Entity\Mailling')
  79.             ->findOneBy(['ancienId' => $id]);
  80.         return new JsonResponse($mailling->getNbMailEnvoye());
  81.     }
  83.     /**
  84.      * @Route("/maillings/checkDelete",methods={"GET"},name="mail.check")
  85.      */
  86.     public function getCheckMailAction()
  87.     {
  88.         $em = $this->get('doctrine.orm.entity_manager');
  89.         $maillings = $em->getRepository("App\Entity\Mailling")
  90.             ->findBy(['envoyer' => 0 , 'enCour' => 0 ]);
  91.         $checkIfMaillingExist = $this->get('check.mailling.exist');
  92.         $anomalieGestion = $this->get('gestion.anomalie');
  93.         foreach ($maillings as $mailling){
  94.             if($checkIfMaillingExist->checKMailling($mailling) < 1){
  95.                 $suivitOuvertures = $em->getRepository('App:SuivitOuvertureMailling')
  96.                     ->findBy(['mailling' => $mailling]);
  97.                 if(count($suivitOuvertures) < 1){
  98.                     $em->remove($mailling);
  99.                 }
  100.                 else{
  101.                     $anomalieGestion->addAnomalieDeleteWithSuivit($mailling);
  102.                 }
  103.             }
  104.         }
  105.         $em->flush();
  106.         return new Response('ok');
  107.     }
  111.     /**
  112.      * @Route("/maillings/send/test/{idMailling}/{idAuthUser}",methods={"GET"},name="send.mailling.test")
  113.      */
  114.     public function getSendMailTestAction($idMailling, $idAuthUser, MaillingEnCour $maillingEnCour, KernelInterface $kernel)
  115.     {
  116.         $em = $this->get('doctrine.orm.entity_manager');
  117.         $mailling = $em->getRepository("App\Entity\Mailling")
  118.             ->find($idMailling);
  119.         $authUser = $em->getRepository("App\Entity\Auth\AuthUser")
  120.             ->find($idAuthUser);
  121.         if($authUser){
  122.             if($mailling){
  123.                 /** @var Mailling $mailling
  124.                  *  @var AuthUser $authUser
  125.                  */
  126.                 if (strpos($mailling->getEnvoyePar()->getAdresseEnvoi(), '@escalconsulting.com') !== false) {
  127.                     $maillingEnCour->addTestSend($mailling,$authUser);
  128.                     return new JsonResponse('mail test lancé en envoie');
  129.                 } else {
  130.                     return new JsonResponse('l\'utilisateur ne possède pas d\'addresse d\'envoi');
  131.                 }
  132.             } else {
  133.                 return new JsonResponse('le mailling n\'existe pas');
  134.             }
  135.         } else {
  136.             return new JsonResponse('l\'utilisateur n\'existe pas');
  137.         }
  138.     }
  142.     /**
  143.      * @Route("/maillings/send/veille/{id}", methods={"GET"}, name="mailling.veille.send")
  144.      */
  145.     public function sendVeilleAction(MaillingEnCour $maillingEnCour, EntityManagerInterface $em, $id){
  146.         $veille = $em->getRepository('App:Veille')->find($id);
  147.         if($veille){
  148.             $match_date = $veille->getDate();
  149.             $date = new \DateTime();
  150.             $interval = $date->diff($match_date);
  151.             if($interval->days == 0) {
  152.                 if(!$veille->getValider()){
  153.                     $veille->setValider(true);
  154.                     $em->persist($veille);
  155.                     $em->flush();
  156.                     $maillingEnCour->addVeilleSend($veille);
  157.                     return new JsonResponse('veille lancer en envoie');
  158.                 }
  159.             }
  160.         }
  161.        return new JsonResponse('veille déja envoyé');
  162.     }
  165.     /**
  166.      * @Route("/maillings/send/date/{idMailling}",methods={"GET"},name="send.mail.date")
  167.      */
  168.     public function getSendMaillingDateAction($idMailling , MaillingEnCour $maillingEnCour, Request $request)
  169.     {
  170.         ini_set('memory_limit',-1);
  171.         set_time_limit(0);
  172.         $dateEnvoie = $request->query->get('date');
  173.         $dateEnvoie = new \DateTime($dateEnvoie);
  174.         $em = $this->get('doctrine.orm.entity_manager');
  175.         $mailling = $em->getRepository("App\Entity\Mailling")
  176.             ->find($idMailling);
  177.         if($mailling){
  178.             if($mailling->getValiderEnvoi()){
  179.                 if(!$mailling->getEnCour()){
  180.                     if(!$mailling->getEnvoyer()){
  181.                         if (strpos($mailling->getEnvoyePar()->getAdresseEnvoi(), '@escalconsulting.com') !== false) {
  182.                             $mailling->setEnCour(true);
  183.                             $em->persist($mailling);
  184.                             $em->flush();
  186.                             if($maillingEnCour->addMaillingSend($mailling, $dateEnvoie, true) == false){
  187.                                 return new JsonResponse('le mailling est déja en cours d\'envoi');
  188.                             }
  189.                             return new JsonResponse('le mailling a été lancé en envoi');
  190.                         } else {
  191.                             return new JsonResponse('l\'utilisateur ne possède pas d\'addresse d\'envoi');
  192.                         }
  193.                     } else {
  194.                         return new JsonResponse('le mailling est déjà en envoyé');
  195.                     }
  196.                 } else {
  197.                     return new JsonResponse('le mailling est déjà en cours d\'envoi');
  198.                 }
  199.             } else {
  200.                 return new JsonResponse('le mailling doit être validé');
  201.             }
  202.         } else {
  203.             return new JsonResponse('le mailling n\'existe pas');
  204.         }
  206.     }
  209.     /**
  210.      * @Route("/maillings/send/{idMailling}",methods={"GET"},name="send.mail.reel")
  211.      */
  212.     public function getSendMaillingAction($idMailling , MaillingEnCour $maillingEnCour)
  213.     {
  214.         ini_set('memory_limit',-1);
  215.         set_time_limit(0);
  216.         $em = $this->get('doctrine.orm.entity_manager');
  217.         $mailling = $em->getRepository("App\Entity\Mailling")
  218.             ->find($idMailling);
  219.         /** @var Mailling $mailling */
  220.         if($mailling){
  221.             if($mailling->getValiderEnvoi()){
  222.                 if(!$mailling->getEnCour()){
  223.                     if(!$mailling->getEnvoyer()){
  224.                         if (strpos($mailling->getEnvoyePar()->getAdresseEnvoi(), '@escalconsulting.com') !== false) {
  225.                             $mailling->setEnCour(true);
  226.                             $em->persist($mailling);
  227.                             $em->flush();
  228.                             if($maillingEnCour->addMaillingSend($mailling, new \DateTime('now')) == false){
  229.                                 return new JsonResponse('le mailling est déja en cours d\'envoi');
  230.                             }
  231.                             return new JsonResponse('le mailling a été lancé en envoi');
  232.                         } else {
  233.                             return new JsonResponse('l\'utilisateur ne possède pas d\'addresse d\'envoi');
  234.                         }
  235.                     } else {
  236.                         return new JsonResponse('le mailling est déjà en envoyé');
  237.                     }
  238.                 } else {
  239.                     return new JsonResponse('le mailling est déjà en cours d\'envoi');
  240.                 }
  241.             } else {
  242.                 return new JsonResponse('le mailling doit être validé');
  243.             }
  244.         } else {
  245.             return new JsonResponse('le mailling n\'existe pas');
  246.         }
  248.     }
  250.     /**
  251.      * @Route("/mailling/enCour/{idMailling}", methods={"GET"}, name="mailling.en.cour.status")
  252.      */
  253.     public function getMaillingInfoEnCourAction($idMailling, EntityManagerInterface $em, MaillingEnCour $maillingEnCour){
  254.         $mailling = $em->getRepository('App:Mailling')->find($idMailling);
  255.         $retour = [];
  256.         if($mailling){
  257.             $debutMailling = $maillingEnCour->getIfMaillingBegin($mailling);
  258.             if($debutMailling !== false){
  259.                 $nbMailling = $maillingEnCour->getNbMailMailling($mailling);
  260.                 $nbMaillingAttente = $maillingEnCour->getNbMailRestantAvantFin($mailling);
  261.                 if($nbMaillingAttente != false){
  262.                     $dateFurtureEnvoie = $maillingEnCour->getHeureEnvoieFuture($mailling);
  263.                     if( $dateFurtureEnvoie == false){
  264.                         $retour['nbMaillAttente'] = $nbMaillingAttente;
  265.                         $retour['nbMailToSend'] = $nbMailling[0];
  266.                         $retour['nbMailSend'] = $nbMailling[1];
  267.                     } else {
  268.                         $retour['message_erreur'] = 'le mailling commencera a être envoyé le ' . $dateFurtureEnvoie;
  269.                     }
  270.                 } else {
  271.                     if($mailling->getEnvoyer() == true){
  272.                         $retour['message_erreur'] = 'le mailling a fini d\'être envoyé';
  273.                     }
  274.                     $retour['message_erreur'] = 'Le mailling est en cours d\'envoi, l\'affichage du diagramme peut prendre plusieurs minutes. Merci de patienter.';
  275.                 }
  277.             } else {
  278.                 $retour['message_erreur'] = 'le mailling n\'est pas en envoie';
  279.             }
  280.         } else {
  281.             $retour['message_erreur'] = 'le mailling n\'existe pas';
  282.         }
  283.         return new JsonResponse($retour);
  284.     }
  286.     /**
  287.      * @Route("/maillings/deleteMailling/{idMailling}", methods={"DELETE"}, name="delete.mailling")
  288.      */
  289.     public function deleteMailling($idMailling, EntityManagerInterface $em){
  290.         $mailling = $em->getRepository('App:Mailling')->find($idMailling);
  291.         if($mailling->getEnCour() === false){
  292.             $maillingsEnCour = $em->getRepository('App:MaillingEnCour')->findBy(['mailling' => $mailling]);
  293.             foreach ($maillingsEnCour as $maillingEnCour){
  294.                 $em->remove($maillingEnCour);
  295.             }
  296.             $em->remove($mailling);
  297.             $em->flush();
  298.             $retour['message'] = 'le mailling a été supprimmer';
  299.         } else {
  300.             $retour['message'] = 'le mailling a déja été lancé en envoie';
  301.         }
  302.         return new JsonResponse($retour);
  303.     }
  305.     /**
  306.      * @Route("/maillings/prepareCoupure/{idClient}", methods={"GET"}, name="mailling.cree.coupure")
  307.      */
  308.     public function creeMaillingCoupure($idClient, EntityManagerInterface $em, GenerateCoupureInterface $generateCoupure){
  309.         $client = $em->getRepository('App:Client')->find($idClient);
  310.         if($client){
  311.             /** @var Client $client */
  312.             $mailling = $em->getRepository('App:Mailling')->findOneBy(['client' => $client, 'typeMail' => 'Coupure', 'envoyer' => false]);
  313.             /** @var Mailling $mailling */
  314.             if($mailling){
  315.                 foreach ($mailling->getPiecesJointes() as $piecesJointe){
  316.                     $mailling->removePiecesJointe($piecesJointe);
  317.                     $em->remove($piecesJointe);
  318.                 }
  319.                 $em->flush();
  320.             } else{
  321.                 $mailling = new Mailling();
  322.                 $mailling->setClient($client);
  323.                 $date = new \DateTime('now');
  324.                 $mailling->setNom('Retombées presse '. $client->getNom(). ' du '.date_format($date, 'd/m/Y'));
  325.                 $mailling->setObjet('Retombées presse '. $client->getNom(). ' du '.date_format($date, 'd/m/Y'));
  326.                 foreach ($client->getRolesUserClient() as $roleUserClient){
  327.                     /** @var ClientRoleUser $roleUserClient */
  328.                     if($roleUserClient->getRole() == 'Bo'){
  329.                         $mailling->setEnvoyePar($roleUserClient->getAuthUser());
  330.                         $mailling->setReplyTo($roleUserClient->getAuthUser());
  331.                     }
  332.                 }
  333.                 $mailling->setTypeMail('Coupure');
  334.             }
  335.             $coupuresClient = $em->getRepository('App:Coupure')->findBy(['client' => $client, 'envoyer' => false]);
  336.             foreach ($coupuresClient as $coupure){
  337.                 /** @var Coupure $coupure */
  338.                 $pieceJointeMailling = new PieceJointeMailling();
  339.                 $pieceJointeMailling->setUrl($coupure->getPiecesJointe());
  340.                 $pieceJointeMailling->setCoupure($coupure);
  341.                 $pieceJointeMailling->setMailling($mailling);
  342.                 $mailling->addPiecesJointe($pieceJointeMailling);
  343.             }
  344.             $mailling->setValiderEnvoi(0);
  345.             $mailling->setEnCour(0);
  346.             $mailling->setEnvoyer(0);
  347.             $mailling->setNbMail(0);
  348.             $mailling->setNbMailEnvoye(0);
  349.             $mailling->setDebutMailCoupure($generateCoupure->generateDebutMail($mailling));
  350.             $mailling->setFinMailCoupure($generateCoupure->generateFinMail($mailling));
  351.             $mailling->sethyperlien(1);
  352.             $em->persist($mailling);
  353.             $em->flush();
  354.         } else {
  355.             $retour['message_erreur'] = 'le client n\'existe pas';
  356.         }
  357.         return new JsonResponse(['idMailling' => $mailling->getId()]);
  358.     }
  360.     /**
  361.      * @Route("/maillings/information/{idMailling}", methods={"GET"}, name="nb.mail.envoyer")
  362.      */
  363.     public function getNombreMailEnvoyer($idMailling, EntityManagerInterface $em){
  364.         $mailling = $em->getRepository('App:Mailling')->findBy(['ancienId' => $idMailling]);
  365.         if(!isset($mailling[0])){
  366.             return new JsonResponse(0);
  367.         }
  368.         $mailling = $mailling[0];
  369.         return new JsonResponse($mailling->getNbMailEnvoye());
  370.     }
  372.     /**
  373.      * @Route("/maillings/refreshNbMail/{idMailling}", methods={"GET"}, name="nb.mail.envoyer.refresh")
  374.      */
  375.     public function getRefreshNombreMail(OvhSend $ovhSend, $idMailling, EntityManagerInterface $em){
  376.         $mailling = $em->getRepository('App:Mailling')->find($idMailling);
  377.         /** @var Mailling $mailling */
  378.         $contactsSend = $ovhSend->getContactSend($mailling);
  379.         $nbMail = 0;
  380.         foreach ($contactsSend as $contactSend) {
  381.             $userInfo = explode('#', $contactSend);
  382.             $userMail = trim($userInfo[0]);
  383.             $blackList = $em->getRepository('App:BlackList')
  384.                 ->findOneBy(['email'=> $userMail]);
  385.             if(!$blackList) {
  386.                 $nbMail = $nbMail + 1;
  387.             }
  388.         }
  389.         if($mailling->getNbMail() != $nbMail){
  390.            $mailling->setNbMail($nbMail);
  391.         }
  392.         $em->persist($mailling);
  393.         $em->flush();
  395.         return new JsonResponse($mailling->getNbMail());
  396.     }
  399.     /**
  400.      * @Route("/mailing/contactsenvoireel/{idMailling}", methods={"GET"}, name="mailing.contact.Envoi.reel")
  401.      */
  402.     public function getContactsEnvoiReel($idMailling, EntityManagerInterface $em) {
  403.         $mailing = $em->getRepository('App:Mailling')->findOneBy(["ancienId" => $idMailling]);
  404.         $mailingsEnCours = $em->getRepository('App:MaillingEnCour')->findBy(["mailling" => $mailing->getId()]);
  405.         $contactsIDIntranet = [];
  406.         foreach ($mailingsEnCours as $mailingEncours) {
  407.             if(!is_null($mailingEncours->getUserId()))
  408.                 $contactsIDIntranet[] = $mailingEncours->getUserId();
  409.         }
  410.         return new JsonResponse($contactsIDIntranet);
  411.     }
  412. }