vendor/shopware/core/Content/Product/SalesChannel/SalesChannelProductSubscriber.php line 49

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Product\SalesChannel;
  5. use Shopware\Core\Checkout\Cart\Price\QuantityPriceCalculator;
  6. use Shopware\Core\Checkout\Cart\Price\Struct\PriceCollection;
  7. use Shopware\Core\Content\Product\ProductEntity;
  8. use Shopware\Core\Content\Product\SalesChannel\Price\ProductPriceDefinitionBuilderInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Pricing\CalculatedListingPrice;
  10. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  11. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  12. use Shopware\Core\System\SystemConfig\SystemConfigService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class SalesChannelProductSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var QuantityPriceCalculator
  19.      */
  20.     private $priceCalculator;
  22.     /**
  23.      * @var ProductPriceDefinitionBuilderInterface
  24.      */
  25.     private $priceDefinitionBuilder;
  27.     /**
  28.      * @var SystemConfigService
  29.      */
  30.     private $systemConfigService;
  32.     public function __construct(
  33.         QuantityPriceCalculator $priceCalculator,
  34.         ProductPriceDefinitionBuilderInterface $priceDefinitionBuilder,
  35.         SystemConfigService $systemConfigService
  36.     ) {
  37.         $this->priceCalculator = $priceCalculator;
  38.         $this->priceDefinitionBuilder = $priceDefinitionBuilder;
  39.         $this->systemConfigService = $systemConfigService;
  40.     }
  42.     public static function getSubscribedEvents()
  43.     {
  44.         return [
  45.             'sales_channel.product.loaded' => 'loaded',
  46.         ];
  47.     }
  49.     public function loaded(SalesChannelEntityLoadedEvent $event): void
  50.     {
  51.         /** @var SalesChannelProductEntity $product */
  52.         foreach ($event->getEntities() as $product) {
  53.             $this->calculatePrices($event->getSalesChannelContext(), $product);
  55.             $product->setCalculatedMaxPurchase(
  56.                 $this->calculateMaxPurchase($product, $event->getSalesChannelContext()->getSalesChannel()->getId())
  57.             );
  59.             $this->markAsNew($event->getSalesChannelContext(), $product);
  61.             $product->setGrouped(
  62.                 $this->isGrouped($product)
  63.             );
  64.         }
  65.     }
  67.     private function isGrouped(ProductEntity $product): bool
  68.     {
  69.         if ($product->getMainVariantId() !== null) {
  70.             return false;
  71.         }
  73.         // get all configured expanded groups
  74.         $groups = array_filter(
  75.             (array) $product->getConfiguratorGroupConfig(),
  76.             static function (array $config) {
  77.                 return $config['expressionForListings'] ?? false;
  78.             }
  79.         );
  81.         // get ids of groups for later usage
  82.         $groups = array_column($groups, 'id');
  84.         // expanded group count matches option count? All variants are displayed
  85.         if ($product->getOptionIds() !== null && \count($groups) === \count($product->getOptionIds())) {
  86.             return false;
  87.         }
  89.         if ($product->getParentId()) {
  90.             return true;
  91.         }
  93.         return false;
  94.     }
  96.     private function calculatePrices(SalesChannelContext $context, SalesChannelProductEntity $product): void
  97.     {
  98.         $prices = $this->priceDefinitionBuilder->build($product, $context);
  100.         //calculate listing price
  101.         $product->setCalculatedListingPrice(
  102.             new CalculatedListingPrice(
  103.                 $this->priceCalculator->calculate($prices->getFrom(), $context),
  104.                 $this->priceCalculator->calculate($prices->getTo(), $context)
  105.             )
  106.         );
  108.         $priceCollection = new PriceCollection();
  109.         foreach ($prices->getPrices() as $price) {
  110.             $priceCollection->add($this->priceCalculator->calculate($price, $context));
  111.         }
  113.         //calculate context prices
  114.         $product->setCalculatedPrices($priceCollection);
  116.         //calculate simple price
  117.         $product->setCalculatedPrice(
  118.             $this->priceCalculator->calculate($prices->getPrice(), $context)
  119.         );
  120.     }
  122.     private function calculateMaxPurchase(SalesChannelProductEntity $product, string $salesChannelId): int
  123.     {
  124.         $fallback = $this->systemConfigService->getInt('core.cart.maxQuantity', $salesChannelId);
  126.         $max = $product->getMaxPurchase() ?? $fallback;
  128.         if ($product->getIsCloseout() && $product->getAvailableStock() < $max) {
  129.             $max = (int) $product->getAvailableStock();
  130.         }
  132.         $max = floor((int) $max / ($product->getPurchaseSteps() ?? 1)) * $product->getPurchaseSteps();
  134.         return (int) max($max, 0);
  135.     }
  137.     private function markAsNew(SalesChannelContext $context, SalesChannelProductEntity $product): void
  138.     {
  139.         $markAsNewDayRange = $this->systemConfigService->get('core.listing.markAsNew', $context->getSalesChannel()->getId());
  141.         $now = new \DateTime();
  143.         /* @var SalesChannelProductEntity $product */
  144.         $product->setIsNew(
  145.             $product->getReleaseDate() instanceof \DateTimeInterface
  146.             && $product->getReleaseDate()->diff($now)->days <= $markAsNewDayRange
  147.         );
  148.     }
  149. }