src/EventSubscriber/Expediting/DocumentationKitGenerator.php line 42

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Expediting\TransitType;
  6. use App\Dto\Expediting\DocumentationKitDatasheet;
  7. use App\Dto\Expediting\DocumentationKitDatasheetContainerInput;
  8. use App\Dto\Expediting\DocumentationKitDatasheetExpeditableInput;
  9. use App\Dto\Expediting\DocumentationKitDatasheetExpeditablePackagingInput;
  10. use App\Dto\Expediting\DocumentationKitDatasheetFreightInput;
  11. use App\Dto\Expediting\DocumentationKitDatasheetPackageInput;
  12. use App\Entity\Expediting\Document;
  13. use App\Entity\Expediting\DocumentationKit;
  14. use App\Entity\Expediting\Item;
  15. use App\Entity\Expediting\Part;
  16. use App\Entity\Expediting\Shipment;
  17. use App\Event\Expediting\DocumentationKitRequestEvent;
  18. use App\Event\Expediting\ShipmentEventInterface;
  19. use App\EventSubscriber\TasksCancelerTrait;
  20. use App\Repository\Scheduler\TaskRepository;
  21. use Doctrine\ORM\EntityManagerInterface;
  22. use Symfony\Bundle\SecurityBundle\Security;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. readonly class DocumentationKitGenerator implements EventSubscriberInterface
  26. {
  27.     use TasksCancelerTrait;
  29.     public function __construct(
  30.         private EntityManagerInterface $entityManager,
  31.         private TaskRepository         $taskRepository,
  32.         private Security               $security,
  33.     ) {}
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             DocumentationKitRequestEvent::IDENTIFIER => ['onDocumentationKitRequest', 0],
  39.         ];
  40.     }
  42.     public function onDocumentationKitRequest(ShipmentEventInterface $event): void
  43.     {
  44.         $shipment = $event->getShipment();
  45.         $documentationKit = (new DocumentationKit())
  46.             ->setData($this->getKitDatasheet($shipment))
  47.             ->setTransitType(TransitType::EXPORT)
  48.             ->setCreatedBy($this->security->getUser());
  49.         $shipment->addDocumentationKit($documentationKit);
  51.         $this->entityManager->persist($shipment);
  52.         $this->entityManager->flush();
  53.     }
  55.     private function getKitDatasheet(Shipment $shipment): DocumentationKitDatasheet
  56.     {
  57.         $datasheet = new DocumentationKitDatasheet();
  58.         if ($shipment->getDocumentationKit()?->getData() instanceof DocumentationKitDatasheet) {
  59.             $previousKit = $shipment->getDocumentationKit()->getData();
  60.             $datasheet->shipper = $previousKit->shipper;
  61.             $datasheet->shipperAddress = $previousKit->shipperAddress;
  62.             $datasheet->buyer = $previousKit->buyer;
  63.             $datasheet->buyerAddress = $previousKit->buyerAddress;
  64.             $datasheet->consignee = $previousKit->consignee;
  65.             $datasheet->consigneeAddress = $previousKit->consigneeAddress;
  66.             $datasheet->notifyParty = $previousKit->notifyParty;
  67.             $datasheet->notifyPartyAddress = $previousKit->notifyPartyAddress;
  68.             $datasheet->formMNumber = $previousKit->formMNumber;
  69.             $datasheet->baNumber = $previousKit->baNumber;
  71.         } else {
  72.             $datasheet->shipper = 'Acme Corp';
  73.             $datasheet->shipperAddress = '123 Acme Way';
  74.             $datasheet->buyer = 'Buyer Inc';
  75.             $datasheet->buyerAddress = '456 Buyer Blvd';
  76.             $datasheet->consignee = 'Consignee Ltd';
  77.             $datasheet->consigneeAddress = '789 Consignee Street';
  78.             $datasheet->notifyParty = 'Notify LLC';
  79.             $datasheet->notifyPartyAddress = '321 Notify Circle';
  80.             $datasheet->formMNumber = 'FM00123';
  81.             $datasheet->baNumber = 'BA00123';
  82.         }
  84.         $datasheet->freights = $this->getFreights($shipment);
  85.         $datasheet->containers = $this->getContainers($shipment);
  86.         $datasheet->packages = $this->getPackages($shipment);
  87.         $datasheet->items = $this->getItems($shipment);
  89.         return $datasheet;
  90.     }
  92.     /** @return DocumentationKitDatasheetFreightInput[] */
  93.     private function getFreights(Shipment $shipment): array
  94.     {
  95.         $freights = [];
  96.         foreach ($shipment->getWorkOrders() as $workOrder) {
  97.             foreach ($workOrder->getFreights() as $freight) {
  98.                 $itemsIds = [];
  99.                 foreach ($freight->getItems() as $item) {
  100.                     $itemsIds []= $item->getId();
  101.                 }
  103.                 $freights []= new DocumentationKitDatasheetFreightInput(
  104.                     id: $freight->getId(),
  105.                     workOrderReference: $workOrder->getReference(),
  106.                     orderNumber: $freight->getOrder()->getNumber(),
  107.                     supplier: $freight->getOrder()->getSupplier()->getName(),
  108.                     invoicesNumbers: $freight->getInvoicesNumbers(),
  109.                     itemsIds: $itemsIds,
  110.                 );
  111.             }
  112.         }
  114.         return $freights;
  115.     }
  117.     /** @return DocumentationKitDatasheetContainerInput[] */
  118.     private function getContainers(Shipment $shipment): array
  119.     {
  120.         $containers = [];
  121.         foreach ($shipment->getContainers() as $container) {
  122.             $containers []= new DocumentationKitDatasheetContainerInput(
  123.                 id: $container->getId(),
  124.                 sealNumber: $container->getsealNumber(),
  125.                 identificationNumber: $container->getidentificationNumber(),
  126.                 containerType: $container->getcontainerType(),
  127.                 containerSize: $container->getcontainerSize(),
  128.             );
  129.         }
  131.         return $containers;
  132.     }
  134.     /** @return DocumentationKitDatasheetPackageInput[] */
  135.     private function getPackages(Shipment $shipment): array
  136.     {
  137.         $packages = [];
  138.         foreach ($shipment->getPackages() as $package) {
  139.             $containerId = null;
  140.             foreach ($package->getContainers() as $container) {
  141.                 if ($container->getShipment() === $shipment) {
  142.                     $containerId = $container->getId();
  143.                     break;
  144.                 }
  145.             }
  147.             $ordersNumbers = [];
  148.             $workOrdersReferences = [];
  149.             foreach ($package->getItems() as $item) {
  150.                 if ($item instanceof Item) {
  151.                     $ordersNumbers []= $item->getOrder()->getNumber();
  152.                     $workOrdersReferences []= $item->getFreight()->getWorkOrder()->getReference();
  153.                 } elseif ($item instanceof Part) {
  154.                     $ordersNumbers []= $item->getItem()->getOrder()->getNumber();
  155.                     $ordersNumbers []= $item->getItem()->getFreight()->getWorkOrder()->getReference();
  156.                 } elseif ($item instanceof Document) {
  157.                     // TODO : Add documents !
  158.                 }
  159.             }
  161.             $packages []= new DocumentationKitDatasheetPackageInput(
  162.                 id: $package->getId(),
  163.                 containerId: $containerId,
  164.                 workOrdersReferences: $workOrdersReferences,
  165.                 ordersNumbers: $ordersNumbers,
  166.                 number: $package->getPackageNumber(),
  167.                 type: $package->getCasingType(),
  168.                 material: $package->getCasingMaterial(),
  169.                 width: $package->getWidth(),
  170.                 length: $package->getLength(),
  171.                 height: $package->getHeight(),
  172.                 weight: $package->getWeight(),
  173.             );
  174.         }
  176.         return $packages;
  177.     }
  179.     /** @return DocumentationKitDatasheetExpeditableInput[] */
  180.     private function getItems(Shipment $shipment): array
  181.     {
  182.         $map = [];
  183.         $packagesIds = [];
  184.         foreach ($shipment->getPackages() as $package) {
  185.             $packagesIds []= $package->getId();
  187.             foreach ($package->getItems() as $item) {
  188.                 if ($item instanceof Part) {
  189.                     $map[$item->getId()] = $item->getItem();
  190.                 } elseif ($item instanceof Item) {
  191.                     $map[$item->getId()] = $item;
  192.                 } else {
  193.                     // TODO : handle Document
  194.                 }
  195.             }
  196.         }
  198.         $items = [];
  199.         foreach ($map as $item) {
  200.             $packagings = [];
  202.             foreach ($item->getParts() as $part) {
  203.                 foreach ($part->getPackages() as $package) {
  204.                     if (!in_array($package->getId(), $packagesIds)) {
  205.                         continue;
  206.                     }
  208.                     $packagings []= new DocumentationKitDatasheetExpeditablePackagingInput(
  209.                         id: $package->getId(),
  210.                         quantity: 0,
  211.                         isPart: true,
  212.                     );
  213.                 }
  214.             }
  216.             foreach ($item->getPackages() as $package) {
  217.                 if (!in_array($package->getId(), $packagesIds)) {
  218.                     continue;
  219.                 }
  221.                 $packagings []= new DocumentationKitDatasheetExpeditablePackagingInput(
  222.                     id: $package->getId(),
  223.                     quantity: $item->getQuantity(),
  224.                     isPart: false,
  225.                 );
  226.             }
  228.             $items []= new DocumentationKitDatasheetExpeditableInput(
  229.                 id: $item->getId(),
  230.                 workOrderReference: $item->getFreight()->getWorkOrder()->getReference(),
  231.                 orderNumber: $item->getOrder()->getNumber(),
  232.                 number: $item->getLineItem()->getNumber(),
  233.                 materialNumber: $item->getLineItem()->getNumber(),
  234.                 description: $item->getLineItem()->getCustomerDescription() ?? $item->getLineItem()->getSupplierDescription(),
  235.                 quantity: $item->getQuantity(),
  236.                 unitPrice: $item->getLineItem()->getValue() / $item->getLineItem()->getQuantity(),
  237.                 countryOfOrigin: $item->getLineItem()->getCountryOfOrigin(),
  238.                 hsCode: $item->getLineItem()->getHsCode(),
  239.                 asset: $item->getLineItem()->getAsset()?->getName(),
  240.                 isDangerous: $item->isDangerous(),
  241.                 packagings: $packagings,
  242.             );
  243.         }
  245.         return $items;
  246.     }
  247. }