custom/plugins/s360-product-recommendations/src/Subscriber/ProductDetailSubscriber.php line 42

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace S360ProductRecommendations\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Content\Cms\SalesChannel\Struct\ProductSliderStruct;
  10. use Shopware\Core\Content\ProductStream\Service\ProductStreamBuilderInterface;
  11. use Shopware\Core\Content\Product\SalesChannel\Listing\ProductListingLoader;
  14. class ProductDetailSubscriber implements EventSubscriberInterface
  15. {
  16.     private EntityRepositoryInterface $categoryRepository;
  19.     private ProductStreamBuilderInterface $productStreamBuilder;
  21.     private ProductListingLoader $listingLoader;
  23.     public function __construct(
  24.         EntityRepositoryInterface $categoryRepository,
  25.         ProductStreamBuilderInterface $productStreamBuilder,
  26.         ProductListingLoader $listingLoader
  27.     ){
  28.         $this->categoryRepository = $categoryRepository;
  29.         $this->productStreamBuilder = $productStreamBuilder;
  30.         $this->listingLoader = $listingLoader;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  36.         return [
  37.             ProductPageLoadedEvent::class => 'onProductPageLoaded'
  38.         ];
  39.     }
  41.     // load either based on dynamic product group id or based on parent category
  42.     public function onProductPageLoaded(ProductPageLoadedEvent $event)
  43.     {
  44.         $productSliderStruct = new ProductSliderStruct();
  45.         $productPage = $event->getPage();
  46.         $context = $event->getContext();
  47.         $limit = 10;
  48.         $activeCategory = $productPage->getHeader()->getNavigation()->getActive();
  49.         $translated = $activeCategory->getTranslated();
  50.         $productStreamId = $translated["customFields"]["s360_product_recommendations_dynamic_product_group"] ?? false;
  51.         $currentProductId = $productPage->getProduct()->getId();
  53.         try {
  54.             if($productStreamId){
  55.                 $filters = $this->productStreamBuilder->buildFilters($productStreamId, $context);
  56.                 $criteria = new Criteria();
  57.                 $criteria->addFilter(...$filters)->setLimit($limit);
  58.                 $searchResult = $this->listingLoader->load($criteria, $event->getSalesChannelContext());
  59.                 $products = $searchResult->getEntities();
  60.                 if($products->has($currentProductId)){
  61.                     $products->remove($currentProductId);
  62.                 }
  63.                 $productSliderStruct->setProducts($products);
  64.             } else {
  65.                 // no dynamic product group assigned: try getting 10 products from parent category
  66.                 $parentCategoryId = $activeCategory->getParentId();
  67.                 $productCollection = $this->getProductCollectionFromCat($parentCategoryId, $limit, $context);
  68.                 // if no products assigned to category, get from current category
  69.                 if($productCollection->count() === 0){
  70.                     $productCollection = $this->getProductCollectionFromCat($activeCategory->getId(), $limit, $context);
  71.                 }
  72.                 if($productCollection->count() > 0){
  73.                     // remove current product id in case it happens to be included
  74.                     $productIds = $productCollection->getIds();
  75.                     unset($productIds[$currentProductId]);
  76.                     if(count($productIds) > 0){
  77.                         $searchResult = $this->listingLoader->load(new Criteria($productIds), $event->getSalesChannelContext());
  78.                         $products = $searchResult->getEntities();
  79.                         $productSliderStruct->setProducts($products);
  80.                     }
  81.                 } 
  82.             }
  83.             // if no products found, struct will be empty
  84.             $productPage->addExtension("s360ProductRecommendations", $productSliderStruct);
  85.         } catch (\Exception $e){
  86.             // if exception, empty struct will be added
  87.             $productPage->addExtension("s360ProductRecommendations", $productSliderStruct);
  88.         }
  89.         
  90.     }
  92.     private function getProductCollectionFromCat($categoryId, $limit, $context){
  93.         $criteria = new Criteria([$categoryId]);
  94.         $criteria->addAssociation('products');
  95.         $criteria->getAssociation('products')->setLimit($limit);
  96.         $categorySearchResult = $this->categoryRepository->search($criteria, $context)->first();
  97.         // products that are assigned directly
  98.         return $categorySearchResult->getProducts();
  99.     }
  100. }