vendor/crehler/mojebambino-engine/src/Subscriber/ProductStatusSubscriber.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /**
  3.  * @copyright 2021 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   13 sty 2021
  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\MojeBambinoEngine\Subscriber;
  16. use Crehler\MojeBambinoEngine\Service\ProductStatusStorefrontService;
  17. use Shopware\Core\Content\Product\ProductEvents;
  18. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  20. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. class ProductStatusSubscriber implements EventSubscriberInterface
  24. {
  25.     private ProductStatusStorefrontService $productStatusService;
  27.     public function __construct(ProductStatusStorefrontService $productStatusService)
  28.     {
  29.         $this->productStatusService = $productStatusService;
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             ProductEvents::PRODUCT_LOADED_EVENT => 'onProductLoaded',
  36.             SalesChannelEntityLoadedEvent::class => 'onProductLoaded'
  37.         ];
  38.     }
  40.     public function onProductLoaded(EntityLoadedEvent $event): void
  41.     {
  42.         try {
  43.             $products = $event->getEntities();
  45.             /** @var SalesChannelProductEntity $product */
  46.             foreach ($products as $product) {
  47.                 if ($product instanceof SalesChannelProductEntity && !$product->hasExtension('productStatus')) {
  48.                     $product->addExtension('productStatus', $this->productStatusService->getProductStatus($product, $event->getContext()));
  49.                 }
  50.             }
  51.         } catch (\Throwable $exception) {
  52.             dd($exception);
  53.         }
  54.     }
  56. }