src/EventSubscriber/EmployeeSubscriber.php line 66

  1. <?php
  4. namespace App\EventSubscriber;
  7. use App\Entity\Employee;
  8. use App\Entity\Invitation;
  9. use App\Entity\User;
  10. use App\Event\Employee\EmployeeCreatedEvent;
  11. use App\Event\Employee\EmployeeDeletedEvent;
  12. use App\Event\Employee\EmployeeUpdatedEvent;
  13. use App\Event\Employee\InvitationAcceptedEvent;
  14. use App\Event\Employee\InvitationRefusedEvent;
  15. use App\Kimia;
  16. use App\Repository\EmployeeRepository;
  17. use App\Service\InvitationService;
  18. use App\Service\NotificationService;
  19. use DateTimeImmutable;
  20. use Symfony\Bundle\SecurityBundle\Security;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. class EmployeeSubscriber implements EventSubscriberInterface
  24. {
  25.     public function __construct(
  26.         private readonly EmployeeRepository  $repository,
  27.         private readonly NotificationService $notificationService,
  28.         private readonly InvitationService   $invitationService,
  29.         private readonly Security $security
  30.     )
  31.     {
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             EmployeeCreatedEvent::class => 'onCreated',
  38.             EmployeeUpdatedEvent::class => 'onUpdated',
  39.             EmployeeDeletedEvent::class => 'onDeleted',
  40.             InvitationAcceptedEvent::class => 'onAccepted',
  41.             InvitationRefusedEvent::class => 'onRefused'
  42.         ];
  43.     }
  45.     public function onCreated(EmployeeCreatedEvent $event): void
  46.     {
  47.         $employee = $event->getEmployee();
  48.         $invitation = $this->invitationService->create(
  49.             $employee->getEmail(),
  50.             "Vous êtes invité à rejoindre l'établissement {$employee->getDepartment()->getEstablishment()->getName()} au département {$employee->getDepartment()->getName()}"
  51.         );
  52.         $employee->setInvitation($invitation);
  53.         $invitation->setEstablishment($employee->getDepartment()->getEstablishment());
  54.         $this->repository->save($employee, true);
  55.         $this->notificationService->notifyUser(
  56.             $employee->getDepartment()->getEstablishment()->getUser(),
  57.             'Invitation envoyé',
  58.             sprintf(
  59.                 "Vous venez d'ajouter l'employé <strong>%s</strong>",
  60.                 $employee->getName()
  61.             ),
  62.             $employee
  63.         );
  64.     }
  66.     public function onUpdated(EmployeeUpdatedEvent $event): void
  67.     {
  68.         $employee = $event->getEmployee();
  69.         $this->notificationService->notifyUser(
  70.             $employee->getDepartment()->getEstablishment()->getUser(),
  71.             'Employé modifié',
  72.             sprintf(
  73.                 "Vous venez de modifier l'employé <strong>%s</strong>",
  74.                 $employee->getName()
  75.             ),
  76.             $employee
  77.         );
  78.     }
  80.     public function onDeleted(EmployeeDeletedEvent $event): void
  81.     {
  82.         $employee = $event->getEmployee();
  83.         $establishment = $employee->getDepartment()->getEstablishment();
  85.         $title = 'Employé supprimé';
  86.         $message = sprintf(
  87.             "L'employé <strong>%s</strong> a été supprimé",
  88.             $employee->getName()
  89.         );
  90.         $this->notificationService->notifyUser(
  91.             $establishment->getUser(),
  92.             $title,
  93.             $message,
  94.             $employee
  95.         );
  96.         $this->notificationService->sendMail(to: $establishment->getEmail(), subject: $title, body: $message);
  97.     }
  99.     public function onAccepted(InvitationAcceptedEvent $event): void
  100.     {
  102.         /** @var User $user */
  103.         $user = $this->security->getUser();
  105.         $title = 'Invitation acceptée';
  106.         $invitation = $event->getInvitation();
  107.         $invitation->setStatus(Kimia::STATUS_ACCEPTED);
  108.         $employee = $this->repository->findOneBy(['invitation' => $invitation]);
  109.         ($employee)
  110.             ->setUser($user)
  111.             ->setStatus(Kimia::STATUS_ACCEPTED)
  112.             ->setIsActive(1)
  113.             ->setActivatedAt(new DateTimeImmutable());
  114.         $this->repository->save($employee, true);
  116.         $message = sprintf(
  117.             "L'employé <strong>%s</strong> a accepté l'invitation de votre établissement",
  118.             $employee->getName()
  119.         );
  120.         $this->notificationService->sendMail(to: $invitation->getEstablishment()->getEmail(), subject: $title, body: $message);
  121.     }
  123.     public function onRefused(InvitationRefusedEvent $event): void
  124.     {
  125.         $employee = $event->getEmployee();
  126.         $establishment = $employee->getDepartment()->getEstablishment();
  128.         $title = 'Invitation refusée';
  129.         $message = sprintf(
  130.             "L'employé <strong>%s</strong> a refusé l'invitation de votre établissement",
  131.             $employee->getName()
  132.         );
  134.         $invitation = $event->getInvitation();
  135.         $invitation->setStatus(Kimia::STATUS_DECLINED);
  136.         $employee = $this->repository->findOneBy(['invitation' => $invitation]);
  137.         $employee->setStatus(Kimia::STATUS_DECLINED);
  138.         $this->repository->save($employee, true);
  139.         $this->notificationService->sendMail(to: $establishment->getEmail(), subject: $title, body: $message);
  140.     }
  141. }