src/EventSubscriber/Expediting/ShipmentScheduler.php line 39

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Expediting\ShipmentType;
  6. use App\Doctrine\Type\Expediting\ShippingSegmentStatus;
  7. use App\Doctrine\Type\Expediting\TransportMode;
  8. use App\Entity\Expediting\ShippingSegment;
  9. use App\Entity\Scheduler\Task;
  10. use App\Event\Expediting\ShipmentBookingEvent;
  11. use App\Event\Expediting\ShipmentStatusUpdateEvent;
  12. use App\Repository\Scheduler\TaskRepository;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. readonly class ShipmentScheduler implements EventSubscriberInterface
  17. {
  18.     public function __construct(
  19.         private EntityManagerInterface $entityManager,
  20.         private TaskRepository         $taskRepository,
  21.     ) {}
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             ShipmentBookingEvent::IDENTIFIER => ['schedulePickup', 90],
  27.             ShipmentStatusUpdateEvent::IDENTIFIER => ['scheduleArrival', 90],
  28.         ];
  29.     }
  31.     public function schedulePickup(ShipmentBookingEvent $event): void
  32.     {
  33.         $segment = $event->getShippingSegment();
  34.         $departureTask = $this->getDepartureTask($segment);
  35.         $this->entityManager->persist($departureTask);
  36.         $this->entityManager->flush();
  37.     }
  39.     public function scheduleArrival(ShipmentStatusUpdateEvent $event): void
  40.     {
  41.         $segment = $event->getShippingSegment();
  42.         if (ShippingSegmentStatus::STARTED !== $segment->getStatus()) {
  43.             return;
  44.         }
  46.         $arrivalTask = $this->getArrivalTask($segment);
  47.         $this->entityManager->persist($arrivalTask);
  48.         $this->entityManager->flush();
  49.     }
  51.     private function getDepartureTask(ShippingSegment $segment): Task
  52.     {
  53.         if (in_array(ShipmentType::PICKUP, $segment->getTypes())) {
  54.             return $this->taskRepository->getPickupTask($segment, createIfNull: true);
  55.         }
  57.         return match ($segment->getTransportMode()) {
  58.             TransportMode::AIR => $this->taskRepository->getAirShipmentDepartureTask($segment, createIfNull: true),
  59.             TransportMode::ROAD => $this->taskRepository->getRoadShipmentDepartureTask($segment, createIfNull: true),
  60.             TransportMode::SEA => $this->taskRepository->getSeaShipmentDepartureTask($segment, createIfNull: true),
  61.             TransportMode::TRAIN => $this->taskRepository->getTrainShipmentDepartureTask($segment, createIfNull: true),
  62.         };
  63.     }
  65.     private function getArrivalTask(ShippingSegment $segment): Task
  66.     {
  67.         if (in_array(ShipmentType::HUB_DELIVERY, $segment->getTypes())) {
  68.             return $this->taskRepository->getHubDeliveryTask($segment, createIfNull: true);
  69.         }
  71.         return match ($segment->getTransportMode()) {
  72.             TransportMode::AIR => $this->taskRepository->getAirShipmentDeliveryTask($segment, createIfNull: true),
  73.             TransportMode::ROAD => $this->taskRepository->getRoadShipmentDeliveryTask($segment, createIfNull: true),
  74.             TransportMode::SEA => $this->taskRepository->getSeaShipmentDeliveryTask($segment, createIfNull: true),
  75.             TransportMode::TRAIN => $this->taskRepository->getTrainShipmentDeliveryTask($segment, createIfNull: true),
  76.         };
  77.     }
  78. }