src/EventSubscriber/Delete/PackagesImportSubscriber.php line 33

  1. <?php
  3. namespace App\EventSubscriber\Delete;
  5. use ApiPlatform\Validator\ValidatorInterface;
  6. use App\Entity\Sales\WorkOrder;
  7. use App\Event\Expediting\FreightDatasheetImportEvent;
  8. use App\Event\Purchasing\OrderDatasheetImportEvent;
  9. use App\Repository\Scheduler\TaskRepository;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpKernel\KernelInterface;
  14. readonly class PackagesImportSubscriber implements EventSubscriberInterface
  15. {
  16.     use BoxMoverTrait;
  18.     public function __construct(
  19.         private KernelInterface $kernel,
  20.         private EntityManagerInterface $entityManager,
  21.         private TaskRepository $taskRepository,
  22.         private ValidatorInterface $validator,
  23.     ) {}
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             FreightDatasheetImportEvent::IDENTIFIER => ['handleRFC', -100],
  29.             OrderDatasheetImportEvent::IDENTIFIER => ['handleBW', -100],
  30.         ];
  31.     }
  33.     public function handleRFC(FreightDatasheetImportEvent $event): void
  34.     {
  35.         $datasheet = $event->getDatasheet();
  37.         /** @var WorkOrder $workOrder */
  38.         $workOrder = $this->entityManager->getRepository(WorkOrder::class)->findOneBy([
  39.             'reference' => $datasheet->workOrderReference,
  40.         ]);
  43.         // If boxes are not attached to work order delete and recreate all - otherwise just update prices and descriptions
  44.         if ($this->deleteOldBoxes($workOrder)) {
  45.             $this->createBoxes($datasheet, $workOrder);
  46.         } else {
  47.             dd('here');
  48.         }
  49.     }
  51.     public function handleBW(OrderDatasheetImportEvent $event): void
  52.     {
  53.         $workOrders = [];
  54.         foreach ($event->getOrder()->getFreights() as $freight) {
  55.             $workOrder = $freight->getWorkOrder();
  56.             $workOrders[$workOrder->getId()] = $workOrder;
  57.         }
  59.         if (empty($workOrders)) {
  60.             return;
  61.         }
  63.         foreach ($workOrders as $workOrder) {
  64.             $this->updateBoxesByWorkOrder($workOrder);
  65.         }
  66.         $this->entityManager->flush();
  67.     }
  68. }