src/EventSubscriber/JobUnableToCompleteSubscriber.php line 42

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 in_array;
  21. final class JobUnableToCompleteSubscriber implements EventSubscriberInterface
  22. {
  23.     /** @var string The relative path inside templates/messages without any extensions */
  24.     private const TEMPLATE = 'job/unable-to-complete';
  26.     public function __construct(
  27.         private readonly TokenStorageInterface $tokenStorage,
  28.         private readonly Message $messageService,
  29.         private readonly ManagerRegistry $managerRegistry,
  30.     )
  31.     {
  32.     }
  34.     #[ArrayShape([KernelEvents::VIEW => "array"])]
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             KernelEvents::VIEW => ['sendMessage', EventPriorities::POST_WRITE],
  39.         ];
  40.     }
  42.     public function sendMessage(ViewEvent $event): void
  43.     {
  44.         $job = $event->getControllerResult();
  45.         $method = $event->getRequest()->getMethod();
  47.         # PUT and PATCH methods are used to update instances, and we are only interested in updated jobs
  48.         if (!$job instanceof Job || !in_array($method, [Request::METHOD_PUT, Request::METHOD_PATCH])) {
  49.             return;
  50.         }
  52.         $previousData = $event->getRequest()->get('previous_data');
  54.         # If the status hasn't changed, we're not interested
  55.         if ($previousData->getStatus() === $job->getStatus()) {
  56.             return;
  57.         }
  59.         # If the status hasn't changed to "unable to complete", we're not interested
  60.         if ($job->getStatus() !== Job::JOB_STATUS_UNABLE_TO_COMPLETE) {
  61.             return;
  62.         }
  64.         $customer = $job->getPond()->getCustomer();
  65.         $schedule = $this->getLatestSchedule($job);
  67.         $message = $this->messageService
  68.             ->withRecipient($customer)
  69.             ->withSubject('We were unable to complete your job')
  70.             ->withTemplate(self::TEMPLATE)
  71.             ->withTemplateData([
  72.                 'addressLine1' => $job->getPond()->getAddress1(),
  73.                 'firstName' => $customer->getFirstName() === 'ANNETTE' ? null : $customer->getFirstName(),
  74.                 'fullAddress' => $job->getPond()->getAddress(),
  75.                 'reason' => $this->getReasonText($schedule),
  76.                 'employeeName' => $schedule->getEmployee()->getUser()->getFirstName(),
  77.                 'notes' => $schedule->getNotes(),
  78.             ]);
  80.         $currentUser = $this->tokenStorage->getToken()->getUser();
  81.         if ($currentUser instanceof User) {
  82.             $message = $message->withCurrentUser($currentUser);
  83.         }
  85.         $message->send();
  86.     }
  88.     private function getLatestSchedule(Job $job): Schedule
  89.     {
  90.         /** @var iterable<int, Schedule> $schedules */
  91.         $schedules = $this->managerRegistry->getRepository(Schedule::class)
  92.             ->findBy(['job' => $job]);
  94.         $sort = [];
  95.         foreach ($schedules as $schedule) {
  96.             $sort[] = $schedule->getDate()->getTimestamp();
  97.         }
  99.         array_multisort($schedules, SORT_DESC, $sort);
  101.         return current($schedules);
  102.     }
  104.     private function getReasonText(Schedule $schedule): string|bool
  105.     {
  106.         return match($schedule->getIncompleteReason()) {
  107.             Schedule::INCOMPLETE_REASON_TIME => 'we ran out of time',
  108.             Schedule::INCOMPLETE_REASON_MATERIALS => 'we had an issue with materials',
  109.             Schedule::INCOMPLETE_REASON_NO_ACCESS => 'we had issues with accessing the pond',
  110.             default => false, // we will handle "other" in the template
  111.         };
  112.     }
  113. }