custom/static-plugins/EfbStorefront/Subscriber/CustomerPriceSubscriber.php line 38

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Uandi\EFB\Storefront\Subscriber;
  5. use Shopware\Core\Content\Product\SalesChannel\Price\AbstractProductPriceCalculator;
  6. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  9. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Uandi\EFB\Storefront\Trait\LockExtensionTrait;
  12. use VioCustomerPrice\Event\CustomerPriceEvent;
  14. class CustomerPriceSubscriber implements EventSubscriberInterface
  15. {
  16.     use LockExtensionTrait;
  18.     private const LOCK = self::class . '_lock';
  20.     private SalesChannelRepositoryInterface $productRepository;
  21.     private AbstractProductPriceCalculator $priceCalculator;
  23.     public function __construct(
  24.         SalesChannelRepositoryInterface $productRepository,
  25.         AbstractProductPriceCalculator $priceCalculator
  26.     ) {
  27.         $this->productRepository = $productRepository;
  28.         $this->priceCalculator = $priceCalculator;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             CustomerPriceEvent::class => 'recalculateCheapestPrice',
  35.         ];
  36.     }
  38.     public function recalculateCheapestPrice(CustomerPriceEvent $event): void
  39.     {
  40.         $product = $event->getProduct();
  41.         $context = $event->getContext();
  43.         if ($this->locked($context, self::LOCK)) {
  44.             return;
  45.         }
  47.         if (null === $product->getParentId()) {
  48.             return;
  49.         }
  51.         $variants = $this->productRepository->searchIds(
  52.             (new Criteria())->addFilter(new EqualsFilter('active', true))->addFilter(new EqualsFilter('parentId', $product->getParentId())),
  53.             $context
  54.         );
  56.         if ($variants->getTotal() <= 1) {
  57.             return;
  58.         }
  60.         $this->lock($context, self::LOCK);
  61.         $products = $this->productRepository->search((new Criteria($variants->getIds()))->addFilter(new EqualsFilter('active', true)), $context);
  62.         $this->unlock($context, self::LOCK);
  64.         $products->sort(function (SalesChannelProductEntity $a, SalesChannelProductEntity $b) {
  65.             return ($a->getCalculatedCheapestPrice()->getTotalPrice()
  66.                     - $b->getCalculatedCheapestPrice()->getTotalPrice())
  67.                 * 1000;
  68.         });
  70.         $product->setCalculatedCheapestPrice($products->first()->getCalculatedCheapestPrice());
  71.     }
  72. }