custom/plugins/EsmCmsExtensions/src/Storefront/Subscriber/OfferSubscriber.php line 56

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace EsmCmsExtensions\Storefront\Subscriber;
  6. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Storefront\Page\Navigation\NavigationPageLoadedEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class OfferSubscriber implements EventSubscriberInterface
  14. {
  15.     protected EntityRepository $offerRepository;
  17.     public function __construct(EntityRepository $offerRepository)
  18.     {
  19.         $this->offerRepository = $offerRepository;
  20.     }
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             ProductListingResultEvent::class => 'onProductListingResult',
  26.             NavigationPageLoadedEvent::class => 'onNavigationPageLoaded',
  27.         ];
  28.     }
  30.     public function onProductListingResult(ProductListingResultEvent $event): void
  31.     {
  32.         $categoryId = $event->getRequest()->get('navigationId');
  33.         if(!$categoryId) {
  34.             return;
  35.         }
  37.         $criteria = new Criteria();
  38.         $criteria->addFilter(new EqualsFilter('categories.id', $categoryId));
  39.         $offer = $this->offerRepository->search($criteria, $event->getContext())->first();
  41.         $event->getResult()->addExtension('offer', $offer);
  42.     }
  44.     public function onNavigationPageLoaded(NavigationPageLoadedEvent $event): void
  45.     {
  46.         $navigationId = $event->getRequest()->attributes->get('navigationId');
  47.         if(!$navigationId) {
  48.             return;
  49.         }
  51.         $criteria = new Criteria();
  52.         $criteria->addFilter(new EqualsFilter('categories.id', $navigationId));
  53.         $offer = $this->offerRepository->search($criteria, $event->getContext())->first();
  54.         $event->getPage()->addExtension('offer', $offer);
  56.     }
  57. }