src/EventSubscriber/Expediting/ShippingPlanScheduler.php line 33

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Entity\Inventory\Warehouse;
  6. use App\Event\Sales\WorkOrderCancelationEvent;
  7. use App\Event\Sales\WorkOrderCreationEvent;
  8. use App\Event\Sales\WorkOrderEventInterface;
  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 ShippingPlanScheduler 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.             WorkOrderCreationEvent::IDENTIFIER => ['handleScheduling', 98],
  28.             WorkOrderReopeningEvent::IDENTIFIER => ['handleScheduling', 98],
  29.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancelation', 98],
  30.         ];
  31.     }
  33.     public function handleScheduling(WorkOrderEventInterface $event): void
  34.     {
  35.         $workOrder = $event->getWorkOrder();
  37.         $shipmentPlanningTask = $this->taskRepository->getShipmentPlanningTask(workOrder: $workOrder, createIfNull: true);
  38.         $this->entityManager->persist($shipmentPlanningTask);
  39.         if ($workOrder->getPlaceOfLoading() instanceof Warehouse) {
  40.             $hubReceptionTask = $this->taskRepository->getHubReceptionTask(workOrder: $workOrder, createIfNull: true);
  41.             $this->entityManager->persist($hubReceptionTask);
  42.         }
  43.         $this->entityManager->flush();
  44.     }
  46.     public function handleCancelation(WorkOrderEventInterface $event): void
  47.     {
  48.         $workOrder = $event->getWorkOrder();
  50.         $tasks = [$this->taskRepository->getShipmentPlanningTask(workOrder: $workOrder)];
  51.         if ($workOrder->getPlaceOfLoading() instanceof Warehouse) {
  52.             $tasks []= $this->taskRepository->getHubReceptionTask(workOrder: $workOrder);
  53.         }
  54.         $this->cancelTasks($tasks);
  55.         $this->entityManager->flush();
  56.     }
  57. }