custom/plugins/CbaxModulCrossSelling/src/Subscriber/FrontendSubscriber.php line 186

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Cbax\ModulCrossSelling\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Framework\Uuid\Uuid;
  7. use Shopware\Core\Defaults;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  10. use Shopware\Storefront\Page\Checkout\Cart\CheckoutCartPageLoadedEvent;
  11. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  17. use Shopware\Core\System\SystemConfig\SystemConfigService;
  18. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  19. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  20. use Symfony\Contracts\Translation\TranslatorInterface;
  21. use Shopware\Core\Content\Product\Aggregate\ProductCrossSelling\ProductCrossSellingEntity;
  22. use Shopware\Core\Content\Product\SalesChannel\CrossSelling\CrossSellingElementCollection;
  23. use Shopware\Core\Content\Product\SalesChannel\CrossSelling\CrossSellingElement;
  24. use Shopware\Core\Content\Product\SalesChannel\CrossSelling\AbstractProductCrossSellingRoute;
  25. use Shopware\Core\Content\Product\ProductCollection;
  26. //use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemCollection;
  27. use Shopware\Storefront\Page\Navigation\NavigationPageLoadedEvent;
  28. use Shopware\Storefront\Page\Search\SearchPageLoadedEvent;
  29. use Shopware\Storefront\Page\LandingPage\LandingPageLoadedEvent;
  31. use Cbax\ModulCrossSelling\CbaxModulCrossSelling;
  33. class FrontendSubscriber implements EventSubscriberInterface
  34. {
  35.     /**
  36.      * @var TranslatorInterface
  37.      */
  38.     private $translator;
  40.     /**
  41.      * @var SystemConfigService
  42.      */
  43.     private $systemConfigService;
  45.     /** SalesChannelProductRepository */
  46.     /**
  47.      * @var SalesChannelRepositoryInterface
  48.      */
  49.     private $salesChannelProductRepository;
  51.     /**
  52.      * @var EntityRepositoryInterface
  53.      */
  54.     private $productRepository;
  56.     /**
  57.      * @var EntityRepositoryInterface
  58.      */
  59.     private $cbaxCrossSellingRepository;
  61.     /**
  62.      * @var EntityRepositoryInterface
  63.      */
  64.     private $alsoViewedRepository;
  66.     /**
  67.      * @var EntityRepositoryInterface
  68.      */
  69.     private $alsoBoughtRepository;
  71.     /**
  72.      * @var AbstractProductCrossSellingRoute
  73.      */
  74.     private $crossSellingLoader;
  76.     /**
  77.      * @var CrossSellingElementCollection
  78.      */
  79.     private $filteredAccessories;
  81.     /**
  82.      * @var CrossSellingElementCollection
  83.      */
  84.     private $filteredSimilarArticle;
  86.     /**
  87.      * @var Connection
  88.      */
  89.     private $connection;
  91.     /**
  92.      * @var string
  93.      */
  94.     private $shopwareVersion;
  96.     public function __construct(
  97.         SystemConfigService $systemConfigService,
  98.         EntityRepositoryInterface $productRepository,
  99.         SalesChannelRepositoryInterface $salesChannelProductRepository,
  100.         EntityRepositoryInterface $cbaxCrossSellingRepository,
  101.         EntityRepositoryInterface $alsoViewedRepository,
  102.         EntityRepositoryInterface $alsoBoughtRepository,
  103.         AbstractProductCrossSellingRoute $crossSellingLoader,
  104.         Connection $connection,
  105.         TranslatorInterface $translator,
  106.         $shopwareVersion
  107.     )
  108.     {
  109.         $this->systemConfigService = $systemConfigService;
  110.         $this->productRepository = $productRepository;
  111.         $this->salesChannelProductRepository = $salesChannelProductRepository;
  112.         $this->cbaxCrossSellingRepository = $cbaxCrossSellingRepository;
  113.         $this->crossSellingLoader = $crossSellingLoader;
  114.         $this->shopwareVersion = $shopwareVersion;
  115.         $this->alsoViewedRepository = $alsoViewedRepository;
  116.         $this->alsoBoughtRepository = $alsoBoughtRepository;
  117.         $this->connection = $connection;
  118.         $this->translator = $translator;
  119.     }
  121.     public static function getSubscribedEvents(): array
  122.     {
  123.         return[
  124.             ProductPageLoadedEvent::class => 'onProductPageLoadedEvent',
  125.             CheckoutCartPageLoadedEvent::class => 'onCheckoutCartPageLoadedEvent',
  126.             CheckoutFinishPageLoadedEvent::class => ['onOrderFinished', -1],
  127.             NavigationPageLoadedEvent::class => 'onNavigationPageLoaded',
  128.             SearchPageLoadedEvent::class => 'onSearchPageLoaded',
  129.             LandingPageLoadedEvent::class => 'onLandingPageLoaded'
  130.         ];
  131.     }
  133.     public function onLandingPageLoaded(LandingPageLoadedEvent $event)
  134.     {
  135.         $context = $event->getSalesChannelContext();
  136.         $salesChannelId = $context->getSalesChannelId();
  137.         $config = $this->systemConfigService->get(CbaxModulCrossSelling::MODUL_NAME, $salesChannelId)['config'];
  139.         if (!empty($config['showLastSeen']) && !empty($config['lastSeenPageTypes']) && in_array('landing', $config['lastSeenPageTypes'])) {
  140.             $lastSeenProducts = $this->getlastSeenProducts($event, $context);
  142.             if (count($lastSeenProducts) > 0) {
  143.                 $page = $event->getPage();
  144.                 $page->assign(['lastSeenArticle' => $lastSeenProducts]);
  145.             }
  146.         }
  147.     }
  149.     public function onSearchPageLoaded(SearchPageLoadedEvent $event)
  150.     {
  151.         $context = $event->getSalesChannelContext();
  152.         $salesChannelId = $context->getSalesChannelId();
  153.         $config = $this->systemConfigService->get(CbaxModulCrossSelling::MODUL_NAME, $salesChannelId)['config'];
  155.         if (!empty($config['showLastSeen']) && !empty($config['lastSeenPageTypes']) && in_array('search', $config['lastSeenPageTypes'])) {
  156.             $lastSeenProducts = $this->getlastSeenProducts($event, $context);
  158.             if (count($lastSeenProducts) > 0) {
  159.                 $page = $event->getPage();
  160.                 $page->assign(['lastSeenArticle' => $lastSeenProducts]);
  161.             }
  162.         }
  163.     }
  165.     private function getlastSeenProducts($event, $context)
  166.     {
  167.         $session = $event->getRequest()->getSession();
  168.         $lastSeen = [];
  170.         if ($session->has('cbaxLastSeen')) {
  171.             $lastSeen = $session->get('cbaxLastSeen');
  172.             $lastSeen = is_array($lastSeen) ? $lastSeen : [];
  173.         }
  175.         if (count($lastSeen) > 0) {
  176.             $lastSeenCriteria = new Criteria();
  177.             $lastSeenCriteria->addFilter(new EqualsAnyFilter('id', $lastSeen));
  179.             return $this->salesChannelProductRepository->search($lastSeenCriteria, $context)->getElements();
  181.         } else {
  182.             return [];
  183.         }
  184.     }
  186.     public function onNavigationPageLoaded(NavigationPageLoadedEvent $event)
  187.     {
  188.         $context = $event->getSalesChannelContext();
  189.         $salesChannelId = $context->getSalesChannelId();
  190.         $config = $this->systemConfigService->get(CbaxModulCrossSelling::MODUL_NAME, $salesChannelId)['config'];
  191.         $page = $event->getPage();
  193.         if (!empty($config['showLastSeen']) && !empty($config['lastSeenPageTypes']) && in_array('navigation', $config['lastSeenPageTypes'])) {
  194.             $lastSeenProducts = $this->getlastSeenProducts($event, $context);
  196.             if (count($lastSeenProducts) > 0) {
  197.                 $page->assign(['lastSeenArticle' => $lastSeenProducts]);
  198.             }
  199.         }
  200.     }
  202.     public function onOrderFinished(CheckoutFinishPageLoadedEvent $event)
  203.     {
  204.         $context = $event->getSalesChannelContext();
  205.         $salesChannelId = $context->getSalesChannelId();
  206.         $config = $this->systemConfigService->get(CbaxModulCrossSelling::MODUL_NAME, $salesChannelId)['config'];
  208.         if (empty($config['showAlsoBought'])) return;
  210.         $order = $event->getPage()->getOrder();
  212.         if (!empty($order) and !empty($order->getLineItems()) and $order->getLineItems()->count() > 1)
  213.         {
  214.             $lineItems = $order->getLineItems();
  215.             $combinations = [];
  216.             $insertValues = '';
  217.             $createdAt = (new \DateTimeImmutable())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  218.             foreach ($lineItems as $key1 => $item1)
  219.             {
  220.                 foreach ($lineItems as $key2 => $item2)
  221.                 {
  222.                     if ($key1 === $key2) continue;
  223.                     if ($item1->getType() !== 'product' || $item2->getType() !== 'product') continue;
  225.                     $combinations[] = [$item1->getProductId(), $item2->getProductId()];
  226.                 }
  227.             }
  228.             foreach ($combinations as $idPair)
  229.             {
  230.                 $insertValues .= '(UNHEX("' . Uuid::randomHex() . '"),UNHEX("' . $idPair[0] . '"),UNHEX("' . $idPair[1] . '"),1,:created_at),';
  231.             }
  233.             $insertValues = rtrim($insertValues, ', ');
  234.             if (!empty($insertValues))
  235.             {
  236.                 try {
  237.                     $this->connection->executeUpdate('
  238.                         INSERT INTO `cbax_cross_selling_also_bought`
  239.                             (`id`, `product_id`, `related_product_id`, `sales`, `created_at`)
  240.                         VALUES ' . $insertValues . ' ON DUPLICATE KEY UPDATE sales=sales+1;',
  241.                         [
  242.                             'created_at' => $createdAt
  243.                         ]
  244.                     );
  246.                 } catch (\Exception $e) {
  248.                 }
  249.             }
  250.         }
  251.     }
  253.     public function onProductPageLoadedEvent(ProductPageLoadedEvent $productPageLoadedEvent)
  254.     {
  255.         $context = $productPageLoadedEvent->getSalesChannelContext();
  256.         $salesChannelId = $context->getSalesChannelId();
  257.         $config = $this->systemConfigService->get(CbaxModulCrossSelling::MODUL_NAME, $salesChannelId)['config'];
  258.         $page = $productPageLoadedEvent->getPage();
  260.         if (!empty($config['showLastSeen']) || !empty($config['showAlsoViewed']))
  261.         {
  262.             $productId = $productPageLoadedEvent->getPage()->getProduct()->getId();
  263.             $session = $productPageLoadedEvent->getRequest()->getSession();
  264.             $lastSeenLimit = !empty($config['lastSeenLimit']) ? $config['lastSeenLimit'] : 5;
  266.             if ($session->has('cbaxLastSeen'))
  267.             {
  268.                 $lastSeen = $session->get('cbaxLastSeen');
  269.                 if (is_array($lastSeen))
  270.                 {
  271.                     $lastSeen = array_filter($lastSeen, function($e) use ($productId) {
  272.                         return ($e !== $productId);
  273.                     });
  274.                     $lastSeen[] = $productId;
  275.                 } else {
  276.                     $lastSeen = [$productId];
  277.                 }
  278.             } else {
  279.                 $lastSeen = [$productId];
  280.             }
  282.             if (count($lastSeen) > $lastSeenLimit + 1)
  283.             {
  284.                 array_shift($lastSeen);
  285.             }
  287.             $session->set('cbaxLastSeen', $lastSeen);
  289.             array_pop($lastSeen);
  291.             if (!empty($config['showLastSeen']) && !empty($config['lastSeenPageTypes']) && in_array('product', $config['lastSeenPageTypes']) && count($lastSeen) > 0)
  292.             {
  293.                 $lastSeenCriteria = new Criteria();
  294.                 $lastSeenCriteria->addFilter(new EqualsAnyFilter('id', $lastSeen));
  296.                 $lastSeenProducts = $this->salesChannelProductRepository->search($lastSeenCriteria, $context)->getElements();
  298.                 if (count($lastSeenProducts) > 0)
  299.                 {
  300.                     $page->assign(['lastSeenArticle' => $lastSeenProducts]);
  301.                 }
  302.             }
  304.             if (!empty($config['showAlsoViewed']))
  305.             {
  306.                 $alsoViewedLimit = !empty($config['alsoViewedLimit']) ? $config['alsoViewedLimit'] : 5;
  308.                 $alsoViewedCriteria1 = new Criteria();
  309.                 $alsoViewedCriteria1->addFilter(new EqualsFilter('productId', $productId));
  310.                 $alsoViewedCriteria1->addSorting(new FieldSorting('viewed', FieldSorting::DESCENDING));
  311.                 $alsoViewedCriteria1->setLimit($alsoViewedLimit);
  313.                 $alsoViewedResult = $this->alsoViewedRepository->search($alsoViewedCriteria1, $context->getContext())->getElements();
  315.                 if (count($alsoViewedResult) > 0)
  316.                 {
  317.                     $alsoViewedIds = array_map(static function($item) {
  318.                         return $item->getRelatedProductId();
  319.                     }, $alsoViewedResult);
  321.                     $alsoViewedCriteria2 = new Criteria($alsoViewedIds);
  322.                     $alsoViewedCriteria2->addFilter(new EqualsFilter('active', true));
  324.                     $alsoViewedProducts = $this->salesChannelProductRepository->search($alsoViewedCriteria2, $context);
  325.                     if ($alsoViewedProducts->getTotal() > 0)
  326.                     {
  327.                         if ($config['alsoProductsLocation'] == 'crossSelling')
  328.                         {
  329.                             $locale = $this->translator->getLocale() ?? 'en-GB';
  330.                             $alsoViewedTitle = $this->translator->trans('cbaxCrossSelling.alsoViewed.title', [], null, $locale);
  332.                             $alsoViewedPCSEntity = new ProductCrossSellingEntity();
  333.                             $alsoViewedPCSEntity->setActive(true);
  334.                             $alsoViewedPCSEntity->setId(Uuid::randomHex());
  335.                             $alsoViewedPCSEntity->setTranslated(['name' => $alsoViewedTitle]);
  336.                             $alsoViewedPCSEntity->setName($alsoViewedTitle);
  337.                             $alsoViewedCSElement = new CrossSellingElement();
  338.                             $alsoViewedCSElement->setCrossSelling($alsoViewedPCSEntity);
  339.                             $alsoViewedCSElement->setProducts($alsoViewedProducts->getEntities());
  340.                             $alsoViewedCSElement->setTotal($alsoViewedProducts->getTotal());
  342.                         } else {
  343.                             $page->assign(['alsoViewedArticle' => $alsoViewedProducts->getElements()]);
  344.                         }
  345.                     }
  346.                 }
  348.                 if (count($lastSeen) > 0)
  349.                 {
  350.                     $insertValues = '';
  351.                     $createdAt = (new \DateTimeImmutable())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  352.                     $productIdBytes = Uuid::fromHexToBytes($productId);
  353.                     foreach ($lastSeen as $seenId)
  354.                     {
  355.                         $insertValues .= '(UNHEX("' . Uuid::randomHex() . '"),:product_id,UNHEX("' . $seenId . '"),1,:created_at),';
  356.                         $insertValues .= '(UNHEX("' . Uuid::randomHex() . '"),UNHEX("' . $seenId . '"),:product_id,1,:created_at),';
  357.                     }
  358.                     $insertValues = rtrim($insertValues, ', ');
  360.                     try {
  361.                         $this->connection->executeUpdate('
  362.                         INSERT INTO `cbax_cross_selling_also_viewed`
  363.                             (`id`, `product_id`, `related_product_id`, `viewed`, `created_at`)
  364.                         VALUES ' . $insertValues . ' ON DUPLICATE KEY UPDATE viewed=viewed+1;',
  365.                             [
  366.                                 'created_at' => $createdAt,
  367.                                 'product_id' => $productIdBytes
  368.                             ]
  369.                         );
  371.                     } catch (\Exception $e) {
  373.                     }
  374.                 }
  375.             }
  376.         }
  378.         if (!empty($config['showAlsoBought']) && !empty($productId)) {
  379.             $alsoBoughtLimit = !empty($config['alsoBoughtLimit']) ? $config['alsoBoughtLimit'] : 5;
  381.             $alsoBoughtCriteria1 = new Criteria();
  382.             $alsoBoughtCriteria1->addFilter(new EqualsFilter('productId', $productId));
  383.             $alsoBoughtCriteria1->addSorting(new FieldSorting('sales', FieldSorting::DESCENDING));
  384.             $alsoBoughtCriteria1->setLimit($alsoBoughtLimit);
  386.             $alsoBoughtResult = $this->alsoBoughtRepository->search($alsoBoughtCriteria1, $context->getContext())->getElements();
  388.             if (count($alsoBoughtResult) > 0) {
  389.                 $alsoBoughtIds = array_map(static function ($item) {
  390.                     return $item->getRelatedProductId();
  391.                 }, $alsoBoughtResult);
  393.                 $alsoBoughtCriteria2 = new Criteria($alsoBoughtIds);
  394.                 $alsoBoughtCriteria2->addFilter(new EqualsFilter('active', true));
  396.                 $alsoBoughtProducts = $this->salesChannelProductRepository->search($alsoBoughtCriteria2, $context);
  398.                 if ($alsoBoughtProducts->getTotal() > 0)
  399.                 {
  400.                     if ($config['alsoProductsLocation'] == 'crossSelling')
  401.                     {
  402.                         if (empty($locale))
  403.                         {
  404.                             $locale = $this->translator->getLocale() ?? 'en-GB';
  405.                         }
  406.                         $alsoBoughtTitle = $this->translator->trans('cbaxCrossSelling.alsoBought.title', [], null, $locale);
  408.                         $alsoBoughtPCSEntity = new ProductCrossSellingEntity();
  409.                         $alsoBoughtPCSEntity->setActive(true);
  410.                         $alsoBoughtPCSEntity->setId(Uuid::randomHex());
  411.                         $alsoBoughtPCSEntity->setTranslated(['name' => $alsoBoughtTitle]);
  412.                         $alsoBoughtPCSEntity->setName($alsoBoughtTitle);
  413.                         $alsoBoughtCSElement = new CrossSellingElement();
  414.                         $alsoBoughtCSElement->setCrossSelling($alsoBoughtPCSEntity);
  415.                         $alsoBoughtCSElement->setProducts($alsoBoughtProducts->getEntities());
  416.                         $alsoBoughtCSElement->setTotal($alsoBoughtProducts->getTotal());
  418.                     } else {
  419.                         $page->assign(['alsoBoughtProducts' => $alsoBoughtProducts->getElements()]);
  420.                     }
  421.                 }
  422.             }
  423.         }
  425.         if (empty($config['activeSimilarContainer']) && empty($config['activeAccessoriesTab'])) return;
  427.         $cmsPage = $page->getCmsPage();
  429.         if (empty($cmsPage))
  430.         {
  431.             $result = $page->getCrossSellings();
  433.         } else
  434.         {
  435.             $crossSellingElement = $cmsPage->getFirstElementOfType('cross-selling');
  436.             if (!empty($crossSellingElement) && !empty($crossSellingElement->getData()))
  437.             {
  438.                 $result = $crossSellingElement->getData()->getCrossSellings();
  439.             }
  440.         }
  442.         // Filtern nur nötig bei echten CS Elementen, wenn nur also.. Pseudo CS Elemnte, nicht nötig
  443.         if (!empty($result) && $result->count() > 0)
  444.         {
  445.             $doFilterung = true;
  447.         } else {
  448.             $doFilterung = false;
  449.         }
  451.         if (!empty($alsoViewedCSElement)) {
  452.             if (empty($result))
  453.             {
  454.                 $result = new CrossSellingElementCollection();
  455.             }
  456.             $result->add($alsoViewedCSElement);
  457.         }
  458.         if (!empty($alsoBoughtCSElement)) {
  459.             if (empty($result))
  460.             {
  461.                 $result = new CrossSellingElementCollection();
  462.             }
  463.             $result->add($alsoBoughtCSElement);
  464.         }
  466.         if (empty($result)) return;
  467.         if ($result->count() === 0) return;
  469.         $crossSellingIds = array_map(static function ($item) {
  470.             return $item->getCrossSelling()->get('id');
  471.         }, $result->getElements());
  473.         if (count($crossSellingIds) > 0)
  474.         {
  475.             // Filtern nur nötig bei echten CS Elementen, wenn nur also... Pseudo CS Elemente, nicht nötig
  476.             if ($doFilterung)
  477.             {
  478.                 $this->filteredAccessories = new CrossSellingElementCollection();
  479.                 $this->filteredSimilarArticle = new CrossSellingElementCollection();
  481.                 $criteria = new Criteria();
  482.                 $criteria->addFilter(new EqualsAnyFilter('crossSellingId', $crossSellingIds));
  483.                 $criteria->addAssociation('crossSelling');
  484.                 $crossSellings = $this->cbaxCrossSellingRepository->search($criteria, $context->getContext())->getElements();
  485.                 $filtered = $result->filter(function ($element) use ($crossSellings, $config) {return $this->filterData($element, $crossSellings, $config);});
  486.                 $result = $filtered;
  488.                 $page->assign(['cbaxCrossSelling' => $crossSellings]);
  489.                 $page->assign(['filteredAccessories' => $this->filteredAccessories]);
  490.                 $page->assign(['filteredSimilarArticle' => $this->filteredSimilarArticle]);
  491.             }
  493.             if (empty($cmsPage))
  494.             {
  495.                 $page->setCrossSellings($result);
  497.             } else {
  498.                 $crossSellingElement->getData()->setCrossSellings($result);
  499.             }
  501.             if (version_compare($this->shopwareVersion, '6.4.11', '>='))
  502.             {
  503.                 $page->assign(['cbaxSW6411' => true]);
  504.             } else {
  505.                 $page->assign(['cbaxSW6411' => false]);
  506.             }
  507.         }
  508.     }
  510.     public function filterData(CrossSellingElement $element, array $crossSellings, $config)
  511.     {
  512.         $accessoriesIds = array();
  513.         $similarArticleIds = array();
  514.         foreach ($crossSellings as $item) {
  515.             if ($item->getCrossSellingGroup() === 'accessories') {
  516.                 $accessoriesIds[] = $item->crossSellingId;
  517.             }
  518.             if ($item->getCrossSellingGroup() === 'similar_article') {
  519.                 $similarArticleIds[] = $item->crossSellingId;
  520.             }
  521.         }
  522.         if (in_array($element->getCrossSelling()->get('id'), $accessoriesIds)) {
  523.             $this->filteredAccessories->add($element);
  524.             if (!empty($config['filterAccessories'])) {
  525.                 return false;
  526.             }
  527.         }
  529.         if (in_array($element->getCrossSelling()->get('id'), $similarArticleIds)) {
  530.             $this->filteredSimilarArticle->add($element);
  531.             if (!empty($config['filterSimilarArticle'])) {
  532.                 return false;
  533.             }
  534.         }
  536.         return true;
  537.     }
  539.     public function onCheckoutCartPageLoadedEvent(CheckoutCartPageLoadedEvent $checkoutCartPageLoadedEvent)
  540.     {
  541.         $salesChannelId = $checkoutCartPageLoadedEvent->getSalesChannelContext()->getSalesChannelId();
  542.         $config = $this->systemConfigService->get(CbaxModulCrossSelling::MODUL_NAME, $salesChannelId)['config'];
  544.         if (empty($config['activeAccessoriesInCart'])) return;
  546.         $page = $checkoutCartPageLoadedEvent->getPage();
  547.         $lineItems = $page->getCart()->getLineItems();
  548.         $filteredLineItems = $lineItems->filterType('product');
  550.         if ($filteredLineItems->count() > 0)
  551.         {
  552.             $context = $checkoutCartPageLoadedEvent->getSalesChannelContext();
  554.             $emptyCriteria = new Criteria();
  555.             $criteria = new Criteria();
  556.             $criteria->addFilter(new EqualsAnyFilter('id', $filteredLineItems->getKeys()));
  558.             $criteria->addAssociation('crossSellings');
  560.             $products = $this->productRepository->search($criteria, $context->getContext());
  562.             $crossSellingIds = array();
  563.             foreach($products->getElements() as $product)
  564.             {
  565.                 $crossSellingIds = array_merge($crossSellingIds, $product->getCrossSellings()->getIds());
  566.             }
  568.             if (count($crossSellingIds) > 0)
  569.             {
  570.                 $request = $checkoutCartPageLoadedEvent->getRequest();
  571.                 $this->filteredAccessories = new CrossSellingElementCollection();
  572.                 $this->filteredSimilarArticle = new CrossSellingElementCollection();
  575.                 $criteria = new Criteria();
  576.                 $criteria->addFilter(new EqualsAnyFilter('crossSellingId', $crossSellingIds));
  578.                 $criteria->addAssociation('crossSelling');
  580.                 $cbaxCrossSellings = $this->cbaxCrossSellingRepository->search($criteria, $context->getContext())->getElements();
  582.                 foreach($filteredLineItems->getKeys() as $id)
  583.                 {
  584.                     $elements = $this->crossSellingLoader->load($id, $request, $context, $emptyCriteria)->getResult();
  586.                     foreach($elements->getElements() as $element)
  587.                     {
  588.                         $this->sortData($element, $cbaxCrossSellings);
  589.                     }
  590.                 }
  592.                 $this->filterSameAccessories($filteredLineItems->getKeys(), $config);
  594.                 if (!empty($config['accessoriesCartOneSlider']) && $this->filteredAccessories->count() > 1)
  595.                 {
  596.                     $counter = 0;
  597.                     $productCollection = new ProductCollection();
  598.                     foreach ($this->filteredAccessories->getElements() as $index => $crossSellingElement)
  599.                     {
  600.                         if ($counter === 0)
  601.                         {
  602.                             $remainingElement = $crossSellingElement;
  603.                         }
  604.                         foreach ($crossSellingElement->getProducts()->getElements() as $prod)
  605.                         {
  606.                             if ($counter < $config['accessoriesCartOneSliderNumber'])
  607.                             {
  608.                                 $productCollection->add($prod);
  609.                                 $counter++;
  611.                             } else {
  612.                                 break;
  613.                             }
  614.                         }
  616.                         $this->filteredAccessories->remove($index);
  617.                     }
  618.                     $remainingElement->setProducts($productCollection);
  619.                     $this->filteredAccessories->add($remainingElement);
  620.                 }
  622.                 if (version_compare($this->shopwareVersion, '6.4.11', '>='))
  623.                 {
  624.                     $page->assign(['cbaxSW6411' => true]);
  625.                 } else {
  626.                     $page->assign(['cbaxSW6411' => false]);
  627.                 }
  629.                 $page->assign(['cbaxCrossSelling' => $cbaxCrossSellings]);
  630.                 $page->assign(['filteredAccessories' => $this->filteredAccessories]);
  631.                 //$page->assign(['filteredSimilarArticle' => $this->filteredSimilarArticle]);
  632.             }
  633.         }
  634.     }
  636.     public function sortData($element, $crossSellings)
  637.     {
  638.         $accessoriesIds = array();
  639.         $similarArticleIds = array();
  640.         foreach ($crossSellings as $item) {
  641.             if ($item->getCrossSellingGroup() === 'accessories') {
  642.                 $accessoriesIds[] = $item->crossSellingId;
  643.             }
  644.             if ($item->getCrossSellingGroup() === 'similar_article') {
  645.                 $similarArticleIds[] = $item->crossSellingId;
  646.             }
  647.         }
  649.         if (in_array($element->getCrossSelling()->get('id'), $accessoriesIds)) {
  650.             $this->filteredAccessories->add($element);
  651.         }
  653.         if (in_array($element->getCrossSelling()->get('id'), $similarArticleIds)) {
  654.             $this->filteredSimilarArticle->add($element);
  655.         }
  656.     }
  658.     public function filterSameAccessories($filteredLineItemsIds, $config)
  659.     {
  660.         $streamIds = array();
  661.         $names = array();
  663.         foreach ($this->filteredAccessories->getElements() as $index => $crossSellingElement) {
  664.             $crossSelling = $crossSellingElement->getCrossSelling();
  665.             if ($crossSelling->getType() === 'productStream' && $crossSelling->getProductStreamId() !== null) {
  666.                 if (!in_array($crossSelling->getProductStreamId(), $streamIds)) {
  667.                     $streamIds[] = $crossSelling->getProductStreamId();
  668.                 } else {
  669.                     $this->filteredAccessories->remove($index);
  670.                 }
  671.             } else if ($crossSelling->getType() === 'productList') {
  672.                 // Abgleich per Name
  673.                 if (!in_array($crossSelling->getTranslated()['name'], $names)) {
  674.                     $names[] = $crossSelling->getTranslated()['name'];
  675.                 } else {
  676.                     $this->filteredAccessories->remove($index);
  677.                 }
  678.             }
  679.         }
  681.         //Produkte schon in cart ausfiltern
  682.         if (!empty($config['accessoriesCartFilter']))
  683.         {
  684.             foreach ($this->filteredAccessories->getElements() as $index => $crossSellingElement)
  685.             {
  686.                 $assignedProducts = $crossSellingElement->getProducts();
  687.                 $assignedProductIds = $assignedProducts->getIds();
  688.                 foreach ($assignedProductIds as $productId)
  689.                 {
  690.                     if (in_array($productId, $filteredLineItemsIds))
  691.                     {
  692.                         $assignedProducts->remove($productId);
  693.                     }
  694.                 }
  695.                 if ($assignedProducts->count() > 0)
  696.                 {
  697.                     $crossSellingElement->setProducts($assignedProducts);
  698.                 } else {
  700.                     $this->filteredAccessories->remove($index);
  701.                 }
  702.             }
  703.         }
  704.     }
  705. }