vendor/crehler/mojebambino-engine/src/Subscriber/ProductPriceRangeSubscriber.php line 49

Open in your IDE?
  1. <?php
  4. namespace Crehler\MojeBambinoEngine\Subscriber;
  7. use Crehler\MojeBambinoEngine\Service\ProductPriceRangeService;
  8. use Shopware\Core\Content\Product\ProductEvents;
  9. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ProductPriceRangeSubscriber implements EventSubscriberInterface
  18. {
  19.     private ProductPriceRangeService $productPriceRange;
  20.     private bool $skip = false;
  22.     public function __construct(ProductPriceRangeService $productPriceRange)
  23.     {
  24.         $this->productPriceRange = $productPriceRange;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'onProductWritten',
  31. //            ProductEvents::PRODUCT_LOADED_EVENT => 'onProductLoaded'
  32.         ];
  33.     }
  35.     public function onProductLoaded(EntityLoadedEvent $event)
  36.     {
  37. //        $products = $event->getEntities();
  38. //        dd($products);
  39. //
  40. //        /** @var SalesChannelProductEntity $product */
  41. //        foreach ($products as $product) {
  42. //            if ($product instanceof SalesChannelProductEntity && !$product->hasExtension('priceRange')) {
  43. //                $product->addExtension('priceRange', $this->productStatusService->getProductPrices($product, $event->getContext()));
  44. //            }
  45. //        }
  46.     }
  49.     public function onProductWritten(EntityWrittenEvent $event)
  50.     {
  51.         try {
  52.             if ($this->skip) return;
  53.             $this->skip = true;
  55.             foreach ($event->getWriteResults() as $elements) {
  56.                 $id = $elements->getPrimaryKey();
  57.                 $this->productPriceRange->getProductPrices($id, $event->getContext());
  58.             }
  59.         } catch (\Throwable $exception) {
  60.             dd($exception);
  61.         }
  64.     }
  66. }