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

Open in your IDE?
  1. <?php
  3. namespace MojeBambino\Extensions\Subscriber;
  5. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  6. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  7. use Doctrine\DBAL\Connection;
  8. use MojeBambino\Extensions\Struct\Dopiski;
  10. class ProductPageSubscriber 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 [ProductPageLoadedEvent::class => 'onProductPageLoaded'];
  20.     }
  21.     
  22.     public function onProductPageLoaded(ProductPageLoadedEvent $event): void{
  23.         $page = $event->getPage();
  24.         $product = $page->getProduct();
  25.         //echo "<pre>"; print_r($product); echo "</pre>";
  26.         $kod = $product->getProductNumber();
  27.         $dopiski = new Dopiski();
  28.         
  29.         $q = $this->connection->createQueryBuilder();
  30.         $q->select(['d.*'])->from('dopiski_kody', 'dk');
  31.         $q->join('dk', 'dopiski', 'd', 'dk.Id=d.Id');
  32.         $q->where('dk.kod= :kod');
  33.         $q->setParameter('kod', $kod);
  34.         $st = $q->execute();
  35.         $dop = $st->fetchAll(\PDO::FETCH_ASSOC);
  36.         $dopiski->setDopiski($dop);
  37.         
  38.         $q6 = $this->connection->createQueryBuilder();
  39.         $q6->select(['*'])->from('wzrost_ceny')->where('kod= :kod')->setMaxResults(1);
  40.         $q6->setParameter('kod', $kod);
  41.         $st6 = $q6->execute();
  42.         $d6 = $st6->fetchAll(\PDO::FETCH_ASSOC);
  43.         if(count($d6)>0){
  44.             foreach($d6 as $dop){
  45.                 $dopiski->setWzrostCeny($dop['data']);
  46.             }
  47.         }
  48.         else{
  49.             $dopiski->setWzrostCeny(count($d6));    
  50.         }
  51.         
  52.         $q7 = $this->connection->createQueryBuilder();
  53.         $q7->select(['*'])->from('cena_do_daty')->where('kod= :kod')->andWhere('data>="'.date("Y-m-d").'"')->setMaxResults(1);
  54.         $q7->setParameter('kod', $kod);
  55.         //echo $q7->getSQL(); 
  56.         $st7 = $q7->execute();
  57.         $d7 = $st7->fetchAll(\PDO::FETCH_ASSOC);
  58.         if(count($d7)>0){
  59.             foreach($d7 as $dop){
  60.                 $dopiski->setCenaDoDaty($dop['data']);
  61.             }
  62.         }
  63.         else{
  64.             $dopiski->setCenaDoDaty(count($d7));
  65.         }
  66.         
  67.         $q8 = $this->connection->createQueryBuilder();
  68.         $q8->select(['*'])->from('omnibus_cena')->where('kod= :kod')->setMaxResults(1);
  69.         $q8->setParameter('kod', $kod);
  70.         $st8 = $q8->execute();
  71.         $d8 = $st8->fetchAll(\PDO::FETCH_ASSOC);
  72.         if(count($d8)>0){
  73.             foreach($d8 as $dop){
  74.                 $dopiski->setOmnibusCena(str_replace(".", ",", $dop['cena'])." zł");
  75.             }
  76.         }
  77.         else{
  78.             $dopiski->setOmnibusCena(count($d8));
  79.         }
  80.         
  81.         $q9 = $this->connection->createQueryBuilder();
  82.         $q9->select(['*'])->from('omnibus_info')->setMaxResults(1);
  83.         $st9 = $q9->execute();
  84.         $d9 = $st9->fetchAll(\PDO::FETCH_ASSOC);
  85.         if(count($d9)>0){
  86.             foreach($d9 as $dop){
  87.                 $dopiski->setOmnibusInfo($dop['info']);
  88.             }
  89.         }
  90.         else{
  91.             $dopiski->setOmnibusInfo(count($d9));
  92.         }
  93.         
  94.         $product->addExtension('dopiski', $dopiski);
  95.     }
  96. }