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

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.     public function __construct(Connection $connection)
  26.     {
  27.         $this->connection = $connection;
  28.     }
  30.     /**
  31.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  32.      */
  33.     public static function getSubscribedEvents()
  34.     {
  35.         return [
  36.             PreWriteValidationEvent::class => 'preValidate',
  37.         ];
  38.     }
  40.     public function preValidate(PreWriteValidationEvent $event): void
  41.     {
  42.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  43.             return;
  44.         }
  46.         $products = $this->findProducts($event->getCommands());
  48.         foreach ($event->getCommands() as $command) {
  49.             if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  50.                 continue;
  51.             }
  52.             if ($command instanceof SetNullOnDeleteCommand) {
  53.                 continue;
  54.             }
  56.             $payload = $command->getPayload();
  58.             $lineItemId = Uuid::fromBytesToHex($command->getPrimaryKey()['id']);
  60.             $productIdChanged = \array_key_exists('product_id', $payload);
  62.             $referenceIdChanged = \array_key_exists('referenced_id', $payload);
  64.             $lineItemPayload = isset($payload['payload']) ? json_decode($payload['payload'], true) : [];
  65.             $orderNumberChanged = \array_key_exists('productNumber', $lineItemPayload);
  67.             if (!$this->isProduct($products, $payload, $lineItemId)) {
  68.                 continue;
  69.             }
  71.             $somethingChanged = $productIdChanged || $referenceIdChanged || $orderNumberChanged;
  73.             $allChanged = $productIdChanged && $referenceIdChanged && $orderNumberChanged;
  75.             // has a field changed?
  76.             if (!$somethingChanged) {
  77.                 continue;
  78.             }
  80.             $productId = isset($payload['product_id']) ? Uuid::fromBytesToHex($payload['product_id']) : null;
  81.             $referenceId = $payload['referenced_id'] ?? null;
  83.             if ($productId !== $referenceId) {
  84.                 $event->getExceptions()->add(
  85.                     new ProductLineItemDifferentIdException($lineItemId)
  86.                 );
  87.             }
  89.             // all fields updated? everything is consistent
  90.             if ($allChanged) {
  91.                 continue;
  92.             }
  94.             $event->getExceptions()->add(
  95.                 new ProductLineItemInconsistentException($lineItemId)
  96.             );
  97.         }
  98.     }
  100.     private function findProducts(array $commands)
  101.     {
  102.         $ids = array_map(function (WriteCommand $command) {
  103.             if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  104.                 return null;
  105.             }
  107.             if ($command instanceof UpdateCommand) {
  108.                 return $command->getPrimaryKey()['id'];
  109.             }
  111.             return null;
  112.         }, $commands);
  114.         $ids = array_values(array_filter($ids));
  116.         $products = $this->connection->fetchAll(
  117.             'SELECT LOWER(HEX(id)) as id FROM order_line_item WHERE id IN (:ids) AND type = \'product\'',
  118.             ['ids' => $ids],
  119.             ['ids' => Connection::PARAM_STR_ARRAY]
  120.         );
  122.         return array_flip(array_column($products, 'id'));
  123.     }
  125.     private function isProduct(array $products, array $payload, string $lineItemId): bool
  126.     {
  127.         if (isset($payload['type'])) {
  128.             return $payload['type'] === LineItem::PRODUCT_LINE_ITEM_TYPE;
  129.         }
  131.         return isset($products[$lineItemId]);
  132.     }
  133. }