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. }