src/EventSubscriber/ScheduleCompleteSubscriber.php line 45

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Symfony\EventListener\EventPriorities;
  6. use App\Entity\Job;
  7. use App\Entity\Schedule;
  8. use App\Entity\User;
  9. use App\Service\Message;
  10. use Doctrine\Persistence\ManagerRegistry;
  11. use JetBrains\PhpStorm\ArrayShape;
  12. use Monolog\DateTimeImmutable;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpKernel\Event\ViewEvent;
  16. use Symfony\Component\HttpKernel\KernelEvents;
  17. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  19. use function in_array;
  21. final class ScheduleCompleteSubscriber implements EventSubscriberInterface
  22. {
  23.     /** @var string The relative path inside templates/messages without any extensions */
  24.     private const TEMPLATE = 'schedule/complete';
  26.     /** @var int The user ID of the admin user to notify */
  27.     private const ADMIN_TO_NOTIFY = 1;
  29.     public function __construct(
  30.         private readonly TokenStorageInterface $tokenStorage,
  31.         private readonly ManagerRegistry $managerRegistry,
  32.         private readonly Message $messageService,
  33.     )
  34.     {
  35.     }
  37.     #[ArrayShape([KernelEvents::VIEW => "array"])]
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             KernelEvents::VIEW => ['sendMessage', EventPriorities::POST_WRITE],
  42.         ];
  43.     }
  45.     public function sendMessage(ViewEvent $event): void
  46.     {
  47.         $job = $event->getControllerResult();
  48.         $method = $event->getRequest()->getMethod();
  50.         # PUT and PATCH methods are used to update instances, and we are only interested in updated jobs
  51.         if (!$job instanceof Job || !in_array($method, [Request::METHOD_PUT, Request::METHOD_PATCH])) {
  52.             return;
  53.         }
  55.         $previousData = $event->getRequest()->get('previous_data');
  57.         # If the status hasn't changed, we're not interested
  58.         if ($previousData->getStatus() === $job->getStatus()) {
  59.             return;
  60.         }
  62.         # If the status hasn't changed to "complete", we're not interested
  63.         if ($job->getStatus() !== Job::JOB_STATUS_COMPLETE) {
  64.             return;
  65.         }
  67.         /** @var User $currentUser */
  68.         $currentUser = $this->tokenStorage->getToken()->getUser();
  70.         /** @var iterable<Schedule> $schedules */
  71.         $schedules = $this->managerRegistry->getRepository(Schedule::class)
  72.             ->findBy([
  73.                 'employee' => $currentUser->getEmployee(),
  74.                 'date' => new DateTimeImmutable('today'),
  75.             ]);
  77.         $completed = 0;
  78.         $total = 0;
  79.         foreach ($schedules as $schedule) {
  80.             $total++;
  81.             if ($schedule->getJob()->getStatus() === Job::JOB_STATUS_COMPLETE) {
  82.                 $completed++;
  83.             }
  84.         }
  86.         # If the employee has not completed all of the jobs today, we're not interested
  87.         if ($completed !== $total) {
  88.             return;
  89.         }
  91.         // @todo find a better way of choosing which admin(s) to notify
  92.         $admin = $this->managerRegistry->getRepository(User::class)
  93.             ->find(self::ADMIN_TO_NOTIFY);
  95.         $message = $this->messageService
  96.             ->withRecipient($admin)
  97.             ->withSubject(sprintf('%s has completed today\'s jobs.', $currentUser->getFirstName()))
  98.             ->withTemplate(self::TEMPLATE)
  99.             ->withTemplateData([
  100.                 'employeeName' => $currentUser->getFirstName(),
  101.             ]);
  103.         if ($currentUser instanceof User) {
  104.             $message = $message->withCurrentUser($currentUser);
  105.         }
  107.         $message->send();
  108.     }
  109. }