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

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\Uuid\Uuid;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class ProductLineItemCommandValidator implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var Connection
  22.      */
  23.     private $connection;
  25.     /**
  26.      * @internal
  27.      */
  28.     public function __construct(Connection $connection)
  29.     {
  30.         $this->connection = $connection;
  31.     }
  33.     /**
  34.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  35.      */
  36.     public static function getSubscribedEvents()
  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($payload['payload'], true) : [];
  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.     private function findProducts(array $commands)
  104.     {
  105.         $ids = array_map(function (WriteCommand $command) {
  106.             if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  107.                 return null;
  108.             }
  110.             if ($command instanceof UpdateCommand) {
  111.                 return $command->getPrimaryKey()['id'];
  112.             }
  114.             return null;
  115.         }, $commands);
  117.         $ids = array_values(array_filter($ids));
  119.         if (empty($ids)) {
  120.             return $ids;
  121.         }
  123.         $products = $this->connection->fetchAll(
  124.             'SELECT LOWER(HEX(id)) as id FROM order_line_item WHERE id IN (:ids) AND type = \'product\'',
  125.             ['ids' => $ids],
  126.             ['ids' => Connection::PARAM_STR_ARRAY]
  127.         );
  129.         return array_flip(array_column($products, 'id'));
  130.     }
  132.     private function isProduct(array $products, array $payload, string $lineItemId): bool
  133.     {
  134.         if (isset($payload['type'])) {
  135.             return $payload['type'] === LineItem::PRODUCT_LINE_ITEM_TYPE;
  136.         }
  138.         return isset($products[$lineItemId]);
  139.     }
  140. }