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.         $SUPERADMINs = $utilisateurRepository->createQueryBuilder('u')
  84.             ->where('u.email LIKE :email')
  85.             ->andWhere('u.notification = true')
  86.             ->setParameters(['email' => $senderEmail])
  87.             ->getQuery()
  88.             ->getResult();
  90.         $destinataires = [];
  92.         foreach ($SUPERADMINs as $SUPERADMIN) {
  93.             $destinataires[] = new Address($SUPERADMIN->getEmail());
  94.         }
  96.         $destinataires = array_unique($destinataires, SORT_REGULAR);
  98.         $email = (new TemplatedEmail())
  99.             ->replyTo($prospect->getEmprunteurEmail())
  100.             ->to(...$destinataires)
  101.             ->subject($prospect->getEntreprise() . ' : nouvelle visite')
  102.             ->htmlTemplate('emails/email_visite.html.twig')
  103.             ->context([
  104.                 'prospect' => $prospect,
  105.                 'lastHistorique' => $lastHistorique
  106.             ]);
  108.         $email->from(new Address('mailer@zada.ai', 'LK1'));
  109.         $email->getHeaders()->addTextHeader('X-Transport', 'main');
  110.     
  111.         $infoSuivi = new InfosSuivi();
  112.         $infoSuivi->setUtilisateur($prospect->getAuteur());
  113.         $infoSuivi->addProspect($prospect);
  114.         $infoSuivi->setHistorique($lastHistorique);
  115.         $infoSuivi->setType('visite');
  116.         $infoSuivi->setDescription('[prospect] a [visite] son espace public.');
  117.         $infoSuivi->setDate(new \DateTime());
  118.         $infoSuivi->setLu(false);
  120.         $this->em->persist($infoSuivi);
  121.         $this->em->flush();
  123.         try {
  124.             $this->mailer->send($email);
  125.     
  126.             return true;
  127.         } catch (TransportExceptionInterface $e) {
  128.             return false;
  129.         }
  130.     }
  132.     public function alertProspect(Prospect $prospect, Request $request)
  133.     {
  134.         $subject = $request->request->get('_mail_subject');
  135.         $message = $request->request->get('_mail_message');
  137.         $addCopy = $request->request->get('_mail_copy');
  138.         if (isset($addCopy)) {
  139.             $emailCopy = $prospect->getCoEmprunteurEmail();
  140.         }
  142.         /** @var Utilisateur $user */
  143.         $user = $this->container->get('security.token_storage')->getToken()->getUser();
  144.         $emailUser = $user->getEmail();
  146.         $smtpEmail       = $user->getSmtpEmail();
  147.         $smtpPassword    = $user->getSmtpPassword();
  148.         $smtpDisplayName = $user->getSmtpDisplayName();
  150.         if (!$smtpEmail || !$smtpPassword) {
  151.             return 'Aucun SMTP configuré pour votre compte. Veuillez renseigner vos paramètres SMTP dans votre profil utilisateur.';
  152.         }
  154.         /** @var \Twig\Environment $twig */
  155.         $twig = $this->container->get('twig');
  157.         $html = $twig->render('emails/email_layout.html.twig', [
  158.             'prospect' => $prospect,
  159.             'message'  => $message,
  160.         ]);
  162.         $email = (new Email())
  163.             ->to($prospect->getEmprunteurEmail())
  164.             ->replyTo($emailUser)
  165.             ->subject($subject)
  166.             ->from(new Address(
  167.                 $smtpEmail,
  168.                 $smtpDisplayName ?: $smtpEmail
  169.             ))
  170.             ->html($html)
  171.         ;
  173.         if (isset($emailCopy)) {
  174.             $email->addCc($emailCopy);
  175.         }
  177.         $dsn = sprintf(
  178.             'smtp://%s:%s@smtp.office365.com:587/?allow_peer=0',
  179.             rawurlencode($smtpEmail),
  180.             $smtpPassword
  181.         );
  183.         $transport     = \Symfony\Component\Mailer\Transport::fromDsn($dsn);
  184.         $dynamicMailer = new \Symfony\Component\Mailer\Mailer($transport);
  186.         try {
  187.             $dynamicMailer->send($email);
  188.             return true;
  189.         } catch (TransportExceptionInterface $e) {
  190.             return 'Erreur envoi SMTP : ' . $e->getMessage();
  191.         }
  192.     }
  194.     public function alertProspectATraiter(Prospect $prospect, Utilisateur $negociateur): bool
  195.     {
  196.         if (!$prospect->getEmprunteurEmail()) {
  197.             return false;
  198.         }
  200.         // Sujet neutre et cohérent
  201.         $subject = sprintf('%s - Votre demande a bien été prise en compte', $prospect->getEntreprise());
  203.         // Message simple, sans répétition, sans phrase inutile
  204.         $message = sprintf(
  205.             "%s va vous rappeler prochainement pour échanger sur votre projet immobilier.",
  206.             trim($negociateur->getPrenom().' '.$negociateur->getNom())
  207.         );
  209.         // Utilisation du NOUVEAU TEMPLATE email_atraiter.html.twig
  210.         $email = (new TemplatedEmail())
  211.             ->to($prospect->getEmprunteurEmail())
  212.             ->subject($subject)
  213.             ->htmlTemplate('emails/email_atraiter.html.twig')
  214.             ->context([
  215.                 'prospect' => $prospect,
  216.                 'message' => nl2br($message),
  217.             ]);
  219.         $email->from(new Address('mailer@zada.ai', 'LK1 Immobilier'));
  220.         $email->getHeaders()->addTextHeader('X-Transport', 'main');
  222.         try {
  223.             $this->mailer->send($email);
  224.             return true;
  225.         } catch (TransportExceptionInterface $e) {
  226.             return false;
  227.         }
  228.     }
  231.     public function alertAuteurProspect(int $prospectId, int $auteurId, Utilisateur $userConnected)
  232.     {
  233.         $auteur = $this->utilisateurRepository->find($auteurId);
  234.         $prospect = $this->prospectRepository->find($prospectId);
  236.         if (!$auteur || !$prospect) {
  237.             return false;
  238.         }
  240.         $pdfPath = $this->creationPdf->createPDF($prospect, '/', 'file');
  242.         $email = (new TemplatedEmail())
  243.             ->from(new Address('mailer@zada.ai', 'LK1'))
  244.             ->to($auteur->getEmail())
  245.             ->subject($prospect->getEntreprise() . ' : nouveau contact à traiter')
  246.             ->htmlTemplate('emails/email_nouveau_contact.html.twig')
  247.             ->context([
  248.                 'prospect' => $prospect,
  249.                 'auteur' => $auteur,
  250.             ])
  251.             ->attachFromPath($pdfPath);
  253.         try {
  254.             $this->mailer->send($email);
  255.             if ($pdfPath) {
  256.                 if (is_file($pdfPath)) {
  257.                     unlink($pdfPath);
  258.                 }
  259.             }
  261.             $this->addNotificationForAdmins($prospect, $auteur, $userConnected);
  262.     
  263.             return true;
  264.         } catch (TransportExceptionInterface $e) {
  265.             if ($pdfPath) {
  266.                 if (is_file($pdfPath)) {
  267.                     unlink($pdfPath);
  268.                 }
  269.             }
  270.             return false;
  271.         }
  272.     }
  274.     /**
  275.      * Méthode pour notifier les SUPERADMIN d'une demande de suppression de programme
  276.      */
  277.     public function alertDemandeSuppression(Programme $programme, Utilisateur $userConnected)
  278.     {
  279.         $entreprise = $programme->getEntreprise();
  281.         if (!$entreprise) {
  282.             return false;
  283.         }
  285.         $superAdmins = $this->utilisateurRepository->createQueryBuilder('u')
  286.             ->where('u.entreprise = :entreprise')
  287.             ->andWhere('u.roles LIKE :roleSuperAdmin')
  288.             ->setParameter('entreprise', $entreprise)
  289.             ->setParameter('roleSuperAdmin', '%ROLE_SUPERADMIN%')
  290.             ->getQuery()
  291.             ->getResult();
  293.         foreach ($superAdmins as $admin) {
  294.             $infoSuivi = new InfosSuivi();
  295.             $infoSuivi->setUtilisateur($admin);
  296.             $infoSuivi->setType('suppr');
  297.             $infoSuivi->setDescription('[user] a fait une [demande de suppression] pour le programme [programme].');
  298.             $infoSuivi->setDate(new \DateTime());
  299.             $infoSuivi->setLu(false);
  300.             $infoSuivi->setConnectedUser($userConnected);
  301.             $infoSuivi->setProgramme($programme);
  303.             $this->em->persist($infoSuivi);
  304.         }
  306.         $this->em->flush();
  308.         return true;
  309.     }
  311.     public function alertRapportATraiter(array $admins, array $prospects)
  312.     {
  313.         if (empty($admins)) {
  314.             return array(
  315.                 'success' => false,
  316.                 'errors' => array('Aucun admin éligible pour recevoir le rapport.')
  317.             );
  318.         }
  320.         // Construire le contenu du rapport
  321.         $lines = array();
  323.         if (empty($prospects)) {
  324.             $lines[] = "Aucun prospect A TRAITER cliqué aujourd'hui.";
  325.         } else {
  326.             $lines[] = "";
  328.             foreach ($prospects as $prospect) {
  329.                 /** @var \App\Entity\Prospect $prospect */
  330.                 $lines[] = sprintf(
  331.                     '- #%d %s %s (%s) - clic : %s',
  332.                     $prospect->getId(),
  333.                     $prospect->getEmprunteurNom(),
  334.                     $prospect->getEmprunteurPrenom(),
  335.                     $prospect->getEmprunteurEmail(),
  336.                     $prospect->getDateCliqueATraiter()
  337.                         ? $prospect->getDateCliqueATraiter()->format('d/m/Y H:i')
  338.                         : 'N/A'
  339.                 );
  340.             }
  341.         }
  343.         $lines[] = "";
  345.         $messageText = implode("\n", $lines);
  347.         // User connecté uniquement pour le reply-to (pas pour le SMTP)
  348.         $emailUser = null;
  349.         if ($this->container->has('security.token_storage')
  350.             && $this->container->get('security.token_storage')->getToken()
  351.         ) {
  352.             $user = $this->container->get('security.token_storage')->getToken()->getUser();
  353.             if ($user instanceof Utilisateur && $user->getEmail()) {
  354.                 $emailUser = $user->getEmail();
  355.             }
  356.         }
  358.         // Rendu du template Twig
  359.         /** @var \Twig\Environment $twig */
  360.         $twig = $this->container->get('twig');
  362.         $html = $twig->render('emails/rapport.html.twig', [
  363.             'prospect' => null,
  364.             'message'  => $messageText,
  365.         ]);
  367.         $success = false;
  368.         $errors  = array();
  370.         foreach ($admins as $admin) {
  371.             if (!method_exists($admin, 'getEmail') || !$admin->getEmail()) {
  372.                 $errors[] = 'Admin sans email valide.';
  373.                 continue;
  374.             }
  376.             $email = (new Email())
  377.                 ->from(new Address('mailer@zada.ai', 'LK1'))
  378.                 ->to($admin->getEmail())
  379.                 ->subject('Rapport quotidien - Prospects A TRAITER cliqués aujourd\'hui')
  380.                 ->html($html);
  382.             if ($emailUser) {
  383.                 $email->replyTo($emailUser);
  384.             }
  386.             // Utilise le transport par défaut "main"
  387.             $email->getHeaders()->addTextHeader('X-Transport', 'main');
  389.             try {
  390.                 $this->mailer->send($email);
  391.                 $success = true;
  392.             } catch (TransportExceptionInterface $e) {
  393.                 $errors[] = sprintf(
  394.                     'Erreur pour %s : %s',
  395.                     $admin->getEmail(),
  396.                     $e->getMessage()
  397.                 );
  398.             }
  399.         }
  401.         return array(
  402.             'success' => $success,
  403.             'errors'  => $errors,
  404.         );
  405.     }
  408.     private function addNotificationForAdmins(Prospect $prospect, ?Utilisateur $auteur, Utilisateur $userConnected)
  409.     {
  410.         $entreprise = $auteur ? $auteur->getEntreprise() : null;
  411.         $queryBuilder = $this->utilisateurRepository->createQueryBuilder('u');
  412.     
  413.         if ($entreprise) {
  414.             $queryBuilder->where('u.entreprise = :entreprise')
  415.                 ->setParameter('entreprise', $entreprise);
  416.         }
  417.     
  418.         $queryBuilder->andWhere(
  419.             $queryBuilder->expr()->orX(
  420.                 $queryBuilder->expr()->like('u.roles', ':rolesAdmin'),
  421.                 $queryBuilder->expr()->like('u.roles', ':rolesSuperAdmin')
  422.             )
  423.         )
  424.         ->setParameter('rolesAdmin', '%ROLE_ADMIN%')
  425.         ->setParameter('rolesSuperAdmin', '%ROLE_SUPERADMIN%');
  426.     
  427.         if (in_array('ROLE_COMMERCIAL', $auteur->getRoles())) {
  428.             $queryBuilder->orWhere('u.roles LIKE :rolesDirecteur')
  429.                 ->setParameter('rolesDirecteur', '%ROLE_DIRECTEUR%');
  430.         }
  432.         if (in_array('ROLE_PARTENAIRE', $auteur->getRoles())) {
  433.             $queryBuilder->orWhere('u.roles LIKE :rolesResponsable')
  434.                 ->setParameter('rolesResponsable', '%ROLE_RESPONSABLE%');
  435.         }
  437.         $admins = $queryBuilder->getQuery()->getResult();
  438.     
  439.         foreach ($admins as $admin) {
  440.             $infoSuivi = new InfosSuivi();
  441.             $infoSuivi->setUtilisateur($admin);
  442.             $infoSuivi->addProspect($prospect);
  443.             $infoSuivi->setType('client');
  444.             $infoSuivi->setDescription('Le client [prospect] a été attribué à [user] par [connectedUser]');
  445.             $infoSuivi->setDate(new \DateTime());
  446.             $infoSuivi->setLu(false);
  447.             $infoSuivi->setAuteur($auteur);
  448.             $infoSuivi->setConnectedUser($userConnected);
  449.     
  450.             $this->em->persist($infoSuivi);
  451.         }
  452.     
  453.         $this->em->flush();
  454.     }
  455. }