src/EventSubscriber/Finance/Quotation/QuotationStatusSubscriber.php line 34

  1. <?php
  3. namespace App\EventSubscriber\Finance\Quotation;
  5. use App\Doctrine\Type\Expediting\ShippingPlanStatus;
  6. use App\Doctrine\Type\Expediting\ShippingSegmentStatus;
  7. use App\Doctrine\Type\Finance\PayableStatus;
  8. use App\Doctrine\Type\Scheduler\TaskStatus;
  9. use App\Entity\Finance\Quotation;
  10. use App\Entity\Scheduler\Task;
  11. use App\Event\Finance\QuotationStatusUpdateEvent;
  12. use App\EventSubscriber\TasksCancelerTrait;
  13. use App\Repository\Scheduler\TaskRepository;
  14. use DateTime;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. readonly class QuotationStatusSubscriber implements EventSubscriberInterface
  19. {
  20.     use TasksCancelerTrait;
  22.     public function __construct(
  23.         private EntityManagerInterface $entityManager,
  24.         private TaskRepository         $taskRepository,
  25.     ) {}
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             QuotationStatusUpdateEvent::IDENTIFIER => ['process', 0],
  31.         ];
  32.     }
  34.     public function process(QuotationStatusUpdateEvent $event): void
  35.     {
  36.         $quotation = $event->getQuotation();
  38.         if (PayableStatus::ACCEPTED === $quotation->getStatus()) {
  39.             $this->updateShippingPlan($quotation, status: ShippingPlanStatus::APPROVED);
  40.             $this->closeReviewTask($quotation);
  41.             $this->closeWorkAwardTask($quotation);
  42.             $this->closeRemainingQuotations($quotation);
  43.             $this->scheduleApprovalIssuance($quotation);
  44.         } elseif (PayableStatus::DECLINED === $quotation->getStatus()) {
  45.             $this->updateShippingPlan($quotation);
  46.             $this->closeReviewTask($quotation);
  47.             $this->cancelApprovalIssuance($quotation);
  48.         } else {
  49.             $this->updateShippingPlan($quotation);
  50.             $this->cancelApprovalIssuance($quotation);
  51.             $this->resetWorkAwardTask($quotation);
  52.             $this->resetQuotationReviewTask($quotation);
  53.             $this->rescheduleRemainingQuotations($quotation);
  54.         }
  55.         $this->entityManager->flush();
  56.     }
  58.     private function updateShippingPlan(Quotation $quotation, ?ShippingPlanStatus $status = ShippingPlanStatus::DRAFTED): void
  59.     {
  60.         $shippingPlan = $quotation->getShippingPlan()
  61.             ->setStatus($status);
  62.         $this->entityManager->persist($shippingPlan);
  64.         $segmentsStatus = ($status === ShippingPlanStatus::DRAFTED)
  65.             ? ShippingSegmentStatus::PLANNED
  66.             : ShippingSegmentStatus::APPROVED;
  67.         foreach ($shippingPlan->getShippingSegments() as $segment) {
  68.             $segment->setStatus($segmentsStatus);
  69.             $this->entityManager->persist($segment);
  70.         }
  71.     }
  73.     private function closeReviewTask(Quotation $quotation): void
  74.     {
  75.         $task = $this->taskRepository->getQuotationReviewTask($quotation, createIfNull: true);
  76.         $task->setStatus(TaskStatus::COMPLETED);
  77.         $task->setCompletedOn(new DateTime());
  78.         $this->entityManager->persist($task);
  79.     }
  81.     private function closeWorkAwardTask(Quotation $quotation): void
  82.     {
  83.         $task = $this->taskRepository->getWorkAwardTask($quotation->getShippingPlan(), createIfNull: true);
  84.         $task->setStatus(TaskStatus::COMPLETED);
  85.         $task->setCompletedOn(new DateTime());
  86.         $this->entityManager->persist($task);
  87.     }
  89.     private function closeRemainingQuotations(Quotation $currentQuotation): void
  90.     {
  91.         $quotations = $currentQuotation->getShippingPlan()->getQuotations();
  92.         foreach ($quotations as $quotation) {
  93.             if ($currentQuotation->getId() !== $quotation->getId() && PayableStatus::AMENDED !== $quotation->getStatus()) {
  94.                 $this->declineQuotation($quotation);
  95.             }
  96.         }
  97.     }
  99.     private function declineQuotation(Quotation $quotation): void
  100.     {
  101.         // First, Update quotation status
  102.         $quotation->setStatus(PayableStatus::QUOTED);
  103.         $this->entityManager->persist($quotation);
  105.         // Then, cancel pending attached tasks
  106.         $pickupQuotationRequestTask = $this->taskRepository->getPickupQuotationRequestTask($quotation);
  107.         $pickupQuotationFillingTask = $this->taskRepository->getPickupQuotationFillingTask($quotation);
  108.         $quotationReviewTask = $this->taskRepository->getQuotationReviewTask($quotation);
  109.         $this->cancelTasks([$pickupQuotationRequestTask, $pickupQuotationFillingTask, $quotationReviewTask]);
  110.     }
  112.     private function scheduleApprovalIssuance(Quotation $quotation): void
  113.     {
  114.         $quotationApprovalIssuanceTask = $this->taskRepository->getQuotationApprovalIssuanceTask($quotation, createIfNull: true);
  115.         $this->entityManager->persist($quotationApprovalIssuanceTask);
  116.     }
  118.     private function rescheduleRemainingQuotations(Quotation $currentQuotation): void
  119.     {
  120.         $quotations = $currentQuotation->getShippingPlan()->getQuotations();
  121.         foreach ($quotations as $quotation) {
  122.             if ($quotation->getId() !== $currentQuotation->getId()) {
  123.                 $this->rescheduleQuotations($quotation);
  124.             }
  125.         }
  126.     }
  128.     private function cancelApprovalIssuance(Quotation $quotation): void
  129.     {
  130.         $quotationApprovalIssuanceTask = $this->taskRepository->getQuotationApprovalIssuanceTask($quotation);
  131.         $this->cancelTasks([$quotationApprovalIssuanceTask]);
  132.     }
  134.     private function rescheduleQuotations(Quotation $quotation): void
  135.     {
  136.         // Only process quotations that were automatically declined by the system
  137.         if (PayableStatus::QUOTED !== $quotation->getStatus()) {
  138.             return;
  139.         }
  141.         // Only reschedule tasks that were canceled, cancel pending attached tasks
  142.         $pickupQuotationRequestTask = $this->taskRepository->getPickupQuotationRequestTask($quotation);
  143.         if (!$pickupQuotationRequestTask instanceof Task) {
  144.             $pickupQuotationRequestTask = $this->taskRepository->getPickupQuotationRequestTask($quotation, createIfNull: true);
  145.             $this->entityManager->persist($pickupQuotationRequestTask);
  146.         }
  147.         $pickupQuotationFillingTask = $this->taskRepository->getPickupQuotationFillingTask($quotation);
  148.         if (!$pickupQuotationFillingTask instanceof Task) {
  149.             $pickupQuotationFillingTask = $this->taskRepository->getPickupQuotationRequestTask($quotation, createIfNull: true);
  150.             $this->entityManager->persist($pickupQuotationFillingTask);
  151.         }
  152.         $quotationReviewTask = $this->taskRepository->getQuotationReviewTask($quotation);
  153.         if (!$quotationReviewTask instanceof Task) {
  154.             $quotationReviewTask = $this->taskRepository->getPickupQuotationRequestTask($quotation, createIfNull: true);
  155.             $this->entityManager->persist($quotationReviewTask);
  156.         }
  157.     }
  159.     private function resetWorkAwardTask(Quotation $quotation): void
  160.     {
  161.         $workOrder = $quotation->getShippingPlan()->getWorkOrder();
  162.         if (null === $workOrder) {
  163.             return;
  164.         }
  166.         $task = $this->taskRepository->getWorkAwardTask($quotation->getShippingPlan(), createIfNull: true);
  167.         $task->setStatus(TaskStatus::PLANNED);
  168.         $task->setCompletedOn(null);
  169.         $this->entityManager->persist($task);
  170.     }
  172.     private function resetQuotationReviewTask(Quotation $quotation): void
  173.     {
  174.         $task = $this->taskRepository->getQuotationReviewTask($quotation, createIfNull: true);
  175.         $task->setStatus(TaskStatus::PLANNED);
  176.         $task->setCompletedOn(null);
  177.         $this->entityManager->persist($task);
  178.     }
  179. }