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