vendor/shopware/core/Content/Product/SalesChannel/Price/ProductPriceCalculator.php line 294

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Product\SalesChannel\Price;
  5. use Shopware\Core\Checkout\Cart\Price\QuantityPriceCalculator;
  6. use Shopware\Core\Checkout\Cart\Price\Struct\CartPrice;
  7. use Shopware\Core\Checkout\Cart\Price\Struct\PriceCollection as CalculatedPriceCollection;
  8. use Shopware\Core\Checkout\Cart\Price\Struct\QuantityPriceDefinition;
  9. use Shopware\Core\Checkout\Cart\Price\Struct\ReferencePriceDefinition;
  10. use Shopware\Core\Content\Product\Aggregate\ProductPrice\ProductPriceCollection;
  11. use Shopware\Core\Content\Product\DataAbstractionLayer\CheapestPrice\CalculatedCheapestPrice;
  12. use Shopware\Core\Content\Product\DataAbstractionLayer\CheapestPrice\CheapestPrice;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Entity;
  14. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Pricing\Price;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Pricing\PriceCollection;
  17. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  18. use Shopware\Core\Framework\Log\Package;
  19. use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
  20. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  21. use Shopware\Core\System\Unit\UnitCollection;
  23. #[Package('inventory')]
  24. class ProductPriceCalculator extends AbstractProductPriceCalculator
  25. {
  26.     private ?UnitCollection $units = null;
  28.     /**
  29.      * @internal
  30.      */
  31.     public function __construct(
  32.         private readonly EntityRepository $unitRepository,
  33.         private readonly QuantityPriceCalculator $calculator
  34.     ) {
  35.     }
  37.     public function getDecorated(): AbstractProductPriceCalculator
  38.     {
  39.         throw new DecorationPatternException(self::class);
  40.     }
  42.     /**
  43.      * @param Entity[] $products
  44.      */
  45.     public function calculate(iterable $products, SalesChannelContext $context): void
  46.     {
  47.         $units = $this->getUnits($context);
  49.         /** @var Entity $product */
  50.         foreach ($products as $product) {
  51.             $this->calculatePrice($product, $context, $units);
  52.             $this->calculateAdvancePrices($product, $context, $units);
  53.             $this->calculateCheapestPrice($product, $context, $units);
  54.         }
  55.     }
  57.     public function reset(): void
  58.     {
  59.         $this->units = null;
  60.     }
  62.     private function calculatePrice(Entity $product, SalesChannelContext $context, UnitCollection $units): void
  63.     {
  64.         $price = $product->get('price');
  65.         $taxId = $product->get('taxId');
  67.         if ($price === null || $taxId === null) {
  68.             return;
  69.         }
  70.         $reference = ReferencePriceDto::createFromEntity($product);
  72.         $definition = $this->buildDefinition($product, $price, $context, $units, $reference);
  74.         $price = $this->calculator->calculate($definition, $context);
  76.         $product->assign([
  77.             'calculatedPrice' => $price,
  78.         ]);
  79.     }
  81.     private function calculateAdvancePrices(Entity $product, SalesChannelContext $context, UnitCollection $units): void
  82.     {
  83.         $prices = $product->get('prices');
  85.         $product->assign(['calculatedPrices' => new CalculatedPriceCollection()]);
  86.         if ($prices === null) {
  87.             return;
  88.         }
  90.         if (!$prices instanceof ProductPriceCollection) {
  91.             return;
  92.         }
  94.         $prices = $this->filterRulePrices($prices, $context);
  95.         if ($prices === null) {
  96.             return;
  97.         }
  98.         $prices->sortByQuantity();
  100.         $reference = ReferencePriceDto::createFromEntity($product);
  102.         $calculated = new CalculatedPriceCollection();
  103.         foreach ($prices as $price) {
  104.             $quantity = $price->getQuantityEnd() ?? $price->getQuantityStart();
  106.             $definition = $this->buildDefinition($product, $price->getPrice(), $context, $units, $reference, $quantity);
  108.             $calculated->add($this->calculator->calculate($definition, $context));
  109.         }
  111.         $product->assign(['calculatedPrices' => $calculated]);
  112.     }
  114.     private function calculateCheapestPrice(Entity $product, SalesChannelContext $context, UnitCollection $units): void
  115.     {
  116.         $cheapest = $product->get('cheapestPrice');
  118.         if ($product->get('taxId') === null) {
  119.             return;
  120.         }
  122.         if (!$cheapest instanceof CheapestPrice) {
  123.             $price = $product->get('price');
  124.             if ($price === null) {
  125.                 return;
  126.             }
  128.             $reference = ReferencePriceDto::createFromEntity($product);
  130.             $definition = $this->buildDefinition($product, $price, $context, $units, $reference);
  132.             $calculated = CalculatedCheapestPrice::createFrom(
  133.                 $this->calculator->calculate($definition, $context)
  134.             );
  136.             $prices = $product->get('calculatedPrices');
  138.             $hasRange = $prices instanceof CalculatedPriceCollection && $prices->count() > 1;
  140.             $calculated->setHasRange($hasRange);
  142.             $product->assign(['calculatedCheapestPrice' => $calculated]);
  144.             return;
  145.         }
  147.         $reference = ReferencePriceDto::createFromCheapestPrice($cheapest);
  149.         $definition = $this->buildDefinition($product, $cheapest->getPrice(), $context, $units, $reference);
  151.         $calculated = CalculatedCheapestPrice::createFrom(
  152.             $this->calculator->calculate($definition, $context)
  153.         );
  154.         $calculated->setVariantId($cheapest->getVariantId());
  156.         $calculated->setHasRange($cheapest->hasRange());
  158.         $product->assign(['calculatedCheapestPrice' => $calculated]);
  159.     }
  161.     private function buildDefinition(
  162.         Entity $product,
  163.         PriceCollection $prices,
  164.         SalesChannelContext $context,
  165.         UnitCollection $units,
  166.         ReferencePriceDto $reference,
  167.         int $quantity = 1
  168.     ): QuantityPriceDefinition {
  169.         $price = $this->getPriceValue($prices, $context);
  171.         $taxId = $product->get('taxId');
  172.         $definition = new QuantityPriceDefinition($price, $context->buildTaxRules($taxId), $quantity);
  173.         $definition->setReferencePriceDefinition(
  174.             $this->buildReferencePriceDefinition($reference, $units)
  175.         );
  176.         $definition->setListPrice(
  177.             $this->getListPrice($prices, $context)
  178.         );
  179.         $definition->setRegulationPrice(
  180.             $this->getRegulationPrice($prices, $context)
  181.         );
  183.         return $definition;
  184.     }
  186.     private function getPriceValue(PriceCollection $price, SalesChannelContext $context): float
  187.     {
  188.         /** @var Price $currency */
  189.         $currency = $price->getCurrencyPrice($context->getCurrencyId());
  191.         $value = $this->getPriceForTaxState($currency, $context);
  193.         if ($currency->getCurrencyId() !== $context->getCurrency()->getId()) {
  194.             $value *= $context->getContext()->getCurrencyFactor();
  195.         }
  197.         return $value;
  198.     }
  200.     private function getPriceForTaxState(Price $price, SalesChannelContext $context): float
  201.     {
  202.         if ($context->getTaxState() === CartPrice::TAX_STATE_GROSS) {
  203.             return $price->getGross();
  204.         }
  206.         return $price->getNet();
  207.     }
  209.     private function getListPrice(PriceCollection $prices, SalesChannelContext $context): ?float
  210.     {
  211.         $price = $prices->getCurrencyPrice($context->getCurrency()->getId());
  212.         if ($price === null || $price->getListPrice() === null) {
  213.             return null;
  214.         }
  216.         $value = $this->getPriceForTaxState($price->getListPrice(), $context);
  218.         if ($price->getCurrencyId() !== $context->getCurrency()->getId()) {
  219.             $value *= $context->getContext()->getCurrencyFactor();
  220.         }
  222.         return $value;
  223.     }
  225.     private function getRegulationPrice(PriceCollection $prices, SalesChannelContext $context): ?float
  226.     {
  227.         $price = $prices->getCurrencyPrice($context->getCurrency()->getId());
  228.         if ($price === null || $price->getRegulationPrice() === null) {
  229.             return null;
  230.         }
  232.         $taxPrice = $this->getPriceForTaxState($price, $context);
  233.         $value = $this->getPriceForTaxState($price->getRegulationPrice(), $context);
  234.         if ($taxPrice === 0.0 || $taxPrice === $value) {
  235.             return null;
  236.         }
  238.         if ($price->getCurrencyId() !== $context->getCurrency()->getId()) {
  239.             $value *= $context->getContext()->getCurrencyFactor();
  240.         }
  242.         return $value;
  243.     }
  245.     private function buildReferencePriceDefinition(ReferencePriceDto $definition, UnitCollection $units): ?ReferencePriceDefinition
  246.     {
  247.         if (
  248.             $definition->getPurchase() === null
  249.             || $definition->getPurchase() <= 0
  250.             || $definition->getUnitId() === null
  251.             || $definition->getReference() === null
  252.             || $definition->getReference() <= 0
  253.             || $definition->getPurchase() === $definition->getReference()
  254.         ) {
  255.             return null;
  256.         }
  258.         $unit = $units->get($definition->getUnitId());
  259.         if ($unit === null) {
  260.             return null;
  261.         }
  263.         return new ReferencePriceDefinition(
  264.             $definition->getPurchase(),
  265.             $definition->getReference(),
  266.             $unit->getTranslation('name')
  267.         );
  268.     }
  270.     private function filterRulePrices(ProductPriceCollection $rules, SalesChannelContext $context): ?ProductPriceCollection
  271.     {
  272.         foreach ($context->getRuleIds() as $ruleId) {
  273.             $filtered = $rules->filterByRuleId($ruleId);
  275.             if (\count($filtered) > 0) {
  276.                 return $filtered;
  277.             }
  278.         }
  280.         return null;
  281.     }
  283.     private function getUnits(SalesChannelContext $context): UnitCollection
  284.     {
  285.         if ($this->units !== null) {
  286.             return $this->units;
  287.         }
  289.         $criteria = new Criteria();
  290.         $criteria->setTitle('product-price-calculator::units');
  292.         /** @var UnitCollection $units */
  293.         $units = $this->unitRepository
  294.             ->search($criteria, $context->getContext())
  295.             ->getEntities();
  297.         return $this->units = $units;
  298.     }
  299. }