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

Open in your IDE?
  1. <?php
  2. declare (strict_types=1);
  4. namespace Crehler\MojeBambinoEngine\Subscriber;
  6. use Shopware\Core\Checkout\Cart\Price\QuantityPriceCalculator;
  7. use Shopware\Core\Checkout\Cart\Price\Struct\QuantityPriceDefinition;
  8. use Shopware\Core\Checkout\Cart\Tax\Struct\TaxRule;
  9. use Shopware\Core\Checkout\Cart\Tax\Struct\TaxRuleCollection;
  10. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  11. use Shopware\Core\Content\Product\ProductEntity;
  12. use Shopware\Core\Content\Product\SalesChannel\Price\ProductPriceCalculator;
  13. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class ProductListResultSubscriber implements EventSubscriberInterface
  20. {
  21.     private EntityRepository $productRepository;
  22.     private QuantityPriceCalculator $quantityPriceCalculator;
  24.     public function __construct(
  25.         EntityRepository        $productRepository,
  26.         QuantityPriceCalculator $quantityPriceCalculator
  27.     )
  28.     {
  29.         $this->productRepository = $productRepository;
  30.         $this->quantityPriceCalculator = $quantityPriceCalculator;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             ProductListingResultEvent::class => 'onProductListingResult',
  37.         ];
  38.     }
  40.     public function onProductListingResult(ProductListingResultEvent $event): void
  41.     {
  42.         try {
  45.             $products = $event->getResult()->getEntities();
  47.             /** @var SalesChannelProductEntity $product */
  48.             foreach ($products as $product) {
  50.                 $parentId = $product->getParentId();
  51.                 if (!$parentId && $product->getChildCount()) {
  52.                     $parentId = $product->getId();
  53.                 }
  55.                 if (!$parentId) {
  56.                     continue;
  57.                 }
  59.                 $this->calculateVersionPrices($event, $product, $parentId);
  60.             }
  61.         } catch (\Throwable $exception) {
  62.             dd($exception);
  63.         }
  64.     }
  66.     private function calculateVersionPrices(ProductListingResultEvent $event, SalesChannelProductEntity $productEntity, string $parentId): void
  67.     {
  68.         $criteria = new Criteria([$parentId]);
  69.         $criteria->getAssociation('children')
  70.             ->addFilter(new EqualsFilter('active', true));
  72.         /** @var SalesChannelProductEntity $parentProduct */
  73.         /** @var ProductEntity $child */
  74.         $parentProduct = $this->productRepository->search($criteria, $event->getContext())->first();
  76.         foreach ($parentProduct->getChildren() as $child) {
  77.             $taxRulesCollection = new TaxRuleCollection();
  78.             $taxRule = new TaxRule($child->getTax()->getTaxRate());
  79.             $taxRulesCollection->set($child->getTax()->getTaxRate(), $taxRule);
  80.             $priceDefinition = new QuantityPriceDefinition(
  81.                 $child->getPrice()->getCurrencyPrice($event->getContext()->getCurrencyId())->getNet(),
  82.                 $taxRulesCollection
  83.             );
  85.             $calculatedPrice = $this->quantityPriceCalculator->calculate($priceDefinition, $event->getSalesChannelContext());
  86.             $productEntity->getCalculatedPrices()->add($calculatedPrice);
  87.         }
  89.         $productEntity->getCalculatedPrices()->sort(fn($price1, $price2) => $price1->getUnitPrice() < $price2->getUnitPrice() ? -1 : 1);
  90.     }
  91. }