vendor/crehler/arrangements/src/Subscriber/ProductListingResultSubscriber.php line 62

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * @copyright 2020 Crehler Sp. z o. o. <https://crehler.com>
  4.  *
  5.  * @author    Jakub Medyński <jme@crehler.com>
  6.  * @support   Crehler <support@crehler.com>
  7.  * @created   27 lip 2020
  8.  *
  9.  * For the full copyright and license information, please view the LICENSE
  10.  * file that was distributed with this source code.
  11.  */
  13. namespace Crehler\Arrangements\Subscriber;
  16. use Crehler\Arrangements\Entity\Arrangement\ArrangementEntity;
  17. use Crehler\Arrangements\Service\ArrangementService;
  18. use Crehler\MojeBambinoEngine\Service\ProductStatusStorefrontService;
  19. use Monolog\Logger;
  20. use PhpOffice\PhpSpreadsheet\Calculation\Logical\Boolean;
  21. use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
  22. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  23. use Shopware\Core\Content\Product\ProductEvents;
  24. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  25. use Shopware\Core\Framework\Context;
  26. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  27. use Shopware\Core\Framework\Struct\ArrayStruct;
  28. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  29. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  31. class ProductListingResultSubscriber implements EventSubscriberInterface
  32. {
  33.     public function __construct(
  34.         private readonly ArrangementService $arrangementService,
  35.         private readonly ProductStatusStorefrontService $productStatusService,
  36.         private bool $skip = false
  37.     )
  38.     {
  39.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             ProductEvents::PRODUCT_LISTING_RESULT => 'handleListingLoaded',
  46.             ProductPageLoadedEvent::class => 'handleProductLoaded',
  47.             'arrangement_product.loaded' => 'handleProductArrangementLoaded',
  48.             ProductIndexerEvent::class =>['onProductIndexer', 1],
  49.         ];
  50.     }
  53.     public function handleProductArrangementLoaded(EntityLoadedEvent $event): void
  54.     {
  55.         foreach ($event->getEntities() as $arrangementsProduct) {
  56.             $product = $arrangementsProduct->getProduct();
  58.             $product->addExtension('productStatus', $this->productStatusService->getProductStatus($product, $event->getContext()));
  59.         }
  60.     }
  62.     public function onProductIndexer($event)
  63.     {
  64.         $this->skip = true;
  65.     }
  67.     public function handleProductLoaded(ProductPageLoadedEvent $event): void
  68.     {
  69.         if ($event->getContext()->getScope() === Context::CRUD_API_SCOPE ||
  70.             $event->getContext()->getScope() === Context::SYSTEM_SCOPE ||
  71.             $this->skip
  72.         ) {
  73.             return;
  74.         }
  75.         /** @var ArrayStruct $foreignKeys */
  76.         $foreignKeys = $event->getPage()->getProduct()->getExtension('foreignKeys');
  77.         if (null !== $foreignKeys->offsetGet('arrangementId')) {
  78.             $arrangement = $this->arrangementService->getArrangementById(
  79.                 $foreignKeys->offsetGet('arrangementId'),
  80.                 $event->getSalesChannelContext(),
  81.                 $event->getRequest()
  82.             );
  83.             $event->getPage()->getProduct()->addExtension('arrangement', $arrangement);
  84.             /** @var ArrangementEntity $arrangement */
  85.             $arrangement = $event->getPage()->getProduct()->getExtension('arrangement');
  86.             $arrangement->setMainProduct($event->getPage()->getProduct());
  87.         }
  88.     }
  90.     public function handleListingLoaded(ProductListingResultEvent $event): void
  91.     {
  92.         if ($event->getContext()->getScope() === Context::CRUD_API_SCOPE) {
  93.             return;
  94.         }
  96.         /** @var SalesChannelProductEntity $product */
  97.         foreach ($event->getResult()->getElements() as $product) {
  99.             /** @var ArrayStruct $foreignKeys */
  100.             $foreignKeys = $product->getExtension('foreignKeys');
  101.             if (null !== $foreignKeys->offsetGet('arrangementId')) {
  102.                 $arrangement = $this->arrangementService->getArrangementById(
  103.                     $foreignKeys->offsetGet('arrangementId'),
  104.                     $event->getSalesChannelContext(),
  105.                     $event->getRequest()
  106.                 );
  107.                 $product->addExtension('arrangement', $arrangement);
  108.             }
  109.         }
  110.     }
  112. }