src/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;
  22. use Symfony\Contracts\Service\ResetInterface;
  24. #[Package('inventory')]
  25. class ProductPriceCalculator extends AbstractProductPriceCalculator implements ResetInterface
  26. {
  27.     private ?UnitCollection $units = null;
  29.     /**
  30.      * @internal
  31.      */
  32.     public function __construct(
  33.         private readonly EntityRepository $unitRepository,
  34.         private readonly QuantityPriceCalculator $calculator
  35.     ) {
  36.     }
  38.     public function getDecorated(): AbstractProductPriceCalculator
  39.     {
  40.         throw new DecorationPatternException(self::class);
  41.     }
  43.     /**
  44.      * @param Entity[] $products
  45.      */
  46.     public function calculate(iterable $products, SalesChannelContext $context): void
  47.     {
  48.         $units = $this->getUnits($context);
  50.         /** @var Entity $product */
  51.         foreach ($products as $product) {
  52.             $this->calculatePrice($product, $context, $units);
  53.             $this->calculateAdvancePrices($product, $context, $units);
  54.             $this->calculateCheapestPrice($product, $context, $units);
  55.         }
  56.     }
  58.     public function reset(): void
  59.     {
  60.         $this->units = null;
  61.     }
  63.     private function calculatePrice(Entity $product, SalesChannelContext $context, UnitCollection $units): void
  64.     {
  65.         $price = $product->get('price');
  66.         $taxId = $product->get('taxId');
  68.         if ($price === null || $taxId === null) {
  69.             return;
  70.         }
  71.         $reference = ReferencePriceDto::createFromEntity($product);
  73.         $definition = $this->buildDefinition($product, $price, $context, $units, $reference);
  75.         $price = $this->calculator->calculate($definition, $context);
  77.         $product->assign([
  78.             'calculatedPrice' => $price,
  79.         ]);
  80.     }
  82.     private function calculateAdvancePrices(Entity $product, SalesChannelContext $context, UnitCollection $units): void
  83.     {
  84.         $prices = $product->get('prices');
  86.         $product->assign(['calculatedPrices' => new CalculatedPriceCollection()]);
  87.         if ($prices === null) {
  88.             return;
  89.         }
  91.         if (!$prices instanceof ProductPriceCollection) {
  92.             return;
  93.         }
  95.         $prices = $this->filterRulePrices($prices, $context);
  96.         if ($prices === null) {
  97.             return;
  98.         }
  99.         $prices->sortByQuantity();
  101.         $reference = ReferencePriceDto::createFromEntity($product);
  103.         $calculated = new CalculatedPriceCollection();
  104.         foreach ($prices as $price) {
  105.             $quantity = $price->getQuantityEnd() ?? $price->getQuantityStart();
  107.             $definition = $this->buildDefinition($product, $price->getPrice(), $context, $units, $reference, $quantity);
  109.             $calculated->add($this->calculator->calculate($definition, $context));
  110.         }
  112.         $product->assign(['calculatedPrices' => $calculated]);
  113.     }
  115.     private function calculateCheapestPrice(Entity $product, SalesChannelContext $context, UnitCollection $units): void
  116.     {
  117.         $cheapest = $product->get('cheapestPrice');
  119.         if ($product->get('taxId') === null) {
  120.             return;
  121.         }
  123.         if (!$cheapest instanceof CheapestPrice) {
  124.             $price = $product->get('price');
  125.             if ($price === null) {
  126.                 return;
  127.             }
  129.             $reference = ReferencePriceDto::createFromEntity($product);
  131.             $definition = $this->buildDefinition($product, $price, $context, $units, $reference);
  133.             $calculated = CalculatedCheapestPrice::createFrom(
  134.                 $this->calculator->calculate($definition, $context)
  135.             );
  137.             $prices = $product->get('calculatedPrices');
  139.             $hasRange = $prices instanceof CalculatedPriceCollection && $prices->count() > 1;
  141.             $calculated->setHasRange($hasRange);
  143.             $product->assign(['calculatedCheapestPrice' => $calculated]);
  145.             return;
  146.         }
  148.         $reference = ReferencePriceDto::createFromCheapestPrice($cheapest);
  150.         $definition = $this->buildDefinition($product, $cheapest->getPrice(), $context, $units, $reference);
  152.         $calculated = CalculatedCheapestPrice::createFrom(
  153.             $this->calculator->calculate($definition, $context)
  154.         );
  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. }