src/EventSubscriber/Expediting/ExpeditablesShippingStatusWatcher.php line 64

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Expediting\ExpeditableStatus;
  6. use App\Doctrine\Type\Expediting\ShipmentType;
  7. use App\Doctrine\Type\Expediting\ShippingSegmentStatus;
  8. use App\Entity\Expediting\ShippingSegment;
  9. use App\Event\Expediting\ShipmentCancelationEvent;
  10. use App\Event\Expediting\ShipmentReschedulingEvent;
  11. use App\Event\Expediting\ShipmentStatusUpdateEvent;
  12. use App\Event\Expediting\ShippingSegmentEventInterface;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  17. readonly class ExpeditablesShippingStatusWatcher implements EventSubscriberInterface
  18. {
  19.     use ExpeditablesStatusUpdaterTrait;
  21.     public function __construct(
  22.         private readonly EntityManagerInterface   $entityManager,
  23.         private readonly EventDispatcherInterface $eventDispatcher,
  24.     ) {}
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             ShipmentStatusUpdateEvent::IDENTIFIER => ['handleUpdate', 0],
  30.             ShipmentReschedulingEvent::IDENTIFIER => ['handleUpdate', 0],
  31.             ShipmentCancelationEvent::IDENTIFIER => ['handleCancelation', 0],
  32.         ];
  33.     }
  35.     public function handleUpdate(ShippingSegmentEventInterface $event): void
  36.     {
  37.         $shippingSegment = $event->getShippingSegment();
  39.         switch ($shippingSegment->getStatus()) {
  40.             case ShippingSegmentStatus::STARTED:
  41.                 $status = in_array(ShipmentType::PICKUP, $shippingSegment->getTypes())
  42.                     ? ExpeditableStatus::COLLECTED
  43.                     : ExpeditableStatus::DEPARTED;
  44.                 break;
  45.             case ShippingSegmentStatus::COMPLETED:
  46.                 $status = in_array(ShipmentType::PICKUP, $shippingSegment->getTypes())
  47.                     ? ExpeditableStatus::RECEIVED
  48.                     : ExpeditableStatus::ARRIVED;
  49.                 break;
  50.             case ShippingSegmentStatus::CANCELED:
  51.                 $this->eventDispatcher->dispatch(new ShipmentCancelationEvent($shippingSegment), ShipmentCancelationEvent::IDENTIFIER);
  52.                 return;
  53.             case ShippingSegmentStatus::PLANNED:
  54.             case ShippingSegmentStatus::APPROVED:
  55.             case ShippingSegmentStatus::BOOKED:
  56.                 return;
  57.         }
  59.         if ($status instanceof ExpeditableStatus) {
  60.             $this->process($shippingSegment, $status);
  61.         }
  62.     }
  64.     public function handleCancelation(ShipmentCancelationEvent $event): void
  65.     {
  66.         $shippingSegment = $event->getShippingSegment();
  67.         $status = in_array(ShipmentType::PICKUP, $shippingSegment->getTypes())
  68.             ? ExpeditableStatus::READY_FOR_PICKUP
  69.             : ExpeditableStatus::MARSHALLED;
  71.         $this->process($shippingSegment, $status);
  72.     }
  74.     private function process(ShippingSegment $shippingSegment, ExpeditableStatus $status): void
  75.     {
  76.         $shippingPlan = $shippingSegment->getShippingPlan();
  77.         if ($workOrder = $shippingPlan->getWorkOrder()) {
  78.             $this->updateExpeditables($workOrder->getPackages(), $status);
  79.         } elseif ($shipment = $shippingPlan->getShipment()) {
  80.             $this->updateExpeditables($shipment->getPackages(), $status);
  81.         }
  82.     }
  83. }