src/EventSubscriber/Inventory/ShipmentStockMovementSubscriber.php line 36

  1. <?php
  3. namespace App\EventSubscriber\Inventory;
  5. use App\Doctrine\Type\Inventory\MovementType;
  6. use App\Entity\Expediting\Package;
  7. use App\Entity\Inventory\PackageStockEntry;
  8. use App\Entity\Inventory\PackageStockExit;
  9. use App\Entity\Inventory\Warehouse;
  10. use App\Event\Inventory\ShipmentStockEntryEvent;
  11. use App\Event\Inventory\ShipmentStockEventInterface;
  12. use App\Event\Inventory\ShipmentStockExitEvent;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use DomainException;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. readonly class ShipmentStockMovementSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(
  20.         private EntityManagerInterface $entityManager,
  21.     ) {}
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             ShipmentStockEntryEvent::IDENTIFIER => ['handleEntry', 0],
  27.             ShipmentStockExitEvent::IDENTIFIER => ['handleExit', 0],
  28.         ];
  29.     }
  31.     public function handleEntry(ShipmentStockEventInterface $event): void
  32.     {
  33.         $this->processMovements($event, MovementType::ENTRY);
  34.     }
  36.     public function handleExit(ShipmentStockEventInterface $event): void
  37.     {
  38.         $this->processMovements($event, MovementType::EXIT);
  39.     }
  41.     private function processMovements(ShipmentStockEventInterface $event, MovementType $movementType): void
  42.     {
  43.         $shippingSegment = $event->getShippingSegment();
  44.         $warehouse = MovementType::ENTRY === $movementType
  45.             ? $shippingSegment->getPlaceOfDischarge()
  46.             : $shippingSegment->getPlaceOfLoading();
  48.         foreach ($shippingSegment->getShippingPlan()->getPackages() as $package) {
  49.             $entity = MovementType::ENTRY === $movementType
  50.                 ? new PackageStockEntry()
  51.                 : new PackageStockExit();
  53.             $entity
  54.                 ->setPackage($package)
  55.                 ->setWarehouse($warehouse)
  56.                 ->setShippingSegment($shippingSegment)
  57.                 ->setCompletedAt($event->getCompletedOn());
  59.              // Before persisting, we need to correctly associate all Exits with the corresponding Entries
  60.             if (MovementType::EXIT === $movementType) {
  61.                 $stockEntry = $this->getPackageStockEntry($package, $warehouse);
  62.                 $entity->setStockEntry($stockEntry);
  63.             }
  65.             $this->entityManager->persist($entity);
  66.         }
  68.         $this->entityManager->flush();
  69.     }
  71.     private function getPackageStockEntry(Package $package, Warehouse $warehouse): PackageStockEntry
  72.     {
  73.         foreach ($package->getMovements() as $movement) {
  74.             if (
  75.                 $movement instanceof PackageStockEntry &&
  76.                 $movement->getWarehouse() === $warehouse
  77.             ) {
  78.                 if ($movement->getStockExit() instanceof PackageStockExit) {
  79.                     throw new DomainException('Last stock entry is already associated with a stock exit.');
  80.                 }
  81.                 return $movement;
  82.             }
  83.         }
  85.         throw new DomainException('No stock entry found for stock exit.');
  86.     }
  87. }