custom/plugins/MojeBambinoExtensions/src/Subscriber/CategoryPageSubscriber.php line 22

Open in your IDE?
  1. <?php
  3. namespace MojeBambino\Extensions\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Doctrine\DBAL\Connection;
  7. use Shopware\Storefront\Page\Navigation\NavigationPageLoadedEvent;
  8. use MojeBambino\Extensions\Struct\Kafelki;
  10. class CategoryPageSubscriber implements EventSubscriberInterface {
  11.     
  12.     private Connection $connection;
  13.     
  14.     public function __construct(Connection $connection){
  15.         $this->connection = $connection;
  16.     }
  17.     
  18.     public static function getSubscribedEvents(): array{
  19.         return [NavigationPageLoadedEvent::class => 'onCategoryPageLoaded'];
  20.     }
  21.     
  22.     public function onCategoryPageLoaded(NavigationPageLoadedEvent $event): void{
  23.         $category = $event->getPage()->getCmsPage();
  24.         $IdKat = "";
  25.         
  26.         $sections = $category->getSections();
  27.         $i = 1;
  28.         foreach($sections->getElements() as $elem){
  29.             foreach($elem->getBlocks()->getElements() as $elem1){
  30.                 if($elem1->getType()=="product-listing"){
  31.                     foreach($elem1->getSlots() as $slot){
  32.                         $ost = $slot->getData()->getListing()->getCurrentFilters();
  33.                         $IdKat = $ost['navigationId'];
  34.                     } 
  35.                 }
  36.             }
  37.             $i++;
  38.         }
  39.         
  40.         $kafelki = new Kafelki();
  41.         
  42.         if($IdKat && $IdKat!=""){
  43.             $query = $this->connection->createQueryBuilder();
  44.             $query->select(['k.*'])->from('kafelki_kategorie', 'kk');
  45.             $query->join('kk', 'kafelki', 'k', 'kk.Id=k.Id');
  46.             $query->join('kk', 'category', 'c', 'kk.IdKat=c.auto_increment');
  47.             $query->where('hex(c.id)= :IdKat')->andWhere("k.active=1");
  48.             $query->setParameter('IdKat', $IdKat);
  49.             $statement = $query->execute();
  50.             $kaf = $statement->fetchAll(\PDO::FETCH_ASSOC);
  51.             $kafelki->setKafle($kaf);
  52.         }
  53.         
  54.         $category->addExtension('kafelki', $kafelki);
  55.     }
  56. }