custom/plugins/SchilderSysteme/src/Subscriber/HeaderSubscriber.php line 39

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace SchilderSysteme\Subscriber;
  6. use Doctrine\DBAL\Connection;
  7. use SchilderSysteme\Traits\ThemeTrait;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Storefront\Pagelet\Header\HeaderPageletLoadedEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class HeaderSubscriber implements EventSubscriberInterface
  14. {
  15.     use ThemeTrait;
  17.     private $productRepository;
  18.     private $connection;
  19.     private $themeRepository;
  21.     public function __construct(
  22.         EntityRepositoryInterface $productRepository,
  23.         Connection $connection,
  24.         EntityRepositoryInterface $themeRepository
  25.     )
  26.     {
  27.         $this->productRepository = $productRepository;
  28.         $this->connection = $connection;
  29.         $this->themeRepository = $themeRepository;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             HeaderPageletLoadedEvent::class => 'onHeaderLoaded'
  36.         ];
  37.     }
  39.     public function onHeaderLoaded(HeaderPageletLoadedEvent $event)
  40.     {
  41.         if(!$this->isCorrectTheme($event->getContext(), $event->getSalesChannelContext(), $this->themeRepository)){
  42.             return;
  43.         }
  45.         $topsellerIds = $this->getTopsellersIds();
  47.         $criteria = new Criteria($topsellerIds);
  48.         $products = $this->productRepository->search($criteria, $event->getContext());
  50.         $event->getPagelet()->addExtension('topsellerProducts', $products);
  51.     }
  53.     private function getTopsellersIds()
  54.     {
  55.         $queryBuilder = $this->connection->createQueryBuilder();
  57.         return $queryBuilder->select('referenced_id, label, sum(quantity) as sales')
  58.             ->from('order_line_item', 'item')
  59.             ->join('item', 'product', 'product', 'item.product_id = product.id')
  60.             ->where('product.active = 1')
  61.             ->groupBy('item.product_id')
  62.             ->orderBy('sales', 'desc')
  63.             ->setMaxResults(20)
  64.             ->execute()->fetchFirstColumn();
  65.     }
  66. }