custom/plugins/WbfkBundles/src/Subscriber/PriceMachineSubscriber.php line 118

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Wbfk\Bundles\Subscriber;
  5. use ApplifactionPriceMachine\Event\BasePriceCalculatedEvent;
  6. use ApplifactionPriceMachine\Event\BeforeProductPricesCalculateEvent;
  7. use ApplifactionPriceMachine\Event\ProductPricesCalculatedEvent;
  8. use ApplifactionPriceMachine\Service\ProductPriceCalculationService;
  9. use Doctrine\DBAL\Connection;
  10. use Psr\Log\LoggerInterface;
  11. use Shopware\Core\Defaults;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class PriceMachineSubscriber implements EventSubscriberInterface
  16. {
  18.     public function __construct(
  19.         private readonly Connection                      $connection,
  20.         private readonly ?ProductPriceCalculationService $productPriceCalculationService,
  21.         private readonly EntityRepository                $productRepository,
  22.         private readonly ?LoggerInterface                $logger
  23.     )
  24.     {
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             BasePriceCalculatedEvent::class => 'calculateBundleChildrenSummaryPrice',
  31.             ProductPricesCalculatedEvent::class => 'runBundleParentPriceCalculations',
  32.             BeforeProductPricesCalculateEvent::class => 'runBundleParentBasePriceCalculation'
  33.         ];
  34.     }
  36.     public function calculateBundleChildrenSummaryPrice(BasePriceCalculatedEvent $event): void
  37.     {
  39.         if ($event->hasTemporaryPrice() && !$event->isListPrice()) return;
  41.         $bundleChildrenPriceSql = 'SELECT 
  42.                     LOWER(HEX(cp.id)) AS child_product_id,
  43.                     cpp.quantity_start AS product_price_quantity_start,
  44.                     bp.quantity AS quantity,
  45.                     LOWER(HEX(cpp.rule_id)) AS rule_id,
  46.                     IFNULL(cpp.price, IFNULL(cp.price, cpa.price)) AS price
  47.                 FROM wbfk_bundle_product bp
  48.                 INNER JOIN product cp ON bp.child_product_id = cp.id AND bp.child_product_version_id = cp.version_id
  49.                 LEFT JOIN product_price cpp ON cpp.product_id = cp.id 
  50.                    AND cpp.product_version_id = cp.version_id 
  51.                    AND :quantity >= cpp.quantity_start  
  52.                    AND (:quantity <= cpp.quantity_end || cpp.quantity_end IS NULL) 
  53.                    AND LOWER(HEX(cpp.rule_id)) = :ruleId
  54.                 LEFT JOIN product cpa ON cp.parent_id = cpa.id AND cp.version_id = cpa.version_id
  55.                 WHERE LOWER(HEX(bp.product_id)) = :productId
  56.                    AND LOWER(HEX(bp.product_version_id)) = :versionId
  57.                 ORDER BY cp.id ASC, cpp.quantity_start ASC';
  59.         $bundleChildrenPriceResults = $this->connection->fetchAllAssociative($bundleChildrenPriceSql, [
  60.             'quantity' => $event->getQuantityStart(),
  61.             'ruleId' => $event->getRuleId(),
  62.             'productId' => $event->getProductId(),
  63.             'versionId' => Defaults::LIVE_VERSION
  64.         ]);
  66.         $totalNet = 0;
  67.         $totalGross = 0;
  68.         foreach ($bundleChildrenPriceResults as $bundleChildrenPriceResult) {
  69.             $childProductId = $bundleChildrenPriceResult['child_product_id'];
  70.             $quantity = $bundleChildrenPriceResult['quantity'];
  71.             $priceRaw = $bundleChildrenPriceResult['price'];
  72.             $priceArray = json_decode($bundleChildrenPriceResult['price'], true);
  74.             if (isset($priceArray[$event->getCurrencyId()])) {
  75.                 $totalGross += $priceArray[$event->getCurrencyId()]['gross'] * $quantity;
  76.                 $totalNet += $priceArray[$event->getCurrencyId()]['net'] * $quantity;
  77.             }
  79.         }
  81.         // Modify event price
  82.         if ($totalNet === 0 || $totalGross === 0) {
  83.             $event->setPrice(null);
  84.         } else {
  85.             $eventPrice = $event->getPrice();
  86.             $eventPrice['gross'] = $totalGross;
  87.             $eventPrice['net'] = $totalNet;
  88.             $event->setPrice($eventPrice);
  89.         }
  91.     }
  93.     public function runBundleParentPriceCalculations(ProductPricesCalculatedEvent $event)
  94.     {
  95.         if (!$this->productPriceCalculationService) return;
  97.         $selectBundleParentsSql = <<<SQL
  98.             SELECT LOWER(HEX(product_id)) AS product_id
  99.             FROM wbfk_bundle_product bp
  100.             WHERE 
  101.                 LOWER(HEX(bp.product_version_id)) = :versionId AND
  102.                 LOWER(HEX(bp.child_product_id)) = :childProductId AND
  103.                 LOWER(HEX(bp.child_product_version_id)) = :versionId
  104.             GROUP BY bp.product_id
  105.         SQL;
  107.         $bundleChildrenPriceResults = $this->connection->fetchAllAssociative($selectBundleParentsSql, [
  108.             'childProductId' => $event->getProductId(),
  109.             'versionId' => Defaults::LIVE_VERSION
  110.         ]);
  112.         foreach ($bundleChildrenPriceResults as $bundleChildrenPriceResult) {
  113.             $this->productPriceCalculationService->runProductPriceCalculation($bundleChildrenPriceResult['product_id'], $event->isDryRun());
  114.         }
  116.     }
  118.     public function runBundleParentBasePriceCalculation(BeforeProductPricesCalculateEvent $event)
  119.     {
  121.         if (!$this->productPriceCalculationService) return;
  123.         $productId = $event->getProductId();
  125.         // Check if product is a bundle parent with no active temporary prices
  126.         $bundleParentCheckSql = <<<SQL
  127.             SELECT p.price AS price
  128.             FROM product p
  129.             INNER JOIN wbfk_bundle_product bp ON p.id = bp.product_id AND p.version_id = bp.product_version_id
  130.             LEFT JOIN apm_temporary_price atp ON atp.product_id = p.id AND 
  131.                                                  atp.product_version_id = p.version_id AND 
  132.                                                  :currentDate >= atp.valid_from AND
  133.                                                  :currentDate <= atp.valid_to
  134.             WHERE 
  135.                 LOWER(HEX(bp.product_version_id)) = :versionId AND
  136.                 LOWER(HEX(bp.product_id)) = :productId AND
  137.                 atp.id IS NULL
  138.             LIMIT 1
  139.         SQL;
  141.         $bundleParentCheckResults = $this->connection->fetchAllAssociative($bundleParentCheckSql, [
  142.             'productId' => $event->getProductId(),
  143.             'versionId' => Defaults::LIVE_VERSION,
  144.             'currentDate' => gmdate("Y-m-d H:i:s")
  145.         ]);
  147.         if (sizeof($bundleParentCheckResults) === 0 || !isset($bundleParentCheckResults[0]['price'])) return;
  149.         $standardCustomerPriceRuleId = '257e09ae47eb4823bdc0f59ed7ce242a';
  150.         $currencyId = 'cb7d2554b0ce847cd82f3ac9bd1c0dfca';
  151.         $parentProductPrices = json_decode($bundleParentCheckResults[0]['price'], true);
  152.         $parentProductPrice = isset($parentProductPrices[$currencyId]) ? $parentProductPrices[$currencyId] : null;
  153.         if (!$parentProductPrice) return;
  155.         $basePriceCalculatedEvent = new BasePriceCalculatedEvent($parentProductPrice, $productId, $standardCustomerPriceRuleId, 1, $currencyId, false);
  156.         $this->calculateBundleChildrenSummaryPrice($basePriceCalculatedEvent);
  157.         $childrenSummaryPrice = $basePriceCalculatedEvent->getPrice();
  158.         if ($parentProductPrice['gross'] !== $childrenSummaryPrice['gross'] || $parentProductPrice['net'] !== $childrenSummaryPrice['net']) {
  159.             $differenceNet = $childrenSummaryPrice['net'] - $parentProductPrice['net'];
  160.             $parentProductPrice['gross'] = $childrenSummaryPrice['gross'];
  161.             $parentProductPrice['net'] = $childrenSummaryPrice['net'];
  162.             $parentProductPrices[$currencyId] = $parentProductPrice;
  163.             $this->productRepository->update([[
  164.                 'id' => $productId,
  165.                 'price' => $parentProductPrices
  166.             ]], $event->getContext());
  167.             if (!!$this->logger) {
  168.                 $this->logger->info('[BUNDLE PRICE] Bundle Parent Price was updated. Difference (net): ' . $differenceNet . ' P-ID: ' . $productId . ' New Price: ' . json_encode($parentProductPrice));
  169.             }
  170.         }
  173.     }
  175. }