custom/plugins/KilbShopwareProductDesigner/src/Subscriber/CartSubscriber.php line 29

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Kilb\KilbShopwareProductDesigner\Subscriber;
  5. use Kilb\KilbShopwareProductDesigner\Constants;
  6. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent;
  7. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\Request;
  11. class CartSubscriber implements EventSubscriberInterface
  12. {
  13.     private const POST_KEY_LINE_ITEMS = 'lineItems';
  15.     /**
  16.      * @return string[]
  17.      */
  18.     public static function getSubscribedEvents(): array
  19.     {
  20.         return[
  21.             BeforeLineItemAddedEvent::class => 'onBeforeLineItemAdded',
  22.         ];
  23.     }
  25.     /**
  26.      * @param BeforeLineItemAddedEvent $event
  27.      * @throws \Shopware\Core\Framework\DataAbstractionLayer\Exception\InconsistentCriteriaIdsException
  28.      */
  29.     public function onBeforeLineItemAdded(BeforeLineItemAddedEvent $event): void
  30.     {
  31.         $cart = $event->getCart();
  32.         $lineItemAdded = $event->getLineItem();
  33.         $lineItemIds = $this->getLineItemIds($lineItemAdded);
  34.         $requestLineItems = $this->getRequestLineItems();
  35.         $requestLineItem = $this->getRequestLineItem($lineItemIds, $requestLineItems);
  37.         $groupSecret = $requestLineItem[Constants::LINE_ITEM_PAYLOAD_KEY_GROUP_SECRET] ?? null;
  38.         $basketImageUrl = $requestLineItem[Constants::LINE_ITEM_PAYLOAD_KEY_BASKET_IMAGE_URL] ?? null;
  40.         if (empty($groupSecret) || empty($basketImageUrl)) {
  41.             return;
  42.         }
  44.         $cart->remove($lineItemAdded->getId());
  46.         $this->setPayloadRecursively($lineItemAdded, $groupSecret, $basketImageUrl);
  48.         $this->updateLineItemId($lineItemAdded, $basketImageUrl);
  50.         $cart->add($lineItemAdded);
  51.     }
  53.     /**
  54.      * @param LineItem $lineItem
  55.      * @param string $groupSecret
  56.      * @param string $basketImageUrl
  57.      * @return void
  58.      */
  59.     private function setPayloadRecursively(LineItem $lineItem, string $groupSecret, string $basketImageUrl): void
  60.     {
  61.         $lineItem->setPayloadValue(Constants::LINE_ITEM_PAYLOAD_KEY_GROUP_SECRET, $groupSecret);
  62.         $lineItem->setPayloadValue(Constants::LINE_ITEM_PAYLOAD_KEY_BASKET_IMAGE_URL, $basketImageUrl);
  64.         foreach ($lineItem->getChildren() as $child) {
  65.             $this->setPayloadRecursively($child, $groupSecret, $basketImageUrl);
  66.         }
  67.     }
  69.     /**
  70.      * @param LineItem $lineItem
  71.      * @param string $basketImageUrl
  72.      *
  73.      * @return void
  74.      */
  75.     private function updateLineItemId(LineItem $lineItem, string $basketImageUrl): void
  76.     {
  77.         $lineItemId = md5($lineItem->getId() . '-' . $basketImageUrl);
  79.         $lineItem->setId($lineItemId);
  80.     }
  82.     /**
  83.      * @param string[] $lineItemIds
  84.      * @param array<string,array<string,string>> $requestLineItems
  85.      *
  86.      * @return array<string,string>
  87.      */
  88.     private function getRequestLineItem(array $lineItemIds, array $requestLineItems): array
  89.     {
  90.         foreach ($requestLineItems as $lineItemId => $lineItem) {
  91.             if (in_array($lineItemId, $lineItemIds)) {
  92.                 return $lineItem;
  93.             }
  94.         }
  96.         return [];
  97.     }
  99.     /**
  100.      * @return array<string,array<string,string>>
  101.      */
  102.     private function getRequestLineItems(): array
  103.     {
  104.         $request = Request::createFromGlobals();
  105.         $requestParams = $request->request->all();
  107.         if (empty($requestParams[self::POST_KEY_LINE_ITEMS])) {
  108.             return [];
  109.         }
  111.         return (array)$requestParams[self::POST_KEY_LINE_ITEMS];
  112.     }
  114.     /**
  115.      * @return string[]
  116.      */
  117.     private function getLineItemIds(LineItem $lineItem): array
  118.     {
  119.         $lineItemIds = [];
  121.         $lineItemIds[] = $lineItem->getId();
  123.         if ($lineItem->getReferencedId()) {
  124.             $lineItemIds[] = $lineItem->getReferencedId();
  125.         }
  127.         foreach ($lineItem->getChildren() as $child) {
  128.             $lineItemIds = array_merge($lineItemIds, $this->getLineItemIds($child));
  129.         }
  131.         return array_unique($lineItemIds);
  132.     }
  133. }