vendor/shopware/core/Content/Product/Cart/ProductLineItemCommandValidator.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Product\Cart;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  7. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItem\OrderLineItemDefinition;
  8. use Shopware\Core\Content\Product\Exception\ProductLineItemDifferentIdException;
  9. use Shopware\Core\Content\Product\Exception\ProductLineItemInconsistentException;
  10. use Shopware\Core\Defaults;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\SetNullOnDeleteCommand;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\UpdateCommand;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Write\Command\WriteCommand;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Write\Validation\PreWriteValidationEvent;
  15. use Shopware\Core\Framework\Log\Package;
  16. use Shopware\Core\Framework\Uuid\Uuid;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. /**
  20. * @deprecated tag:v6.5.0 - reason:becomes-internal - EventSubscribers will become internal in v6.5.0
  21. */
  22. #[Package('inventory')]
  23. class ProductLineItemCommandValidator implements EventSubscriberInterface
  24. {
  25. private Connection $connection;
  27. /**
  28. * @internal
  29. */
  30. public function __construct(Connection $connection)
  31. {
  32. $this->connection = $connection;
  33. }
  35. /**
  36. * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  37. */
  38. public static function getSubscribedEvents()
  39. {
  40. return [
  41. PreWriteValidationEvent::class => 'preValidate',
  42. ];
  43. }
  45. public function preValidate(PreWriteValidationEvent $event): void
  46. {
  47. if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  48. return;
  49. }
  51. $products = $this->findProducts($event->getCommands());
  53. foreach ($event->getCommands() as $command) {
  54. if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  55. continue;
  56. }
  57. if ($command instanceof SetNullOnDeleteCommand) {
  58. continue;
  59. }
  61. $payload = $command->getPayload();
  63. $lineItemId = Uuid::fromBytesToHex($command->getPrimaryKey()['id']);
  65. $productIdChanged = \array_key_exists('product_id', $payload);
  67. $referenceIdChanged = \array_key_exists('referenced_id', $payload);
  69. $lineItemPayload = isset($payload['payload']) ? json_decode($payload['payload'], true) : [];
  70. $orderNumberChanged = \array_key_exists('productNumber', $lineItemPayload);
  72. if (!$this->isProduct($products, $payload, $lineItemId)) {
  73. continue;
  74. }
  76. $somethingChanged = $productIdChanged || $referenceIdChanged || $orderNumberChanged;
  78. $allChanged = $productIdChanged && $referenceIdChanged && $orderNumberChanged;
  80. // has a field changed?
  81. if (!$somethingChanged) {
  82. continue;
  83. }
  85. $productId = isset($payload['product_id']) ? Uuid::fromBytesToHex($payload['product_id']) : null;
  86. $referenceId = $payload['referenced_id'] ?? null;
  88. if ($productId !== $referenceId) {
  89. $event->getExceptions()->add(
  90. new ProductLineItemDifferentIdException($lineItemId)
  91. );
  92. }
  94. // all fields updated? everything is consistent
  95. if ($allChanged) {
  96. continue;
  97. }
  99. $event->getExceptions()->add(
  100. new ProductLineItemInconsistentException($lineItemId)
  101. );
  102. }
  103. }
  105. /**
  106. * @param list<WriteCommand> $commands
  107. *
  108. * @return array<string, int>
  109. */
  110. private function findProducts(array $commands): array
  111. {
  112. $ids = array_map(function (WriteCommand $command) {
  113. if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  114. return null;
  115. }
  117. if ($command instanceof UpdateCommand) {
  118. return $command->getPrimaryKey()['id'];
  119. }
  121. return null;
  122. }, $commands);
  124. $ids = array_values(array_filter($ids));
  126. if (empty($ids)) {
  127. return [];
  128. }
  130. /** @var array<string, int> $products */
  131. $products = \array_flip($this->connection->fetchFirstColumn(
  132. 'SELECT DISTINCT LOWER(HEX(id)) FROM order_line_item WHERE id IN (:ids) AND type = \'product\'',
  133. ['ids' => $ids],
  134. ['ids' => Connection::PARAM_STR_ARRAY]
  135. ));
  137. return $products;
  138. }
  140. /**
  141. * @param array<string, mixed> $products
  142. * @param array<string, mixed> $payload
  143. */
  144. private function isProduct(array $products, array $payload, string $lineItemId): bool
  145. {
  146. if (isset($payload['type'])) {
  147. return $payload['type'] === LineItem::PRODUCT_LINE_ITEM_TYPE;
  148. }
  150. return isset($products[$lineItemId]);
  151. }
  152. }