src/EventSubscriber/Sales/WorkOrderStatusWatcher.php line 70

  1. <?php
  3. namespace App\EventSubscriber\Sales;
  5. use App\Doctrine\Type\Identity\UserRole;
  6. use App\Doctrine\Type\Sales\WorkOrderStatus;
  7. use App\Doctrine\Type\Scheduler\TaskStatus;
  8. use App\Event\Sales\WorkOrderApprovalEvent;
  9. use App\Event\Sales\WorkOrderCancelationEvent;
  10. use App\Event\Sales\WorkOrderCreationEvent;
  11. use App\Event\Sales\WorkOrderEventInterface;
  12. use App\Event\Sales\WorkOrderReopeningEvent;
  13. use App\EventSubscriber\TasksCancelerTrait;
  14. use App\Repository\Scheduler\TaskRepository;
  15. use DateTime;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. readonly class WorkOrderStatusWatcher implements EventSubscriberInterface
  20. {
  21.     use TasksCancelerTrait;
  23.     public function __construct(
  24.         private EntityManagerInterface $entityManager,
  25.         private TaskRepository         $taskRepository,
  26.     ) {}
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             WorkOrderCreationEvent::IDENTIFIER => ['handleScheduling', 99],
  32.             WorkOrderReopeningEvent::IDENTIFIER => ['handleScheduling', 99],
  33.             WorkOrderApprovalEvent::IDENTIFIER => ['handleApproval', 99],
  34.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancelation', 99],
  35.         ];
  36.     }
  38.     public function handleScheduling(WorkOrderEventInterface $event): void
  39.     {
  40.         $workOrder = $event->getWorkOrder();
  41.         $workOrderReviewTask = $this->taskRepository->getWorkOrderReviewRequestTask(workOrder: $workOrder, createIfNull: true);
  42.         $issuerRoles = $workOrder->getCreatedBy()?->getRoles(asEnum: true) ?? [];
  44.         if (in_array(UserRole::ROLE_CLIENT, $issuerRoles) && in_array(UserRole::ROLE_WORK_ORDER_REVIEWER, $issuerRoles)) {
  45.             $workOrderReviewTask
  46.                 ->setStatus(TaskStatus::COMPLETED)
  47.                 ->setCompletedOn(new DateTime());
  49.             $workOrder->setStatus(WorkOrderStatus::APPROVED);
  50.             $this->entityManager->persist($workOrder);
  52.         } else {
  53.             $workOrderAuthorizationRequestTask = $this->taskRepository->getWorkOrderAuthorizationRequestTask(workOrder: $workOrder, createIfNull: true);
  54.             $this->entityManager->persist($workOrderAuthorizationRequestTask);
  55.         }
  57.         $this->entityManager->persist($workOrderReviewTask);
  58.         $this->entityManager->flush();
  59.     }
  61.     public function handleApproval(WorkOrderApprovalEvent $event): void
  62.     {
  63.         $workOrder = $event->getWorkOrder();
  64.         $workOrderReviewRequestTask = $this->taskRepository->getWorkOrderReviewRequestTask(workOrder: $workOrder);
  65.         $workOrderReviewRequestTask->setStatus(TaskStatus::COMPLETED);
  66.         $workOrderReviewRequestTask->setCompletedOn(new DateTime());
  67.         $this->entityManager->flush();
  68.     }
  70.     public function handleCancelation(WorkOrderCancelationEvent $event): void
  71.     {
  72.         $workOrder = $event->getWorkOrder();
  74.         $tasks = [
  75.             $this->taskRepository->getWorkOrderReviewRequestTask(workOrder: $workOrder),
  76.             $this->taskRepository->getWorkOrderAuthorizationRequestTask(workOrder: $workOrder),
  77.         ];
  78.         $this->cancelTasks($tasks);
  79.         $this->entityManager->flush();
  80.     }
  81. }