custom/plugins/EconsorAtBitConfiguratorConnector/src/Subscriber/AtBitSessionCleaner.php line 34

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Econsor\Shopware\AtBitConfiguratorConnector\Subscriber;
  5. use Econsor\Shopware\AtBitConfiguratorConnector\Services\AtBitPriceCalculator;
  6. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  7. use Shopware\Core\Checkout\Cart\Event\LineItemQuantityChangedEvent;
  8. use Shopware\Core\Checkout\Cart\Event\LineItemRemovedEvent;
  9. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  10. use Shopware\Core\Framework\Struct\ArrayStruct;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\HttpFoundation\Session\Session;
  14. class AtBitSessionCleaner implements EventSubscriberInterface
  15. {
  16.     private $session;
  17.     private $priceCalculator;
  19.     public function __construct(Session $session, AtBitPriceCalculator $priceCalculator)
  20.     {
  21.         $this->session         = $session;
  22.         $this->priceCalculator = $priceCalculator;
  23.     }
  25.     public static function getSubscribedEvents(): array
  26.     {
  27.         return [
  28.             LineItemRemovedEvent::class          => 'onLineItemRemoved',
  29.             LineItemQuantityChangedEvent::class   => 'onQuantityChanged',
  30.             CheckoutOrderPlacedEvent::class       => 'onOrderPlaced',
  31.         ];
  32.     }
  34.     public function onLineItemRemoved(LineItemRemovedEvent $event): void
  35.     {
  36.         $id     = $event->getLineItem()->getId();
  37.         $config = $this->session->has('atBitConfiguratorProducts')
  38.             ? $this->session->get('atBitConfiguratorProducts')
  39.             : null;
  41.         if ($config && array_key_exists($id, $config)) {
  42.             unset($config[$id]);
  43.             $this->session->set('atBitConfiguratorProducts', $config);
  44.         }
  45.     }
  47.     public function onQuantityChanged(LineItemQuantityChangedEvent $event): void
  48.     {
  49.         if (!$configuratorProduct = $this->getLineItemFromSession($event->getLineItem()->getId())) {
  50.             return;
  51.         }
  53.         $quantity = $event->getLineItem()->getQuantity();
  55.         /** @var ArrayStruct $extension */
  56.         $extension = $configuratorProduct->getExtension('atbitConfiguration');
  58.         $configuratorProduct->setQuantity($quantity);
  59.         $configuratorProduct->setPrice($this->priceCalculator->calculate(
  60.             (float) $extension->get('GesamtpreisOhneMwSt'),
  61.             (float) $extension->get('MwSt'),
  62.             $quantity
  63.         ));
  65.         $this->setLineItemFromSession($configuratorProduct, $event->getLineItem()->getId());
  66.     }
  68.     public function onOrderPlaced(CheckoutOrderPlacedEvent $event): void
  69.     {
  70.         $this->session->remove('atBitConfiguratorProducts');
  71.     }
  73.     private function getLineItemFromSession(string $id): ?LineItem
  74.     {
  75.         $lineItems = $this->session->get('atBitConfiguratorProducts');
  76.         if ($lineItems && array_key_exists($id, $lineItems)) {
  77.             return $lineItems[$id];
  78.         }
  79.         return null;
  80.     }
  82.     private function setLineItemFromSession(LineItem $lineItem, string $id): void
  83.     {
  84.         if ($lineItems = $this->session->get('atBitConfiguratorProducts')) {
  85.             $lineItems[$id] = $lineItem;
  86.             $this->session->set('atBitConfiguratorProducts', $lineItems);
  87.         }
  88.     }
  89. }