src/Service/Notification.php line 81

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Entity\Historique;
  6. use App\Entity\InfosSuivi;
  7. use App\Entity\Lot;
  8. use App\Entity\Programme;
  9. use App\Entity\Prospect;
  10. use App\Entity\Impression;
  11. use App\Entity\Utilisateur;
  12. use App\Repository\ProspectRepository;
  13. use Symfony\Component\Mime\Email;
  14. use Symfony\Component\Mime\Address;
  15. use App\Repository\UtilisateurRepository;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Doctrine\Persistence\ManagerRegistry;
  18. use Symfony\Bridge\Twig\Mime\TemplatedEmail;
  19. use Symfony\Component\HttpFoundation\Cookie;
  20. use Symfony\Component\HttpFoundation\Request;
  21. use Symfony\Component\Mailer\MailerInterface;
  22. use Symfony\Component\HttpFoundation\Response;
  23. use Symfony\Contracts\Translation\TranslatorInterface;
  24. use Symfony\Component\DependencyInjection\ContainerInterface;
  25. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  26. use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
  28. class Notification
  29. {
  31.     protected $doctrine;
  32.     protected $container;
  33.     protected $mailer;
  34.     protected $utilisateurRepository;
  35.     protected $prospectRepository;
  36.     protected $router;
  37.     private $creationPdf;
  38.     private $em;
  40.     public function __construct(ContainerInterface $container, ManagerRegistry $doctrine, MailerInterface $mailer, UtilisateurRepository $utilisateurRepository, ProspectRepository $prospectRepository, UrlGeneratorInterface $router, CreationPdf $creationPdf, EntityManagerInterface $em)
  41.     {
  42.         $this->container = $container;
  43.         $this->doctrine = $doctrine;
  44.         $this->mailer = $mailer;
  45.         $this->utilisateurRepository = $utilisateurRepository;
  46.         $this->prospectRepository = $prospectRepository;
  47.         $this->router = $router;
  48.         $this->creationPdf = $creationPdf;
  49.         $this->em = $em;
  50.     }
  52.     public function alertInterne(Prospect $prospect, Impression $impression, Lot $lot, UtilisateurRepository $utilisateurRepository)
  53.     {
  54.         $utilisateurs = $utilisateurRepository->findBy( ['notification' => true]);
  55.         $destinataires = [];
  56.         foreach($utilisateurs as $utilisateur){
  57.             $destinataires[] = new Address($utilisateur->getEmail());
  58.         }
  60.         $email = (new TemplatedEmail())
  61.             ->from(new Address('mailer@zada.ai', 'Élise Bala'))
  62.             ->replyTo($prospect->getEmprunteurEmail())
  63.             ->to(...$destinataires)
  64.             ->subject($prospect->getEntreprise() . ' : nouveau retour de prospect')
  65.             ->htmlTemplate('emails/email_impression.html.twig')
  66.             ->context([
  67.                 'prospect' => $prospect,
  68.                 'impression' => $impression,
  69.                 'lot' => $lot
  70.             ])
  71.         ;
  73.         try {
  74.             $this->mailer->send($email);
  75.             return true;
  76.         } catch (TransportExceptionInterface $e) {
  77.             return false;
  78.         }
  79.     }
  81.     public function alertVisite(Prospect $prospect, UtilisateurRepository $utilisateurRepository, string $senderEmail, Historique $lastHistorique)
  82.     {
  83.         $existingInfosSuivi = $this->em->getRepository(InfosSuivi::class)->findOneBy([
  84.             'historique' => $lastHistorique,
  85.             'type' => 'visite'
  86.         ]);
  88.         if ($existingInfosSuivi !== null) {
  89.             return false;
  90.         }
  92.         $SUPERADMINs = $utilisateurRepository->createQueryBuilder('u')
  93.             ->where('u.email LIKE :email')
  94.             ->andWhere('u.notification = true')
  95.             ->setParameters(['email' => $senderEmail])
  96.             ->getQuery()
  97.             ->getResult();
  99.         $destinataires = [];
  101.         foreach ($SUPERADMINs as $SUPERADMIN) {
  102.             $destinataires[] = new Address($SUPERADMIN->getEmail());
  103.         }
  105.         $destinataires = array_unique($destinataires, SORT_REGULAR);
  107.         $email = (new TemplatedEmail())
  108.             ->replyTo($prospect->getEmprunteurEmail())
  109.             ->to(...$destinataires)
  110.             ->subject($prospect->getEntreprise() . ' : nouvelle visite')
  111.             ->htmlTemplate('emails/email_visite.html.twig')
  112.             ->context([
  113.                 'prospect' => $prospect,
  114.                 'lastHistorique' => $lastHistorique
  115.             ]);
  117.         $email->from(new Address('mailer@zada.ai', 'LK1'));
  118.         $email->getHeaders()->addTextHeader('X-Transport', 'main');
  120.         $infoSuivi = new InfosSuivi();
  121.         $infoSuivi->setUtilisateur($prospect->getAuteur());
  122.         $infoSuivi->addProspect($prospect);
  123.         $infoSuivi->setHistorique($lastHistorique);
  124.         $infoSuivi->setType('visite');
  125.         $infoSuivi->setDescription('[prospect] a [visite] son espace public.');
  126.         $infoSuivi->setDate(new \DateTime());
  127.         $infoSuivi->setLu(false);
  129.         $this->em->persist($infoSuivi);
  130.         $this->em->flush();
  132.         try {
  133.             $this->mailer->send($email);
  135.             return true;
  136.         } catch (TransportExceptionInterface $e) {
  137.             return false;
  138.         }
  139.     }
  141.     public function alertProspect(Prospect $prospect, Request $request)
  142.     {
  143.         $subject = $request->request->get('_mail_subject');
  144.         $message = $request->request->get('_mail_message');
  146.         $addCopy = $request->request->get('_mail_copy');
  147.         if (isset($addCopy)) {
  148.             $emailCopy = $prospect->getCoEmprunteurEmail();
  149.         }
  151.         /** @var Utilisateur $user */
  152.         $user = $this->container->get('security.token_storage')->getToken()->getUser();
  153.         $emailUser = $user->getEmail();
  155.         $smtpEmail       = $user->getSmtpEmail();
  156.         $smtpPassword    = $user->getSmtpPassword();
  157.         $smtpDisplayName = $user->getSmtpDisplayName();
  159.         if (!$smtpEmail || !$smtpPassword) {
  160.             return 'Aucun SMTP configuré pour votre compte. Veuillez renseigner vos paramètres SMTP dans votre profil utilisateur.';
  161.         }
  163.         /** @var \Twig\Environment $twig */
  164.         $twig = $this->container->get('twig');
  166.         $html = $twig->render('emails/email_layout.html.twig', [
  167.             'prospect' => $prospect,
  168.             'message'  => $message,
  169.         ]);
  171.         $email = (new Email())
  172.             ->to($prospect->getEmprunteurEmail())
  173.             ->replyTo($emailUser)
  174.             ->subject($subject)
  175.             ->from(new Address(
  176.                 $smtpEmail,
  177.                 $smtpDisplayName ?: $smtpEmail
  178.             ))
  179.             ->html($html)
  180.         ;
  182.         if (isset($emailCopy)) {
  183.             $email->addCc($emailCopy);
  184.         }
  186.         $dsn = sprintf(
  187.             'smtp://%s:%s@smtp.office365.com:587/?allow_peer=0',
  188.             rawurlencode($smtpEmail),
  189.             $smtpPassword
  190.         );
  192.         $transport     = \Symfony\Component\Mailer\Transport::fromDsn($dsn);
  193.         $dynamicMailer = new \Symfony\Component\Mailer\Mailer($transport);
  195.         try {
  196.             $dynamicMailer->send($email);
  197.             return true;
  198.         } catch (TransportExceptionInterface $e) {
  199.             return 'Erreur envoi SMTP : ' . $e->getMessage();
  200.         }
  201.     }
  203.     public function alertProspectATraiter(Prospect $prospect, Utilisateur $negociateur): bool
  204.     {
  205.         if (!$prospect->getEmprunteurEmail()) {
  206.             return false;
  207.         }
  209.         $subject = sprintf('%s - Demande confirmée : un expert vous contacte rapidement', $prospect->getEntreprise());
  211.         $message = sprintf(
  212.             "Suite à votre demande d'informations, un expert %s va vous rappeler dans les plus brefs délais pour échanger sur votre projet.\nDans l'intervalle, vous pouvez également nous proposer un créneau horaire à votre convenance.",
  213.             $prospect->getEntreprise()
  214.         );
  216.         // Utilisation du NOUVEAU TEMPLATE email_atraiter.html.twig
  217.         $email = (new TemplatedEmail())
  218.             ->to($prospect->getEmprunteurEmail())
  219.             ->subject($subject)
  220.             ->htmlTemplate('emails/email_atraiter.html.twig')
  221.             ->context([
  222.                 'prospect' => $prospect,
  223.                 'message' => nl2br($message),
  224.             ]);
  226.         $email->from(new Address('mailer@zada.ai', 'LK1 Immobilier'));
  227.         $email->getHeaders()->addTextHeader('X-Transport', 'main');
  229.         try {
  230.             $this->mailer->send($email);
  231.             return true;
  232.         } catch (TransportExceptionInterface $e) {
  233.             return false;
  234.         }
  235.     }
  238.     public function alertAuteurProspect(int $prospectId, int $auteurId, Utilisateur $userConnected)
  239.     {
  240.         $auteur = $this->utilisateurRepository->find($auteurId);
  241.         $prospect = $this->prospectRepository->find($prospectId);
  243.         if (!$auteur || !$prospect) {
  244.             return false;
  245.         }
  247.         $pdfPath = $this->creationPdf->createPDF($prospect, '/', 'file');
  249.         $email = (new TemplatedEmail())
  250.             ->from(new Address('mailer@zada.ai', 'LK1'))
  251.             ->to($auteur->getEmail())
  252.             ->subject($prospect->getEntreprise() . ' : nouveau contact à traiter')
  253.             ->htmlTemplate('emails/email_nouveau_contact.html.twig')
  254.             ->context([
  255.                 'prospect' => $prospect,
  256.                 'auteur' => $auteur,
  257.             ])
  258.             ->attachFromPath($pdfPath);
  260.         try {
  261.             $this->mailer->send($email);
  262.             if ($pdfPath) {
  263.                 if (is_file($pdfPath)) {
  264.                     unlink($pdfPath);
  265.                 }
  266.             }
  268.             $this->addNotificationForAdmins($prospect, $auteur, $userConnected);
  269.     
  270.             return true;
  271.         } catch (TransportExceptionInterface $e) {
  272.             if ($pdfPath) {
  273.                 if (is_file($pdfPath)) {
  274.                     unlink($pdfPath);
  275.                 }
  276.             }
  277.             return false;
  278.         }
  279.     }
  281.     /**
  282.      * Méthode pour notifier les SUPERADMIN d'une demande de suppression de programme
  283.      */
  284.     public function alertDemandeSuppression(Programme $programme, Utilisateur $userConnected)
  285.     {
  286.         $entreprise = $programme->getEntreprise();
  288.         if (!$entreprise) {
  289.             return false;
  290.         }
  292.         $superAdmins = $this->utilisateurRepository->createQueryBuilder('u')
  293.             ->where('u.entreprise = :entreprise')
  294.             ->andWhere('u.roles LIKE :roleSuperAdmin')
  295.             ->setParameter('entreprise', $entreprise)
  296.             ->setParameter('roleSuperAdmin', '%ROLE_SUPERADMIN%')
  297.             ->getQuery()
  298.             ->getResult();
  300.         foreach ($superAdmins as $admin) {
  301.             $infoSuivi = new InfosSuivi();
  302.             $infoSuivi->setUtilisateur($admin);
  303.             $infoSuivi->setType('suppr');
  304.             $infoSuivi->setDescription('[user] a fait une [demande de suppression] pour le programme [programme].');
  305.             $infoSuivi->setDate(new \DateTime());
  306.             $infoSuivi->setLu(false);
  307.             $infoSuivi->setConnectedUser($userConnected);
  308.             $infoSuivi->setProgramme($programme);
  310.             $this->em->persist($infoSuivi);
  311.         }
  313.         $this->em->flush();
  315.         return true;
  316.     }
  318.     public function alertRapportATraiter(array $admins, array $prospects, \DateTimeInterface $start, \DateTimeInterface $end)
  319.     {
  320.         if (empty($admins)) {
  321.             return array(
  322.                 'success' => false,
  323.                 'errors' => array('Aucun admin éligible pour recevoir le rapport.')
  324.             );
  325.         }
  327.         // Préparer les données structurées pour le template
  328.         $prospectData = array();
  330.         foreach ($prospects as $prospect) {
  331.             /** @var \App\Entity\Prospect $prospect */
  332.             $hasClicked = $prospect->getDateCliqueATraiter()
  333.                 && $prospect->getDateCliqueATraiter() >= $start
  334.                 && $prospect->getDateCliqueATraiter() <= $end;
  336.             $negociateur = $prospect->getAuteur()
  337.                 ? trim($prospect->getAuteur()->getPrenom() . ' ' . $prospect->getAuteur()->getNom())
  338.                 : 'Non assigné';
  340.             $client = trim($prospect->getEmprunteurNom() . ' ' . $prospect->getEmprunteurPrenom());
  342.             $prospectData[] = array(
  343.                 'id' => $prospect->getId(),
  344.                 'client' => $client,
  345.                 'negociateur' => $negociateur,
  346.                 'hasClicked' => $hasClicked,
  347.                 'dateCreation' => $prospect->getDateDerniereModification()
  348.                     ? $prospect->getDateDerniereModification()->format('d/m/Y à H\hi')
  349.                     : 'N/A'
  350.             );
  351.         }
  353.         // User connecté uniquement pour le reply-to (pas pour le SMTP)
  354.         $emailUser = null;
  355.         if ($this->container->has('security.token_storage')
  356.             && $this->container->get('security.token_storage')->getToken()
  357.         ) {
  358.             $user = $this->container->get('security.token_storage')->getToken()->getUser();
  359.             if ($user instanceof Utilisateur && $user->getEmail()) {
  360.                 $emailUser = $user->getEmail();
  361.             }
  362.         }
  364.         // Rendu du template Twig
  365.         /** @var \Twig\Environment $twig */
  366.         $twig = $this->container->get('twig');
  368.         $html = $twig->render('emails/rapport.html.twig', [
  369.             'prospects' => $prospectData,
  370.             'start' => $start,
  371.             'end' => $end,
  372.             'totalProspects' => count($prospectData),
  373.             'prospectsCliques' => count(array_filter($prospectData, function($p) { return $p['hasClicked']; })),
  374.             'prospectsNonCliques' => count(array_filter($prospectData, function($p) { return !$p['hasClicked']; }))
  375.         ]);
  377.         $success = false;
  378.         $errors  = array();
  380.         foreach ($admins as $admin) {
  381.             if (!method_exists($admin, 'getEmail') || !$admin->getEmail()) {
  382.                 $errors[] = 'Admin sans email valide.';
  383.                 continue;
  384.             }
  386.             $email = (new Email())
  387.                 ->from(new Address('mailer@zada.ai', 'LK1'))
  388.                 ->to($admin->getEmail())
  389.                 ->subject('Rapport quotidien - Prospects A TRAITER (depuis ' . $start->format('d/m/Y à H\hi') . ')')
  390.                 ->html($html);
  392.             if ($emailUser) {
  393.                 $email->replyTo($emailUser);
  394.             }
  396.             // Utilise le transport par défaut "main"
  397.             $email->getHeaders()->addTextHeader('X-Transport', 'main');
  399.             try {
  400.                 $this->mailer->send($email);
  401.                 $success = true;
  402.             } catch (TransportExceptionInterface $e) {
  403.                 $errors[] = sprintf(
  404.                     'Erreur pour %s : %s',
  405.                     $admin->getEmail(),
  406.                     $e->getMessage()
  407.                 );
  408.             }
  409.         }
  411.         return array(
  412.             'success' => $success,
  413.             'errors'  => $errors,
  414.         );
  415.     }
  418.     private function addNotificationForAdmins(Prospect $prospect, ?Utilisateur $auteur, Utilisateur $userConnected)
  419.     {
  420.         $entreprise = $auteur ? $auteur->getEntreprise() : null;
  421.         $queryBuilder = $this->utilisateurRepository->createQueryBuilder('u');
  422.     
  423.         if ($entreprise) {
  424.             $queryBuilder->where('u.entreprise = :entreprise')
  425.                 ->setParameter('entreprise', $entreprise);
  426.         }
  427.     
  428.         $queryBuilder->andWhere(
  429.             $queryBuilder->expr()->orX(
  430.                 $queryBuilder->expr()->like('u.roles', ':rolesAdmin'),
  431.                 $queryBuilder->expr()->like('u.roles', ':rolesSuperAdmin')
  432.             )
  433.         )
  434.         ->setParameter('rolesAdmin', '%ROLE_ADMIN%')
  435.         ->setParameter('rolesSuperAdmin', '%ROLE_SUPERADMIN%');
  436.     
  437.         if (in_array('ROLE_COMMERCIAL', $auteur->getRoles())) {
  438.             $queryBuilder->orWhere('u.roles LIKE :rolesDirecteur')
  439.                 ->setParameter('rolesDirecteur', '%ROLE_DIRECTEUR%');
  440.         }
  442.         if (in_array('ROLE_PARTENAIRE', $auteur->getRoles())) {
  443.             $queryBuilder->orWhere('u.roles LIKE :rolesResponsable')
  444.                 ->setParameter('rolesResponsable', '%ROLE_RESPONSABLE%');
  445.         }
  447.         $admins = $queryBuilder->getQuery()->getResult();
  448.     
  449.         foreach ($admins as $admin) {
  450.             $infoSuivi = new InfosSuivi();
  451.             $infoSuivi->setUtilisateur($admin);
  452.             $infoSuivi->addProspect($prospect);
  453.             $infoSuivi->setType('client');
  454.             $infoSuivi->setDescription('Le client [prospect] a été attribué à [user] par [connectedUser]');
  455.             $infoSuivi->setDate(new \DateTime());
  456.             $infoSuivi->setLu(false);
  457.             $infoSuivi->setAuteur($auteur);
  458.             $infoSuivi->setConnectedUser($userConnected);
  459.     
  460.             $this->em->persist($infoSuivi);
  461.         }
  462.     
  463.         $this->em->flush();
  464.     }
  465. }