custom/plugins/NetiNextAccessManager/src/Subscriber/CartSubscriber.php line 48

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace NetInventors\NetiNextAccessManager\Subscriber;
  7. use NetInventors\NetiNextAccessManager\Components\Errors\Checkout\Cart\CustomerGroupBlockedForBuyError;
  8. use NetInventors\NetiNextAccessManager\Service\CustomerService;
  9. use NetInventors\NetiNextAccessManager\Service\PluginConfig;
  10. use Shopware\Core\Checkout\Cart\Event\AfterLineItemAddedEvent;
  11. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  12. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  13. use Shopware\Core\Content\Product\ProductEntity;
  14. use Shopware\Core\Framework\Context;
  15. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. class CartSubscriber implements EventSubscriberInterface
  20. {
  21.     private PluginConfig              $pluginConfig;
  23.     private CustomerService           $customerService;
  25.     private CartService               $cartService;
  27.     private EntityRepositoryInterface $productRepository;
  29.     public function __construct(
  30.         PluginConfig              $pluginConfig,
  31.         CustomerService           $customerService,
  32.         CartService               $cartService,
  33.         EntityRepositoryInterface $productRepository
  34.     ) {
  35.         $this->pluginConfig      = $pluginConfig;
  36.         $this->customerService   = $customerService;
  37.         $this->productRepository = $productRepository;
  38.         $this->cartService       = $cartService;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             AfterLineItemAddedEvent::class => 'onAfterItemAdded',
  45.         ];
  46.     }
  48.     public function onAfterItemAdded(AfterLineItemAddedEvent $event): void
  49.     {
  50.         if (!$this->pluginConfig->isActive() || [] === $this->pluginConfig->getGroupsForBlockedBuyButton()) {
  51.             return;
  52.         }
  54.         $salesChannelContext = $event->getSalesChannelContext();
  56.         if (!$this->customerService->isBuyButtonBlocked($salesChannelContext)) {
  57.             return;
  58.         }
  60.         $items = $event->getLineItems();
  61.         $cart  = $event->getCart();
  63.         $productNames = $this->getProducts($items, $event->getContext());
  65.         /** @var LineItem $item */
  66.         foreach ($items as $item) {
  67.             $itemId   = $item->getId();
  68.             $itemName = (string) ($productNames[$itemId] ?? $itemId);
  70.             $this->cartService->remove($cart, $itemId, $salesChannelContext);
  71.             $cart->addErrors(
  72.                 new CustomerGroupBlockedForBuyError(
  73.                     $itemId,
  74.                     $itemName
  75.                 )
  76.             );
  77.         }
  78.     }
  80.     private function getProducts(array $items, Context $context): array
  81.     {
  82.         $productNames = [];
  83.         $productIds   = [];
  85.         /** @var LineItem $item */
  86.         foreach ($items as $item) {
  87.             $productIds[] = [ 'id' => $item->getId() ];
  88.         }
  90.         $products = $this->productRepository->search(new Criteria($productIds), $context)->getElements();
  92.         /** @var ProductEntity $product */
  93.         foreach ($products as $product) {
  94.             $productNames[$product->getId()] = $product->getName() ?? $product->getProductNumber();
  95.         }
  97.         return $productNames;
  98.     }
  99. }