src/EventListener/OrderPlacedListener.php line 50

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\Gos\OrderPart;
  6. use App\Entity\Gos\OrderProductVariant;
  7. use App\Entity\Gos\Orders;
  8. use App\Entity\Gos\UserFlag;
  9. use App\Event\OrderPlacedEvent;
  10. use App\Utils\OmittedUpsellUtils;
  11. use App\Utils\SalesManago\v2\Action\Contact\ExternalEvent\Purchase\PurchaseEventAction;
  12. use App\Utils\SalesManago\v2\Action\Contact\ExternalEvent\Purchase\PurchaseEventContext;
  13. use App\Utils\SalesManago\v2\Flow\PurchaseFlow;
  14. use App\Utils\UserFlagService;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class OrderPlacedListener implements EventSubscriberInterface
  19. {
  20.     private $entityManager;
  21.     private $userFlagService;
  22.     private $omittedUpsellUtils;
  23.     private $salesManagoPurchaseFlow;
  25.     public function __construct(
  26.         EntityManagerInterface $entityManager,
  27.         UserFlagService $userFlagService,
  28.         OmittedUpsellUtils $omittedUpsellUtils,
  29.         PurchaseFlow $salesManagoPurchaseFlow
  30.     )
  31.     {
  32.         $this->entityManager   = $entityManager;
  33.         $this->userFlagService = $userFlagService;
  34.         $this->omittedUpsellUtils = $omittedUpsellUtils;
  35.         $this->salesManagoPurchaseFlow = $salesManagoPurchaseFlow;
  36.     }
  38.     public static function getSubscribedEvents(): array
  39.     {
  40.         return [
  41.             OrderPlacedEvent::ORDER_PLACED => [
  42.                 ['assignFlagToUser', 10],
  43.                 ['createOmittedUpsellRecords', 9],
  44.                 ['removeOmittedUpsellIfPurchased', 8],
  45.                 ['sendSalesManago2PurchaseEvent', 7],
  46.             ],
  47.         ];
  48.     }
  50.     public function assignFlagToUser(OrderPlacedEvent $event): void
  51.     {
  52.         $orderId = $event->getOrderId();
  53.         $order   = $this->entityManager->getRepository(Orders::class)->find($orderId);
  55.         /** @var OrderPart $orderPart */
  56.         foreach ($order->getOrderPart() as $orderPart)
  57.         {
  58.             /** @var OrderProductVariant $opv */
  59.             foreach ($orderPart->getOrderProductVariant() as $opv)
  60.             {
  61.                 $orderedProductVariants[] = $opv->getProductVariant()->getProductVariantNoComplete();
  62.             }
  63.         }
  65.         $matchedUserFlags = $this->entityManager
  66.             ->getRepository(UserFlag::class)
  67.             ->findActiveByProductVariant($orderedProductVariants ?? []);
  69.         if (empty($matchedUserFlags))
  70.         {
  71.             return;
  72.         }
  74.         foreach ($matchedUserFlags as $userFlag)
  75.         {
  76.             $this->userFlagService->assignToUser($userFlag, $order->getUser());
  77.         }
  78.     }
  80.     public function createOmittedUpsellRecords(OrderPlacedEvent $event)
  81.     {
  82.         $orderId = $event->getOrderId();
  83.         $order   = $this->entityManager->getRepository(Orders::class)->find($orderId);
  85.         $this->omittedUpsellUtils->create($order);
  86.     }
  88.     public function removeOmittedUpsellIfPurchased(OrderPlacedEvent $event)
  89.     {
  90.         $orderId = $event->getOrderId();
  91.         $order   = $this->entityManager->getRepository(Orders::class)->find($orderId);
  93.         $this->omittedUpsellUtils->removePurchased($order);
  94.     }
  96.     public function sendSalesManago2PurchaseEvent(OrderPlacedEvent $event): void
  97.     {
  98.         $orderId = $event->getOrderId();
  99.         $order   = $this->entityManager->getRepository(Orders::class)->find($orderId);
  101.         if (!$order) {
  102.             return;
  103.         }
  105.         $this->salesManagoPurchaseFlow->handle($order);
  106.     }
  107. }