custom/plugins/NimbitsProductSuccessorNext/src/Subscriber/Subscriber.php line 57

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Nimbits\NimbitsProductSuccessorNext\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Shopware\Core\Content\Product\ProductEvents;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  11. use Shopware\Core\Content\Cms\CmsPageEntity;
  12. use Symfony\Component\HttpKernel\KernelEvents;
  13. use Symfony\Component\HttpKernel\Event\KernelEvent;
  14. use Shopware\Storefront\Event\StorefrontRenderEvent;
  15. use Shopware\Storefront\Pagelet\Footer\FooterPageletLoadedEvent;
  16. use Nimbits\NimbitsProductSuccessorNext\Setting\Service\SettingService;
  17. use Shopware\Core\Framework\Struct\ArrayEntity;
  18. use Shopware\Core\Framework\Struct\StructCollection;
  20. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  23. use Shopware\Core\Content\Product\SalesChannel\Detail\AbstractProductDetailRoute;
  26. class Subscriber implements EventSubscriberInterface
  27. {
  28.     
  29.     /** @var SettingService $settingsService */
  30.     protected $settingsService;
  31.     
  32.     /** @var AbstractProductDetailRoute $productDetailRoute */
  33.     protected $productDetailRoute;
  34.     
  35.     /** @var EntityRepositoryInterface $productSuccessorRepository */
  36.     protected $productSuccessorRepository;
  38.     public function __construct(
  39.         SettingService $settingsService,
  40.         AbstractProductDetailRoute $productDetailRoute,
  41.         EntityRepositoryInterface $productSuccessorRepository
  42.     ) 
  43.     {
  44.         $this->settingsService = $settingsService;
  45.         $this->productDetailRoute = $productDetailRoute;
  46.         $this->productSuccessorRepository = $productSuccessorRepository;
  47.     }
  49.     public static function getSubscribedEvents(): array
  50.     {
  51.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  52.         return [
  53.             ProductPageLoadedEvent::class => 'onProductPageLoaded'
  54.         ];
  55.     }
  56.     
  57.     public function onProductPageLoaded(ProductPageLoadedEvent $event)
  58.     {
  59.         $productId = $event->getPage()->getProduct()->getId();
  60.         
  61.         $event->getPage()->getProduct()->addExtension('nimbitsProductSuccessorSettings', $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId()));
  62.         
  63.         $successors = $this->productSuccessorRepository->search(
  64.                 (new Criteria())
  65.                     ->addFilter(new EqualsFilter('productIdFrom', $productId)),
  66.                 \Shopware\Core\Framework\Context::createDefaultContext()
  67.         );
  68.         
  69.         $successors = $successors->getElements();
  70.         if(count($successors) == 0)
  71.             return;
  72.         
  73.         $sucessorArticles = [];
  74.         
  75.         foreach($successors as $k => $successor)
  76.         {
  77.             try
  78.             {
  79.                 $criteria = (new Criteria())
  80.                 ->addAssociation('manufacturer.media')
  81.                 ->addAssociation('options.group')
  82.                 ->addAssociation('properties.group')
  83.                 ->addAssociation('mainCategories.category');
  85.                 $criteria
  86.                 ->getAssociation('media');
  87.             
  88.                 $sucessorArticles[] = $this->productDetailRoute->load($successor->getProductIdTo(), 
  89.                     $event->getRequest(), $event->getSalesChannelContext(), $criteria)->getProduct();
  90.             }
  91.             catch(\Exception $e)
  92.             {
  93.                 //there might be inactivate products in the list; we must not display them and just skip therefore
  94.             }
  95.         }
  96.         
  97.         $event->getPage()->getProduct()->addExtension('nimbitsProductSuccessor', (new StructCollection())->assign(['articles' => $sucessorArticles]));
  98.     }
  101.     
  102. }
  103. ?>