src/EventSubscriber/MissionSubscriber.php line 251

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Mission;
  6. use App\Entity\SystemEmail;
  7. use App\Entity\User;
  8. use App\Enum\Role;
  9. use App\Enum\Trigger;
  10. use App\Event\Mission\ContactAddedEvent;
  11. use App\Event\Mission\MissionAcceptedEvent;
  12. use App\Event\Mission\MissionActivatedEvent;
  13. use App\Event\Mission\MissionArchivedEvent;
  14. use App\Event\Mission\MissionCancelledEvent;
  15. use App\Event\Mission\MissionDesiredDeliveryUpdatedAfterValidationEvent;
  16. use App\Event\Mission\MissionDesiredDeliveryUpdatedBeforeValidationEvent;
  17. use App\Event\Mission\MissionInitialTimeEvent;
  18. use App\Event\Mission\MissionRealTimeEvent;
  19. use App\Event\Mission\MissionRefusedEvent;
  20. use App\Event\Mission\MissionWithoutSubContractorCheckedEvent;
  21. use App\Event\Mission\MissionWithoutWorkflowEvent;
  22. use App\Repository\SystemEmailRepository;
  23. use App\Repository\UserRepository;
  24. use App\Service\NotificationService;
  25. use App\Service\TriggerService;
  26. use Symfony\Bridge\Twig\Mime\NotificationEmail;
  27. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  28. use Symfony\Component\Mailer\MailerInterface;
  29. use Symfony\Component\Mime\Address;
  30. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  31. use Symfony\Component\Routing\RouterInterface;
  32. use App\Event\Mission\MissionSendEvent;
  33. use App\Repository\MissionParticipantRepository;
  34. use App\Enum\AdminMail;
  35. use App\Enum\Manager;
  36. use App\Event\Admin\MissionNotificationActivatedEvent;
  37. use App\Event\Mission\MissionCanActivateEvent;
  38. use App\Event\Mission\MissionResendEvent;
  39. use App\Service\MissionService;
  40. use App\Service\StepsService;
  41. use App\Service\WorkflowStepService;
  42. use  App\Service\RelanceService;
  43. use Symfony\Component\Security\Core\Security;
  44. use App\Event\Mission\MissionClosedEvent;
  45. use Doctrine\ORM\EntityManagerInterface;
  46. use App\Service\DynamicHostService;
  48. class MissionSubscriber implements EventSubscriberInterface
  49. {
  50.     public function __construct(
  51.         private MailerInterface $mailer,
  52.         private UserRepository $userRepository,
  53.         private RouterInterface $router,
  54.         private TriggerService $triggerService,
  55.         private SystemEmailRepository $systemEmailRepository,
  56.         private NotificationService $notificationService,
  57.         private MissionParticipantRepository $missionParticipantRepository,
  58.         private Security $security,
  59.         private WorkflowStepService $workflowStepService,
  60.         private StepsService $stepsService,
  61.         private MissionService $missionService,
  62.         private RelanceService $relanceService,
  63.         private EntityManagerInterface $entityManagerInterface,
  64.         private DynamicHostService $dynamicHostService, 
  65.         
  67.     ){}
  69.     public static function getSubscribedEvents()
  70.     {
  71.         return [
  72.             MissionRefusedEvent::NAME => 'onMissionRefused',
  73.             MissionArchivedEvent::NAME => 'onMissionArchived',
  74.             MissionWithoutWorkflowEvent::NAME => 'onMissionWithoutWorkflow',
  75.             MissionCancelledEvent::NAME => 'onMissionCancelled',
  76.             MissionAcceptedEvent::NAME => 'onMissionAccepted',
  77.             MissionInitialTimeEvent::NAME => 'onMissionInitialTime',
  78.             MissionRealTimeEvent::NAME => 'onMissionRealTime',
  79.             MissionCanActivateEvent::NAME => 'onMissionCanActivateEvent',
  80.             ContactAddedEvent::NAME => 'onContactAdded',
  81.             MissionWithoutSubContractorCheckedEvent::NAME => 'onMissionWithoutSubContractorChecked',
  82.             MissionActivatedEvent::NAME => 'onMissionActivated',
  83.             MissionDesiredDeliveryUpdatedAfterValidationEvent::NAME => 'onMissionDesiredDeliveryUpdatedAfterValidation',
  84.             MissionDesiredDeliveryUpdatedBeforeValidationEvent::NAME => 'onMissionDesiredDeliveryUpdatedBeforeValidation',
  85.             MissionSendEvent::NAME => 'onMissionSend',
  86.             MissionResendEvent::NAME=>'onMissionResend',
  87.             MissionNotificationActivatedEvent::NAME=>'onMissionNotificationActivatedEvent',
  88.             MissionClosedEvent::NAME=>'onMissionClosedEvent'
  89.         ];
  90.     }
  91.     
  92.     public function onMissionClosedEvent(MissionClosedEvent $event){
  93.         $mission = $event->getMission();
  94.         $participant = $mission->getParticipants();
  95.         $listIdParticipant = [];
  96.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_FINISH]);
  97.         foreach ($mission->getParticipants() as $participant) {
  98.             if ($participant->getRole() === Role::ROLE_SUBCONTRACTOR 
  99.                 and !in_array($participant->getId(), $listIdParticipant) and $participant->getUser()->getSalary() != 1
  100.                ) {
  101.                 $user = $participant->getUser();
  102.                 $this->notificationService->create($email, $user, $user, null, $mission->getWorkflow()?->getActiveStep(), $mission->getCampaign(),null,false,false,null,null,$mission);
  103.                 $listIdParticipant[] = $participant->getId();
  104.             }
  105.         }
  107.     }
  109.     public function onMissionCanActivateEvent(MissionCanActivateEvent $missionCanActivateEvent){
  110.         $mission= $missionCanActivateEvent->getMission();
  111.         $marge= $missionCanActivateEvent->getMarge();
  112.         $refPanier = $mission->getReference();
  113.         $productName = $mission->getProduct()->getName();
  114.         $content = "Ce projet portant la référence $refPanier présente une marge ({$marge} %)insuffisante.
  115.          Nous vous invitons à modifier le panier ou à revoir la tarification des prestataires pour activer la mission (Produit: $productName )";
  116.         
  117.          $admins = $this->dynamicHostService->getMailAdmin();
  118.         $addressFrom = new Address("caroline.b@my-flow.fr@my-flow.fr", "Myflow");
  119.         foreach ($admins as $admin){
  120.             $addressTo = new Address($admin->value);
  121.             $this->notificationService->sendEmail($addressFrom,$addressTo, "Projet avec marge insuffisante",$content);
  122.         }
  123.     }
  124.     public function onMissionNotificationActivatedEvent(MissionNotificationActivatedEvent $missionNotificationActivatedEvent)
  125.     {   // We commented this code because in line 263 NOTIFICATION_APRES_ACTIVATION is send to a subcontractor (onMissionNotificationActivatedEvent)
  126.         // $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::NOTIFICATION_APRES_ACTIVATION]);
  127.         // foreach ($missionNotificationActivatedEvent->getMission()->getCampaign()->getCompany()->getUsers() as $user) {
  128.         //     if($user->isEnabled()){
  129.         //         $this->notificationService->create($email, $user, $user, $user->getCompany(),$missionNotificationActivatedEvent->getMission()->getWorkflow()?->getSteps()?->first());
  130.         //     }
  131.         // }
  132.     }
  133.     public function onMissionSend(MissionSendEvent $event){
  134.         $user = $event->getUser();
  135.         $mission = $event->getMission();
  136.         $company = $mission->getCampaign()->getCompany();
  137.         if (!$mission instanceof Mission) {
  138.             return;
  139.         }
  141.         if (!$user instanceof User) {
  142.             return;
  143.         }
  145.         // if ((gettype($event->getRole()) != 'string' && trim($event->getRole()) == 'ROLE_VALIDATOR') ||   $event->getRole() == 'ROLE_VALIDATOR'){
  146.         //     $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::AJOUT_VALIDATEUR]);
  147.         // }else{
  148.         //     $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::AJOUT_OBSERVATEUR]);
  149.         // }
  150.         // if (null !== $email) {
  151.         //     $this->notificationService->create($email, $user, $user, $company, $mission->getWorkflow()?->getActiveStep(), $mission->getCampaign());
  152.         // }
  153.     }
  155.     public function onMissionRefused(MissionRefusedEvent $event)
  156.     {
  157.         $mission = $event->getMission();
  159.         if (!$mission instanceof Mission) {
  160.             return;
  161.         }
  163.         $intervenant = $event->getIntervenant();
  165.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_REFUSEE_INTERVENANT]);
  167.         if (null !== $email) {
  168.             $this->notificationService->create($email, $intervenant, $intervenant, $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign(), null, false, false,null, null, $mission);
  169.         }
  171.          $admins = $this->dynamicHostService->getMailAdmin();
  172.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_REFUSEE_ADMIN]);
  174.         if (null !== $email) {
  175.             foreach ($admins as $admin) {
  176.                 $this->notificationService->create($email, $admin->value, $intervenant, $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign(), null, false, false,null, null, $mission);
  177.             }
  178.         }
  179.     }
  181.     public function onMissionArchived(MissionArchivedEvent $event)
  182.     {
  183.         $mission = $event->getMission();
  185.         if (!$mission instanceof Mission) {
  186.             return;
  187.         }
  188.         foreach ($mission->getWorkflow()->getSteps()->last()->getActions() as $action) {
  190.             foreach ($action->getTriggers() as $trigger) {
  191.                 if ($trigger->getTriggerType() === Trigger::MISSION_ARCHIVED) {
  192.                     
  193.                     $this->triggerService->execute($trigger);
  194.                 }
  195.             }
  196.         }
  198.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_ARCHIVED_CLIENT]);
  200.         if (null !== $email) {
  201.             $this->notificationService->create($email, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign());
  202.         }
  204.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_ARCHIVED_PRESTATAIRE]);
  206.         if (null !== $email) {
  207.             foreach ($mission->getParticipants() as $participant) {
  208.                 if ($participant->getRole() === Role::ROLE_SUBCONTRACTOR) {
  209.                     $this->notificationService->create($email, $participant->getUser(), $participant->getUser(), $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign());
  210.                 }
  211.             }
  212.         }
  214.          $admins = $this->dynamicHostService->getMailAdmin();
  215.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_ARCHIVED_ADMIN]);
  217.         if (null !== $email) {
  218.             foreach ($admins as $admin){
  219.                 $this->notificationService->create($email, $admin->value, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign());
  220.             }
  221.         }
  222.     }
  224.     public function onMissionWithoutWorkflow(MissionWithoutWorkflowEvent $event)
  225.     {
  226.         
  227.         $mission = $event->getMission();
  229.         if (!$mission instanceof Mission) {
  230.             return;
  231.         }
  233.          $admins = $this->dynamicHostService->getMailAdmin();
  235.         foreach ($admins as $admin) {
  236.             $notification = (new NotificationEmail())
  237.                 ->to(new Address($admin->value))
  238.                 ->subject('Une mission a été créée sans workflow')
  239.                 ->content('
  240.                 <p>Bonjour,</p>
  241.                 <p>La mission '. $mission->getReference() .' contient un produit "'.$mission->getProduct()->getName().'" qui n\'a pas de Workflow associé.</p>
  242.                 <p>Merci d\'en créer un pour ce produit et d\'aller le relier à la mission.</p>
  243.             ')
  244.                 ->action('Modifier la mission', $this->router->generate('handle_mission_campaign', ['id' => $mission->getCampaign()->getId()], UrlGeneratorInterface::ABSOLUTE_URL))
  245.                 ->markAsPublic()
  246.             ;
  247.             $this->mailer->send($notification);
  248.         }
  249.     }
  251.     public function onMissionDesiredDeliveryUpdatedAfterValidation(MissionDesiredDeliveryUpdatedAfterValidationEvent $event)
  252.     {
  253.         $mission = $event->getMission();
  254.         
  256.         if (!$mission instanceof Mission) {
  257.             return;
  258.         }
  260.         // $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_DESIRED_DELIVERY_UPDATED_AFTER_VALIDATION]);
  261.         // $emailParticipants = [];
  263.         // foreach ($mission->getParticipants() as $participant) {
  265.         //     $user= $participant->getUser();
  266.         //     $emailUser = $user->getEmail();
  268.         //     if(!in_array($emailUser, $emailParticipants) && ! $this->security->isGranted('ROLE_SUBCONTRACTOR')){
  270.         //         $this->notificationService->create($email, $user, $user, $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign());
  271.         //         $emailParticipants=[...$emailParticipants, $emailUser];
  273.         //     }
  274.         // }
  275.         
  276.         // if (null !== $email && [...$emailParticipants, $mission->getCampaign()->getOrderedBy()->getEmail()]) {
  277.         //     $this->notificationService->create($email, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign());
  278.         // }
  279.     }
  281.     public function onMissionDesiredDeliveryUpdatedBeforeValidation(MissionDesiredDeliveryUpdatedBeforeValidationEvent $event)
  282.     {
  283.         $mission = $event->getMission();
  285.         if (!$mission instanceof Mission) {
  286.             return;
  287.         }
  289.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_DESIRED_DELIVERY_UPDATED_BEFORE_VALIDATION]);
  291.         if (null !== $email) {
  292.             $this->notificationService->create($email, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign());
  293.         }
  294.     }
  296.     public function onMissionCancelled(MissionCancelledEvent $event)
  297.     {
  298.         $mission = $event->getMission();
  300.         if (!$mission instanceof Mission) {
  301.             return;
  302.         }
  304.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_CANCELLED]);
  306.         if (null !== $email) {
  307.             $this->notificationService->create($email, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(),null,null,null,false,false,null,null,$mission);
  308.             
  309.              $admins = $this->dynamicHostService->getMailAdmin();
  310.             foreach ($admins as $admin) {
  311.                 $this->notificationService->create($email, $admin->value, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(),null,null,null,false,false,null,null,$mission);
  312.             }
  313.         }
  314.     }
  316.     public function onMissionAccepted(MissionAcceptedEvent $event)
  317.     {
  318.         $mission = $event->getMission();
  320.         if (!$mission instanceof Mission) {
  321.             return;
  322.         }
  324.         $intervenant = $event->getIntervenant();
  326.         $emailClient = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::NOTIFICATION_APRES_ACTIVATION]);
  328.         if (null !== $emailClient) {
  329.             if(in_array("ROLE_SUBCONTRACTOR",$intervenant->getRoles())){
  330.                 $this->notificationService->create($emailClient, $intervenant, $intervenant, $mission->getCampaign()->getOrderedBy()->getCompany(),null,$mission->getCampaign());
  331.             }
  332.         }
  334.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_ACTIVER_CLIENT]);
  336.         if (null !== $email) {
  337.             $this->notificationService->create($email, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(),null,$mission->getCampaign());
  338.         }
  339.     }
  341.     public function onMissionInitialTime(MissionInitialTimeEvent $event)
  342.     {
  343.         $mission = $event->getMission();
  345.         if (!$mission instanceof Mission) {
  346.             return;
  347.         }
  348.          $admins = $this->dynamicHostService->getMailAdmin();
  350.         foreach ($admins as $admin) {
  351.             $notification = (new NotificationEmail())
  352.                 ->to(new Address($admin->value))
  353.                 ->subject('Un intervenant vient d\'ajouter le temps initial d\'une mission')
  354.                 ->content('
  355.                     <p>Bonjour,</p>
  356.                     <p>Le temps initial pour la mission '. $mission->getCampaign()->getName() .' vient d\'être ajouté</p>
  357.                 ')
  358.                 ->action('Voir la mission', $this->router->generate('mission_edit', ['id' => $mission->getId()], UrlGeneratorInterface::ABSOLUTE_URL))
  359.                 ->markAsPublic()
  360.             ;
  362.             try {
  363.                 $this->mailer->send($notification);
  364.             } catch (\Exception $e) { /* TODO: logger ou afficher une alerte que l'email n'a pas été envoyé */ }
  365.         }
  366.     }
  368.     public function onMissionRealTime(MissionRealTimeEvent $event)
  369.     {
  370.         $mission = $event->getMission();
  372.         if (!$mission instanceof Mission) {
  373.             return;
  374.         }
  376.         $emailSystem = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::RENSEIGNEZ_TEMPS_MISSION]);
  378.         if (null !== $emailSystem) {
  379.             foreach ($mission->getParticipants() as $participant) {
  380.                 if ($participant->getRole() === Role::ROLE_SUBCONTRACTOR) {
  381.                     $this->notificationService->create($emailSystem, $participant->getUser(), $participant->getUser(), $mission->getCampaign()->getOrderedBy()->getCompany(), null, $mission->getCampaign());
  382.                 }
  383.             }
  384.         }
  385.     }
  387.     public function onContactAdded(ContactAddedEvent $event)
  388.     {
  389.         $contact = $event->getContact();
  391.         if (!$contact instanceof User || !$contact->isEnabled()) {
  392.             return;
  393.         }
  394.         
  395.             if ($event->getParticipant()->getRole() == Role::ROLE_VALIDATOR){
  396.                 $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::AJOUT_VALIDATEUR]);
  397.             }else{
  398.                 $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::AJOUT_OBSERVATEUR]);
  399.             }
  401.             if (null !== $email) {
  402.                 $this->notificationService->create($email, $contact, $contact, $contact->getCompany(), false, $event->getMission()->getCampaign());
  403.             }
  405.             $contact->setAutorizationDateAt(new \DateTimeImmutable());
  406.             $this->entityManagerInterface->flush();
  407.     }
  409.     public function onMissionActivated(MissionActivatedEvent $event)
  410.     {
  411.         $mission = $event->getMission();
  412.         $client = $event->getClient();
  414.         if (!$mission instanceof Mission) {
  415.             return;
  416.         }
  418.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_ACTIVER_CLIENT]);
  420.         if (null !== $email) {
  421.             $this->notificationService->create($email, $client, $client, $client->getCompany(), $mission->getWorkflow()?->getSteps()?->first());
  422.         }
  423.     }
  425.     public function onMissionWithoutSubContractorChecked(MissionWithoutSubContractorCheckedEvent $event)
  426.     {
  427.         $mission = $event->getMission();
  429.         if (!$mission instanceof Mission) {
  430.             return;
  431.         }
  433.         $email = $this->systemEmailRepository->findOneBy(['code' => SystemEmail::MISSION_SANS_PARTENAIRE]);
  435.         if (null !== $email) {
  436.            /* $this->notificationService->create($email, 'admin@my-flow.fr', $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany());*/
  438.             if (null !== $email->getSmsContent()) {
  439.                  $admins = $this->dynamicHostService->getMailAdmin();
  441.                 foreach ($admins as $admin) {
  442.                     $this->notificationService->create($email, $admin->value, $mission->getCampaign()->getOrderedBy(), $mission->getCampaign()->getOrderedBy()->getCompany(), null, null, null, true);
  443.                 }
  444.             }
  445.         }
  446.     }
  447.     public function onMissionResend(MissionResendEvent $missionResendEvent){
  448.          $this->relanceService->sendMailForResponsableStep(mission: $missionResendEvent->getMission());
  449.     }
  450. }