src/EventSubscriber/Inventory/ShipmentStatusWatcher.php line 38

  1. <?php
  3. namespace App\EventSubscriber\Inventory;
  5. use App\Doctrine\Type\Expediting\ShippingSegmentStatus;
  6. use App\Entity\Inventory\Warehouse;
  7. use App\Event\Expediting\ShipmentCancelationEvent;
  8. use App\Event\Expediting\ShipmentReschedulingEvent;
  9. use App\Event\Expediting\ShipmentStatusUpdateEvent;
  10. use App\Event\Expediting\ShippingSegmentEventInterface;
  11. use App\Event\Inventory\ShipmentStockEntryEvent;
  12. use App\Event\Inventory\ShipmentStockExitEvent;
  13. use App\Processor\Expediting\ShipmentStatusConsumerTrait;
  14. use App\Repository\Scheduler\TaskRepository;
  15. use DateTimeInterface;
  16. use DomainException;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  20. readonly class ShipmentStatusWatcher implements EventSubscriberInterface
  21. {
  22.     use ShipmentStatusConsumerTrait;
  24.     public function __construct(
  25.         private TaskRepository           $taskRepository,
  26.         private EventDispatcherInterface $eventDispatcher,
  27.     ) {}
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             ShipmentStatusUpdateEvent::IDENTIFIER => ['handleUpdate', 0],
  33.             ShipmentReschedulingEvent::IDENTIFIER => ['handleUpdate', -100],
  34.             ShipmentCancelationEvent::IDENTIFIER => ['handleCancelation', -100],
  35.         ];
  36.     }
  38.     public function handleUpdate(ShippingSegmentEventInterface $event): void
  39.     {
  40.         $shippingSegment = $event->getShippingSegment();
  42.         if (
  43.             $shippingSegment->getPlaceOfDischarge() instanceof Warehouse &&
  44.             ShippingSegmentStatus::COMPLETED === $shippingSegment->getStatus()
  45.         ) {
  46.             // If ShippingSegment status is completed and destination is a hub, we need to log packages stock entries
  47.             $completedOn = $this->getArrivalTask($shippingSegment)->getCompletedOn();
  48.             if (!$completedOn instanceof DateTimeInterface) {
  49.                 throw new DomainException('ShipmentStockEntryEvent fired without an completion date.');
  50.             }
  52.             $this->eventDispatcher->dispatch(new ShipmentStockEntryEvent($shippingSegment, $completedOn), ShipmentStockEntryEvent::IDENTIFIER);
  54.         } elseif (
  55.             $shippingSegment->getPlaceOfLoading() instanceof Warehouse &&
  56.             ShippingSegmentStatus::STARTED === $shippingSegment->getStatus()
  57.         ) {
  58.             // If ShippingSegment status is started and loading place is a hub, we need to log packages stock exists
  59.             $completedOn = $this->getDepartureTask($shippingSegment)->getCompletedOn();
  60.             if (!$completedOn instanceof DateTimeInterface) {
  61.                 throw new DomainException('ShipmentStockExitEvent fired without an completion date.');
  62.             }
  64.             $this->eventDispatcher->dispatch(new ShipmentStockExitEvent($shippingSegment, $completedOn), ShipmentStockExitEvent::IDENTIFIER);
  65.         }
  66.     }
  67. }