src/EventSubscriber/JobIncompleteSubscriber.php line 46

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 Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpKernel\Event\ViewEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  16. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  18. use function array_multisort;
  19. use function current;
  20. use function in_array;
  22. final class JobIncompleteSubscriber implements EventSubscriberInterface
  23. {
  24.     /** @var string The relative path inside templates/messages without any extensions */
  25.     private const TEMPLATE = 'job/incomplete';
  27.     /** @var int The user ID of the admin user to notify */
  28.     private const ADMIN_TO_NOTIFY = 1;
  30.     public function __construct(
  31.         private readonly TokenStorageInterface $tokenStorage,
  32.         private readonly ManagerRegistry $managerRegistry,
  33.         private readonly Message $messageService,
  34.     )
  35.     {
  36.     }
  38.     #[ArrayShape([KernelEvents::VIEW => "array"])]
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             KernelEvents::VIEW => ['sendMessage', EventPriorities::POST_WRITE],
  43.         ];
  44.     }
  46.     public function sendMessage(ViewEvent $event): void
  47.     {
  48.         $job = $event->getControllerResult();
  49.         $method = $event->getRequest()->getMethod();
  51.         # PUT and PATCH methods are used to update instances, and we are only interested in updated jobs
  52.         if (!$job instanceof Job || !in_array($method, [Request::METHOD_PUT, Request::METHOD_PATCH])) {
  53.             return;
  54.         }
  56.         $previousData = $event->getRequest()->get('previous_data');
  58.         # If the status hasn't changed, we're not interested
  59.         if ($previousData->getStatus() === $job->getStatus()) {
  60.             return;
  61.         }
  63.         # If the status hasn't changed to "unable to complete", we're not interested
  64.         if ($job->getStatus() !== Job::JOB_STATUS_UNABLE_TO_COMPLETE) {
  65.             return;
  66.         }
  68.         // @todo find a better way of choosing which admin(s) to notify
  69.         $admin = $this->managerRegistry->getRepository(User::class)
  70.             ->find(self::ADMIN_TO_NOTIFY);
  72.         /** @var User $currentUser */
  73.         $currentUser = $this->tokenStorage->getToken()->getUser();
  75.         $schedule = $this->getLatestSchedule($job);
  77.         $message = $this->messageService
  78.             ->withRecipient($admin)
  79.             ->withSubject('A job was marked as incomplete')
  80.             ->withTemplate(self::TEMPLATE)
  81.             ->withTemplateData([
  82.                 'employeeName' => $currentUser->getFirstName(),
  83.                 'addressLine1' => $job->getPond()->getAddress1(),
  84.                 'customerName' => $job->getPond()->getCustomer()->getFirstName(),
  85.                 'fullAddress' => $job->getPond()->getAddress(),
  86.                 'reason' => $this->getReasonText($schedule),
  87.                 'notes' => $schedule->getNotes(),
  88.             ]);
  90.         if ($currentUser instanceof User) {
  91.             $message = $message->withCurrentUser($currentUser);
  92.         }
  94.         $message->send();
  95.     }
  97.     private function getLatestSchedule(Job $job): Schedule
  98.     {
  99.         /** @var iterable<int, Schedule> $schedules */
  100.         $schedules = $this->managerRegistry->getRepository(Schedule::class)
  101.             ->findBy(['job' => $job]);
  103.         $sort = [];
  104.         foreach ($schedules as $schedule) {
  105.             $sort[] = $schedule->getDate()->getTimestamp();
  106.         }
  108.         array_multisort($schedules, SORT_DESC, $sort);
  110.         return current($schedules);
  111.     }
  113.     private function getReasonText(Schedule $schedule): string|bool
  114.     {
  115.         return match($schedule->getIncompleteReason()) {
  116.             Schedule::INCOMPLETE_REASON_TIME => 'we ran out of time',
  117.             Schedule::INCOMPLETE_REASON_MATERIALS => 'we had an issue with materials',
  118.             Schedule::INCOMPLETE_REASON_NO_ACCESS => 'we had issues with accessing the pond',
  119.             default => false, // we will handle "other" in the template
  120.         };
  121.     }
  122. }