src/EventSubscriber/Expediting/ProofOfCollectionScheduler.php line 45

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Expediting\ShipmentType;
  6. use App\Doctrine\Type\Scheduler\TaskStatus;
  7. use App\Event\Expediting\ShipmentStatusUpdateEvent;
  8. use App\Event\Sales\SignedPocUploadEvent;
  9. use App\Repository\Scheduler\TaskRepository;
  10. use DateTime;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. readonly class ProofOfCollectionScheduler 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.             SignedPocUploadEvent::IDENTIFIER => ['process', 0],
  26.         ];
  27.     }
  29.     public function schedule(ShipmentStatusUpdateEvent $event): void
  30.     {
  31.         $segment = $event->getShippingSegment();
  32.         $shippingPlan = $segment->getShippingPlan();
  33.         $workOrder = $shippingPlan->getWorkOrder();
  34.         if (null === $workOrder || !in_array(ShipmentType::PICKUP, $segment->getTypes())) {
  35.             return;
  36.         }
  38.         $pocIssuanceTask = $this->taskRepository->getPocIssuanceTask($workOrder, createIfNull: true);
  39.         $signedPocUploadTask = $this->taskRepository->getSignedPocUploadTask($workOrder, createIfNull: true);
  40.         $this->entityManager->persist($pocIssuanceTask);
  41.         $this->entityManager->persist($signedPocUploadTask);
  42.         $this->entityManager->flush();
  43.     }
  45.     public function process(SignedPocUploadEvent $event): void
  46.     {
  47.         $workOrder = $event->getWorkOrder();
  49.         // Mark upload task as complete
  50.         $signedPocUploadTask = $this->taskRepository->getSignedPocUploadTask($workOrder);
  51.         $signedPocUploadTask->setStatus(TaskStatus::COMPLETED);
  52.         $signedPocUploadTask->setCompletedOn(new DateTime());
  53.         $this->entityManager->persist($signedPocUploadTask);
  55.         // Schedule uploaded file for email issuance
  56.         $signedPocIssuanceTask = $this->taskRepository->getSignedPocIssuanceTask($workOrder, createIfNull: true);
  57.         $this->entityManager->persist($signedPocIssuanceTask);
  59.         $this->entityManager->flush();
  60.     }
  61. }