src/EventSubscriber/Expediting/ExpeditablesReadinessWatcher.php line 58

  1. <?php
  3. namespace App\EventSubscriber\Expediting;
  5. use App\Doctrine\Type\Expediting\ExpeditableStatus;
  6. use App\Doctrine\Type\Sales\WorkOrderStatus;
  7. use App\Entity\Sales\WorkOrder;
  8. use App\Event\Expediting\FreightDatasheetImportEvent;
  9. use App\Event\Expediting\FreightDocumentUploadEvent;
  10. use App\Event\Sales\WorkOrderApprovalEvent;
  11. use App\Event\Sales\WorkOrderCancelationEvent;
  12. use App\Event\Sales\WorkOrderReopeningEvent;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  17. readonly class ExpeditablesReadinessWatcher implements EventSubscriberInterface
  18. {
  19.     use ExpeditablesStatusUpdaterTrait;
  20.     use FreightDocumentUploadCheckerTrait;
  22.     public function __construct(
  23.         private readonly EntityManagerInterface   $entityManager,
  24.         private readonly EventDispatcherInterface $eventDispatcher,
  25.     ) {}
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             FreightDatasheetImportEvent::IDENTIFIER => ['handleDatasheetImport', -10],
  31.             FreightDocumentUploadEvent::IDENTIFIER => ['handleDocumentUpload', -10],
  32.             WorkOrderApprovalEvent::IDENTIFIER => ['handleApproval', -10],
  33.             WorkOrderReopeningEvent::IDENTIFIER => ['handleReopening', -10],
  34.             WorkOrderCancelationEvent::IDENTIFIER => ['handleCancelation', -200],
  35.         ];
  36.     }
  38.     public function handleDatasheetImport(FreightDatasheetImportEvent $event): void
  39.     {
  40.         /** @var WorkOrder $workOrder */
  41.         $workOrder = $this->entityManager->getRepository(WorkOrder::class)->findOneBy([
  42.             'reference' => $event->getDatasheet()->workOrderReference,
  43.         ]);
  45.         $this->process($workOrder);
  46.     }
  48.     public function handleDocumentUpload(FreightDocumentUploadEvent $event): void
  49.     {
  50.         $this->process($event->getFreight()->getWorkOrder());
  51.     }
  53.     public function handleApproval(WorkOrderApprovalEvent $event): void
  54.     {
  55.         $this->process($event->getWorkOrder());
  56.     }
  58.     public function handleReopening(WorkOrderReopeningEvent $event): void
  59.     {
  60.         $this->process($event->getWorkOrder());
  61.     }
  63.     public function handleCancelation(WorkOrderCancelationEvent $event): void
  64.     {
  65.         $this->updateExpeditables(packages: $event->getWorkOrder()->getPackages(), status: ExpeditableStatus::CANCELED);
  66.     }
  68.     private function process(WorkOrder $workOrder): void
  69.     {
  70.         $hasAuthorization = $workOrder->getStatus() === WorkOrderStatus::APPROVED;
  72.         $hasDocuments = true;
  73.         foreach ($workOrder->getFreights() as $freight) {
  74.             if (!$this->freightHasExpeditingDocuments($freight)) {
  75.                 $hasDocuments = false;
  76.                 break;
  77.             }
  78.         }
  80.         if ($hasAuthorization && $hasDocuments) {
  81.             $this->updateExpeditables(packages: $workOrder->getPackages(), status: ExpeditableStatus::READY_FOR_PICKUP);
  82.         } elseif ($hasAuthorization) {
  83.             $this->updateExpeditables(packages: $workOrder->getPackages(), status: ExpeditableStatus::AWAITING_DOCUMENTS);
  84.         } elseif ($hasDocuments) {
  85.             $this->updateExpeditables(packages: $workOrder->getPackages(), status: ExpeditableStatus::AWAITING_AUTHORIZATION);
  86.         }
  87.     }
  88. }