vendor/shopware/core/Checkout/Customer/Subscriber/CustomerMetaFieldSubscriber.php line 39

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Checkout\Customer\Subscriber;
  5. use Doctrine\DBAL\ArrayParameterType;
  6. use Doctrine\DBAL\Connection;
  7. use Shopware\Core\Checkout\Order\OrderDefinition;
  8. use Shopware\Core\Checkout\Order\OrderStates;
  9. use Shopware\Core\Defaults;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableQuery;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\DeleteCommand;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  13. use Shopware\Core\Framework\Log\Package;
  14. use Shopware\Core\Framework\Uuid\Uuid;
  15. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. /**
  19.  * @internal
  20.  */
  21. #[Package('customer-order')]
  22. class CustomerMetaFieldSubscriber implements EventSubscriberInterface
  23. {
  24.     /**
  25.      * @internal
  26.      */
  27.     public function __construct(private readonly Connection $connection)
  28.     {
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             StateMachineTransitionEvent::class => 'fillCustomerMetaDataFields',
  35.             PreWriteValidationEvent::class => 'deleteOrder',
  36.         ];
  37.     }
  39.     public function fillCustomerMetaDataFields(StateMachineTransitionEvent $event): void
  40.     {
  41.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  42.             return;
  43.         }
  45.         if ($event->getEntityName() !== 'order') {
  46.             return;
  47.         }
  49.         if ($event->getToPlace()->getTechnicalName() !== OrderStates::STATE_COMPLETED && $event->getFromPlace()->getTechnicalName() !== OrderStates::STATE_COMPLETED) {
  50.             return;
  51.         }
  53.         $this->updateCustomer([$event->getEntityId()]);
  54.     }
  56.     public function deleteOrder(PreWriteValidationEvent $event): void
  57.     {
  58.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  59.             return;
  60.         }
  62.         $orderIds = [];
  63.         foreach ($event->getCommands() as $command) {
  64.             if ($command->getDefinition()->getClass() === OrderDefinition::class
  65.                 && $command instanceof DeleteCommand
  66.             ) {
  67.                 $orderIds[] = Uuid::fromBytesToHex($command->getPrimaryKey()['id']);
  68.             }
  69.         }
  71.         $this->updateCustomer($orderIds, true);
  72.     }
  74.     /**
  75.      * @param array<string> $orderIds
  76.      */
  77.     private function updateCustomer(array $orderIds, bool $isDelete = false): void
  78.     {
  79.         if (empty($orderIds)) {
  80.             return;
  81.         }
  83.         $customerIds = $this->connection->fetchFirstColumn(
  84.             'SELECT DISTINCT LOWER(HEX(customer_id)) FROM `order_customer` WHERE order_id IN (:ids) AND order_version_id = :version AND customer_id IS NOT NULL',
  85.             ['ids' => Uuid::fromHexToBytesList($orderIds), 'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION)],
  86.             ['ids' => ArrayParameterType::STRING]
  87.         );
  89.         if (empty($customerIds)) {
  90.             return;
  91.         }
  93.         $parameters = [
  94.             'customerIds' => Uuid::fromHexToBytesList($customerIds),
  95.             'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION),
  96.             'state' => OrderStates::STATE_COMPLETED,
  97.         ];
  98.         $types = [
  99.             'customerIds' => ArrayParameterType::STRING,
  100.         ];
  102.         $whereOrder = '';
  103.         if ($isDelete) {
  104.             $whereOrder = 'AND `order`.id NOT IN (:exceptOrderIds)';
  105.             $parameters['exceptOrderIds'] = Uuid::fromHexToBytesList($orderIds);
  106.             $types['exceptOrderIds'] = ArrayParameterType::STRING;
  107.         }
  109.         $select = '
  110.             SELECT `order_customer`.customer_id as id,
  111.                    COUNT(`order`.id) as order_count,
  112.                    SUM(`order`.amount_total) as order_total_amount,
  113.                    MAX(`order`.order_date_time) as last_order_date
  115.             FROM `order_customer`
  117.             INNER JOIN `order`
  118.                 ON `order`.id = `order_customer`.order_id
  119.                 AND `order`.version_id = `order_customer`.order_version_id
  120.                 AND `order`.version_id = :version
  121.                 ' . $whereOrder . '
  123.             INNER JOIN `state_machine_state`
  124.                 ON `state_machine_state`.id = `order`.state_id
  125.                 AND `state_machine_state`.technical_name = :state
  127.             WHERE `order_customer`.customer_id IN (:customerIds)
  128.             GROUP BY `order_customer`.customer_id
  129.         ';
  131.         $data = $this->connection->fetchAllAssociative($select, $parameters, $types);
  133.         if (empty($data)) {
  134.             foreach ($customerIds as $customerId) {
  135.                 $data[] = [
  136.                     'id' => Uuid::fromHexToBytes($customerId),
  137.                     'order_count' => 0,
  138.                     'order_total_amount' => 0,
  139.                     'last_order_date' => null,
  140.                 ];
  141.             }
  142.         }
  144.         $update = new RetryableQuery(
  145.             $this->connection,
  146.             $this->connection->prepare('UPDATE `customer` SET order_count = :order_count, order_total_amount = :order_total_amount, last_order_date = :last_order_date WHERE id = :id')
  147.         );
  149.         foreach ($data as $record) {
  150.             $update->execute($record);
  151.         }
  152.     }
  153. }