src/EventSubscriber/Expediting/PackagesLabelsScheduler.php line 55

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Scheduler\TaskStatus;
  6. use App\Entity\Sales\WorkOrder;
  7. use App\Event\Expediting\FreightDatasheetImportEvent;
  8. use App\Event\Sales\WorkOrderCancelationEvent;
  9. use App\Event\Sales\WorkOrderReopeningEvent;
  10. use App\EventSubscriber\TasksCancelerTrait;
  11. use App\Repository\Scheduler\TaskRepository;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. readonly class PackagesLabelsScheduler implements EventSubscriberInterface
  16. {
  17.     use TasksCancelerTrait;
  19.     public function __construct(
  20.         private EntityManagerInterface $entityManager,
  21.         private TaskRepository         $taskRepository,
  22.     ) {}
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             FreightDatasheetImportEvent::IDENTIFIER => ['handleDatasheet', 0],
  28.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancelation', 0],
  29.             WorkOrderReopeningEvent::IDENTIFIER => ['handleReopening', 0],
  30.         ];
  31.     }
  33.     public function handleDatasheet(FreightDatasheetImportEvent $event): void
  34.     {
  35.         $datasheet = $event->getDatasheet();
  37.         /** @var WorkOrder $workOrder */
  38.         $workOrder = $this->entityManager->getRepository(WorkOrder::class)->findOneBy([
  39.             'reference' => $datasheet->workOrderReference,
  40.         ]);
  42.         $shippingLabelsIssuanceTask = $this->taskRepository->getShippingLabelsIssuanceTask($workOrder, createIfNull: true);
  43.         $this->entityManager->persist($shippingLabelsIssuanceTask);
  44.         $this->entityManager->flush();
  45.     }
  47.     public function handleCancelation(WorkOrderCancelationEvent $event): void
  48.     {
  49.         $workOrder = $event->getWorkOrder();
  50.         $shippingLabelsIssuanceTask = $this->taskRepository->getShippingLabelsIssuanceTask($workOrder);
  51.         $this->cancelTasks([$shippingLabelsIssuanceTask]);
  52.         $this->entityManager->flush();
  53.     }
  55.     public function handleReopening(WorkOrderReopeningEvent $event): void
  56.     {
  57.         $workOrder = $event->getWorkOrder();
  58.         $freightDatasheetImportTask = $this->taskRepository->getFreightDatasheetImportTask($workOrder);
  59.         if (TaskStatus::COMPLETED !== $freightDatasheetImportTask->getStatus()) {
  60.             return;
  61.         }
  63.         $shippingLabelsIssuanceTask = $this->taskRepository->getShippingLabelsIssuanceTask($workOrder, createIfNull: true);
  64.         $this->entityManager->persist($shippingLabelsIssuanceTask);
  65.         $this->entityManager->flush();
  66.     }
  67. }