custom/plugins/GrimmTheme/src/Storefront/Subscriber/CartSubscriber.php line 37

Open in your IDE?
  1. <?php
  2. declare(strict_types = 1);
  4. namespace GrimmTheme\Storefront\Subscriber;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Shopware\Storefront\Page\Checkout\Cart\CheckoutCartPageLoadedEvent;
  8. use Shopware\Storefront\Page\Checkout\Offcanvas\OffcanvasCartPageLoadedEvent;
  9. use Shopware\Storefront\Page\PageLoadedEvent;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  13. use Shopware\Core\Framework\Struct\ArrayStruct;
  14. use Swag\CustomizedProducts\Core\Checkout\CustomizedProductsCartDataCollector;
  15. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  17. class CartSubscriber implements EventSubscriberInterface {
  18.     
  20.     private $productRepository;
  23.     public function __construct(
  24.         EntityRepositoryInterface $productRepository
  25.     ) {
  26.         $this->productRepository = $productRepository;
  27.     }
  29.     public static function getSubscribedEvents()
  30.     {
  31.         return [
  32.             CheckoutCartPageLoadedEvent::class => 'onCartPageLoadedEvent',
  33.             OffcanvasCartPageLoadedEvent::class => 'asdf'
  34.         ];
  35.     }
  37.     public function asdf(OffcanvasCartPageLoadedEvent $event) {
  38.         $this->determineIfCrossSelling($event);
  39.     }
  41.     public function onCartPageLoadedEvent(CheckoutCartPageLoadedEvent $event) {
  42.         $this->determineIfCrossSelling($event);
  43.     }
  45.     public function determineIfCrossSelling(PageLoadedEvent $event) {
  46.         $cart = $event->getPage()->getCart();
  47.         $lineItemIds = [];
  48.         foreach($cart->getLineItems() as $lineItem) {
  49.             if($lineItem->getType() === CustomizedProductsCartDataCollector::CUSTOMIZED_PRODUCTS_TEMPLATE_LINE_ITEM_TYPE) {
  50.                 $filteredArray = $lineItem->getChildren()->filterFlatByType(LineItem::PRODUCT_LINE_ITEM_TYPE);
  51.                 if(count($filteredArray) > 0) {
  52.                     $lineItemIds[] = $filteredArray[0]->getReferencedId();
  53.                 }
  54.             } 
  55.             if($lineItem->getType() === LineItem::PRODUCT_LINE_ITEM_TYPE) {
  56.                 $lineItemIds[] = $lineItem->getReferencedId();
  57.             }
  58.         }
  59.         
  60.         $productsWithCrossSelling = [];
  63.         foreach($this->getShit($lineItemIds, $event) as $product) {
  64.             if(count($product->getCrossSellings()) > 0) {
  65.                 $productsWithCrossSelling[] = $product->getId();
  66.             }
  67.         }
  70.         foreach($cart->getLineItems() as $lineItem) {
  71.             if($lineItem->getType() === CustomizedProductsCartDataCollector::CUSTOMIZED_PRODUCTS_TEMPLATE_LINE_ITEM_TYPE) {
  72.                 $filteredArray = $lineItem->getChildren()->filterFlatByType(LineItem::PRODUCT_LINE_ITEM_TYPE);
  73.                 if(count($filteredArray) > 0) {
  74.                     $productChild = $filteredArray[0];
  75.                     if(in_array($productChild->getReferencedId(), $productsWithCrossSelling)) {
  76.                         $lineItem->addExtension('s360_crossSelling', new ArrayStruct([true]));
  77.                     }
  78.                 }
  80.             } 
  82.             if($lineItem->getType() === LineItem::PRODUCT_LINE_ITEM_TYPE) {
  83.                 if(in_array($lineItem->getId(), $productsWithCrossSelling)) {
  84.                     $lineItem->addExtension('s360_crossSelling', new ArrayStruct([true]));
  85.                 }
  86.             }
  87.         }
  88.     }
  90.     private function getShit(Array $ids, PageLoadedEvent $event) {
  91.         $criteria = (new Criteria())
  92.             ->addFilter(new EqualsAnyFilter('id', $ids))
  93.             ->addAssociation('crossSellings');
  95.         // EntitySearchResult
  96.         return $this->productRepository->search($criteria, $event->getContext());
  97.     }
  98. }