src/EventSubscriber/Finance/Quotation/WorkAwardScheduler.php line 77

  1. <?php
  3. namespace App\EventSubscriber\Finance\Quotation;
  5. use App\Doctrine\Type\Scheduler\TaskStatus;
  6. use App\Doctrine\Type\Scheduler\TaskType;
  7. use App\Entity\Expediting\ShippingPlan;
  8. use App\Entity\Sales\WorkOrder;
  9. use App\Event\Expediting\FreightDatasheetImportEvent;
  10. use App\Event\Expediting\ShippingPlanCreationEvent;
  11. use App\Event\Sales\WorkOrderCancelationEvent;
  12. use App\Event\Sales\WorkOrderReopeningEvent;
  13. use App\EventSubscriber\TasksCancelerTrait;
  14. use App\Repository\Common\CompanyRepository;
  15. use App\Repository\Scheduler\TaskRepository;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  20. readonly class WorkAwardScheduler implements EventSubscriberInterface
  21. {
  22.     use TasksCancelerTrait;
  24.     public function __construct(
  25.         private TaskRepository           $taskRepository,
  26.         private CompanyRepository        $companyRepository,
  27.         private EntityManagerInterface   $entityManager,
  28.         private EventDispatcherInterface $eventDispatcher,
  29.     ) {}
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             ShippingPlanCreationEvent::IDENTIFIER => ['handleShippingPlan', 10],
  35.             FreightDatasheetImportEvent::IDENTIFIER => ['handleDatasheetImport', 10],
  36.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancelation', -90],
  37.             WorkOrderReopeningEvent::IDENTIFIER => ['handleReopening', 10],
  38.         ];
  39.     }
  41.     public function handleShippingPlan(ShippingPlanCreationEvent $event): void
  42.     {
  43.         $shippingPlan = $event->getShippingPlan();
  44.         $workOrder = $shippingPlan->getWorkOrder();
  45.         if (!$workOrder instanceof WorkOrder) {
  46.             return;
  47.         }
  49.         $freightDatasheetImportTask = $this->taskRepository->getFreightDatasheetImportTask($workOrder);
  50.         if (TaskStatus::COMPLETED === $freightDatasheetImportTask->getStatus()) {
  51.             $this->process($workOrder);
  52.         }
  53.     }
  55.     public function handleDatasheetImport(FreightDatasheetImportEvent $event): void
  56.     {
  57.         /** @var WorkOrder $workOrder */
  58.         $workOrder = $this->entityManager->getRepository(WorkOrder::class)->findOneBy([
  59.             'reference' => $event->getDatasheet()->workOrderReference,
  60.         ]);
  62.         $shipmentPlanningTask = $this->taskRepository->getShipmentPlanningTask($workOrder);
  63.         if (TaskStatus::COMPLETED === $shipmentPlanningTask->getStatus()) {
  64.             $this->process($workOrder);
  65.         }
  66.     }
  68.     private function process(WorkOrder $workOrder): void
  69.     {
  70.         // By now, we know for sure a shipping plan was created
  71.         $shippingPlan = $workOrder->getShippingPlans()->last();
  72.         $workAwardTask = $this->taskRepository->getWorkAwardTask($shippingPlan, createIfNull: true);
  73.         $this->entityManager->persist($workAwardTask);
  74.         $this->entityManager->flush();
  75.     }
  77.     public function handleCancelation(WorkOrderCancelationEvent $event): void
  78.     {
  79.         $shippingPlan = $event->getWorkOrder()->getShippingPlans()?->last();
  80.         if (!$shippingPlan instanceof ShippingPlan) {
  81.             return;
  82.         }
  84.         $workAwardTask = $this->taskRepository->getWorkAwardTask($shippingPlan);
  85.         $this->cancelTasks([$workAwardTask]);
  86.         $this->entityManager->flush();
  87.     }
  89.     public function handleReopening(WorkOrderReopeningEvent $event): void
  90.     {
  91.         $shippingPlan = $event->getWorkOrder()->getShippingPlans()?->last();
  92.         if (!$shippingPlan instanceof ShippingPlan) {
  93.             return;
  94.         }
  96.         $canceledWorkAwardTask = $this->taskRepository->findOneBy([
  97.             'entity' => WorkOrder::class,
  98.             'entityId' => $event->getWorkOrder()->getId(),
  99.             'type' => TaskType::TRANSPORT_AGENT_SELECTION,
  100.             'status' => TaskStatus::CANCELED,
  101.         ]);
  102.         if (null === $canceledWorkAwardTask) {
  103.             return;
  104.         }
  106.         // No need to check if any planned or completed tasks exists as they are kept untouched in that case
  107.         $workAwardTask = $this->taskRepository->getWorkAwardTask($shippingPlan, createIfNull: true);
  108.         $this->entityManager->persist($workAwardTask);
  109.         $this->entityManager->flush();
  110.     }
  111. }