vendor/crehler/inspirations/src/Subscriber/ProductListingResultSubscriber.php line 53

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   25 wrz 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\Inspirations\Subscriber;
  15. use Crehler\Inspirations\Entity\Inspiration\Aggregate\InspirationProduct\InspirationProductEntity;
  16. use Crehler\Inspirations\Service\InspirationService;
  17. use Crehler\MojeBambinoEngine\Service\ProductStatusStorefrontService;
  18. use PhpOffice\PhpSpreadsheet\Calculation\Logical\Boolean;
  19. use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
  20. use Shopware\Core\Content\Product\ProductEvents;
  21. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  22. use Shopware\Core\Framework\Context;
  23. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  24. use Shopware\Core\Framework\Struct\ArrayStruct;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  27. class ProductListingResultSubscriber implements EventSubscriberInterface
  28. {
  29.     private InspirationService $inspirationService;
  31.     private ProductStatusStorefrontService $productStatusService;
  32.     private bool $skip = false;
  34.     public function __construct(InspirationService $inspirationService, ProductStatusStorefrontService $productStatusService)
  35.     {
  36.         $this->inspirationService = $inspirationService;
  37.         $this->productStatusService = $productStatusService;
  38.     }
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             ProductIndexerEvent::class =>['onProductIndexer', 1],
  44.             ProductEvents::PRODUCT_LOADED_EVENT => 'handleProductListingResult',
  45.             'arrangement_product.loaded' => 'handleProductInspirationLoaded'
  46.         ];
  47.     }
  49.     public function onProductIndexer($event)
  50.     {
  51.         $this->skip = true;
  52.     }
  53.     public function handleProductInspirationLoaded(EntityLoadedEvent $event): void
  54.     {
  55.         /** @var InspirationProductEntity $inspirationProduct */
  56.         foreach ($event->getEntities() as $inspirationProduct) {
  57.             $product = $inspirationProduct->getProduct();
  59.             $product->addExtension('productStatus', $this->productStatusService->getProductStatus($product, $event->getContext()));
  60.         }
  61.     }
  62.     public function handleProductListingResult(EntityLoadedEvent $event): void
  63.     {
  64.         if ($event->getContext()->getScope() === Context::CRUD_API_SCOPE ||
  65.             $event->getContext()->getScope() === Context::SYSTEM_SCOPE ||
  66.             $this->skip) {
  67.             return;
  68.         }
  70.         $products = $event->getEntities();
  71.         $context = $event->getContext();
  73.         /** @var SalesChannelProductEntity $product */
  74.         foreach ($products as $product) {
  75.             /** @var ArrayStruct $foreignKeys */
  76.             $foreignKeys = $product->getExtension('foreignKeys');
  77.             if (null !== $foreignKeys->offsetGet('inspirationId')) {
  79.                 $inspiration = $this->inspirationService->getInspirationById(
  80.                     $foreignKeys->offsetGet('inspirationId'),
  81.                     $context
  82.                 );
  84.                 $product->addExtension('inspiration', $inspiration);
  85.             }
  86.         }
  87.     }
  88. }