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

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