src/EventSubscriber/OrderStatusPaymentSubscriber.php line 33

  1. <?php
  3. namespace App\EventSubscriber;
  5. use ApiPlatform\Symfony\EventListener\EventPriorities;
  6. use App\Document\Parameters\OrderStatus;
  7. use Doctrine\ODM\MongoDB\DocumentManager;
  8. use Doctrine\ODM\MongoDB\MongoDBException;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpKernel\Event\ViewEvent;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  14. class OrderStatusPaymentSubscriber implements EventSubscriberInterface
  15. {
  16.     public function __construct(private readonly DocumentManager $manager)
  17.     {
  18.     }
  20.     /**
  21.      * @return array<string, mixed>
  22.      */
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             KernelEvents::VIEW => ['setHasPaymentOrderStatus', EventPriorities::PRE_WRITE],
  27.         ];
  28.     }
  30.     /**
  31.      * @throws MongoDBException
  32.      */
  33.     public function setHasPaymentOrderStatus(ViewEvent $event): void
  34.     {
  35.         $orderStatus = $event->getControllerResult();
  36.         $method = $event->getRequest()->getMethod();
  38.         if (!$orderStatus instanceof OrderStatus || !in_array($method, [Request::METHOD_POST, Request::METHOD_PUT])) {
  39.             return;
  40.         }
  42.         $hasPayment = $orderStatus->isHasPayment();
  43.         if ($hasPayment) {
  44.             // Créer une requête pour mettre à jour les documents qui ne sont pas l'objet courant
  45.             $queryBuilder = $this->manager->createQueryBuilder(OrderStatus::class)
  46.                 ->updateMany()
  47.                 ->field('id')->notEqual($orderStatus->getId())
  48.                 ->field('hasPayment')->set(false);
  50.             // Exécuter la requête
  51.             $queryBuilder->getQuery()->execute();
  52.         }
  53.     }
  54. }