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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace DISco\GA4\Subscriber;
  5. use Exception;
  6. use Shopware\Core\Checkout\Cart\LineItem\LineItemCollection;
  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\ProductListingResultEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityCollection;
  14. use Shopware\Storefront\Page\Checkout\Cart\CheckoutCartPageLoadedEvent;
  15. use Shopware\Storefront\Page\Checkout\Confirm\CheckoutConfirmPageLoadedEvent;
  16. use Shopware\Storefront\Page\Checkout\Finish\CheckoutFinishPageLoadedEvent;
  17. use Shopware\Storefront\Page\Checkout\Offcanvas\OffcanvasCartPageLoadedEvent;
  18. use Shopware\Storefront\Page\Navigation\NavigationPageLoadedEvent;
  19. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  20. use Shopware\Storefront\Page\Search\SearchPageLoadedEvent;
  21. use Shopware\Storefront\Page\Wishlist\WishlistPageLoadedEvent;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. class FrontendSubscriber implements EventSubscriberInterface
  25. {
  28.     public function __construct()
  29.     {
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  36.         return [
  37.             ProductListingCriteriaEvent::class => 'onProductListingCriteria',
  38.             SearchPageLoadedEvent::class => 'onSearchPageLoadedEvent',
  39.             ProductPageLoadedEvent::class => 'onProductPageLoadedEvent',
  40.             NavigationPageLoadedEvent::class => 'onNavigationPageLoadedEvent',
  41.             CheckoutCartPageLoadedEvent::class => 'onCheckoutCartPageLoadedEvent',
  42.             CheckoutConfirmPageLoadedEvent::class => 'onCheckoutConfirmPageLoadedEvent',
  43.             CheckoutFinishPageLoadedEvent::class => 'onCheckoutFinishPageLoadedEvent',
  44.             WishlistPageLoadedEvent::class => 'onWishlistPageLoadedEvent',
  45.             OffcanvasCartPageLoadedEvent::class => 'onOffcanvasCartPageLoadedEvent'
  46.         ];
  47.     }
  49.     public function onOffcanvasCartPageLoadedEvent(OffcanvasCartPageLoadedEvent $event): bool
  50.     {
  51.         try {
  52.             $elements = $event->getPage()->getCart()->getLineItems()->getElements();
  53.             if (!empty($elements)) {
  54.                 $collection = array_filter($elements);
  55.                 $disGA4Extension = new LineItemCollection($collection);
  56.                 $event->getContext()->addExtension('disGA4LineItemsExtension', $disGA4Extension);
  57.             }
  58.         } catch (Exception $e) {
  59.         }
  61.         return true;
  63.     }
  65.     public function onProductListingCriteria(ProductListingCriteriaEvent $event): bool
  66.     {
  67.         $event->getCriteria()->addAssociation('categories');
  68.         $event->getCriteria()->addAssociation('seoCategory');
  69.         $event->getCriteria()->addAssociation('manufacturer');
  70.         return true;
  72.     }
  75.     public function onProductListingResultEvent(ProductListingResultEvent $event): bool
  76.     {
  78.         try {
  79.             $elements = [];
  81.             foreach ($event->getResult()->getElements() as $product) {
  83.                 $elements[] = $product;
  85.             }
  87.             if (!empty($elements)) {
  88.                 $collection = array_filter($elements);
  89.                 $disGA4Extension = new EntityCollection($collection);
  90.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  92.             }
  94.         } catch (Exception $e) {
  96.         }
  98.         return true;
  101.     }
  103.     public function onWishlistPageLoadedEvent(WishlistPageLoadedEvent $event): bool
  104.     {
  106.         try {
  107.             $elements = $event->getPage()->getWishlist()->getProductListing()->getElements();
  109.             if (!empty($elements)) {
  110.                 $collection = array_filter($elements);
  111.                 $disGA4Extension = new EntityCollection($collection);
  112.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  113.             }
  114.         } catch (Exception $e) {
  115.         }
  117.         return true;
  118.     }
  121.     public function onSearchPageLoadedEvent(SearchPageLoadedEvent $event): bool
  122.     {
  123.         try {
  124.             $elements = $event->getPage()->getListing()->getElements();
  126.             if (!empty($elements)) {
  127.                 $collection = array_filter($elements);
  128.                 $disGA4Extension = new EntityCollection($collection);
  129.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  131.             }
  132.         } catch (Exception $e) {
  133.         }
  135.         return true;
  136.     }
  138.     public function onProductPageLoadedEvent(ProductPageLoadedEvent $event): bool
  139.     {
  140.         try {
  142.             $elements = [$event->getPage()->getProduct()];
  143.             $cmsList = ['product-box', 'product-slider', 'cross-selling'];
  145.             if ($event->getPage()->getProduct()->getCmsPage()) {
  146.                 try {
  147.                     $cmsElements = $event->getPage()->getCmsPage()->getSections()->getBlocks()->getSlots()->getElements();
  149.                     foreach ($cmsElements as $key => $object) {
  150.                         if (!in_array($object->getType(), $cmsList)) {
  151.                             unset($cmsElements[$key]);
  152.                         }
  153.                     }
  154.                     foreach ($cmsElements as $object) {
  156.                         $data = $object->getData();
  158.                         switch ($data) {
  159.                             case $data instanceof CrossSellingStruct:
  160.                                 if ($data->getCrossSellings()) {
  161.                                     foreach ($data->getCrossSellings()->getElements() as $crossSelling) {
  162.                                         foreach ($crossSelling->getProducts() as $product) {
  163.                                             $elements[] = $product;
  164.                                         }
  165.                                     }
  166.                                 }
  167.                                 break;
  168.                             case $data instanceof ProductBoxStruct:
  169.                                 $elements[] = $data->getProduct();
  170.                                 break;
  171.                             case $data instanceof ProductSliderStruct :
  172.                                 foreach ($data->getProducts() as $product) {
  173.                                     $elements[] = $product;
  174.                                 }
  175.                                 break;
  176.                             case $data instanceof ProductListingStruct:
  177.                                 foreach ($data->getListing()->getEntities() as $product) {
  178.                                     $elements[] = $product;
  179.                                 }
  180.                                 break;
  181.                         }
  182.                     }
  183.                 } catch (Exception $e) {
  184.                 }
  185.             } else {
  186.                 $crossSellings = $event->getPage()->getCrossSellings();
  187.                 if (!empty($crossSellings->getElements())) {
  188.                     $crossSellingsElements = $crossSellings->getElements();
  189.                     foreach ($crossSellingsElements as $crossSellingsElement) {
  190.                         foreach ($crossSellingsElement->getProducts() as $product) {
  191.                             $elements[] = $product;
  192.                         }
  193.                     }
  194.                 }
  196.             }
  199.             if (!empty($elements)) {
  200.                 $collection = array_filter($elements);
  201.                 $disGA4Extension = new EntityCollection($collection);
  202.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  203.             }
  204.         } catch (Exception $e) {
  205.         }
  207.         return true;
  209.     }
  211.     public function onNavigationPageLoadedEvent(NavigationPageLoadedEvent $event): bool
  212.     {
  213.         $cmsList = ['product-box', 'product-listing', 'product-slider', 'cross-selling'];
  214.         $elements = [];
  216.         try {
  217.             $cmsElements = $event->getPage()->getCmsPage()->getSections()->getBlocks()->getSlots()->getElements();
  219.             foreach ($cmsElements as $key => $object) {
  220.                 if (!in_array($object->getType(), $cmsList)) {
  221.                     unset($cmsElements[$key]);
  222.                 }
  223.             }
  224.             foreach ($cmsElements as $object) {
  226.                 $data = $object->getData();
  228.                 switch ($data) {
  229.                     case $data instanceof CrossSellingStruct:
  230.                         if ($data->getCrossSellings()) {
  231.                             foreach ($data->getCrossSellings()->getElements() as $crossSelling) {
  232.                                 foreach ($crossSelling->getProducts() as $product) {
  233.                                     $elements[] = $product;
  234.                                 }
  235.                             }
  236.                         }
  237.                         break;
  238.                     case $data instanceof ProductBoxStruct:
  239.                         $elements[] = $data->getProduct();
  240.                         break;
  241.                     case $data instanceof ProductSliderStruct :
  242.                         foreach ($data->getProducts() as $product) {
  243.                             $elements[] = $product;
  244.                         }
  245.                         break;
  246.                     case $data instanceof ProductListingStruct:
  247.                         if ($data->getListing()) {
  248.                             foreach ($data->getListing()->getEntities() as $product) {
  249.                                 $elements[] = $product;
  250.                             }
  251.                         }
  252.                         break;
  253.                 }
  254.             }
  256.             if ($event->getPage()->getCmsPage()->getProducts()) {
  257.                 foreach ($event->getPage()->getCmsPage()->getProducts() as $product) {
  259.                     $elements[] = $product;
  261.                 }
  262.             }
  265.             if (!empty($elements)) {
  266.                 $collection = array_filter($elements);
  267.                 $disGA4Extension = new EntityCollection($collection);
  268.                 $event->getContext()->addExtension('disGA4ProductsExtension', $disGA4Extension);
  269.             }
  270.         } catch (Exception $e) {
  271.         }
  273.         return true;
  274.     }
  276.     public function onCheckoutCartPageLoadedEvent(CheckoutCartPageLoadedEvent $event): bool
  277.     {
  279.         try {
  280.             $elements = $event->getPage()->getCart()->getLineItems()->getElements();
  281.             if (!empty($elements)) {
  282.                 $collection = array_filter($elements);
  283.                 $disGA4Extension = new LineItemCollection($collection);
  284.                 $event->getContext()->addExtension('disGA4LineItemsExtension', $disGA4Extension);
  285.             }
  286.         } catch (Exception $e) {
  287.         }
  289.         return true;
  290.     }
  292.     public function onCheckoutConfirmPageLoadedEvent(CheckoutConfirmPageLoadedEvent $event): bool
  293.     {
  294.         try {
  295.             $elements = $event->getPage()->getCart()->getLineItems()->getElements();
  297.             if (!empty($elements)) {
  298.                 $collection = array_filter($elements);
  299.                 $disGA4Extension = new LineItemCollection($collection);
  300.                 $event->getContext()->addExtension('disGA4LineItemsExtension', $disGA4Extension);
  301.             }
  302.         } catch (Exception $e) {
  303.         }
  305.         return true;
  306.     }
  308.     public function onCheckoutFinishPageLoadedEvent(CheckoutFinishPageLoadedEvent $event): bool
  309.     {
  310.         try {
  311.             $elements = $event->getPage()->getOrder()->getLineItems()->getElements();
  313.             if (!empty($elements)) {
  314.                 $collection = array_filter($elements);
  315.                 $disGA4Extension = new LineItemCollection($collection);
  316.                 $event->getContext()->addExtension('disGA4LineItemsExtension', $disGA4Extension);
  317.             }
  318.         } catch (Exception $e) {
  319.         }
  321.         return true;
  322.     }
  324. }