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\Actualite;
  13. use App\Entity\Auth\AuthUser;
  14. use App\Entity\Client;
  15. use App\Entity\ClientRoleUser;
  16. use App\Entity\Coupure;
  17. use App\Entity\Email\AdresseMailVerif;
  18. use App\Entity\Email\EmailRetour;
  19. use App\Entity\Mailling;
  20. use App\Entity\PieceJointeMailling;
  21. use App\Entity\ThemeDescriptif;
  22. use App\Entity\Veille;
  23. use App\Ovh\OvhSend;
  24. use App\Service\Coupure\GenerateCoupureInterface;
  25. use App\Service\Ftp\FtpGetPieceJointe;
  26. use App\Service\MaillingEnCour\MaillingEnCour;
  27. use Doctrine\ORM\EntityManagerInterface;
  28. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  29. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  30. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Route;
  31. use Spipu\Html2Pdf\Html2Pdf;
  32. use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  33. use Symfony\Component\HttpFoundation\JsonResponse;
  34. use Symfony\Component\HttpFoundation\Request;
  35. use Symfony\Component\HttpFoundation\Response;
  36. use Symfony\Component\HttpKernel\KernelInterface;
  37. use Symfony\Component\Serializer\Mapping\Factory\ClassMetadataFactory;
  38. use Symfony\Component\Serializer\Mapping\Loader\AnnotationLoader;
  39. use Symfony\Component\Serializer\Normalizer\DateTimeNormalizer;
  40. use Symfony\Component\Serializer\Normalizer\PropertyNormalizer;
  41. use Symfony\Component\Serializer\Serializer;
  42. use Symfony\Component\Serializer\Encoder\XmlEncoder;
  43. use Symfony\Component\Serializer\Encoder\JsonEncoder;
  44. use Doctrine\Common\Annotations\AnnotationReader;
  45. use PDO;
  47. class MaillingController extends Controller
  48. {
  52.     /**
  53.      * @Route("api/maillings/maillings/getErreur/{idMailling}", methods={"GET"}, name="get.erreur.mailling.en.cours")
  54.      */
  55.     public function getErreurMaillingEnCourAction($idMailling, EntityManagerInterface $em, MaillingEnCour $maillingEnCour){
  56.         $maillingEnCoursErreur = $maillingEnCour->getMaillingErreur($idMailling);
  57.         $encoders = array(new XmlEncoder(), new JsonEncoder());
  58.         $classMetadataFactory = new ClassMetadataFactory(new AnnotationLoader(new AnnotationReader()));
  59.         $normalizer = new PropertyNormalizer($classMetadataFactory);
  60.         $dateTimeNormalizer = new DateTimeNormalizer('d-m-y H:i');
  61.         $serializer = new Serializer([$normalizer,$dateTimeNormalizer], $encoders);
  62.         $jsonContent = $serializer->normalize($maillingEnCoursErreur, null, array('groups' => array('email_retour')));
  63.         $response = new JsonResponse($jsonContent);
  64.         $response->headers->set('Content-Type', 'application/json');
  65.         return $response;
  66.     }
  68.     /**
  69.      * @Route("/maillings/content/{id}",methods={"GET"},name="get.mailling.content")
  70.      */
  71.     public function getMaillingContentAction($id, Request $request, KernelInterface $kernel)
  72.     {
  73.         $em = $this->get('doctrine.orm.entity_manager');
  74.         $mailling = $em->getRepository('App\Entity\Mailling')
  75.             ->find($request->get('id'));
  76.         $path = $kernel->getRootDir() . '/../public/maillings/' . $mailling->getAncienId() . '.html';
  77.         $read = file_get_contents($path);
  78.         return new JsonResponse(utf8_encode($read));
  79.     }
  81.     /**
  82.      * @Route("/maillings/getNbEnvoyer/{id}",methods={"GET"},name="get.mailling.nb.envoyer")
  83.      */
  84.     public function getMaillingNbEnvoyer($id)
  85.     {
  86.         $em = $this->get('doctrine.orm.entity_manager');
  87.         $mailling = $em->getRepository('App\Entity\Mailling')
  88.             ->findOneBy(['ancienId' => $id]);
  89.         return new JsonResponse($mailling->getNbMailEnvoye());
  90.     }
  92.     /**
  93.      * @Route("/maillings/checkDelete",methods={"GET"},name="mail.check")
  94.      */
  95.     public function getCheckMailAction()
  96.     {
  97.         $em = $this->get('doctrine.orm.entity_manager');
  98.         $maillings = $em->getRepository("App\Entity\Mailling")
  99.             ->findBy(['envoyer' => 0 , 'enCour' => 0 ]);
  100.         $checkIfMaillingExist = $this->get('check.mailling.exist');
  101.         $anomalieGestion = $this->get('gestion.anomalie');
  102.         foreach ($maillings as $mailling){
  103.             if($checkIfMaillingExist->checKMailling($mailling) < 1){
  104.                 $suivitOuvertures = $em->getRepository('App:SuivitOuvertureMailling')
  105.                     ->findBy(['mailling' => $mailling]);
  106.                 if(count($suivitOuvertures) < 1){
  107.                     $em->remove($mailling);
  108.                 }
  109.                 else{
  110.                     $anomalieGestion->addAnomalieDeleteWithSuivit($mailling);
  111.                 }
  112.             }
  113.         }
  114.         $em->flush();
  115.         return new Response('ok');
  116.     }
  120.     /**
  121.      * @Route("/maillings/send/test/{idMailling}/{idAuthUser}",methods={"GET"},name="send.mailling.test")
  122.      */
  123.     public function getSendMailTestAction($idMailling, $idAuthUser, MaillingEnCour $maillingEnCour, KernelInterface $kernel)
  124.     {
  125.         $em = $this->get('doctrine.orm.entity_manager');
  126.         $mailling = $em->getRepository("App\Entity\Mailling")
  127.             ->find($idMailling);
  128.         $authUser = $em->getRepository("App\Entity\Auth\AuthUser")
  129.             ->find($idAuthUser);
  130.         if($authUser){
  131.             if($mailling){
  132.                 /** @var Mailling $mailling
  133.                  *  @var AuthUser $authUser
  134.                  */
  135.                 if (strpos($mailling->getEnvoyePar()->getAdresseEnvoi(), '@escalconsulting.com') !== false) {
  136.                     $maillingEnCour->addTestSend($mailling,$authUser);
  137.                     return new JsonResponse('mail test lancé en envoi');
  138.                 } else {
  139.                     return new JsonResponse('l\'utilisateur ne possède pas d\'addresse d\'envoi');
  140.                 }
  141.             } else {
  142.                 return new JsonResponse('le mailling n\'existe pas');
  143.             }
  144.         } else {
  145.             return new JsonResponse('l\'utilisateur n\'existe pas');
  146.         }
  147.     }
  151.     /**
  152.      * @Route("/maillings/send/veille/{id}", methods={"GET"}, name="mailling.veille.send")
  153.      */
  154.     public function sendVeilleAction(MaillingEnCour $maillingEnCour, EntityManagerInterface $em, $id, KernelInterface $kernel){
  155.         $veille = $em->getRepository('App:Veille')->find($id);
  156.         if($veille){
  157.             $match_date = $veille->getDate();
  158.             $date = new \DateTime();
  159.             $interval = $date->diff($match_date);
  160.             if($interval->days == 0) {
  161.                 if(!$veille->getValider()){
  162.                     $veille->setValider(true);
  163.                     $em->persist($veille);
  164.                     $em->flush();
  165.                     $maillingEnCour->addVeilleSend($veille);
  166.                     $this->importerVeilleNetwork($id, $em, $kernel);
  167.                     return new JsonResponse('veille lancer en envoi');
  168.                 }
  169.             }
  170.         }
  171.        return new JsonResponse('veille déja envoyé');
  172.     }
  175.     /**
  176.      * @Route("/maillings/importer/veille/network/{id}", methods={"GET"}, name="mailling_importer_veille_network")
  177.      */
  178.     public function importerVeilleNetwork($id, EntityManagerInterface $em, KernelInterface $kernel){
  179.         $veille = $em->getRepository('App:Veille')->find($id);
  180.         if ($veille){
  181.             $spreadsheet = new Spreadsheet();
  182.             $sheet = $spreadsheet->getActiveSheet();
  183.             $date = new \DateTime('today');
  184.             $dateF = new \DateTime('tomorrow');
  185.             $sheet->setCellValue("A1", "Articles veille du " . $date->format('Y-m-d'));
  186.             $ligne = 2;
  187.             $veilles =  $em->getRepository('App:Veille')->findAll();
  188.             foreach ($veilles as $veille) {
  189.                 if($veille->getDate()>= $date && $veille->getDate()<= $dateF){
  190.                     foreach ($veille->getVeilleThematiques() as $veilleThematique) {
  191.                         foreach ($veilleThematique->getElementsVeille() as $element) {
  192.                             $sheet->setCellValue("A" . $ligne, '=Hyperlink("'.$element->getLiens().'")');
  193.                             $ligne = $ligne + 1;
  194.                         }
  195.                     }
  196.                 }
  197.             }
  198.             foreach (range('A', 'B') as $columnID) {
  199.                 $spreadsheet->getActiveSheet()->getColumnDimension($columnID)
  200.                     ->setAutoSize(true);
  201.             }
  202.             $writer = new Xlsx($spreadsheet);
  203.             $fileName = './excelStat/Veille Quotidienne du '. $date->format('Y-m-d').'.xlsx';
  204.             $writer->save($fileName);
  205.             $file = $kernel->getRootDir() . '/../public/excelStat/Veille Quotidienne du '. $date->format('Y-m-d').'.xlsx';
  206.             // Enregistrement sur le Network
  207.             $ftp_server = "docs.escalconsulting.com";
  208.             $ftp_conn = ftp_connect($ftp_server) or die("Could not connect to $ftp_server");
  209.             ftp_login($ftp_conn, 'informatique', 'E9;b5+AAx%k6')or die("Cannot login");
  210.             ftp_pasv($ftp_conn, true) or die("Cannot switch to passive mode");
  211.             ftp_put($ftp_conn, "/../ESCAL Consulting/Network/Conseil/Veille Quotidienne/Veille Quotidienne du ". $date->format('Y-m-d').".xlsx", $file);
  212.             ftp_close($ftp_conn);
  213.             // retirer du fichier public
  214.             if (file_exists($file)) {
  215.                 unlink($file);
  216.             }
  217.         }
  218.         return new JsonResponse('veille importee');
  219.     }
  221.     /**
  222.      * @Route("/maillings/supprimer/veille/network/{id}", methods={"GET"}, name="mailling_supprimer_veille_network")
  223.      */
  224.     public function supprimerVeilleNetwork($id, EntityManagerInterface $em, KernelInterface $kernel){
  225.         $veille = $em->getRepository('App:Veille')->find($id);
  226.         if ($veille){
  227.             $date = new \DateTime('today');
  228.             // supprimer du network
  229.             $ftp_server = "docs.escalconsulting.com";
  230.             $ftp_conn = ftp_connect($ftp_server) or die("Could not connect to $ftp_server");
  231.             ftp_login($ftp_conn, 'informatique', 'E9;b5+AAx%k6') or die("Cannot login");
  232.             ftp_pasv($ftp_conn, true) or die("Cannot switch to passive mode");
  233.             ftp_delete($ftp_conn, "/../ESCAL Consulting/Network/Conseil/Veille Quotidienne/Veille Quotidienne du ". $date->format('Y-m-d').".xlsx");
  234.             ftp_close($ftp_conn);
  235.         }
  236.         return new JsonResponse('veille supprimée');
  237.     }
  240.     /**
  241.      * @Route("/maillings/send/date/{idMailling}",methods={"GET"},name="send.mail.date")
  242.      */
  243.     public function getSendMaillingDateAction($idMailling , MaillingEnCour $maillingEnCour, Request $request)
  244.     {
  245.         ini_set('memory_limit',-1);
  246.         set_time_limit(0);
  247.         $dateEnvoie = $request->query->get('date');
  248.         $dateEnvoie = new \DateTime($dateEnvoie);
  249.         $em = $this->get('doctrine.orm.entity_manager');
  250.         $mailling = $em->getRepository("App\Entity\Mailling")
  251.             ->find($idMailling);
  252.         if($mailling){
  253.             if($mailling->getValiderEnvoi()){
  254.                 if(!$mailling->getEnCour()){
  255.                     if(!$mailling->getEnvoyer()){
  256.                         if (strpos($mailling->getEnvoyePar()->getAdresseEnvoi(), '@escalconsulting.com') !== false) {
  257.                             $mailling->setEnCour(true);
  258.                             $em->persist($mailling);
  259.                             $em->flush();
  261.                             if($maillingEnCour->addMaillingSend($mailling, $dateEnvoie, true) == false){
  262.                                 return new JsonResponse('le mailling est déja en cours d\'envoi');
  263.                             }
  264.                             return new JsonResponse('le mailling a été lancé en envoi');
  265.                         } else {
  266.                             return new JsonResponse('l\'utilisateur ne possède pas d\'addresse d\'envoi');
  267.                         }
  268.                     } else {
  269.                         return new JsonResponse('le mailling est déjà en envoyé');
  270.                     }
  271.                 } else {
  272.                     return new JsonResponse('le mailling est déjà en cours d\'envoi');
  273.                 }
  274.             } else {
  275.                 return new JsonResponse('le mailling doit être validé');
  276.             }
  277.         } else {
  278.             return new JsonResponse('le mailling n\'existe pas');
  279.         }
  281.     }
  284.     /**
  285.      * @Route("/maillings/send/{idMailling}",methods={"GET"},name="send.mail.reel")
  286.      */
  287.     public function getSendMaillingAction($idMailling , MaillingEnCour $maillingEnCour, OvhSend $ovhSend, ActualiteController $actualiteController)
  288.     {
  289.         ini_set('memory_limit',-1);
  290.         set_time_limit(0);
  291.         $em = $this->get('doctrine.orm.entity_manager');
  292.         $mailling = $em->getRepository("App\Entity\Mailling")
  293.             ->find($idMailling);
  294.         /** @var Mailling $mailling */
  295.         if($mailling){
  296.             if($mailling->getValiderEnvoi()){
  297.                 if(!$mailling->getEnCour()){
  298.                     if(!$mailling->getEnvoyer()){
  299.                         if (strpos($mailling->getEnvoyePar()->getAdresseEnvoi(), '@escalconsulting.com') !== false) {
  300.                             $mailling->setEnCour(true);
  301.                             $em->persist($mailling);
  302.                             $em->flush();
  303.                             if ($mailling->getTypeMail() == 'CP') {
  304.                                 // on créé une actualité
  305.                                 $this->creerActualiteMailing($idMailling, $em, $ovhSend, $actualiteController);
  306.                                 // on envoie le contenu final du cp à intranet
  307.                                 try
  308.                                 {
  309.                                     $bdd = new PDO('mysql:host=185.126.230.125;dbname=escal_web;charset=utf8', 'escalprod', 'skl001');
  310.                                 }
  311.                                 catch (Exception $e)
  312.                                 {
  313.                                     die('Erreur : ' . $e->getMessage());
  314.                                 }
  315.                                 $contenu = $mailling->getContent();
  316.                                 $query = 'UPDATE `ecw_mails` SET `contenu_cp`="'.$contenu.'"  WHERE `ID_mail`='.$mailling->getAncienId();
  317.                                 $retour = $bdd->exec($query);
  318.                             }
  319.                             if($maillingEnCour->addMaillingSend($mailling, new \DateTime('now')) == false){
  320.                                 return new JsonResponse('le mailling est déja en cours d\'envoi');
  321.                             }
  322.                             return new JsonResponse('le mailling a été lancé en envoi');
  323.                         } else {
  324.                             return new JsonResponse('l\'utilisateur ne possède pas d\'addresse d\'envoi');
  325.                         }
  326.                     } else {
  327.                         return new JsonResponse('le mailling est déjà en envoyé');
  328.                     }
  329.                 } else {
  330.                     return new JsonResponse('le mailling est déjà en cours d\'envoi');
  331.                 }
  332.             } else {
  333.                 return new JsonResponse('le mailling doit être validé');
  334.             }
  335.         } else {
  336.             return new JsonResponse('le mailling n\'existe pas');
  337.         }
  339.     }
  341.     /**
  342.      * @Route("/maillings/creer/actualite/suite/envoie/{idMailling}", methods={"GET"}, name="creer_actu_mailing")
  343.      */
  344.     public function creerActualiteMailing($idMailling, EntityManagerInterface $em, OvhSend $ovhSend, ActualiteController $actualiteController){
  345.         $mailling = $em->getRepository('App:Mailling')->find($idMailling);
  346.         $actualite = new Actualite();
  347.         $nomMailling = str_replace('&#039;', '\'', $mailling->getNom());
  348.         $actualite->setNom($nomMailling);
  349.         $actualite->setClient($mailling->getClient());
  350.         $actualite->setPitch($mailling->getResumer());
  351.         $actualite->setCreation(new \DateTime('now'));
  352.         $actualite->setAuteur($mailling->getEnvoyePar());
  353.         $em->persist($actualite);
  354.         $em->flush();
  355.         $actualite = $em->getRepository('App:Actualite')->findDerniereActu();
  356.         $theme = new ThemeDescriptif();
  357.         $theme->setLibelle($mailling->getResumerCour());
  358.         $theme->setActualite($actualite);
  359.         $em->persist($theme);
  360.         $em->flush();
  361.         $actualiteController->parutionImporterCopie($actualite->getId(), 0, $em);
  362.         try
  363.         {
  364.             $bdd = new PDO('mysql:host=185.126.230.125;dbname=escal_web;charset=utf8', 'escalprod', 'skl001');
  365.         }
  366.         catch (Exception $e)
  367.         {
  368.             die('Erreur : ' . $e->getMessage());
  369.         }
  370.         $query = 'SELECT MAX(`ID_actualite`) as actuId FROM `ecw_actualites`';
  371.         $reponse = $bdd->query($query);
  372.         while ($row = $reponse->fetch()) {
  373.             $actuAncienId = $row['actuId'];
  374.         }
  375.         $reponse->closeCursor();
  376.         $actualite->setAncienId($actuAncienId);
  377.         $em->flush();
  378.         $ovhSend->sendMailNouvelleActualite($actualite);
  379.         return new JsonResponse('ok');
  380.     }
  382.     /**
  383.      * @Route("/mailling/enCour/{idMailling}", methods={"GET"}, name="mailling.en.cour.status")
  384.      */
  385.     public function getMaillingInfoEnCourAction($idMailling, EntityManagerInterface $em, MaillingEnCour $maillingEnCour){
  386.         $mailling = $em->getRepository('App:Mailling')->find($idMailling);
  387.         $retour = [];
  388.         if($mailling){
  389.             $debutMailling = $maillingEnCour->getIfMaillingBegin($mailling);
  390.             if($debutMailling !== false){
  391.                 $nbMailling = $maillingEnCour->getNbMailMailling($mailling);
  392.                 $nbMaillingAttente = $maillingEnCour->getNbMailRestantAvantFin($mailling);
  393.                 if($nbMaillingAttente != false){
  394.                     $dateFurtureEnvoie = $maillingEnCour->getHeureEnvoieFuture($mailling);
  395.                     if( $dateFurtureEnvoie == false){
  396.                         $retour['nbMaillAttente'] = $nbMaillingAttente;
  397.                         $retour['nbMailToSend'] = $nbMailling[0];
  398.                         $retour['nbMailSend'] = $nbMailling[1];
  399.                     } else {
  400.                         $retour['message_erreur'] = 'le mailling commencera a être envoyé le ' . $dateFurtureEnvoie;
  401.                     }
  402.                 } else {
  403.                     if($mailling->getEnvoyer() == true){
  404.                         $retour['message_erreur'] = 'le mailling a fini d\'être envoyé';
  405.                     }
  406.                     $retour['message_erreur'] = 'Le mailling est en cours d\'envoi, l\'affichage du diagramme peut prendre plusieurs minutes. Merci de patienter.';
  407.                 }
  409.             } else {
  410.                 $retour['message_erreur'] = 'le mailling n\'est pas en envoi';
  411.             }
  412.         } else {
  413.             $retour['message_erreur'] = 'le mailling n\'existe pas';
  414.         }
  415.         return new JsonResponse($retour);
  416.     }
  418.     /**
  419.      * @Route("/maillings/deleteMailling/{idMailling}", methods={"DELETE"}, name="delete.mailling")
  420.      */
  421.     public function deleteMailling($idMailling, EntityManagerInterface $em){
  422.         $mailling = $em->getRepository('App:Mailling')->find($idMailling);
  423.         if($mailling->getEnCour() === false){
  424.             $maillingsEnCour = $em->getRepository('App:MaillingEnCour')->findBy(['mailling' => $mailling]);
  425.             foreach ($maillingsEnCour as $maillingEnCour){
  426.                 $em->remove($maillingEnCour);
  427.             }
  428.             $em->remove($mailling);
  429.             $em->flush();
  430.             $retour['message'] = 'le mailling a été supprimé';
  431.         } else {
  432.             $retour['message'] = 'le mailling a déjà été lancé en envoi';
  433.         }
  434.         return new JsonResponse($retour);
  435.     }
  437.     /**
  438.      * @Route("/maillings/prepareCoupure/{idClient}", methods={"GET"}, name="mailling.cree.coupure")
  439.      */
  440.     public function creeMaillingCoupure($idClient, EntityManagerInterface $em, GenerateCoupureInterface $generateCoupure){
  441.         $client = $em->getRepository('App:Client')->find($idClient);
  442.         if($client){
  443.             /** @var Client $client */
  444.             $mailling = $em->getRepository('App:Mailling')->findOneBy(['client' => $client, 'typeMail' => 'Coupure', 'envoyer' => false]);
  445.             /** @var Mailling $mailling */
  446.             if($mailling){
  447.                 foreach ($mailling->getPiecesJointes() as $piecesJointe){
  448.                     $mailling->removePiecesJointe($piecesJointe);
  449.                     $em->remove($piecesJointe);
  450.                 }
  451.                 $em->flush();
  452.             } else{
  453.                 $mailling = new Mailling();
  454.                 $mailling->setClient($client);
  455.                 $date = new \DateTime('now');
  456.                 $mailling->setNom('Retombées presse '. $client->getNom(). ' du '.date_format($date, 'd/m/Y'));
  457.                 $mailling->setObjet('Retombées presse '. $client->getNom(). ' du '.date_format($date, 'd/m/Y'));
  458.                 foreach ($client->getRolesUserClient() as $roleUserClient){
  459.                     /** @var ClientRoleUser $roleUserClient */
  460.                     if($roleUserClient->getRole() == 'Bo'){
  461.                         $mailling->setEnvoyePar($roleUserClient->getAuthUser());
  462.                         $mailling->setReplyTo($roleUserClient->getAuthUser());
  463.                     }
  464.                 }
  465.                 $mailling->setTypeMail('Coupure');
  466.             }
  467.             $coupuresClient = $em->getRepository('App:Coupure')->findBy(['client' => $client, 'envoyer' => false]);
  468.             foreach ($coupuresClient as $coupure){
  469.                 /** @var Coupure $coupure */
  470.                 $pieceJointeMailling = new PieceJointeMailling();
  471.                 $pieceJointeMailling->setUrl($coupure->getPiecesJointe());
  472.                 $pieceJointeMailling->setCoupure($coupure);
  473.                 $pieceJointeMailling->setMailling($mailling);
  474.                 $mailling->addPiecesJointe($pieceJointeMailling);
  475.             }
  476.             $mailling->setValiderEnvoi(0);
  477.             $mailling->setEnCour(0);
  478.             $mailling->setEnvoyer(0);
  479.             $mailling->setNbMail(0);
  480.             $mailling->setNbMailEnvoye(0);
  481.             $mailling->setDebutMailCoupure($generateCoupure->generateDebutMail($mailling));
  482.             $mailling->setFinMailCoupure($generateCoupure->generateFinMail($mailling));
  483.             $mailling->sethyperlien(1);
  484.             $em->persist($mailling);
  485.             $em->flush();
  486.         } else {
  487.             $retour['message_erreur'] = 'le client n\'existe pas';
  488.         }
  489.         return new JsonResponse(['idMailling' => $mailling->getId()]);
  490.     }
  492.     /**
  493.      * @Route("/maillings/information/{idMailling}", methods={"GET"}, name="nb.mail.envoyer")
  494.      */
  495.     public function getNombreMailEnvoyer($idMailling, EntityManagerInterface $em){
  496.         $mailling = $em->getRepository('App:Mailling')->findBy(['ancienId' => $idMailling]);
  497.         if(!isset($mailling[0])){
  498.             return new JsonResponse(0);
  499.         }
  500.         $mailling = $mailling[0];
  501.         return new JsonResponse($mailling->getNbMailEnvoye());
  502.     }
  504.     /**
  505.      * @Route("/maillings/refreshNbMail/{idMailling}", methods={"GET"}, name="nb.mail.envoyer.refresh")
  506.      */
  507.     public function getRefreshNombreMail(OvhSend $ovhSend, $idMailling, EntityManagerInterface $em){
  508.         $mailling = $em->getRepository('App:Mailling')->find($idMailling);
  509.         /** @var Mailling $mailling */
  510.         $contactsSend = $ovhSend->getContactSend($mailling);
  511.         $nbMail = 0;
  512.         foreach ($contactsSend as $contactSend) {
  513.             $userInfo = explode('#', $contactSend);
  514.             $userMail = trim($userInfo[0]);
  515.             $blackList = $em->getRepository('App:BlackList')
  516.                 ->findOneBy(['email'=> $userMail]);
  517.             if(!$blackList) {
  518.                 $nbMail = $nbMail + 1;
  519.             }
  520.         }
  521.         if($mailling->getNbMail() != $nbMail){
  522.            $mailling->setNbMail($nbMail);
  523.         }
  524.         $em->persist($mailling);
  525.         $em->flush();
  527.         return new JsonResponse($mailling->getNbMail());
  528.     }
  531.     /**
  532.      * @Route("/mailing/contactsenvoireel/{idMailling}", methods={"GET"}, name="mailing.contact.Envoi.reel")
  533.      */
  534.     public function getContactsEnvoiReel($idMailling, EntityManagerInterface $em) {
  535.         $mailing = $em->getRepository('App:Mailling')->findOneBy(["ancienId" => $idMailling]);
  536.         $mailingsEnCours = $em->getRepository('App:MaillingEnCour')->findBy(["mailling" => $mailing->getId()]);
  537.         $contactsIDIntranet = [];
  538.         foreach ($mailingsEnCours as $mailingEncours) {
  539.             if(!is_null($mailingEncours->getUserId()))
  540.                 $contactsIDIntranet[] = $mailingEncours->getUserId();
  541.         }
  542.         return new JsonResponse($contactsIDIntranet);
  543.     }
  545.     /**
  546.      * @Route("/mailing/get/contacts/safe/{idMailling}", methods={"GET"}, name="mailing_contact_safe_envoi")
  547.      */
  548.     public function getContactsSafeEnvoi($idMailling, EntityManagerInterface $em, OvhSend $ovhSend) {
  549.         $contactsSafe = '';
  550.         // liste contacts hors blacklist et email retour
  551.         $mailing = $em->getRepository('App:Mailling')->findOneBy(["ancienId" => $idMailling]);
  552.         $contactsSend = $ovhSend->getContactSend($mailing);
  553.         foreach ($contactsSend as $contactSend) {
  554.             $contactInfo = explode('#', $contactSend);
  555.             $contactMail = trim($contactInfo[0]);
  556.             $contactID = trim($contactInfo[1]);
  557.             $adresseEmailVerif = $em->getRepository('App:Email\AdresseMailVerif')->findOneBy(['email' => $contactMail]);
  558.             // Rapidité de traitement
  559.             $qb = $em->createQueryBuilder();
  560.             $emailRetour = $qb->select('1')
  561.                 ->from(EmailRetour::class, 'er')
  562.                 ->where('er.email = :email')
  563.                 ->setParameter('email', $contactMail)
  564.                 ->orderBy('er.id', 'DESC')
  565.                 ->setMaxResults(1)
  566.                 ->getQuery()
  567.                 ->getResult();
  568.             $safeToSend = 0;
  569.             //Si l'adresse mail a deja ete verifie  : recuperer le statut de l'adresse mail verifiee
  570.             if ($adresseEmailVerif){
  571.                 // Gestion de cas des adresses mails de type "Accept All"
  572.                 if(!$emailRetour && $adresseEmailVerif->getSafeToSend()==1){
  573.                     $safeToSend = 1;
  574.                 }
  575.             }
  576.             $blackList = $em->getRepository('App:BlackList')->findOneBy(['email' => $contactMail]);
  577.             if (!$blackList || $blackList->getAutorise() == 1) {
  578.                 $dateDuJour = new \DateTime('now');
  579.                 //La dateAbsence correspond à la date de retour
  580.                 if($emailRetour && $emailRetour->getDateAbsence()>$dateDuJour) {
  581.                     $safeToSend = 0;
  582.                 }
  583.                 // Ne pas bloquer l'envoi à l'adresse mail classée 'autre' par les BO
  584.                 if($emailRetour && $emailRetour->getRaison() == 'autre') {
  585.                     $safeToSend = 1;
  586.                 }
  587.                 if($safeToSend == 1) {
  588.                     $contactsSafe = $contactsSafe . '"'.$contactMail.'", ';
  589.                 }
  590.             }
  591.             // vérifier si contact dans les listes coeur de cible et itw articles du client, envoyer obligatoirement
  592.             $contact = $em->getRepository('App\Entity\Contact')->findOneBy(['ancienId' => $contactID]);
  593.             $safeInListe = false;
  594.             if ($contact != null) {
  595.                 $listes = $em->getRepository('App:ListeContact')->findListeCoeurCibleEtItwArticlesClient($mailing->getClient()->getNom());
  596.                 foreach ($listes as $liste){
  597.                     $asso = $this->getDoctrine()->getRepository('App:ListeContactContact')->findBy(['contact' => $contact, 'listeContact' => $liste]);
  598.                     if ($asso != null) {
  599.                         $safeInListe = true;
  600.                     }
  601.                 }
  602.                 if ($safeInListe === true) {
  603.                     $safeToSend = 1;
  604.                 }
  605.             }
  606.             if($safeToSend == 1) {
  607.                 $contactsSafe = $contactsSafe . '"'.$contactMail.'", ';
  608.             }
  609.         }
  610.         return new JsonResponse($contactsSafe);
  611.     }
  614.     /**
  615.      * @Route("/api/maillings/auteur/intranet/{maillingId}", methods={"GET"}, name="rechercher_auteur_intranet_mailling")
  616.      */
  617.     public function rechercherAncienIdAuteur ($maillingId)
  618.     {
  619.         $mailling = $this->getDoctrine()->getRepository('App:Mailling')->find($maillingId);
  620.         $authUserId = 0;
  621.         // récupérer ancien id authuser
  622.         if($mailling->getAuteur() != null) {
  623.             if($mailling->getAuteur()->getUser() != null) {
  624.                 $nomPrenom = $mailling->getAuteur()->getUser()->getPrenom() . "." . $mailling->getAuteur()->getUser()->getNom();
  625.                 if (strpos($nomPrenom, ' ') !== false) {
  626.                     $nomPrenom = str_replace(' ', '.', $nomPrenom);
  627.                 }
  628.                 $url = 'extranet.escalconsulting.com/information/getMembreByNom.php?name=' . $nomPrenom;
  629.                 $c = curl_init();
  630.                 curl_setopt($c, CURLOPT_URL, $url);
  631.                 curl_setopt($c, CURLOPT_RETURNTRANSFER, true);
  632.                 curl_setopt($c, CURLOPT_HEADER, false);
  633.                 $output = curl_exec($c);
  634.                 curl_close($c);
  635.                 $output = json_decode($output);
  636.                 $output = (array)$output;
  637.                 $authUserId = $output['id'];
  638.             }
  639.         }
  640.         return new JsonResponse($authUserId);
  641.     }
  643.     /**
  644.      * @Route("/api/maillings/liste/associee/associer/{maillingId}/{listeAId}", methods={"GET"}, name="mailling_liste_associee_associer")
  645.      */
  646.     public function addMailingListeAssociee($maillingId, $listeAId, EntityManagerInterface $em): JsonResponse
  647.     {
  648.         $mailling = $this->getDoctrine()->getRepository('App:Mailling')->find($maillingId);
  649.         $listeA = $this->getDoctrine()->getRepository('App:ListeContact')->find($listeAId);
  650.         $mailling->addListesAssociee($listeA);
  651.         $em->flush();
  652.         return new JsonResponse("ok");
  653.     }
  656.     /**
  657.      * @Route("/api/maillings/liste/desassociee/associer/{maillingId}/{listeDId}", methods={"GET"}, name="mailling_liste_desassociee_associer")
  658.      */
  659.     public function addMailingListeDesassociee($maillingId, $listeDId, EntityManagerInterface $em): JsonResponse
  660.     {
  661.         $mailling = $this->getDoctrine()->getRepository('App:Mailling')->find($maillingId);
  662.         $listeD = $this->getDoctrine()->getRepository('App:ListeContact')->find($listeDId);
  663.         $mailling->addListesDesassociee($listeD);
  664.         $em->flush();
  665.         return new JsonResponse("ok");
  666.     }
  669.     /**
  670.      * @Route("/api/maillings/liste/associee/desassocier/{maillingId}", methods={"GET"}, name="mailling_liste_associee_desassocier")
  671.      */
  672.     public function deleteMailingListeAssociee($maillingId, EntityManagerInterface $em): JsonResponse
  673.     {
  674.         $mailling = $this->getDoctrine()->getRepository('App:Mailling')->find($maillingId);
  675.         $associations = $mailling->getListesAssociees();
  676.         foreach ($associations as $association) {
  677.             $mailling->removeListesAssociee($association);
  678.         }
  679.         $em->flush();
  680.         return new JsonResponse("ok");
  681.     }
  684.     /**
  685.      * @Route("/api/maillings/liste/desassociee/desassocier/{maillingId}", methods={"GET"}, name="mailling_liste_desassociee_desassocier")
  686.      */
  687.     public function deleteMailingListeDesassociee($maillingId, EntityManagerInterface $em): JsonResponse
  688.     {
  689.         $mailling = $this->getDoctrine()->getRepository('App:Mailling')->find($maillingId);
  690.         $associations = $mailling->getListesDesassociees();
  691.         foreach ($associations as $association) {
  692.             $mailling->removeListesDesassociee($association);
  693.         }
  694.         $em->flush();
  695.         return new JsonResponse("ok");
  696.     }
  699.     /**
  700.      * @Route("/api/maillings/importation/copie/mailling/{maillingId}/{ancienId}", methods={"GET"}, name="mailing_importer_copie_intranet")
  701.      */
  702.     public function mailingImporterCopie ($maillingId, $ancienId, EntityManagerInterface $em)
  703.     {
  704.         try
  705.         {
  706.             $bdd = new PDO('mysql:host=185.126.230.125;dbname=escal_web;charset=utf8', 'escalprod', 'skl001');
  707.         }
  708.         catch (Exception $e)
  709.         {
  710.             die('Erreur : ' . $e->getMessage());
  711.         }
  712.         // récupérer données mailing
  713.         $mailling = $this->getDoctrine()->getRepository('App:Mailling')->find($maillingId);
  714.         // récupérer ancien id auteur
  715.         $authUserId = 0;
  716.         if($mailling->getAuteur() != null) {
  717.             $nomPrenom = $mailling->getAuteur()->getUser()->getPrenom().".".$mailling->getAuteur()->getUser()->getNom();
  718.             if (strpos($nomPrenom,' ') !== false) {
  719.                 $nomPrenom = str_replace(' ','.', $nomPrenom);
  720.             }
  721.             $url = 'extranet.escalconsulting.com/information/getMembreByNom.php?name='.$nomPrenom;
  722.             $c = curl_init();
  723.             curl_setopt($c, CURLOPT_URL, $url);
  724.             curl_setopt($c, CURLOPT_RETURNTRANSFER, true);
  725.             curl_setopt($c, CURLOPT_HEADER, false);
  726.             $output = curl_exec($c);
  727.             curl_close($c);
  728.             $output = json_decode($output);
  729.             $output = (array)$output;
  730.             $authUserId = $output['id'];
  731.         }
  732.         // récupérer nom
  733.         $nom = $mailling->getNom();
  734.         // récupérer from
  735.         $from = $mailling->getEnvoyePar()->getUser()->getEmail();
  736.         // récupérer nomfrom
  737.         $nomfrom = $mailling->getAuteur()->getUser()->getPrenom()." ".$mailling->getAuteur()->getUser()->getNom();
  738.         // récupérer replyto
  739.         $replyto = $mailling->getReplyTo()->getUser()->getEmail();
  740.         // récupérer objet
  741.         $objet = $mailling->getObjet();
  742.         // récupérer id client
  743.         if($mailling->getClient() != null){
  744.             $clientId = $mailling->getClient()->getAncienId();
  745.         } else {
  746.             $clientId = 0;
  747.         }
  748.         // récupérer priorite
  749.         if($mailling->getPriorite() == 1){
  750.             $priorite = "1 (Highest)";
  751.         } else if($mailling->getPriorite() == 2){
  752.             $priorite = "2 (High)";
  753.         } else if($mailling->getPriorite() == 3){
  754.             $priorite = "3 (Normal)";
  755.         } else if($mailling->getPriorite() == 4){
  756.             $priorite = "4 (Low)";
  757.         } else if($mailling->getPriorite() == 5){
  758.             $priorite = "5 (Lowest)";
  759.         }
  760.         $cc = '';
  761.         $bcc = '';
  762.         $format = 'Html';
  763.         $typeId = 3;
  764.         // récupérer ancien id signataire
  765.         $signataireId = 0;
  766.         if($mailling->getEnvoyePar() != null) {
  767.             $nomPrenomBis = $mailling->getEnvoyePar()->getUser()->getPrenom().".".$mailling->getEnvoyePar()->getUser()->getNom();
  768.             if (strpos($nomPrenomBis,' ') !== false) {
  769.                 $nomPrenomBis = str_replace(' ','.', $nomPrenomBis);
  770.             }
  771.             $url = 'extranet.escalconsulting.com/information/getMembreByNom.php?name='.$nomPrenomBis;
  772.             $c = curl_init();
  773.             curl_setopt($c, CURLOPT_URL, $url);
  774.             curl_setopt($c, CURLOPT_RETURNTRANSFER, true);
  775.             curl_setopt($c, CURLOPT_HEADER, false);
  776.             $output = curl_exec($c);
  777.             curl_close($c);
  778.             $output = json_decode($output);
  779.             $output = (array)$output;
  780.             $signataireId = $output['id'];
  781.         }
  782.         $track = 'N';
  783.         $dejaEnvoye = 0;
  784.         $dateEnvoi = null;
  785.         // récupérer création
  786.         if ($mailling->getCreation() != null) {
  787.             $creation = $mailling->getCreation()->format('Y-m-d H:i');
  788.         } else {
  789.             $creation = '';
  790.         }
  791.         // récupérer modification
  792.         if ($mailling->getModification() != null) {
  793.             $modification = $mailling->getModification()->format('Y-m-d H:i');
  794.         } else {
  795.             $modification = '';
  796.         }
  797.         $encours = 0;
  798.         $postfb = 0;
  799.         $posttw = 0;
  800.         $postfbes = 0;
  801.         $posttwes = 0;
  802.         $heureenvoi = '00:00:00';
  803.         // récupérer id outil
  804.         if($mailling->getOutil() != null){
  805.             $outilId = $mailling->getOutil()->getId();
  806.         } else {
  807.             $outilId = 0;
  808.         }
  809.         // récupérer id niveau
  810.         if($mailling->getNiveau() != null){
  811.             $niveauId = $mailling->getNiveau()->getId();
  812.         } else {
  813.             $niveauId = 0;
  814.         }
  815.         // récupérer id sous niveau
  816.         if($mailling->getSousNiveau() != null){
  817.             $sousniveauId = $mailling->getSousNiveau()->getId();
  818.         } else {
  819.             $sousniveauId = 0;
  820.         }
  822.         // récupérer contenu
  823.         $contenu = $mailling->getContent();
  825.         // si ce n'est pas une mise à jour
  826.         if ($ancienId == 0) {
  827.             // on insère le mailling
  828.             if (strpos($nom,'"') !== false) {
  829.                 $nom = str_replace('"','\"', $nom);
  830.             }
  831.             if (strpos($objet,'"') !== false) {
  832.                 $objet = str_replace('"','\"', $objet);
  833.             }
  834.             if (strpos($contenu,'"') !== false) {
  835.                 $contenu = str_replace('"','\"', $contenu);
  836.             }
  838.             $query = 'INSERT INTO `ecw_mails`(`nom_mail`, `cc_mail`, `bcc_mail`, `from_mail`, `nomfrom_mail`, `replyto_mail`, `objet_mail`, `client_mail`, `format_mail`, `priorite_mail`, `IDtype_mail`, `IDmembresignature_mail`, `track_mail`, `DejaEnvoye`, `dateenvoi_mail`, `ID_auteur_mail`, `creation_mail`, `modif_mail`, `encours`, `post_facebook`, `post_twitter`, `post_facebook_escal`, `post_twitter_escal`, `heureenvoi_mail`, `ID_outil`, `ID_niveau`, `ID_sous_niveau`, `contenu_cp`) '
  839.                 .' VALUES ("'.$nom.'","'.$cc.'","'.$bcc.'","'.$from.'","'.$nomfrom.'","'.$replyto.'","'.$objet.'",'.$clientId.',"'.$format.'","'.$priorite.'",'.$typeId.','.$signataireId.',"'.$track.'",'.$dejaEnvoye.',NULL,'.$authUserId.',"'.$creation.'", NULL,'.$encours.','.$postfb.','.$posttw.','.$postfbes.','.$posttwes.',"'.$heureenvoi.'",'.$outilId.','.$niveauId.','.$sousniveauId.',"'.$contenu.'")';
  840.             $retour = $bdd->exec($query);
  841.             if (!$retour) {
  842.                 echo 'Problème lors de l\'insertion du mailing';
  843.             }
  845.             // on récupère le mailing nouvellement créé
  846.             $query = 'SELECT MAX(`ID_mail`) as mailId FROM `ecw_mails`';
  847.             $reponse = $bdd->query($query);
  848.             while ($row = $reponse->fetch()) {
  849.                 $maillingAncienId = $row['mailId'];
  850.             }
  851.             $reponse->closeCursor();
  853.             // on insère les associations du mailing
  854.             // liste associee
  855.             $listeAsso = $mailling->getListesAssociees();
  856.             if(count($listeAsso) > 0) {
  857.                 $query10 = 'DELETE FROM `ecw_mail_liste_asso` WHERE `ID_mail`='.$maillingAncienId;
  858.                 $retour10 = $bdd->exec($query10);
  859.                 foreach ($listeAsso as $liste) {
  860.                     $query11 = 'INSERT INTO `ecw_mail_liste_asso`(`ID_mail`, `ID_liste_contact`) '
  861.                         .' VALUES ('.$maillingAncienId.','.$liste->getAncienId().')';
  862.                     $retour11 = $bdd->exec($query11);
  863.                     if (!$retour11) {
  864.                         echo 'Problème lors de l\'insertion de l\'asso mailing liste associee';
  865.                     }
  866.                 }
  867.             }
  868.             // liste desassociee
  869.             $listeDesa = $mailling->getListesDesassociees();
  870.             if(count($listeDesa) > 0) {
  871.                 $query12 = 'DELETE FROM `ecw_mail_listetoremove_asso` WHERE `ID_mail`=' . $maillingAncienId;
  872.                 $retour12 = $bdd->exec($query12);
  873.                 foreach ($listeDesa as $liste) {
  874.                     $query13 = 'INSERT INTO `ecw_mail_listetoremove_asso`(`ID_mail`, `ID_liste_contact`) '
  875.                         . ' VALUES (' . $maillingAncienId . ',' . $liste->getAncienId() . ')';
  876.                     $retour13 = $bdd->exec($query13);
  877.                     if (!$retour13) {
  878.                         echo 'Problème lors de l\'insertion de l\'asso mailing liste desassociee';
  879.                     }
  880.                 }
  881.             }
  882.             return new JsonResponse($maillingAncienId);
  884.         }
  885.         // si c'est une mise à jour
  886.         else if ($ancienId != 0) {
  887.             // on met à jour le mailing
  888.             if (strpos($nom,'"') !== false) {
  889.                 $nom = str_replace('"','\"', $nom);
  890.             }
  891.             if (strpos($objet,'"') !== false) {
  892.                 $objet = str_replace('"','\"', $objet);
  893.             }
  894.             if (strpos($contenu,'"') !== false) {
  895.                 $contenu = str_replace('"','\"', $contenu);
  896.             }
  897.             $query = 'UPDATE `ecw_mails` SET `nom_mail`="'.$nom.'",`cc_mail`="'.$cc.'",`bcc_mail`="'.$bcc.'",`from_mail`="'.$from.'",`nomfrom_mail`="'.$nomfrom.'",`replyto_mail`="'.$replyto.'",`objet_mail`="'.$objet.'",`client_mail`='.$clientId.', `format_mail`="'.$format.'", `priorite_mail`="'.$priorite.'", `IDtype_mail`='.$typeId.', `IDmembresignature_mail`='.$signataireId.', `track_mail`="'.$track.'", `DejaEnvoye`='.$dejaEnvoye.', `dateenvoi_mail`= NULL, `ID_auteur_mail`='.$authUserId.', `modif_mail`="'.$modification.'", `encours`='.$encours.', `post_facebook`='.$postfb.', `post_twitter`='.$posttw.', `post_facebook_escal`='.$postfbes.', `post_twitter_escal`='.$posttwes.', `heureenvoi_mail`="'.$heureenvoi.'", `ID_outil`='.$outilId.', `ID_niveau`='.$niveauId.', `ID_sous_niveau`='.$sousniveauId.', `contenu_cp`="'.$contenu.'"  WHERE `ID_mail`='.$ancienId;
  898.             $retour = $bdd->exec($query);
  900.             // on update les associations du mailing
  901.             // liste associee
  902.             $listeAsso = $mailling->getListesAssociees();
  903.             $query10 = 'DELETE FROM `ecw_mail_liste_asso` WHERE `ID_mail`='.$ancienId;
  904.             $retour10 = $bdd->exec($query10);
  905.             if(count($listeAsso) > 0) {
  906.                 foreach ($listeAsso as $liste) {
  907.                     $query11 = 'INSERT INTO `ecw_mail_liste_asso`(`ID_mail`, `ID_liste_contact`) '
  908.                         .' VALUES ('.$ancienId.','.$liste->getAncienId().')';
  909.                     $retour11 = $bdd->exec($query11);
  910.                     if (!$retour11) {
  911.                         echo 'Problème lors de l\'insertion de l\'asso mailing liste associee';
  912.                     }
  913.                 }
  914.             }
  915.             // liste desassociee
  916.             $listeDesa = $mailling->getListesDesassociees();
  917.             $query12 = 'DELETE FROM `ecw_mail_listetoremove_asso` WHERE `ID_mail`=' . $ancienId;
  918.             $retour12 = $bdd->exec($query12);
  919.             if(count($listeDesa) > 0) {
  920.                 foreach ($listeDesa as $liste) {
  921.                     $query13 = 'INSERT INTO `ecw_mail_listetoremove_asso`(`ID_mail`, `ID_liste_contact`) '
  922.                         . ' VALUES (' . $ancienId . ',' . $liste->getAncienId() . ')';
  923.                     $retour13 = $bdd->exec($query13);
  924.                     if (!$retour13) {
  925.                         echo 'Problème lors de l\'insertion de l\'asso mailing liste desassociee';
  926.                     }
  927.                 }
  928.             }
  929.             return new JsonResponse($ancienId);
  930.         }
  931.     }
  934.     /**
  935.      * @Route("/api/maillings/considerer/envoye/{ancienIdMailing}", methods={"GET"}, name="mailing_considerer_envoyer")
  936.      */
  937.     public function considererEnvoyeMailing($ancienIdMailing, EntityManagerInterface $em): JsonResponse
  938.     {
  939.         try
  940.         {
  941.             $bdd = new PDO('mysql:host=185.126.230.125;dbname=escal_web;charset=utf8', 'escalprod', 'skl001');
  942.         }
  943.         catch (Exception $e)
  944.         {
  945.             die('Erreur : ' . $e->getMessage());
  946.         }
  947.         if ($ancienIdMailing != 0 && $ancienIdMailing != '') {
  948.             $query = 'UPDATE `ecw_mails` SET `DejaEnvoye`= 1 WHERE `ID_mail`='.$ancienIdMailing;
  949.             $retour = $bdd->exec($query);
  950.         }
  951.         return new JsonResponse("ok");
  952.     }
  954.     /**
  955.      * @Route("/api/maillings/total/contact/liste/{mailingId}/{type}", methods={"GET"}, name="mailing_total_contact_liste")
  956.      */
  957.     public function detailsListeContactInfo ($mailingId, $type, EntityManagerInterface $em)
  958.     {
  959.         $ids = array();
  960.         $mailing = $em->getRepository('App:Mailling')->find($mailingId);
  961.         if ($type == 'associe') {
  962.             $listesMailling = $mailing->getListesAssociees();
  963.         } else {
  964.             $listesMailling = $mailing->getListesDesassociees();
  965.         }
  966.         foreach ($listesMailling as $liste){
  967.             $ids[] = $liste->getId();
  968.         }
  969.         $contacts = $this->getDoctrine()->getRepository('App:Contact')->findDistinctTotalContactMailing($ids);
  970.         $encoders = array(new XmlEncoder(), new JsonEncoder());
  971.         $classMetadataFactory = new ClassMetadataFactory(new AnnotationLoader(new AnnotationReader()));
  972.         $normalizer = new PropertyNormalizer($classMetadataFactory);
  973.         $normalizerDate = new DateTimeNormalizer();
  974.         $serializer = new Serializer([$normalizer, $normalizerDate], $encoders);
  975.         $jsonContent = $serializer->normalize($contacts, null, array('groups' => array('contact')));
  976.         $response = new JsonResponse($jsonContent);
  977.         $response->headers->set('Content-Type', 'application/json');
  978.         return $response;
  979.     }
  982.     /**
  983.      * @Route("/api/maillings/importation/supprimer/copie/mailing/{ancienIdMailing}", methods={"GET"}, name="mailing_supprimer_copie_intranet")
  984.      */
  985.     public function mailingSupprimerCopie ($ancienIdMailing)
  986.     {
  987.         try
  988.         {
  989.             $bdd = new PDO('mysql:host=185.126.230.125;dbname=escal_web;charset=utf8', 'escalprod', 'skl001');
  990.         }
  991.         catch (Exception $e)
  992.         {
  993.             die('Erreur : ' . $e->getMessage());
  994.         }
  995.         // supprimer asso liste associee
  996.         $query = 'DELETE FROM `ecw_mail_liste_asso` WHERE `ID_mail`='.$ancienIdMailing;
  997.         $retour = $bdd->exec($query);
  998.         // supprimer asso liste desassociee
  999.         $query1 = 'DELETE FROM `ecw_mail_listetoremove_asso` WHERE `ID_mail`='.$ancienIdMailing;
  1000.         $retour1 = $bdd->exec($query1);
  1001.         // supprimer mailing
  1002.         $query5 = 'DELETE FROM `ecw_mails` WHERE `ID_mail`='.$ancienIdMailing;
  1003.         $retour5 = $bdd->exec($query5);
  1005.         return new JsonResponse('ok');
  1006.     }
  1009.     /**
  1010.      * @Route("/api/maillings/add/ftp/html/{maillingId}", methods={"GET"}, name="mailing_add_ftp_copie_intranet")
  1011.      */
  1012.     public function addMailHtml ($maillingId, FtpGetPieceJointe $ftp)
  1013.     {
  1014.         $result = $ftp->addMailHTML($maillingId);
  1015.         if(isset($result['type'])){
  1016.             return new Response(json_encode($result));
  1017.         }
  1019.         return new Response('{ "status": "ok" }');
  1020.     }
  1021. }