custom/plugins/db_ProductConfigurator/src/Storefront/Page/Cart/CartItemSubscriber.php line 61

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace db_ProductConfigurator\Storefront\Page\Cart;
  6. use Shopware\Core\Checkout\Cart\Event\AfterLineItemAddedEvent;
  7. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent;
  8. use Shopware\Core\Checkout\Cart\Event\CartChangedEvent;
  9. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  10. use Shopware\Core\Checkout\Cart\Price\QuantityPriceCalculator;
  11. use Shopware\Core\Checkout\Cart\Price\Struct\QuantityPriceDefinition;
  12. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  13. use Shopware\Core\Content\Product\Cart\ProductGatewayInterface;
  14. use Shopware\Core\Framework\Struct\ArrayStruct;
  15. use Shopware\Core\Framework\Uuid\Uuid;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  19. class CartItemSubscriber implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var RequestStack
  23.      */
  24.     private RequestStack $requestStack;
  26.     /**
  27.      * @var CartService
  28.      */
  29.     private $cartService;
  31.     /**
  32.      * @var QuantityPriceCalculator
  33.      */
  34.     private $calculator;
  36.     /**
  37.      * @var ProductGatewayInterface
  38.      */
  39.     private $productGateway;
  42.     public function __construct(
  43.         RequestStack $requestStack,
  44.         CartService $cartService,
  45.         QuantityPriceCalculator $calculator,
  46.         ProductGatewayInterface $productGateway
  47.     ) {
  48.         $this->requestStack = $requestStack;
  49.         $this->cartService = $cartService;
  50.         $this->calculator = $calculator;
  51.         $this->productGateway = $productGateway;
  52.     }
  54.     public static function getSubscribedEvents(): array
  55.     {
  56.         return [
  57.             BeforeLineItemAddedEvent::class => 'beforeLineItemAdded'
  58.         ];
  59.     }
  61.     public function beforeLineItemAdded(BeforeLineItemAddedEvent $event): void
  62.     {
  63.         $request = $this->requestStack->getCurrentRequest();
  65.         $dbConfiguration = $request->get('dbConfigurator');
  66.         $dbPrice = $request->get('dbCalculatedPrice');
  68.         if ($dbConfiguration) {
  70.             $lineItem = $event->getLineItem();
  71.             $cart = $event->getCart();
  73.             $product = $this->productGateway->get([$lineItem->getId()], $event->getSalesChannelContext());
  75.             $productId = $lineItem->getId();
  77.             $dbQuantity =  $request->get('db-quantity');
  79.             if ($dbQuantity) {
  80.                 $quantity = (int)$dbQuantity;
  81.             } else {
  82.                 $quantity = $cart->get($lineItem->getId())->getQuantity();
  83.             }
  87.             $cart->remove($lineItem->getId());
  89.             $newId = Uuid::randomHex();
  91.             $newItem = new LineItem($newId, LineItem::PRODUCT_LINE_ITEM_TYPE, $productId, $quantity);
  93.             $newItem->setPayloadValue('dbPrice', $dbPrice);
  94.             $newItem->setPayloadValue('dbConfigurator', json_decode($dbConfiguration, true))
  95.                 ->setStackable(true)
  96.                 ->setRemovable(true);
  98.             $cart->add($newItem);
  99.         }
  100.     }
  101. }