src/EventSubscriber/Expediting/TransitDocumentUploadScheduler.php line 47

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Scheduler\TaskStatus;
  6. use App\Entity\Expediting\Shipment;
  7. use App\Event\Expediting\ShipmentStatusUpdateEvent;
  8. use App\Event\Sales\TransitDocumentUploadEvent;
  9. use App\Repository\Scheduler\TaskRepository;
  10. use DateTime;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. readonly class TransitDocumentUploadScheduler implements EventSubscriberInterface
  15. {
  16.     public function __construct(
  17.         private EntityManagerInterface $entityManager,
  18.         private TaskRepository $taskRepository,
  19.     ) {}
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             ShipmentStatusUpdateEvent::IDENTIFIER => ['schedule', 0],
  25.             TransitDocumentUploadEvent::IDENTIFIER => ['process', 0],
  26.         ];
  27.     }
  29.     public function schedule(ShipmentStatusUpdateEvent $event): void
  30.     {
  31.         $segment = $event->getShippingSegment();
  32.         $shippingPlan = $segment->getShippingPlan();
  33.         $shipment = $shippingPlan->getShipment();
  35.         // Todo : update this to detect when a transit document is required
  36.         if (!$shipment instanceof Shipment) {
  37.             return;
  38.         }
  40.         foreach ($shipment->getWorkOrders() as $workOrder) {
  41.             $transitDocumentUploadTask = $this->taskRepository->getTransitDocumentUploadTask($workOrder, createIfNull: true);
  42.             $this->entityManager->persist($transitDocumentUploadTask);
  43.         }
  44.         $this->entityManager->flush();
  45.     }
  47.     public function process(TransitDocumentUploadEvent $event): void
  48.     {
  49.         $workOrder = $event->getWorkOrder();
  51.         // Mark upload task as complete
  52.         $transitDocumentUploadTask = $this->taskRepository->getTransitDocumentUploadTask($workOrder, createIfNull: true);
  53.         $transitDocumentUploadTask->setStatus(TaskStatus::COMPLETED);
  54.         $transitDocumentUploadTask->setCompletedOn(new DateTime());
  55.         $this->entityManager->persist($transitDocumentUploadTask);
  56.         $this->entityManager->flush();
  57.     }
  58. }