platform/src/Core/Content/Product/Cart/ProductLineItemCommandValidator.php line 37

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.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             PreWriteValidationEvent::class => 'preValidate',
  34.         ];
  35.     }
  37.     public function preValidate(PreWriteValidationEvent $event): void
  38.     {
  39.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  40.             return;
  41.         }
  43.         $products = $this->findProducts($event->getCommands());
  45.         foreach ($event->getCommands() as $command) {
  46.             if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  47.                 continue;
  48.             }
  49.             if ($command instanceof SetNullOnDeleteCommand) {
  50.                 continue;
  51.             }
  53.             $payload = $command->getPayload();
  55.             $lineItemId = Uuid::fromBytesToHex($command->getPrimaryKey()['id']);
  57.             $productIdChanged = \array_key_exists('product_id', $payload);
  59.             $referenceIdChanged = \array_key_exists('referenced_id', $payload);
  61.             $lineItemPayload = isset($payload['payload']) ? json_decode($payload['payload'], true) : [];
  62.             $orderNumberChanged = \array_key_exists('productNumber', $lineItemPayload);
  64.             if (!$this->isProduct($products, $payload, $lineItemId)) {
  65.                 continue;
  66.             }
  68.             $somethingChanged = $productIdChanged || $referenceIdChanged || $orderNumberChanged;
  70.             $allChanged = $productIdChanged && $referenceIdChanged && $orderNumberChanged;
  72.             // has a field changed?
  73.             if (!$somethingChanged) {
  74.                 continue;
  75.             }
  77.             $productId = isset($payload['product_id']) ? Uuid::fromBytesToHex($payload['product_id']) : null;
  78.             $referenceId = $payload['referenced_id'] ?? null;
  80.             if ($productId !== $referenceId) {
  81.                 $event->getExceptions()->add(
  82.                     new ProductLineItemDifferentIdException($lineItemId)
  83.                 );
  84.             }
  86.             // all fields updated? everything is consistent
  87.             if ($allChanged) {
  88.                 continue;
  89.             }
  91.             $event->getExceptions()->add(
  92.                 new ProductLineItemInconsistentException($lineItemId)
  93.             );
  94.         }
  95.     }
  97.     private function findProducts(array $commands)
  98.     {
  99.         $ids = array_map(function (WriteCommand $command) {
  100.             if ($command->getDefinition()->getClass() !== OrderLineItemDefinition::class) {
  101.                 return null;
  102.             }
  104.             if ($command instanceof UpdateCommand) {
  105.                 return $command->getPrimaryKey()['id'];
  106.             }
  108.             return null;
  109.         }, $commands);
  111.         $ids = array_values(array_filter($ids));
  113.         $products = $this->connection->fetchAll(
  114.             'SELECT LOWER(HEX(id)) as id FROM order_line_item WHERE id IN (:ids) AND type = \'product\'',
  115.             ['ids' => $ids],
  116.             ['ids' => Connection::PARAM_STR_ARRAY]
  117.         );
  119.         return array_flip(array_column($products, 'id'));
  120.     }
  122.     private function isProduct(array $products, array $payload, string $lineItemId): bool
  123.     {
  124.         if (isset($payload['type'])) {
  125.             return $payload['type'] === LineItem::PRODUCT_LINE_ITEM_TYPE;
  126.         }
  128.         return isset($products[$lineItemId]);
  129.     }
  130. }