src/EventSubscriber/Purchasing/OrderDatasheetImportSchedulingSubscriber.php line 51

  1. <?php
  3. namespace App\EventSubscriber\Purchasing;
  5. use App\Event\Sales\WorkOrderCancelationEvent;
  6. use App\Event\Sales\WorkOrderCreationEvent;
  7. use App\Event\Sales\WorkOrderEventInterface;
  8. use App\Event\Sales\WorkOrderReopeningEvent;
  9. use App\EventSubscriber\TasksCancelerTrait;
  10. use App\Repository\Scheduler\TaskRepository;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. readonly class OrderDatasheetImportSchedulingSubscriber implements EventSubscriberInterface
  15. {
  16.     use TasksCancelerTrait;
  18.     public function __construct(
  19.         private EntityManagerInterface $entityManager,
  20.         private TaskRepository         $taskRepository,
  21.     ) {}
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             WorkOrderCreationEvent::IDENTIFIER => ['handleScheduling', 70],
  27.             WorkOrderReopeningEvent::IDENTIFIER => ['handleScheduling', 70],
  28.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancelation', 70],
  29.         ];
  30.     }
  32.     /** It is important to only execute this after work order is persisted and not after the purchase order is persisted */
  33.     public function handleScheduling(WorkOrderEventInterface $event): void
  34.     {
  35.         $workOrder = $event->getWorkOrder();
  37.         foreach ($workOrder->getFreights() as $freight) {
  38.             $order = $freight->getOrder();
  39.             $purchaseOrderDatasheetRequestTask = $this->taskRepository->getPurchaseOrderDatasheetRequestTask(order: $order, createIfNull: true);
  40.             $purchaseOrderDatasheetImportTask = $this->taskRepository->getPurchaseOrderDatasheetImportTask(order: $order, createIfNull: true);
  42.             $purchaseOrderDatasheetRequestTask->addWorkOrder($freight->getWorkOrder());
  43.             $purchaseOrderDatasheetImportTask->addWorkOrder($freight->getWorkOrder());
  45.             $this->entityManager->persist($purchaseOrderDatasheetRequestTask);
  46.             $this->entityManager->persist($purchaseOrderDatasheetImportTask);
  47.         }
  48.         $this->entityManager->flush();
  49.     }
  51.     public function handleCancelation(WorkOrderCancelationEvent $event): void
  52.     {
  53.         $workOrder = $event->getWorkOrder();
  55.         $tasks = [];
  56.         foreach ($workOrder->getFreights() as $freight) {
  57.             $tasks []= $this->taskRepository->getPurchaseOrderDatasheetRequestTask(order: $freight->getOrder());
  58.             $tasks []= $this->taskRepository->getPurchaseOrderDatasheetImportTask(order: $freight->getOrder());
  59.         }
  60.         $this->cancelTasks($tasks);
  61.         $this->entityManager->flush();
  62.     }
  63. }