src/Core/Checkout/Customer/Subscriber/CustomerMetaFieldSubscriber.php line 38

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