src/EventSubscriber/Purchasing/OrderDatasheetImportCompletionSubscriber.php line 27

  1. <?php
  3. namespace App\EventSubscriber\Purchasing;
  5. use App\Doctrine\Type\Scheduler\TaskStatus;
  6. use App\Event\Purchasing\OrderDatasheetImportEvent;
  7. use App\Event\Purchasing\OrderEventInterface;
  8. use App\Repository\Scheduler\TaskRepository;
  9. use DateTime;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. readonly class OrderDatasheetImportCompletionSubscriber implements EventSubscriberInterface
  14. {
  15.     public function __construct(
  16.         private EntityManagerInterface $entityManager,
  17.         private TaskRepository         $taskRepository,
  18.     ) {}
  20.     public static function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             OrderDatasheetImportEvent::IDENTIFIER => 'process',
  24.         ];
  25.     }
  27.     public function process(OrderEventInterface $event): void
  28.     {
  29.         $order = $event->getOrder();
  31.         $purchaseOrderDatasheetImportTask = $this->taskRepository->getPurchaseOrderDatasheetImportTask(order: $order, createIfNull: true);
  32.         $purchaseOrderDatasheetImportTask->setStatus(TaskStatus::COMPLETED);
  33.         $purchaseOrderDatasheetImportTask->setCompletedOn(new DateTime());
  34.         $this->entityManager->persist($purchaseOrderDatasheetImportTask);
  35.         $this->entityManager->flush();
  36.     }
  37. }