src/EventSubscriber/OrderPaymentEventSubscriber.php line 40

Open in your IDE?
  1. <?php
  2.     namespace App\EventSubscriber;
  4.     /* 
  5.     bin/stripe listen --forward-to localhost:4242/cultureroute/public/stripe/webhook
  6.     */
  7.     use App\Event\OrderPaymentEvent;
  8.     use App\Event\OrderEvent;
  9.     use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11.     use Psr\Log\LoggerInterface;
  13.     use App\Entity\ShopPanier;
  14.     use App\Entity\ShopOrder;
  15.     use App\Entity\ShopOrderProduct;
  16.     use App\Entity\User;
  18.     use Doctrine\ORM\EntityManagerInterface;
  20.     class OrderPaymentEventSubscriber implements EventSubscriberInterface
  21.     {
  22.         private $entityManager;
  23.         private $logger;
  24.         public function __construct(LoggerInterface $lifecycleLogger, EntityManagerInterface $entityManager, OrderEventSubscriber $orderEventSubscriber)
  25.         {
  26.             $this->logger = $lifecycleLogger;
  27.             $this->entityManager = $entityManager;
  28.             $this->dispatcher = new  \Symfony\Component\EventDispatcher\EventDispatcher();
  29.             $this->dispatcher->addSubscriber($orderEventSubscriber);
  30.         }
  31.         public static function getSubscribedEvents() : array
  32.         {
  33.             return [
  34.                 OrderPaymentEvent::SUCCESS => 'onPaymentSuccess',
  35.                 OrderPaymentEvent::CREATED => 'onPaymentCreated',
  36.             ];
  37.         }
  39.        
  40.         public function onPaymentCreated(OrderPaymentEvent $event)
  41.         {
  42.             $reference = $event->getOrderReference();
  43.             // Log the event
  44.             $this->logger->info(OrderPaymentEvent::CREATED, [
  45.                 'reference'=>$reference,
  46.             ]);
  47.             $panier = $this->entityManager->getRepository(ShopPanier::class)->findBy(['reference'=>$reference]);
  48.             if (!$panier) {
  49.                 throw new \Error('Pas de panier avec la référence "'.$reference.'"');
  50.                 return;
  51.             }
  52.             $ShopPanier = $panier[0];
  53.             $user = $ShopPanier->getUser();
  54.     
  55.             $entityManager = $this->entityManager;
  56.             $ShopOrderStatus = $entityManager->getRepository(\App\Entity\ShopOrderStatus::class)->findOneBy(['code'=>'created']);
  57.             // Nouvelle commande
  58.             $order = new ShopOrder();
  59.             $order->setUser($user);
  60.             $order->setStatus($ShopOrderStatus);
  61.             $order->setReference($reference);
  62.             $order->setAdress($ShopPanier->getAdress());
  63.             $order->setTotal(0);
  64.             $entityManager->persist($order);
  65.     
  66.             // Traitement des éléments de la commande
  67.             foreach($panier as $panierElt) {
  68.                 // Nouveau produit de la commande
  69.                 $shopOrderProduct = new ShopOrderProduct();
  70.                 $shopOrderProduct->setShopOrder($order);
  71.                 $shopOrderProduct->setProduct($panierElt->getProduit());
  72.                 $shopOrderProduct->setQuantite($panierElt->getUnit());
  73.                 $shopOrderProduct->setPrice($panierElt->getProduit()->getPrice());
  74.                 $shopOrderProduct->setIntitule($panierElt->getProduit()->getIntitule());
  75.                 $shopOrderProduct->setDescriptif($panierElt->getProduit()->getDescriptif());
  76.                 $shopOrderProduct->setCategorie($panierElt->getProduit()->getCategorie());
  77.                 $shopOrderProduct->setPoints($panierElt->getProduit()->getPoints());
  78.                 $entityManager->persist($shopOrderProduct);
  80.                 $order->setTotal($order->getTotal() + $shopOrderProduct->getTotal());
  82.                 //On supprime les éléments du panier en cours
  83.                 $panierEltToDelete = $entityManager->getRepository(ShopPanier::class)->find($panierElt->getId());
  84.                 $entityManager->remove($panierEltToDelete);
  85.             }
  86.             $entityManager->persist($order);
  87.     
  88.             $entityManager->flush();
  89.         }
  91.         public function onPaymentSuccess(OrderPaymentEvent $event)
  92.         {
  93.             $reference = $event->getOrderReference();
  94.             // Log the event
  95.             $this->logger->info(OrderPaymentEvent::SUCCESS, [
  96.                 'reference'=>$reference,
  97.             ]);
  98.             $shopOrder = $this->entityManager->getRepository(ShopOrder::class)->findOneBy(['reference'=>$reference]);
  99.             if (!$shopOrder) {
  100.                 throw new \Error('Pas de commande avec la référence "'.$reference.'"');
  101.                 return;
  102.             }
  103.             $OrderEvent = new OrderEvent($shopOrder);
  104.             $this->dispatcher->dispatch($OrderEvent, OrderEvent::CONFIRMED);
  105.         }
  106.     }