src/Core/Content/Product/Cart/ProductLineItemCommandValidator.php line 42

  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.  * @internal
  21.  */
  22. #[Package('inventory')]
  23. class ProductLineItemCommandValidator implements EventSubscriberInterface
  24. {
  25.     /**
  26.      * @internal
  27.      */
  28.     public function __construct(private readonly Connection $connection)
  29.     {
  30.     }
  32.     /**
  33.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  34.      */
  35.     public static function getSubscribedEvents(): array
  36.     {
  37.         return [
  38.             PreWriteValidationEvent::class => 'preValidate',
  39.         ];
  40.     }
  42.     public function preValidate(PreWriteValidationEvent $event): void
  43.     {
  44.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  45.             return;
  46.         }
  48.         $products = $this->findProducts($event->getCommands());
  50.         foreach ($event->getCommands() as $command) {
  51.             if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  52.                 continue;
  53.             }
  54.             if ($command instanceof SetNullOnDeleteCommand) {
  55.                 continue;
  56.             }
  58.             $payload = $command->getPayload();
  60.             $lineItemId = Uuid::fromBytesToHex($command->getPrimaryKey()['id']);
  62.             $productIdChanged = \array_key_exists('product_id', $payload);
  64.             $referenceIdChanged = \array_key_exists('referenced_id', $payload);
  66.             $lineItemPayload = isset($payload['payload']) ? json_decode((string) $payload['payload'], true, 512, \JSON_THROW_ON_ERROR) : [];
  67.             $orderNumberChanged = \array_key_exists('productNumber', $lineItemPayload);
  69.             if (!$this->isProduct($products, $payload, $lineItemId)) {
  70.                 continue;
  71.             }
  73.             $somethingChanged = $productIdChanged || $referenceIdChanged || $orderNumberChanged;
  75.             $allChanged = $productIdChanged && $referenceIdChanged && $orderNumberChanged;
  77.             // has a field changed?
  78.             if (!$somethingChanged) {
  79.                 continue;
  80.             }
  82.             $productId = isset($payload['product_id']) ? Uuid::fromBytesToHex($payload['product_id']) : null;
  83.             $referenceId = $payload['referenced_id'] ?? null;
  85.             if ($productId !== $referenceId) {
  86.                 $event->getExceptions()->add(
  87.                     new ProductLineItemDifferentIdException($lineItemId)
  88.                 );
  89.             }
  91.             // all fields updated? everything is consistent
  92.             if ($allChanged) {
  93.                 continue;
  94.             }
  96.             $event->getExceptions()->add(
  97.                 new ProductLineItemInconsistentException($lineItemId)
  98.             );
  99.         }
  100.     }
  102.     /**
  103.      * @param list<WriteCommand> $commands
  104.      *
  105.      * @return array<string, int>
  106.      */
  107.     private function findProducts(array $commands): array
  108.     {
  109.         $ids = array_map(function (WriteCommand $command) {
  110.             if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  111.                 return null;
  112.             }
  114.             if ($command instanceof UpdateCommand) {
  115.                 return $command->getPrimaryKey()['id'];
  116.             }
  118.             return null;
  119.         }, $commands);
  121.         $ids = array_values(array_filter($ids));
  123.         if (empty($ids)) {
  124.             return [];
  125.         }
  127.         /** @var array<string, int> $products */
  128.         $products = \array_flip($this->connection->fetchFirstColumn(
  129.             'SELECT DISTINCT LOWER(HEX(id)) FROM order_line_item WHERE id IN (:ids) AND type = \'product\'',
  130.             ['ids' => $ids],
  131.             ['ids' => Connection::PARAM_STR_ARRAY]
  132.         ));
  134.         return $products;
  135.     }
  137.     /**
  138.      * @param array<string, mixed> $products
  139.      * @param array<string, mixed> $payload
  140.      */
  141.     private function isProduct(array $products, array $payload, string $lineItemId): bool
  142.     {
  143.         if (isset($payload['type'])) {
  144.             return $payload['type'] === LineItem::PRODUCT_LINE_ITEM_TYPE;
  145.         }
  147.         return isset($products[$lineItemId]);
  148.     }
  149. }