custom/plugins/ZeobvBundleProducts/src/Core/Subscriber/ProductSubscriber.php line 54

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Zeobv\BundleProducts\Core\Subscriber;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Shopware\Core\Framework\Struct\ArrayStruct;
  9. use Shopware\Core\Content\Product\ProductEntity;
  10. use Shopware\Core\Content\Product\ProductEvents;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  12. use Shopware\Core\Content\Product\Aggregate\ProductPrice\ProductPriceCollection;
  13. use Shopware\Core\Content\Product\DataAbstractionLayer\CheapestPrice\CheapestPriceContainer;
  14. use Zeobv\BundleProducts\Factory\ProductBundleFactory;
  15. use Zeobv\BundleProducts\Struct\BundleProduct\BundlePrice;
  16. use Zeobv\BundleProducts\Service\ConfigService;
  17. use Zeobv\BundleProducts\Repository\BundleProductRepository;
  18. use Zeobv\BundleProducts\Struct\BundleProduct\ProductBundle;
  20. class ProductSubscriber implements EventSubscriberInterface
  21. {
  22.     protected BundleProductRepository $bundleProductRepository;
  23.     protected ProductBundleFactory $productBundleFactory;
  24.     protected ConfigService $configService;
  26.     public function __construct(
  27.         BundleProductRepository $bundleProductRepository,
  28.         ProductBundleFactory $productBundleFactory,
  29.         ConfigService $configService
  30.     ) {
  31.         $this->bundleProductRepository = $bundleProductRepository;
  32.         $this->productBundleFactory = $productBundleFactory;
  33.         $this->configService = $configService;
  34.     }
  36.     /**
  37.      * @return array
  38.      */
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             ProductEvents::PRODUCT_LOADED_EVENT => [
  43.                 ['onProductLoaded', -1]
  44.             ],
  45.         ];
  46.     }
  48.     /**
  49.      * @param EntityLoadedEvent $event
  50.      *
  51.      * @throws \Doctrine\DBAL\Driver\Exception
  52.      * @throws \Doctrine\DBAL\Exception
  53.      */
  54.     public function onProductLoaded(EntityLoadedEvent $event): void
  55.     {
  56.         // We perform another query to get the bundle products,
  57.         // check for the context so we don't want to arrive in an infinite loop
  58.         if ($event->getContext()->hasExtension('zeobvBundleProductContext')) {
  59.             /** @var ArrayStruct $arrayStruct */
  60.             $arrayStruct = $event->getContext()->getExtension('zeobvBundleProductContext');
  61.             $contextIds = $arrayStruct->all();
  62.             $oldIds = $contextIds['productIds'];
  64.             if (count(array_diff($event->getIds(), $oldIds)) == 0) {
  65.                 $event->getContext()->removeExtension('zeobvBundleProductContext');
  66.                 return;
  67.             }
  68.         }
  70.         # Create an index to be able to quickly reference products later from the ProductCollection using the product ID
  71.         $index = array_flip($event->getIds());
  73.         # Get products of bundles grouped by product id, we can call these "Bundles"
  74.         $bundles = $this->bundleProductRepository->getBundleProductContents($event->getIds(), $event->getContext());
  76.         if (count($bundles) < 1) {
  77.             return;
  78.         }
  80.         # Loop over the bundles to determine availability of the so-called "bundle product"
  81.         # and create a ProductBundle struct for later use.
  82.         foreach ($bundles as $bundleProductId => $productsInBundle) {
  84.             /** @var ProductEntity $productEntity */
  85.             $productEntity = $event->getEntities()[$index[$bundleProductId]] ?? $event->getEntities()[$bundleProductId];
  86.             $productBundle = $this->productBundleFactory->create($bundleProductId, $productsInBundle);
  88.             if (
  89.                 $productBundle->getBundlePriceMode() === BundlePrice::BUNDLE_PRICE_MODE_SUM
  90.                 && $productBundle->getBundlePrice()
  91.             ) {
  92.                 # Set new price
  93.                 $productEntity->setPrice($productBundle->getBundlePrice()->getPrice());
  95.                 $productEntity->setPrices($productBundle->getAdvancedPrices() ?: new ProductPriceCollection([]));
  96.                 $productEntity->setCheapestPriceContainer(new CheapestPriceContainer([]));
  98.                 # @feature-deprecated  (flag:FEATURE_NEXT_15815) tag:v6.5.0 -
  99.                 # CheapestPrice will only be available for SalesChannelProductEntity
  100.                 if (method_exists($productEntity, 'setCheapestPrice')) {
  101.                     $productEntity->setCheapestPrice(null);
  102.                 }
  103.             }
  105.             if ($this->configService->overridePurchasePrice()) {
  106.                 $productEntity->setPurchasePrices($productBundle->getBundlePurchasePrice()->getPrice());
  107.             }
  109.             if ($productBundle->getOverrideStockFieldOfBundleProduct()) {
  110.                 $productEntity->setStock($productBundle->getVirtualStock());
  111.             }
  113.             $productEntity->setAvailableStock($productBundle->getVirtualAvailableStock());
  114.             if ($this->configService->getOverrideMaxPurchase()) {
  115.                 $productEntity->setMaxPurchase($productBundle->getMaxPurchase());
  116.             }
  118.             $productEntity->setIsCloseout($productBundle->isBackordersDisabled());
  120.             if ($productBundle->getDeliveryTime() !== null) {
  121.                 $productEntity->setDeliveryTimeId($productBundle->getDeliveryTime()->getId());
  122.                 $productEntity->setDeliveryTime($productBundle->getDeliveryTime());
  123.             }
  125.             if (!$this->configService->getOverrideBundleWeight() &&  $productBundle->getWeight() > 0) {
  126.                 $productEntity->setWeight($productBundle->getWeight());
  127.             } elseif ($this->configService->getOverrideBundleWeight()) {
  128.                 $productEntity->setWeight($this->configService->getBundleWeightOverride());
  129.             }
  131.             if ($productBundle->isBackordersDisabled()) {
  132.                 $productEntity->setAvailable($productBundle->isInStock());
  133.             }
  135.             $productEntity->addExtension(ProductBundle::EXTENSION_NAME, $productBundle);
  136.         }
  137.     }
  138. }