src/EventSubscriber/Expediting/ExpeditablesLabelsScheduler.php line 53

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Expediting\ExpeditingStatus;
  6. use App\Doctrine\Type\Scheduler\TaskStatus;
  7. use App\Entity\Sales\WorkOrder;
  8. use App\Event\Purchasing\OrderDatasheetImportEvent;
  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 Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. readonly class ExpeditablesLabelsScheduler implements EventSubscriberInterface
  19. {
  20.     use TasksCancelerTrait;
  22.     public function __construct(
  23.         private EntityManagerInterface $entityManager,
  24.         private TaskRepository         $taskRepository,
  25.     ) {}
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             WorkOrderCreationEvent::IDENTIFIER => ['handleScheduling', 0],
  31.             WorkOrderReopeningEvent::IDENTIFIER => ['handleScheduling', 0],
  32.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancelation', 0],
  33.             OrderDatasheetImportEvent::IDENTIFIER => ['handleOrdersDatasheet', 0],
  34.         ];
  35.     }
  37.     public function handleScheduling(WorkOrderEventInterface $event): void
  38.     {
  39.         $workOrder = $event->getWorkOrder();
  40.         foreach ($workOrder->getFreights() as $freight) {
  41.             $purchaseOrderDatasheetImportTask = $this->taskRepository->getPurchaseOrderDatasheetImportTask(order: $freight->getOrder());
  43.             if (TaskStatus::COMPLETED !== $purchaseOrderDatasheetImportTask?->getStatus()) {
  44.                 return;
  45.             }
  46.         }
  48.         // Only scheduling labels issuance if all datasheets are imported
  49.         $this->scheduleStickers($workOrder);
  50.         $this->entityManager->flush();
  51.     }
  53.     public function handleCancelation(WorkOrderCancelationEvent $event): void
  54.     {
  55.         $expeditablesLabelsIssuanceTask = $this->taskRepository->getExpeditablesLabelsIssuanceTask(workOrder: $event->getWorkOrder());
  56.         $this->cancelTasks([$expeditablesLabelsIssuanceTask]);
  57.         $this->entityManager->flush();
  58.     }
  60.     public function handleOrdersDatasheet(OrderDatasheetImportEvent $event): void
  61.     {
  62.         $order = $event->getOrder();
  64.         foreach ($order->getFreights() as $freight) {
  65.             $this->scheduleStickers($freight->getWorkOrder());
  66.         }
  68.         $this->entityManager->flush();
  69.     }
  71.     public function scheduleStickers(WorkOrder $workOrder): void
  72.     {
  73.         foreach ($workOrder->getItems() as $item) {
  74.             if (!in_array($item->getStatus(), [ExpeditingStatus::PLANNED, ExpeditingStatus::READY, ExpeditingStatus::AUTHORIZED, ExpeditingStatus::BOOKED])) {
  75.                 return;
  76.             }
  77.         }
  79.         // Only schedule issuance if items ware not collected or already received at facility
  80.         $expeditablesLabelsIssuanceTask = $this->taskRepository->getExpeditablesLabelsIssuanceTask(workOrder: $workOrder, createIfNull: true);
  81.         $this->entityManager->persist($expeditablesLabelsIssuanceTask);
  82.     }
  83. }