custom/plugins/DIScoGA4/src/Subscriber/FrontendSubscriber.php line 79

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace DISco\GA4\Subscriber;
  5. use Exception;
  6. use Psr\Log\LoggerInterface;
  7. use Shopware\Core\Content\Cms\SalesChannel\Struct\CrossSellingStruct;
  8. use Shopware\Core\Content\Cms\SalesChannel\Struct\ProductBoxStruct;
  9. use Shopware\Core\Content\Cms\SalesChannel\Struct\ProductListingStruct;
  10. use Shopware\Core\Content\Cms\SalesChannel\Struct\ProductSliderStruct;
  11. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  12. use Shopware\Core\Content\Product\Events\ProductSearchCriteriaEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityCollection;
  14. use Shopware\Storefront\Page\Navigation\NavigationPageLoadedEvent;
  15. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  16. use Shopware\Storefront\Page\Search\SearchPageLoadedEvent;
  17. use Shopware\Storefront\Page\Wishlist\WishlistPageLoadedEvent;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Swag\EnterpriseSearch\Search\Page\SearchPageLoadedEvent as EnterpriseSearchPageLoadedEvent;
  22. class FrontendSubscriber implements EventSubscriberInterface
  23. {
  24.     private LoggerInterface $logger;
  25.     
  26.     public function __construct(LoggerInterface $logger)
  27.     {
  28.         $this->logger = $logger;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             ProductListingCriteriaEvent::class => 'onProductListingCriteria',
  35.             ProductSearchCriteriaEvent::class => 'onProductSearchCriteriaEvent',
  36.             SearchPageLoadedEvent::class => 'onSearchPageLoadedEvent',
  37.             ProductPageLoadedEvent::class => 'onProductPageLoadedEvent',
  38.             NavigationPageLoadedEvent::class => 'onNavigationPageLoadedEvent',
  39.             EnterpriseSearchPageLoadedEvent::class => 'onEnterpriseSearchPageLoadedEvent',
  40.             WishlistPageLoadedEvent::class => 'onWishlistPageLoadedEvent'
  41.         ];
  42.     }
  44.     public function onEnterpriseSearchPageLoadedEvent(EnterpriseSearchPageLoadedEvent $event): void
  45.     {
  46.         try {
  47.             $elements = $event->getPage()->getListing()->getElements();
  48.             if (empty($elements)) {
  49.                 return;
  50.             }
  52.             $collection = array_filter($elements);
  53.             /* @phpstan-ignore-next-line */
  54.             $disGA4Extension = new EntityCollection($collection);
  55.             $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  56.         } catch (Exception $e) {
  57.             $this->logger->error($e->getMessage(), ['trace' => $e->getTrace()]);
  58.         }
  59.     }
  61.     public function onProductSearchCriteriaEvent(ProductSearchCriteriaEvent $event): bool
  62.     {
  63.         $event->getCriteria()->addAssociation('categories');
  64.         $event->getCriteria()->addAssociation('seoCategory');
  65.         $event->getCriteria()->addAssociation('manufacturer');
  67.         return true;
  68.     }
  70.     public function onProductListingCriteria(ProductListingCriteriaEvent $event): bool
  71.     {
  72.         $event->getCriteria()->addAssociation('categories');
  73.         $event->getCriteria()->addAssociation('seoCategory');
  74.         $event->getCriteria()->addAssociation('manufacturer');
  76.         return true;
  77.     }
  79.     public function onWishlistPageLoadedEvent(WishlistPageLoadedEvent $event): bool
  80.     {
  81.         try {
  82.             $elements = $event->getPage()->getWishlist()->getProductListing()->getElements();
  84.             if (!empty($elements)) {
  85.                 $collection = array_filter($elements);
  86.                 $disGA4Extension = new EntityCollection($collection);
  87.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  88.             }
  89.         } catch (Exception $e) {
  90.             $this->logger->error($e->getMessage(), ['trace' => $e->getTrace()]);
  91.         }
  93.         return true;
  94.     }
  96.     public function onSearchPageLoadedEvent(SearchPageLoadedEvent $event): bool
  97.     {
  98.         try {
  99.             $elements = $event->getPage()->getListing()->getElements();
  101.             if (!empty($elements)) {
  102.                 $collection = array_filter($elements);
  103.                 $disGA4Extension = new EntityCollection($collection);
  104.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  106.             }
  107.         } catch (Exception $e) {
  108.             $this->logger->error($e->getMessage(), ['trace' => $e->getTrace()]);
  109.         }
  111.         return true;
  112.     }
  114.     public function onProductPageLoadedEvent(ProductPageLoadedEvent $event): bool
  115.     {
  116.         try {
  117.             $elements = [$event->getPage()->getProduct()];
  118.             $cmsList = ['product-box', 'product-slider', 'cross-selling'];
  120.             if ($event->getPage()->getProduct()->getCmsPage()) {
  121.                 try {
  122.                     $cmsElements = $event->getPage()->getCmsPage()->getSections()->getBlocks()->getSlots()->getElements();
  124.                     foreach ($cmsElements as $key => $object) {
  125.                         if (!in_array($object->getType(), $cmsList)) {
  126.                             unset($cmsElements[$key]);
  127.                         }
  128.                     }
  129.                     foreach ($cmsElements as $object) {
  131.                         $data = $object->getData();
  133.                         switch ($data) {
  134.                             case $data instanceof CrossSellingStruct:
  135.                                 if ($data->getCrossSellings()) {
  136.                                     foreach ($data->getCrossSellings()->getElements() as $crossSelling) {
  137.                                         foreach ($crossSelling->getProducts() as $product) {
  138.                                             $elements[] = $product;
  139.                                         }
  140.                                     }
  141.                                 }
  142.                                 break;
  143.                             case $data instanceof ProductBoxStruct:
  144.                                 if (null !== $data->getProduct()) {
  145.                                     $elements[] = $data->getProduct();
  146.                                 }
  147.                                 break;
  148.                             case $data instanceof ProductSliderStruct :
  149.                                 foreach ($data->getProducts() as $product) {
  150.                                     $elements[] = $product;
  151.                                 }
  152.                                 break;
  153.                             case $data instanceof ProductListingStruct:
  154.                                 foreach ($data->getListing()->getEntities() as $product) {
  155.                                     $elements[] = $product;
  156.                                 }
  157.                                 break;
  158.                         }
  159.                     }
  160.                 } catch (Exception $e) {
  161.                     $this->logger->error($e->getMessage(), ['trace' => $e->getTrace()]);
  162.                 }
  163.             } else {
  164.                 $crossSellings = $event->getPage()->getCrossSellings();
  165.                 if (!empty($crossSellings->getElements())) {
  166.                     $crossSellingsElements = $crossSellings->getElements();
  167.                     foreach ($crossSellingsElements as $crossSellingsElement) {
  168.                         foreach ($crossSellingsElement->getProducts() as $product) {
  169.                             $elements[] = $product;
  170.                         }
  171.                     }
  172.                 }
  173.             }
  175.             if (!empty($elements)) {
  176.                 $collection = array_filter($elements);
  177.                 $disGA4Extension = new EntityCollection($collection);
  178.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  179.             }
  180.         } catch (Exception $e) {
  181.             $this->logger->error($e->getMessage(), ['trace' => $e->getTrace()]);
  182.         }
  184.         return true;
  185.     }
  187.     public function onNavigationPageLoadedEvent(NavigationPageLoadedEvent $event): bool
  188.     {
  189.         $cmsList = ['product-box', 'product-listing', 'product-slider', 'cross-selling'];
  190.         $elements = [];
  192.         try {
  193.             $cmsElements = $event->getPage()->getCmsPage()->getSections()->getBlocks()->getSlots()->getElements();
  195.             foreach ($cmsElements as $key => $object) {
  196.                 if (!in_array($object->getType(), $cmsList)) {
  197.                     unset($cmsElements[$key]);
  198.                 }
  199.             }
  200.             foreach ($cmsElements as $object) {
  202.                 $data = $object->getData();
  204.                 switch ($data) {
  205.                     case $data instanceof CrossSellingStruct:
  206.                         if ($data->getCrossSellings()) {
  207.                             foreach ($data->getCrossSellings()->getElements() as $crossSelling) {
  208.                                 foreach ($crossSelling->getProducts() as $product) {
  209.                                     $elements[] = $product;
  210.                                 }
  211.                             }
  212.                         }
  213.                         break;
  214.                     case $data instanceof ProductBoxStruct:
  215.                         if (null !== $data->getProduct()) {
  216.                             $elements[] = $data->getProduct();
  217.                         }
  218.                         break;
  219.                     case $data instanceof ProductSliderStruct :
  220.                         foreach ($data->getProducts() as $product) {
  221.                             $elements[] = $product;
  222.                         }
  223.                         break;
  224.                     case $data instanceof ProductListingStruct:
  225.                         if ($data->getListing()) {
  226.                             foreach ($data->getListing()->getEntities() as $product) {
  227.                                 $elements[] = $product;
  228.                             }
  229.                         }
  230.                         break;
  231.                 }
  232.             }
  234.             if ($event->getPage()->getCmsPage()->getProducts()) {
  235.                 foreach ($event->getPage()->getCmsPage()->getProducts() as $product) {
  237.                     $elements[] = $product;
  239.                 }
  240.             }
  242.             if (!empty($elements)) {
  243.                 $collection = array_filter($elements);
  244.                 $disGA4Extension = new EntityCollection($collection);
  245.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  246.             }
  247.         } catch (Exception $e) {
  248.             $this->logger->error($e->getMessage(), ['trace' => $e->getTrace()]);
  249.         }
  251.         return true;
  252.     }
  253. }