custom/plugins/HuebertAccessoriesDirectly/src/Subscriber/CrossSellingSubscriber.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  4. namespace Huebert\AccessoriesDirectly\Subscriber;
  6. use Shopware\Core\Content\Product\ProductEntity;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Storefront\Page\Product\Configurator\ProductPageConfiguratorLoader;
  11. use Shopware\Storefront\Page\Product\CrossSelling\CrossSellingLoadedEvent;
  12. use Shopware\Storefront\Page\Product\CrossSelling\CrossSellingProductCriteriaEvent;
  13. use Shopware\Core\Content\Product\Events\ProductCrossSellingsLoadedEvent;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class CrossSellingSubscriber implements EventSubscriberInterface
  17. {
  18.     protected $optionRepository;
  20.     /**
  21.      * @var ProductPageConfiguratorLoader
  22.      */
  23.     private $configuratorLoader;
  25.     public function __construct(EntityRepositoryInterface $optionRepository, ProductPageConfiguratorLoader $configuratorLoader)
  26.     {
  27.         $this->optionRepository = $optionRepository;
  28.         $this->configuratorLoader = $configuratorLoader;
  29.     }
  32.     public static function getSubscribedEvents()
  33.     {
  34.         return [
  35.             CrossSellingLoadedEvent::class => "onCrossSellingLoaded",
  36.             ProductCrossSellingsLoadedEvent::class => "onProductCrossSellingLoaded"
  37.         ];
  38.     }
  40.     //legacy function for < 6.3.2.0
  41.     public function onCrossSellingLoaded(CrossSellingLoadedEvent $crossSellingLoadedEvent)
  42.     {
  44.         $elements = $crossSellingLoadedEvent->getCrossSellingResult()->getElements();
  45.         foreach ($elements as $element) {
  46.             $products = $element->getProducts();
  47.             foreach ($products as $product) {
  48.                 if ($product->getOptionIds()) {
  50.                     $parts = [];
  51.                     foreach ($product->getOptionIds() as $optionId) {
  52.                         $criteria = New Criteria();
  53.                         $criteria
  54.                             ->addFilter(new EqualsFilter('id', $optionId))
  55.                             ->addAssociation('group');
  56.                         $option = $this->optionRepository->search($criteria, $crossSellingLoadedEvent->getContext())->first();
  57.                         $parts[] = [
  58.                             'group' => $option->getGroup()->getTranslation('name'),
  59.                             'option' => $option->getTranslation('name')
  60.                         ];
  61.                     }
  62.                     $product->setVariation(
  63.                         $parts
  64.                     );
  66.                 }
  67.             }
  68.         }
  69.     }
  71.     public function onProductCrossSellingLoaded(ProductCrossSellingsLoadedEvent $crossSellingLoadedEvent)
  72.     {
  73.         $elements = $crossSellingLoadedEvent->getCrossSellings();
  74.         foreach ($elements as $element) {
  76.             $products = $element->getProducts();
  77.             foreach ($products as $product) {
  78.                 $_productConfigurator = $this->configuratorLoader->load($product, $crossSellingLoadedEvent->getSalesChannelContext());
  80.                 if ($product->getOptionIds() && count($product->getVariation()) === 0) {
  82.                     $parts = [];
  83.                     foreach ($product->getOptionIds() as $optionId) {
  84.                         $criteria = New Criteria();
  85.                         $criteria
  86.                             ->addFilter(new EqualsFilter('id', $optionId))
  87.                             ->addAssociation('group');
  88.                         $option = $this->optionRepository->search($criteria, $crossSellingLoadedEvent->getContext())->first();
  89.                         if ($option) {
  90.                             $groupName = null;
  91.                             if ($option->getGroup()) {
  92.                                 if ($option->getGroup()->getTranslation('name')) {
  93.                                     $groupName = $option->getGroup()->getTranslation('name');
  94.                                 }
  95.                             }
  96.                             $optionName = null;
  97.                             if ($option->getTranslation('name')) {
  98.                                 $optionName = $option->getTranslation('name');
  99.                             }
  100.                             $parts[] = [
  101.                                 'group' => $groupName,
  102.                                 'option' => $optionName
  103.                             ];
  104.                         }
  105.                     }
  106.                     if (count($parts) > 0) {
  107.                         $product->setVariation(
  108.                             $parts
  109.                         );
  110.                     }
  112.                 }
  114.                 $product->assign(
  115.                   [  'productConfigurator' => $_productConfigurator,]
  116.                 );
  117.             }
  118.         }
  119.     }
  120. }