vendor/shopware/core/Checkout/Promotion/DataAbstractionLayer/PromotionRedemptionUpdater.php line 90

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Promotion\DataAbstractionLayer;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  7. use Shopware\Core\Checkout\Promotion\Cart\PromotionProcessor;
  8. use Shopware\Core\Checkout\Promotion\PromotionDefinition;
  9. use Shopware\Core\Defaults;
  10. use Shopware\Core\Framework\Adapter\Cache\CacheClearer;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableQuery;
  13. use Shopware\Core\Framework\Uuid\Uuid;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class PromotionRedemptionUpdater implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var Connection
  20.      */
  21.     private $connection;
  23.     /**
  24.      * @var CacheClearer
  25.      */
  26.     private $cacheClearer;
  28.     public function __construct(Connection $connection, CacheClearer $cacheClearer)
  29.     {
  30.         $this->connection = $connection;
  31.         $this->cacheClearer = $cacheClearer;
  32.     }
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             CheckoutOrderPlacedEvent::class => 'orderPlaced',
  38.         ];
  39.     }
  41.     public function update(array $ids, Context $context): void
  42.     {
  43.         $ids = array_filter(array_unique($ids));
  45.         if (empty($ids) || $context->getVersionId() !== Defaults::LIVE_VERSION) {
  46.             return;
  47.         }
  49.         $sql = <<<SQL
  50.                 SELECT JSON_UNQUOTE(JSON_EXTRACT(`order_line_item`.`payload`, '$.promotionId')) as promotion_id,
  51.                        COUNT(DISTINCT order_line_item.id) as total,
  52.                        LOWER(HEX(order_customer.customer_id)) as customer_id
  53.                 FROM order_line_item
  54.                 INNER JOIN order_customer
  55.                     ON order_customer.order_id = order_line_item.order_id
  56.                     AND order_customer.version_id = order_line_item.version_id
  57.                 WHERE order_line_item.type = :type
  58.                 AND JSON_EXTRACT(`order_line_item`.`payload`, "$.promotionId") IN (:ids)
  59.                 AND order_line_item.version_id = :versionId
  60.                 GROUP BY JSON_EXTRACT(`order_line_item`.`payload`, "$.promotionId"), order_customer.customer_id
  61. SQL;
  63.         $promotions = $this->connection->fetchAll(
  64.             $sql,
  65.             ['type' => PromotionProcessor::LINE_ITEM_TYPE, 'ids' => $ids, 'versionId' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION)],
  66.             ['ids' => Connection::PARAM_STR_ARRAY]
  67.         );
  69.         if (empty($promotions)) {
  70.             return;
  71.         }
  72.         $update = new RetryableQuery(
  73.             $this->connection->prepare('UPDATE promotion SET order_count = :count, orders_per_customer_count = :customerCount WHERE id = :id')
  74.         );
  76.         // group the promotions to update each promotion with a single update statement
  77.         $promotions = $this->groupByPromotion($promotions);
  79.         foreach ($promotions as $id => $totals) {
  80.             $total = array_sum($totals);
  82.             $update->execute([
  83.                 'id' => Uuid::fromHexToBytes($id),
  84.                 'count' => (int) $total,
  85.                 'customerCount' => json_encode($totals),
  86.             ]);
  87.         }
  88.     }
  90.     public function orderPlaced(CheckoutOrderPlacedEvent $event): void
  91.     {
  92.         $lineItems = $event->getOrder()->getLineItems();
  94.         if (!$lineItems) {
  95.             return;
  96.         }
  98.         $promotionIds = $lineItems
  99.             ->filterByType(PromotionProcessor::LINE_ITEM_TYPE)
  100.             ->getPayloadsProperty('promotionId');
  102.         // update redemption counts immediately
  103.         $this->update($promotionIds, $event->getContext());
  105.         $this->cacheClearer->invalidateIds($promotionIds, PromotionDefinition::ENTITY_NAME);
  106.     }
  108.     private function groupByPromotion(array $promotions): array
  109.     {
  110.         $grouped = [];
  111.         foreach ($promotions as $promotion) {
  112.             $id = $promotion['promotion_id'];
  113.             $customerId = $promotion['customer_id'];
  114.             $grouped[$id][$customerId] = (int) $promotion['total'];
  115.         }
  117.         return $grouped;
  118.     }
  119. }