custom/plugins/WbfkBundles/src/Subscriber/ProductSubscriber.php line 139

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wbfk\Bundles\Subscriber;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\Exception;
  9. use Shopware\Core\Content\Product\ProductEvents;
  10. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  11. use Shopware\Core\Defaults;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  17. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  18. use Shopware\Core\System\SystemConfig\SystemConfigService;
  19. use Shopware\Storefront\Page\Product\ProductPageCriteriaEvent;
  20. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. use Wbfk\Bundles\Core\Content\Product\DataAbstractionLayer\BundleFilter;
  23. use Wbfk\Bundles\Core\Content\Product\DataAbstractionLayer\BundleStockUpdater;
  24. use Wbfk\Bundles\Entity\Bundle\BundleProductCollection;
  25. use Wbfk\Bundles\Service\BundleProductDeliveryAndAvailabilityCalculator;
  26. use WbfkExtensions\Core\Content\WbfkProductExtension\WbfkProductExtensionEntity;
  27. use ApplifactionPriceMachine\Service\ProductPriceCalculationService;
  29. class ProductSubscriber implements EventSubscriberInterface
  30. {
  31.     public function __construct(
  32.         protected readonly BundleProductDeliveryAndAvailabilityCalculator $bundleProductDeliveryAndAvailabilityCalculator,
  33.         protected readonly EntityRepository $bundleProductRepository,
  34.         protected readonly SystemConfigService $systemConfigService,
  35.         protected readonly Connection $connection,
  36.         protected readonly BundleFilter $bundleFilter,
  37.         protected readonly BundleStockUpdater $bundleStockUpdater,
  38.         protected readonly ?ProductPriceCalculationService $productPriceCalculationService
  39.     ) {
  40.     }
  42.     public static function getSubscribedEvents(): array
  43.     {
  44.         return [
  45.             'sales_channel.product.loaded' => 'onProductLoaded',
  46.             ProductPageCriteriaEvent::class => 'onProductCriteriaLoaded',
  47.             ProductPageLoadedEvent::class => 'onProductPageLoaded',
  48.             ProductEvents::PRODUCT_WRITTEN_EVENT => [['queueBundleParentPriceCalculation'], ['updateBundleCloseoutStatus']],
  49.         ];
  50.     }
  52.     public function getBundles(string $productId, SalesChannelContext $scContext): BundleProductCollection
  53.     {
  54.         $context = $scContext->getContext();
  55.         $criteria = new Criteria();
  56.         $criteria->setTitle("Getting bundle products child products data");
  57.         $criteria->addAssociation('childProduct');
  58.         $criteria->addFilter(new EqualsFilter('productId', $productId));
  60.         /** @var BundleProductCollection $bundles */
  61.         $bundles = $this->bundleProductRepository->search($criteria, $context)->getEntities();
  63.         return $bundles;
  64.     }
  66.     public function onProductLoaded(SalesChannelEntityLoadedEvent $event)
  67.     {
  68.         $products = $event->getEntities();
  69.         $scContext = $event->getSalesChannelContext();
  71.         $sysMaxQuantity = $this->systemConfigService->getInt(
  72.             'core.cart.maxQuantity',
  73.             $scContext->getSalesChannel()->getId()
  74.         );
  77.         /** @var SalesChannelProductEntity $scProduct */
  78.         foreach ($products as $scProduct) {
  79.             $bundles = $this->getBundles($scProduct->getId(), $scContext);
  81.             if ($bundles->count() === 0) {
  82.                 return null;
  83.             }
  85.             /** @noinspection PhpDeprecationInspection */
  86.             $scProduct->addExtension('wbfk_bundle_product', $bundles);
  88.             // Calculate the max available Quantity.
  89.             $steps = $scProduct->get('purchaseSteps') ?? 1;
  90.             $min = $scProduct->get('minPurchase') ?? 1;
  91.             $max = $scProduct->get('maxPurchase') ?? $sysMaxQuantity;
  93.             // If the max Quantity is set to "0", we ignore it.
  94.             // #1124: ANG12299  kann nicht angenommen werden
  95.             $max = $max <= 0 ? $sysMaxQuantity : $max;
  97.             // the amount of times the purchase step is fitting in between min and max added to the minimum
  98.             $max = \floor(($max - $min) / $steps) * $steps + $min;
  99.             $maxPurchase = [$max];
  101.             // Consider Child-Articles
  102.             $parentCloseOut = $scProduct->get('isCloseout');
  103.             foreach ($bundles as $bundleProduct) {
  104.                 $childProduct = $bundleProduct->getChildProduct();
  105.                 /*
  106.                  * If the bundle or the child is in clearance sale (closeout) we restrict the bundle by the stock of the child article.
  107.                  * But we ignore the configured quantities on the child, since quantities can and should be configured on the bundle product.
  108.                  */
  109.                 if ($childProduct->get('isCloseout') || $parentCloseOut) {
  110.                     $stock = (int)$childProduct->get('availableStock');
  112.                     /** @var WbfkProductExtensionEntity $wpe */
  113.                     if ($wpe = $childProduct->getExtension('WbfkProductExtension')) {
  114.                         $stock = $wpe->getSuppliersTotalStock();
  115.                     }
  117.                     // Also consider if this child is multiple times in the bundle
  118.                     $maxPurchase[] = floor($stock / $bundleProduct->getQuantity());
  119.                 }
  120.             }
  121.             $scProduct->setCalculatedMaxPurchase((int)min($maxPurchase));
  122.         }
  123.     }
  125.     public function onProductCriteriaLoaded(ProductPageCriteriaEvent $event): void
  126.     {
  127.         $event->getCriteria()->addAssociation('wbfk_bundle_product');
  128.     }
  130.     public function onProductPageLoaded(ProductPageLoadedEvent $event): void
  131.     {
  132.         $product = $event->getPage()->getProduct();
  133.         if (!$product->getExtension('wbfk_bundle_product')->count()) {
  134.             return;
  135.         }
  136.         $this->bundleProductDeliveryAndAvailabilityCalculator->calculatedDeliveryAndAvailability($product, $event->getSalesChannelContext());
  137.     }
  139.     public function queueBundleParentPriceCalculation(EntityWrittenEvent $event): void
  140.     {
  141.         // Only queue the price calculation of bundle parents, if the Price Machine Plugin is installed.
  142.         if (!$this->productPriceCalculationService) {
  143.             return;
  144.         }
  146.         $bundleParentIdSql = '
  147.                 SELECT 
  148.                     LOWER(HEX(wbp.product_id)) AS parent_product_id
  149.                 FROM wbfk_bundle_product wbp
  150.                 WHERE LOWER(HEX(wbp.child_product_id)) = :childProductId
  151.                     AND LOWER(HEX(wbp.product_version_id)) = :versionId
  152.                     AND LOWER(HEX(wbp.child_product_version_id)) = :versionId
  153.                 GROUP BY wbp.product_id';
  155.         foreach ($event->getWriteResults() as $entityWriteResult) {
  156.             $bundleChildProductId = $entityWriteResult->getPrimaryKey();
  158.             $bundleParentIdResults = $this->connection->fetchAllAssociative($bundleParentIdSql, [
  159.                 'childProductId' => $bundleChildProductId,
  160.                 'versionId' => Defaults::LIVE_VERSION,
  161.             ]);
  163.             foreach ($bundleParentIdResults as $bundleParentIdResult) {
  164.                 $this->productPriceCalculationService->queueProductPriceCalculation($bundleParentIdResult['parent_product_id']);
  165.             }
  166.         }
  167.     }
  170.     /**
  171.      * @throws Exception
  172.      */
  173.     public function updateBundleCloseoutStatus(EntityWrittenEvent $event): void
  174.     {
  175.         $closeoutUpdatedProductIds = array_reduce($event->getPayloads(), function (array $closeOutUpdatedProductIds, array $payload) {
  176.             if (isset($payload['isCloseout'])) {
  177.                 $closeOutUpdatedProductIds[] = $payload['id'];
  178.             }
  180.             return $closeOutUpdatedProductIds;
  181.         }, []);
  183.         $bundleChildrenIds = $this->bundleFilter->filterBundleChildrenIds($closeoutUpdatedProductIds, $event->getContext());
  184.         $bundleIds = $this->bundleFilter->findParentIds($bundleChildrenIds, $event->getContext());
  185.         $this->bundleStockUpdater->updateBundleStockAndAvailability($bundleIds, $event->getContext());
  186.     }
  188. }