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

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\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. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  19. */
  20. #[Package('customer-order')]
  21. class CustomerMetaFieldSubscriber implements EventSubscriberInterface
  22. {
  23. private Connection $connection;
  25. /**
  26. * @internal
  27. */
  28. public function __construct(Connection $connection)
  29. {
  30. $this->connection = $connection;
  31. }
  33. public static function getSubscribedEvents(): array
  34. {
  35. return [
  36. StateMachineTransitionEvent::class => 'fillCustomerMetaDataFields',
  37. PreWriteValidationEvent::class => 'deleteOrder',
  38. ];
  39. }
  41. public function fillCustomerMetaDataFields(StateMachineTransitionEvent $event): void
  42. {
  43. if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  44. return;
  45. }
  47. if ($event->getEntityName() !== 'order') {
  48. return;
  49. }
  51. if ($event->getToPlace()->getTechnicalName() !== OrderStates::STATE_COMPLETED && $event->getFromPlace()->getTechnicalName() !== OrderStates::STATE_COMPLETED) {
  52. return;
  53. }
  55. $this->updateCustomer([$event->getEntityId()]);
  56. }
  58. public function deleteOrder(PreWriteValidationEvent $event): void
  59. {
  60. if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  61. return;
  62. }
  64. $orderIds = [];
  65. foreach ($event->getCommands() as $command) {
  66. if ($command->getDefinition()->getClass() === OrderDefinition::class
  67. && $command instanceof DeleteCommand
  68. ) {
  69. $orderIds[] = Uuid::fromBytesToHex($command->getPrimaryKey()['id']);
  70. }
  71. }
  73. $this->updateCustomer($orderIds, true);
  74. }
  76. /**
  77. * @param array<string> $orderIds
  78. */
  79. private function updateCustomer(array $orderIds, bool $isDelete = false): void
  80. {
  81. if (empty($orderIds)) {
  82. return;
  83. }
  85. $customerIds = $this->connection->fetchFirstColumn(
  86. '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',
  87. ['ids' => Uuid::fromHexToBytesList($orderIds), 'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION)],
  88. ['ids' => Connection::PARAM_STR_ARRAY]
  89. );
  91. if (empty($customerIds)) {
  92. return;
  93. }
  95. $parameters = [
  96. 'customerIds' => Uuid::fromHexToBytesList($customerIds),
  97. 'version' => Uuid::fromHexToBytes(Defaults::LIVE_VERSION),
  98. 'state' => OrderStates::STATE_COMPLETED,
  99. ];
  100. $types = [
  101. 'customerIds' => Connection::PARAM_STR_ARRAY,
  102. ];
  104. $whereOrder = '';
  105. if ($isDelete) {
  106. $whereOrder = 'AND `order`.id NOT IN (:exceptOrderIds)';
  107. $parameters['exceptOrderIds'] = Uuid::fromHexToBytesList($orderIds);
  108. $types['exceptOrderIds'] = Connection::PARAM_STR_ARRAY;
  109. }
  111. $select = '
  112. SELECT `order_customer`.customer_id as id,
  113. COUNT(`order`.id) as order_count,
  114. SUM(`order`.amount_total) as order_total_amount,
  115. MAX(`order`.order_date_time) as last_order_date
  117. FROM `order_customer`
  119. INNER JOIN `order`
  120. ON `order`.id = `order_customer`.order_id
  121. AND `order`.version_id = `order_customer`.order_version_id
  122. AND `order`.version_id = :version
  123. ' . $whereOrder . '
  125. INNER JOIN `state_machine_state`
  126. ON `state_machine_state`.id = `order`.state_id
  127. AND `state_machine_state`.technical_name = :state
  129. WHERE `order_customer`.customer_id IN (:customerIds)
  130. GROUP BY `order_customer`.customer_id
  131. ';
  133. $data = $this->connection->fetchAllAssociative($select, $parameters, $types);
  135. if (empty($data)) {
  136. foreach ($customerIds as $customerId) {
  137. $data[] = [
  138. 'id' => Uuid::fromHexToBytes($customerId),
  139. 'order_count' => 0,
  140. 'order_total_amount' => 0,
  141. 'last_order_date' => null,
  142. ];
  143. }
  144. }
  146. $update = new RetryableQuery(
  147. $this->connection,
  148. $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')
  149. );
  151. foreach ($data as $record) {
  152. $update->execute($record);
  153. }
  154. }
  155. }