src/EventSubscriber/Finance/Quotation/QuotationDraftsGenerator.php line 46

  1. <?php
  3. namespace App\EventSubscriber\Finance\Quotation;
  5. use App\Doctrine\Type\Expediting\ShipmentType;
  6. use App\Doctrine\Type\Finance\PayableStatus;
  7. use App\Doctrine\Type\Scheduler\TaskStatus;
  8. use App\Entity\Expediting\ShippingPlan;
  9. use App\Entity\Expediting\ShippingSegment;
  10. use App\Entity\Finance\Quotation;
  11. use App\Entity\Sales\WorkOrder;
  12. use App\Event\Expediting\FreightDatasheetImportEvent;
  13. use App\Event\Expediting\ShippingPlanCreationEvent;
  14. use App\Event\Finance\QuotationCreationEvent;
  15. use App\Event\Sales\WorkOrderCancelationEvent;
  16. use App\Event\Sales\WorkOrderReopeningEvent;
  17. use App\EventSubscriber\TasksCancelerTrait;
  18. use App\Repository\Common\CompanyRepository;
  19. use App\Repository\Scheduler\TaskRepository;
  20. use Doctrine\Common\Collections\Collection;
  21. use Doctrine\ORM\EntityManagerInterface;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  25. readonly class QuotationDraftsGenerator implements EventSubscriberInterface
  26. {
  27.     use TasksCancelerTrait;
  29.     public function __construct(
  30.         private TaskRepository           $taskRepository,
  31.         private CompanyRepository        $companyRepository,
  32.         private EntityManagerInterface   $entityManager,
  33.         private EventDispatcherInterface $eventDispatcher,
  34.     ) {}
  36.     public static function getSubscribedEvents(): array
  37.     {
  38.         return [
  39.             ShippingPlanCreationEvent::IDENTIFIER => ['handleShippingPlan', 0],
  40.             FreightDatasheetImportEvent::IDENTIFIER => ['handleDatasheetImport', 0],
  41.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancellation', -100],
  42.             WorkOrderReopeningEvent::IDENTIFIER => ['handleReopening', 0],
  43.         ];
  44.     }
  46.     public function handleShippingPlan(ShippingPlanCreationEvent $event): void
  47.     {
  48.         $shippingPlan = $event->getShippingPlan();
  49.         $workOrder = $shippingPlan->getWorkOrder();
  50.         if (!$workOrder instanceof WorkOrder) {
  51.             return;
  52.         }
  54.         $freightDatasheetImportTask = $this->taskRepository->getFreightDatasheetImportTask($workOrder);
  55.         if (TaskStatus::COMPLETED === $freightDatasheetImportTask->getStatus()) {
  56.             $this->process($workOrder, $shippingPlan);
  57.         }
  58.     }
  60.     public function handleDatasheetImport(FreightDatasheetImportEvent $event): void
  61.     {
  62.         /** @var WorkOrder $workOrder */
  63.         $workOrder = $this->entityManager->getRepository(WorkOrder::class)->findOneBy([
  64.             'reference' => $event->getDatasheet()->workOrderReference,
  65.         ]);
  67.         $shipmentPlanningTask = $this->taskRepository->getShipmentPlanningTask($workOrder);
  68.         if (TaskStatus::COMPLETED === $shipmentPlanningTask->getStatus()) {
  69.             foreach ($workOrder->getShippingPlans() as $shippingPlan) {
  70.                 $this->process($workOrder, $shippingPlan);
  71.             }
  72.         }
  73.     }
  75.     public function handleCancellation(WorkOrderCancelationEvent $event): void
  76.     {
  77.         /** @var Collection<int, Quotation> $quotations */
  78.         $quotations = $this->entityManager->getRepository(Quotation::class)->findBy([
  79.             'shippingPlan' => $event->getWorkOrder()->getShippingPlans()->first(),
  80.         ]);
  82.         $pendingTasks = [];
  83.         foreach ($quotations as $quotation) {
  84.             if (PayableStatus::DRAFTED !== $quotation->getStatus()) {
  85.                 continue;
  86.             }
  88.             $pendingTasks []= $this->taskRepository->getPickupQuotationRequestTask($quotation);
  89.             $pendingTasks []= $this->taskRepository->getPickupQuotationFillingTask($quotation);
  90.         }
  91.         $this->cancelTasks($pendingTasks);
  92.         $this->entityManager->flush();
  93.     }
  95.     public function handleReopening(WorkOrderReopeningEvent $event): void
  96.     {
  97.         /** @var Collection<int, Quotation> $quotations */
  98.         $quotations = $this->entityManager->getRepository(Quotation::class)->findBy([
  99.             'shippingPlan' => $event->getWorkOrder()->getShippingPlans()->first(),
  100.         ]);
  102.         foreach ($quotations as $quotation) {
  103.             if (PayableStatus::DRAFTED !== $quotation->getStatus()) {
  104.                 continue;
  105.             }
  107.             $pickupQuotationRequestTask = $this->taskRepository->getPickupQuotationRequestTask($quotation, createIfNull: true);
  108.             $pickupQuotationFillingTask = $this->taskRepository->getPickupQuotationFillingTask($quotation, createIfNull: true);
  109.             $this->entityManager->persist($pickupQuotationRequestTask);
  110.             $this->entityManager->persist($pickupQuotationFillingTask);
  111.         }
  112.         $this->entityManager->flush();
  113.     }
  115.     private function process(WorkOrder $workOrder, ShippingPlan $shippingPlan): void
  116.     {
  117.         $types = [];
  118.         $firstSegment = $shippingPlan->getShippingSegments()->first();
  119.         foreach ($shippingPlan->getShippingSegments() as $segment) {
  120.             $types = array_merge($types, $segment->getTypes());
  121.         }
  123.         // No quotation on work orders that consists of an hub reception if goods are expected to be part of a consolidation
  124.         $isConsolidation = in_array(ShipmentType::AIR_CONSOLIDATION, $types) || in_array(ShipmentType::SEA_CONSOLIDATION, $types);
  125.         if ($isConsolidation && in_array(ShipmentType::HUB_RECEPTION, $firstSegment->getTypes())) {
  126.             return;
  127.         }
  129.         if ($isConsolidation) {
  130.             // For pickups that are expected to be consolidated, only seek quotation for pickup
  131.             $this->createDraft($workOrder, $shippingPlan, [$shippingPlan->getShippingSegments()->first()]);
  132.         } else {
  133.             // For direct shipments, seek quotation for the whole shipping plan
  134.             $this->createDraft($workOrder, $shippingPlan, $shippingPlan->getShippingSegments()->toArray());
  135.         }
  136.     }
  138.     /**
  139.      * @param WorkOrder $workOrder
  140.      * @param ShippingPlan $shippingPlan
  141.      * @param ShippingSegment[] $segments
  142.      * @return void
  143.      */
  144.     private function createDraft(WorkOrder $workOrder, ShippingPlan $shippingPlan, array $segments): void
  145.     {
  146.         $pickUpCountryCode = $segments[0]->getPlaceOfLoading()->getCountryCode();
  147.         $transportAgencies = $this->companyRepository->findTransportersByCountryCode($pickUpCountryCode);
  149.         $events = [];
  150.         foreach ($transportAgencies as $agency) {
  151.             $quotation = $this->entityManager->getRepository(Quotation::class)->findOneBy([
  152.                 'shippingPlan' => $shippingPlan,
  153.                 'payableTo' => $agency,
  154.             ]);
  156.             if ($quotation instanceof Quotation) {
  157.                 continue;
  158.             }
  160.             $quotation = (new Quotation())
  161.                 ->setShippingPlan($shippingPlan)
  162.                 ->setPayableBy($workOrder->getContract()->getTenant())
  163.                 ->setCreatedBy($shippingPlan->getCreatedBy())
  164.                 ->setPayableTo($agency);
  166.             $this->entityManager->persist($quotation);
  167.             $this->entityManager->flush();
  168.             $events []= new QuotationCreationEvent($quotation);
  169.         }
  171.         // Only dispatch events after flushing
  172.         foreach ($events as $event) {
  173.             $this->eventDispatcher->dispatch($event, $event::IDENTIFIER);
  174.         }
  175.     }
  176. }