custom/plugins/CioSponsoredOrderConfirmation/src/Subscriber/AddToCartSubscriber.php line 42

Open in your IDE?
  1. <?php
  3. namespace CioSponsoredOrderConfirmation\Subscriber;
  5. use CioProductCustomerInputs\Service\SessionService;
  6. use Shopware\Core\Checkout\Cart\Error\IncompleteLineItemError;
  7. use Shopware\Core\Checkout\Cart\Event\AfterLineItemAddedEvent;
  8. use Shopware\Core\Checkout\Cart\Event\BeforeLineItemAddedEvent;
  9. use Shopware\Core\Checkout\Cart\Event\CartChangedEvent;
  10. use Shopware\Core\Content\Product\ProductEntity;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Storefront\Framework\Routing\Router;
  15. use Symfony\Component\DependencyInjection\ContainerInterface;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\HttpFoundation\RedirectResponse;
  18. use Symfony\Component\HttpFoundation\RequestStack;
  20. class AddToCartSubscriber implements EventSubscriberInterface
  21. {
  22.     private ContainerInterface $container;
  23.     private Router $router;
  24.     private RequestStack $requestStack;
  25.     private SessionService $sessionService;
  27.     public function __construct(ContainerInterface $container, Router $router, RequestStack $requestStack, SessionService $sessionService)
  28.     {
  29.         $this->container = $container;
  30.         $this->router = $router;
  31.         $this->requestStack = $requestStack;
  32.         $this->sessionService = $sessionService;
  33.     }
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             BeforeLineItemAddedEvent::class => 'onBeforeLineItemAddedEvent'
  39.         ];
  40.     }
  42.     public function onBeforeLineItemAddedEvent(BeforeLineItemAddedEvent $event)
  43.     {
  44.         // Handle only product line items to avoid invalid referencedId filters (e.g. "frontend.cart.offcanvas")
  45.         if ($event->getLineItem()->getType() !== \Shopware\Core\Checkout\Cart\LineItem\LineItem::PRODUCT_LINE_ITEM_TYPE) {
  46.             return;
  47.         }
  49.         $lineItem = clone $event->getLineItem();
  51.         /** @var EntityRepositoryInterface $productRepository */
  52.         $productRepository = $this->container->get('product.repository');
  54.         $criteria = (new Criteria())->addFilter(new EqualsFilter('id', $lineItem->getReferencedId()));
  56.         /** @var ProductEntity|null $product */
  57.         $product = $productRepository->search($criteria, $event->getContext())->first();
  59.         if (!is_null($product) && is_array($product->getCustomFields())) {
  60.             $numberOfRows = $this->getCustomFieldValue($product, 'cio_customer_input_count_rows', 0);
  61.             $numberOfCells = count($this->getCustomFieldValue($product, 'cio_customer_input_general_group', []));
  63.             for ($row = 1; $row <= $numberOfRows; $row++) {
  64.                 for ($cell = 1; $cell <= $numberOfCells; $cell++) {
  65.                     $error = false;
  66.                     $value = $this->sessionService->getCustomerInputFromSession($product->getProductNumber(), 'value', $row, $cell);
  67.                     // 0 is a valid value
  68.                     if (!is_numeric($value)) {
  69.                         if (empty($value)) {
  70.                             $error = true;
  71.                         }
  72.                     }
  74.                     if ($error) {
  75.                         if ($event->getCart()->has($event->getLineItem()->getId())) {
  76.                             $event->getCart()->remove($event->getLineItem()->getId());
  77.                         }
  79.                         $event->getCart()->addErrors(new IncompleteLineItemError($event->getLineItem()->getReferencedId(), 'cioCustomInputError'));
  81.                         if ($this->requestStack->getCurrentRequest()->request->has('cioAlternativeRedirectTo')) {
  82.                             (new RedirectResponse(
  83.                                 $this->router->generate('frontend.detail.page', ['productId' => $event->getLineItem()->getId()])
  84.                             ))->send();
  86.                         }
  87.                     }
  88.                 }
  89.             }
  90.         }
  91.     }
  93.     protected function getCustomFieldValue(ProductEntity $productEntity, $key, $default = null)
  94.     {
  95.         if (!is_array($productEntity->getCustomFields()) || !key_exists($key, $productEntity->getCustomFields())) {
  96.             return $default;
  97.         }
  99.         return $productEntity->getCustomFields()[$key];
  100.     }
  101. }