custom/plugins/ThemeOkeOnline/src/Storefront/Page/Checkout/CheckoutCartPageLoadedEventSubscriber.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace ThemeOkeOnline\Storefront\Page\Checkout;
  5. use Symfony\Component\HttpFoundation\Request;
  6. use Shopware\Core\Content\Product\ProductCollection;
  7. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  8. use Shopware\Core\Checkout\Cart\LineItem\LineItemCollection;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Storefront\Page\Checkout\Cart\CheckoutCartPageLoadedEvent;
  12. use Shopware\Core\Content\Product\SalesChannel\CrossSelling\AbstractProductCrossSellingRoute;
  13. use Shopware\Core\Content\Product\SalesChannel\CrossSelling\ProductCrossSellingRouteResponse;
  14. use Shopware\Core\System\SystemConfig\SystemConfigService;
  16. class CheckoutCartPageLoadedEventSubscriber implements EventSubscriberInterface
  17. {
  18.     private SalesChannelContext $context;
  20.     /** @var ProductCrossSellingRoute $crossSellLoaderRoute */
  21.     private $crossSellLoaderRoute;
  24.     public function __construct(
  25.         AbstractProductCrossSellingRoute $crossSellLoaderRoute,
  26.         SystemConfigService $systemConfigService
  27.     )
  28.     {
  29.         $this->crossSellLoaderRoute = $crossSellLoaderRoute;
  30.         $this->systemConfigService = $systemConfigService;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             CheckoutCartPageLoadedEvent::class => ['addCrossSellProductsToCartPage']
  37.         ];
  38.     }
  40.     public function addCrossSellProductsToCartPage(CheckoutCartPageLoadedEvent $event)
  41.     {
  42.         $this->setSalesChannelContext($event->getSalesChannelContext());
  43.         $page = $event->getPage();
  44.         $cart = $page->getCart();
  45.         
  46.         // collect all productIds of products in cart
  47.         $productIds = $this->getProductIdsFromLineItems($cart->getLineItems());
  49.         $productCollection = new ProductCollection();
  51.         $maxNumProductsInCart = $this->systemConfigService->get("ThemeOkeonline.config.maxNumProductsInCart") ?? 6;
  53.         foreach($productIds as $productId)
  54.         {
  55.             if($productCollection->count() > $maxNumProductsInCart)
  56.                 break;
  58.             // load all CrossSelling products, trough the loader, to handle normal crossselling products, but also the productstream variant
  59.             $crossSellResponse = $this->crossSellLoaderRoute->load($productId, new Request(), $this->getSalesChannelContext(), new Criteria());
  60.             
  61.             // merge all CrossSelling prodicts in one ProductCollection
  62.             $productCollection = $this->mergeCrossSellingProductsCollectionFromObject($crossSellResponse, $productCollection);
  63.         }
  65.         // add Extension to the page
  67.         if($productCollection->count() > 0)
  68.         {
  69.             $page->addExtension(
  70.                 'crossSellProducts',
  71.                 $productCollection
  72.             );
  73.         }
  76.         
  77.     }
  79.     private function getProductIdsFromLineItems(LineItemCollection $lineItems): array
  80.     {
  81.         // get both normal products, and cp-products
  82.         return array_merge(
  83.             $this->getProductIdsFromProducts($lineItems),
  84.             $this->getProductIdsFromCustomizedProducts($lineItems)
  85.         );
  86.     }
  88.     private function getProductIdsFromCustomizedProducts(LineItemCollection $lineItems): array
  89.     {
  90.         $ids = array();
  92.         // loop trough the Cp's and get the ReferenceIds from there underlaying products
  93.         $lineItems->filterType('customized-products')->map(function($lineItem) use (&$ids) {
  94.             $ids = array_merge($ids, array_values($lineItem->getChildren()->filterType('product')->getReferenceIds()));
  95.         });
  97.         return $ids;
  98.     }
  100.     private function getProductIdsFromProducts(LineItemCollection $lineItems): array
  101.     {
  102.         return $lineItems->filterType('product')->getReferenceIds();   
  103.     }
  105.     private function mergeCrossSellingProductsCollectionFromObject(ProductCrossSellingRouteResponse $crossSellResponse, ProductCollection $productCollection): ProductCollection
  106.     {
  107.         if($array = $crossSellResponse->getResult())
  108.         {
  109.             foreach($array as $crossSellingElement)
  110.             {
  111.                 $productCollection->merge($crossSellingElement->getProducts());
  112.             }
  114.         }
  116.         return $productCollection;
  117.     }
  119.     private function setSalesChannelContext(SalesChannelContext $context): void
  120.     {
  121.         $this->context = $context;
  122.     }
  124.     private function getSalesChannelContext(): SalesChannelContext
  125.     {
  126.         return $this->context;
  127.     }
  129. }