src/EventSubscriber/Expediting/BookingScheduler.php line 50

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Finance\PayableStatus;
  6. use App\Doctrine\Type\Scheduler\TaskStatus;
  7. use App\Event\Expediting\ShipmentBookingEvent;
  8. use App\Event\Finance\QuotationStatusUpdateEvent;
  9. use App\EventSubscriber\TasksCancelerTrait;
  10. use App\Repository\Scheduler\TaskRepository;
  11. use DateTime;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. readonly class BookingScheduler implements EventSubscriberInterface
  16. {
  17.     use TasksCancelerTrait;
  19.     public function __construct(
  20.         private EntityManagerInterface $entityManager,
  21.         private TaskRepository         $taskRepository,
  22.     ) {}
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             QuotationStatusUpdateEvent::IDENTIFIER => ['schedule', 0],
  28.             ShipmentBookingEvent::IDENTIFIER => ['close', 100],
  29.         ];
  30.     }
  32.     public function schedule(QuotationStatusUpdateEvent $event): void
  33.     {
  34.         $quotation = $event->getQuotation();
  35.         $currentSegment = $quotation->getShippingPlan()->getCurrentSegment();
  36.         if (null === $currentSegment) {
  37.             return;
  38.         }
  40.         if (PayableStatus::ACCEPTED === $quotation->getStatus()) {
  41.             $bookingTask = $this->taskRepository->getBookingTask($currentSegment, createIfNull: true);
  42.             $this->entityManager->persist($bookingTask);
  43.         } else {
  44.             $bookingTask = $this->taskRepository->getBookingTask($currentSegment);
  45.             $this->cancelTasks([$bookingTask]);
  46.         }
  47.         $this->entityManager->flush();
  48.     }
  50.     public function close(ShipmentBookingEvent $event): void
  51.     {
  52.         $segment = $event->getShippingSegment();
  53.         $bookingTask = $this->taskRepository->getBookingTask($segment, createIfNull: true);
  54.         $bookingTask->setStatus(TaskStatus::COMPLETED);
  55.         $bookingTask->setCompletedOn(new DateTime());
  56.         $this->entityManager->persist($bookingTask);
  57.         $this->entityManager->flush();
  58.     }
  59. }