platform/src/Core/Checkout/Customer/Subscriber/CustomerMetaFieldSubscriber.php line 33

Open in your IDE?
  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\Uuid\Uuid;
  13. use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class CustomerMetaFieldSubscriber implements EventSubscriberInterface
  17. {
  18.     private Connection $connection;
  20.     public function __construct(Connection $connection)
  21.     {
  22.         $this->connection = $connection;
  23.     }
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             StateMachineTransitionEvent::class => 'fillCustomerMetaDataFields',
  29.             PreWriteValidationEvent::class => 'deleteOrder',
  30.         ];
  31.     }
  33.     public function fillCustomerMetaDataFields(StateMachineTransitionEvent $event): void
  34.     {
  35.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  36.             return;
  37.         }
  39.         if ($event->getEntityName() !== 'order') {
  40.             return;
  41.         }
  43.         if ($event->getToPlace()->getTechnicalName() !== OrderStates::STATE_COMPLETED && $event->getFromPlace()->getTechnicalName() !== OrderStates::STATE_COMPLETED) {
  44.             return;
  45.         }
  47.         $this->updateCustomer([$event->getEntityId()]);
  48.     }
  50.     public function deleteOrder(PreWriteValidationEvent $event): void
  51.     {
  52.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  53.             return;
  54.         }
  56.         $orderIds = [];
  57.         foreach ($event->getCommands() as $command) {
  58.             if ($command->getDefinition()->getClass() === OrderDefinition::class
  59.                 && $command instanceof DeleteCommand
  60.             ) {
  61.                 $orderIds[] = Uuid::fromBytesToHex($command->getPrimaryKey()['id']);
  62.             }
  63.         }
  65.         $this->updateCustomer($orderIds, true);
  66.     }
  68.     private function updateCustomer(array $orderIds, bool $isDelete = false): void
  69.     {
  70.         if (empty($orderIds)) {
  71.             return;
  72.         }
  74.         $customerIds = $this->connection->fetchFirstColumn(
  75.             'SELECT DISTINCT LOWER(HEX(customer_id)) FROM `order_customer` WHERE order_id IN (:ids) AND order_version_id = :version',
  76.             ['ids' => Uuid::fromHexToBytesList($orderIds), 'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION)],
  77.             ['ids' => Connection::PARAM_STR_ARRAY]
  78.         );
  80.         if (empty($customerIds)) {
  81.             return;
  82.         }
  84.         $whereOrder = $isDelete ? 'AND `order`.id NOT IN (:exceptOrderIds)' : '';
  85.         $select = '
  86.             SELECT `order_customer`.customer_id as id,
  87.                    COUNT(`order`.id) as order_count,
  88.                    SUM(`order`.amount_total) as order_total_amount,
  89.                    MAX(`order`.order_date_time) as last_order_date
  91.             FROM `order_customer`
  93.             INNER JOIN `order`
  94.                 ON `order`.id = `order_customer`.order_id
  95.                 AND `order`.version_id = `order_customer`.order_version_id
  96.                 AND `order`.version_id = :version
  97.                 ' . $whereOrder . '
  99.             INNER JOIN `state_machine_state`
  100.                 ON `state_machine_state`.id = `order`.state_id
  101.                 AND `state_machine_state`.technical_name = :state
  103.             WHERE `order_customer`.customer_id IN (:customerIds)
  104.             GROUP BY `order_customer`.customer_id
  105.         ';
  107.         $data = $this->connection->fetchAllAssociative($select, [
  108.             'customerIds' => Uuid::fromHexToBytesList($customerIds),
  109.             'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION),
  110.             'state' => OrderStates::STATE_COMPLETED,
  111.             'exceptOrderIds' => Uuid::fromHexToBytesList($orderIds),
  112.         ], [
  113.             'customerIds' => Connection::PARAM_STR_ARRAY,
  114.             'exceptOrderIds' => Connection::PARAM_STR_ARRAY,
  115.         ]);
  117.         if (empty($data)) {
  118.             foreach ($customerIds as $customerId) {
  119.                 $data[] = [
  120.                     'id' => Uuid::fromHexToBytes($customerId),
  121.                     'order_count' => 0,
  122.                     'order_total_amount' => 0,
  123.                     'last_order_date' => null,
  124.                 ];
  125.             }
  126.         }
  128.         $update = new RetryableQuery(
  129.             $this->connection,
  130.             $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')
  131.         );
  133.         foreach ($data as $record) {
  134.             $update->execute($record);
  135.         }
  136.     }
  137. }