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

  1. <?php
  3. namespace App\EventSubscriber\Finance\Quotation;
  5. use App\Doctrine\Type\Finance\PayableStatus;
  6. use App\Doctrine\Type\Scheduler\TaskStatus;
  7. use App\Entity\Finance\Quotation;
  8. use App\Event\Finance\QuotationCreationEvent;
  9. use App\Event\Finance\QuotationEditEvent;
  10. use App\Event\Finance\QuotationEventInterface;
  11. use App\EventSubscriber\TasksCancelerTrait;
  12. use App\Repository\Scheduler\TaskRepository;
  13. use DateTime;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. readonly class QuotationSchedulingSubscriber implements EventSubscriberInterface
  18. {
  19.     use TasksCancelerTrait;
  21.     public function __construct(
  22.         private EntityManagerInterface $entityManager,
  23.         private TaskRepository         $taskRepository,
  24.     ) {}
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             QuotationCreationEvent::IDENTIFIER => ['process', 0],
  30.             QuotationEditEvent::IDENTIFIER => ['process', 0],
  31.         ];
  32.     }
  34.     public function process(QuotationEventInterface $event): void
  35.     {
  36.         $quotation = $event->getQuotation();
  38.         // Handle scheduling and updating current quotation object
  39.         if ($quotation->isFilled()) {
  40.             if ($event instanceof QuotationEditEvent) {
  41.                 $pickupQuotationRequestTask = $this->taskRepository->getPickupQuotationRequestTask($quotation);
  42.                 $this->cancelTasks([$pickupQuotationRequestTask]);
  43.             }
  44.             $this->scheduleFilledQuotationTasks($quotation);
  45.         } else {
  46.             $this->scheduleQuotationDraftTasks($quotation);
  47.         }
  49.         // If a original form is attached, it is most certainly amended and all it's attached tasks should be canceled
  50.         if ($quotation->getOriginalForm() instanceof Quotation) {
  51.             $originalForm = $quotation->getOriginalForm();
  52.             $pickupQuotationRequestTask = $this->taskRepository->getPickupQuotationRequestTask($originalForm);
  53.             $pickupQuotationFillingTask = $this->taskRepository->getPickupQuotationFillingTask($originalForm);
  54.             $this->cancelTasks([$pickupQuotationRequestTask, $pickupQuotationFillingTask]);
  56.             $originalForm->setStatus(PayableStatus::AMENDED);
  57.             $this->entityManager->persist($originalForm);
  58.         }
  60.         $this->entityManager->flush();
  61.     }
  63.     private function scheduleFilledQuotationTasks(Quotation $quotation): void
  64.     {
  65.         $quotation->setStatus(PayableStatus::READY_FOR_REVIEW);
  66.         $quotationReviewTask = $this->taskRepository->getQuotationReviewTask($quotation, createIfNull: true);
  67.         $pickupQuotationFillingTask = $this->taskRepository->getPickupQuotationFillingTask($quotation, createIfNull: true);
  68.         $pickupQuotationFillingTask
  69.             ->setStatus(TaskStatus::COMPLETED)
  70.             ->setCompletedOn(new DateTime());
  72.         $this->entityManager->persist($pickupQuotationFillingTask);
  73.         $this->entityManager->persist($quotationReviewTask);
  74.     }
  76.     private function scheduleQuotationDraftTasks(Quotation $quotation): void
  77.     {
  78.         $quotation->setStatus(PayableStatus::DRAFTED);
  79.         $pickupQuotationRequestTask = $this->taskRepository->getPickupQuotationRequestTask($quotation, createIfNull: true);
  80.         $pickupQuotationFillingTask = $this->taskRepository->getPickupQuotationFillingTask($quotation, createIfNull: true);
  81.         $this->entityManager->persist($pickupQuotationRequestTask);
  82.         $this->entityManager->persist($pickupQuotationFillingTask);
  83.     }
  84. }