custom/plugins/WbmTagManagerAnalytics/src/Subscriber/CartAddPrice/AfterLineItemAddedSubscriber.php line 44

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wbm\TagManagerAnalytics\Subscriber\CartAddPrice;
  7. use Shopware\Core\Checkout\Cart\Event\AfterLineItemAddedEvent;
  8. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  9. use Shopware\Core\Checkout\Cart\Price\Struct\CalculatedPrice;
  10. use Shopware\Core\Content\Product\ProductEntity;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  17. use Wbm\TagManagerAnalytics\Utility\SessionUtility;
  19. class AfterLineItemAddedSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var SessionInterface
  23.      */
  24.     protected $session;
  26.     /**
  27.      * @var EntityRepositoryInterface
  28.      */
  29.     protected $productRepository;
  31.     public function __construct(SessionInterface $session, EntityRepositoryInterface $productRepository)
  32.     {
  33.         $this->session = $session;
  34.         $this->productRepository = $productRepository;
  35.     }
  37.     public static function getSubscribedEvents()
  38.     {
  39.         return [
  40.             AfterLineItemAddedEvent::class => 'onAfterLineItemAdded'
  41.         ];
  42.     }
  44.     public function onAfterLineItemAdded(AfterLineItemAddedEvent $event)
  45.     {
  46.         if (!$this->session->has(SessionUtility::UPDATE_FLAG)
  47.             || $this->session->get(SessionUtility::UPDATE_FLAG) !== SessionUtility::ADDCART_UPDATEFLAG_VALUE) {
  48.             return;
  49.         }
  51.         $lineItems = [];
  52.         /** @var LineItem $addedLineItem */
  53.         foreach ($event->getLineItems() as $addedLineItem) {
  54.             $cartLineItem = $event->getCart()->getLineItems()->get($addedLineItem->getId());
  55.             if (!$cartLineItem instanceof LineItem || !$cartLineItem->getPrice() instanceof CalculatedPrice) {
  56.                 continue;
  57.             }
  59.             if (
  60.                 !empty($cartLineItem->getPayload())
  61.                 && isset($cartLineItem->getPayload()['productNumber'])
  62.                 && !empty($cartLineItem->getPayload()['productNumber'])
  63.             ) {
  64.                 $lineItems[$cartLineItem->getPayload()['productNumber']] = $cartLineItem->getPrice()->getUnitPrice();
  65.                 continue;
  66.             }
  68.             // in case payload productNumber is not set, get the productNumber from DB product
  69.             $criteria = new Criteria();
  70.             $criteria->addFilter(new EqualsFilter('id', $addedLineItem->getId()));
  71.             $product = $this->productRepository->search($criteria, $event->getContext())->first();
  73.             if ($product instanceof ProductEntity) {
  74.                 $lineItems[$product->getProductNumber()] = $cartLineItem->getPrice()->getUnitPrice();
  75.             }
  76.         }
  78.         $this->session->set(SessionUtility::ADDCART_CART_ITEMS, $lineItems);
  79.     }
  80. }