custom/plugins/WbfkITScope/src/Subscriber/UpdatePurchasePriceOfBundleOnChildPurchasePriceUpdate.php line 34

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wbfk\ITScope\Subscriber;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\Exception;
  9. use Shopware\Core\Content\Product\ProductEvents;
  10. use Shopware\Core\Defaults;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Wbfk\ITScope\Service\CheapestBundlePurchasePriceUpdaterService;
  15. class UpdatePurchasePriceOfBundleOnChildPurchasePriceUpdate implements EventSubscriberInterface
  16. {
  17.     public function __construct(
  18.         private readonly CheapestBundlePurchasePriceUpdaterService $cheapestBundlePurchasePriceUpdaterService,
  19.         private readonly Connection $connection,
  20.     ) {
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'onProductWritten',
  27.         ];
  28.     }
  30.     /**
  31.      * @throws \Doctrine\DBAL\Driver\Exception
  32.      * @throws Exception
  33.      */
  34.     public function onProductWritten(EntityWrittenEvent $event): void
  35.     {
  36.         $productIds = $this->findPurchasePriceUpdatedProductIds($event->getPayloads());
  37.         if (empty($productIds)) {
  38.             return;
  39.         }
  40.         $bundleParentProductIds = $this->findBundleParentProductIds($productIds);
  41.         if (empty($bundleParentProductIds)) {
  42.             return;
  43.         }
  44.         foreach ($bundleParentProductIds as $bundleParentProductId) {
  45.             $this->cheapestBundlePurchasePriceUpdaterService->updateBestPurchasePriceForBundleProductId($bundleParentProductId);
  46.         }
  47.     }
  49.     public function findPurchasePriceUpdatedProductIds(array $payloads): array
  50.     {
  51.         return array_filter(array_map(static function ($payload) {
  52.             return isset($payload['purchasePrices']) ? $payload['id'] : false;
  53.         }, $payloads));
  54.     }
  56.     /**
  57.      * @throws Exception
  58.      * @throws \Doctrine\DBAL\Driver\Exception
  59.      */
  60.     private function findBundleParentProductIds(array $childProductIds): array
  61.     {
  62.         $childProductIdsHex = implode(",", array_map(fn($childProductId) => '0x'.$childProductId, $childProductIds));
  63.         $liveVersionIdHex = '0x'.Defaults::LIVE_VERSION;
  64.         $parentProductIdQuery = <<<SQL
  65.             SELECT DISTINCT LOWER(HEX(product_id)) AS product_id
  66.             FROM wbfk_bundle_product
  67.             WHERE child_product_id IN ($childProductIdsHex)
  68.               AND product_version_id = $liveVersionIdHex
  69.             SQL;
  71.         $bundleProductRows = $this->connection->executeQuery($parentProductIdQuery)->fetchAllAssociative();
  73.         return array_map(fn($bundleProductRow) => $bundleProductRow['product_id'], $bundleProductRows);
  74.     }
  75. }