custom/plugins/NimbitsPriceOnRequestNext/src/Subscriber/StorefrontSubscriber.php line 71

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Nimbits\NimbitsPriceOnRequestNext\Subscriber;
  5. use Nimbits\NimbitsPriceOnRequestNext\Service\PriceOnRequestService;
  6. use Nimbits\NimbitsPriceOnRequestNext\Setting\Service\SettingService;
  7. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  8. use Shopware\Core\Content\Product\SalesChannel\Detail\AbstractProductDetailRoute;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  13. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  14. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  15. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  16. use Shopware\Storefront\Page\Checkout\Cart\CheckoutCartPageLoadedEvent;
  17. use Shopware\Storefront\Page\Checkout\Confirm\CheckoutConfirmPageLoadedEvent;
  18. use Shopware\Storefront\Page\Checkout\Offcanvas\OffcanvasCartPageLoadedEvent;
  19. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  20. use Shopware\Storefront\Pagelet\Footer\FooterPageletLoadedEvent;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. use Symfony\Component\HttpFoundation\RedirectResponse;
  23. use Symfony\Component\HttpFoundation\Request;
  24. use Symfony\Component\HttpKernel\Event\ControllerArgumentsEvent;
  25. use Symfony\Component\HttpKernel\KernelEvents;
  28. //use Symfony\Component\DependencyInjection\ContainerBuilder;
  30. class StorefrontSubscriber implements EventSubscriberInterface
  31. {
  32.     private SettingService $settingsService;
  33.     private CartService $cartService;
  34.     private $productRepository;
  35.     private $productDetailRoute;
  36.     private PriceOnRequestService $priceOnRequestService;
  37.     private SalesChannelRepositoryInterface $salesChannelProductRepository;
  40.     public function __construct(
  41.         SettingService                  $settingsService,
  42.         CartService                     $cartService,
  43.         EntityRepositoryInterface       $productRepository,
  44.         AbstractProductDetailRoute      $productDetailRoute,
  45.         PriceOnRequestService           $priceOnRequestService,
  46.         SalesChannelRepositoryInterface $salesChannelProductRepository
  47.     )
  48.     {
  49.         $this->settingsService = $settingsService;
  50.         $this->cartService = $cartService;
  51.         $this->productRepository = $productRepository;
  52.         $this->productDetailRoute = $productDetailRoute;
  53.         $this->priceOnRequestService = $priceOnRequestService;
  54.         $this->salesChannelProductRepository = $salesChannelProductRepository;
  55.     }
  57.     public static function getSubscribedEvents(): array
  58.     {
  59.         // Return the events to listen to as array like this:  <event to listen to> => <method to execute>
  60.         return [
  61.             KernelEvents::CONTROLLER_ARGUMENTS => 'beforeController',
  62.             ProductPageLoadedEvent::class => 'onProductPageLoaded',
  63.             'sales_channel.product.loaded' => 'productsLoaded',
  64.             OffcanvasCartPageLoadedEvent::class => 'onOffcanvasCartPageLoaded',
  65.             CheckoutCartPageLoadedEvent::class => 'onCheckoutCartPageLoaded',
  66.             CheckoutConfirmPageLoadedEvent::class => 'onCheckoutPageLoaded',
  67.             FooterPageletLoadedEvent::class => 'onFooterLoaded'
  68.         ];
  69.     }
  71.     public function beforeController(ControllerArgumentsEvent $event)
  72.     {
  73.         if ($event->getRequest()->getPathInfo() == '/checkout/product/add-by-number') {
  74.             /** @var $salesChannelContext SalesChannelContext */
  75.             $salesChannelContext = $event->getArguments()[1];
  77.             $product = $this->salesChannelProductRepository->search(
  78.                 (new Criteria())
  79.                     ->addFilter(new EqualsFilter('productNumber', $event->getRequest()->get('number'))),
  80.                 $salesChannelContext
  81.             );
  83.             if ($product->count() > 0) {
  84.                 if ($this->priceOnRequestService->checkForProductCheckoutDisabled($product->first(), $salesChannelContext->getCurrentCustomerGroup()->getName())) {
  85.                     $event->setController(function (Request $request, SalesChannelContext $salesChannelContext) {
  86.                         return new RedirectResponse($request->getUriForPath('/checkout/cart?nb_por_nbpn=1'));
  87.                     });
  88.                 }
  89.             }
  90.         }
  91.     }
  93.     public function onProductPageLoaded(ProductPageLoadedEvent $event)
  94.     {
  95.         $config = $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId());
  97.         $product = $event->getPage()->getProduct();
  98.         $productId = $event->getPage()->getProduct()->getId();
  99.         $event->getPage()->getProduct()->addExtension('nimbitsPriceOnRequestSettings', $config);
  102.         $salesChannelContext = $event->getSalesChannelContext();
  103.         $salesChannelId = $event->getSalesChannelContext()->getSalesChannel()->getId();
  105.         $cg = $event->getSalesChannelContext()->getCurrentCustomerGroup()->getName();
  108.         $priceOnRequestService = $this->priceOnRequestService;
  109.         $priceOnRequestService->setSalesChannelId($salesChannelId);
  111.         $porRuleset = $priceOnRequestService->getPriceOnRequestRules($product, $cg);
  113.         $event->getPage()->getProduct()->addExtension('nimbits_por', $porRuleset);
  115.         $customer = $salesChannelContext->getCustomer();
  116.         if ($customer != null) {
  117.             $event->getPage()->addExtension('nimbits_por_customer', $customer);
  118.         }
  121.     }
  123.     public function productsLoaded(SalesChannelEntityLoadedEvent $event): void
  124.     {
  125.         $config = $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId());
  127.         $salesChannelContext = $event->getSalesChannelContext();
  128.         $salesChannelId = $event->getSalesChannelContext()->getSalesChannel()->getId();
  130.         $priceOnRequestService = $this->priceOnRequestService;
  131.         $priceOnRequestService->setSalesChannelId($salesChannelId);
  133.         $products = [];
  134.         foreach ($event->getEntities() as $product) {
  135.             $products[] = $product;
  136.             $cg = $event->getSalesChannelContext()->getCurrentCustomerGroup()->getName();
  139.             $porRuleset = $priceOnRequestService->getPriceOnRequestRules($product, $cg);
  140.             $product->addExtension('nimbits_por', $porRuleset);
  141.         }
  143.     }
  145.     public function onOffcanvasCartPageLoaded(OffcanvasCartPageLoadedEvent $event)
  146.     {
  147.         $salesChannelContext = $event->getSalesChannelContext();
  148.         $salesChannelId = $event->getSalesChannelContext()->getSalesChannel()->getId();
  151.         $cg = $event->getSalesChannelContext()->getCurrentCustomerGroup()->getName();
  153.         $config = $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId());
  155.         $priceOnRequestService = $this->priceOnRequestService;
  156.         $priceOnRequestService->setSalesChannelId($salesChannelId);
  158.         $event->getPage()->addExtension('nimbitsPriceOnRequestSettings', $config);
  161.         $currentCart = $this->cartService->getCart($salesChannelContext->getToken(), $salesChannelContext);
  164.         $lineitems = $currentCart->getLineItems();
  166.         //iterate cart and apply price on request rules to each item and the cart
  167.         $products = [];
  168.         $productNumbers = [];
  170.         foreach ($lineitems as $item) {
  171.             $payload = $item->getPayload();
  174.             if (!isset($payload["productNumber"])) {
  175.                 continue;
  176.             }
  178.             //xtract children's productNumbers if any
  179.             foreach ($item->getChildren() as $child) {
  180.                 $payloadChild = $child->getPayload();
  182.                 if (!isset($payloadChild["productNumber"])) {
  183.                     continue;
  184.                 }
  185.                 $productNumbers[] = $payloadChild["productNumber"];
  186.             }
  188.             $productNumbers[] = $payload["productNumber"];
  189.         }
  191.         $prods = $this->salesChannelProductRepository->search(
  192.             (new Criteria())
  193.                 ->addFilter(new EqualsAnyFilter('productNumber', $productNumbers)),
  194.             $salesChannelContext
  195.         );
  197.         $prods = $prods->getElements();
  200.         //$product = $this->productDetailRoute->load($prods[$akeys[0]]->getId(), $event->getRequest(),$salesChannelContext, $criteria)->getProduct();
  202.         foreach ($prods as $p) {
  203.             $products[$p->getProductNumber()] = $p;
  204.         }
  206.         foreach ($lineitems as $item) {
  207.             $payload = $item->getPayload();
  209.             $rulesets = [];
  211.             if (!isset($payload["productNumber"])) {
  212.                 continue;
  213.             }
  215.             foreach ($item->getChildren() as $child) {
  216.                 $payloadChild = $child->getPayload();
  218.                 if (!isset($payloadChild["productNumber"])) {
  219.                     continue;
  220.                 }
  222.                 if (isset($products[$payloadChild["productNumber"]])) {
  223.                     $product = $products[$payloadChild["productNumber"]];
  224.                     $porRuleset = $priceOnRequestService->getPriceOnRequestRules($product, $cg);
  225.                     $rulesets[] = $porRuleset;
  226.                 }
  227.             }
  229.             if (isset($products[$payload["productNumber"]])) {
  230.                 $product = $products[$payload["productNumber"]];
  231.                 $porRuleset = $priceOnRequestService->getPriceOnRequestRules($product, $cg);
  233.                 $rulesets[] = $porRuleset;
  235.             }
  238.             $porRuleset = $priceOnRequestService->sortRulesets($rulesets);
  239.             $item->addExtension('nimbits_por', $porRuleset);
  240.         }
  243.         $checkoutdisabled = $priceOnRequestService->checkForCheckoutDisabled($products, $cg);
  245.         $event->getPage()->addExtension('nimbits_por', $checkoutdisabled);
  246.     }
  248.     public function onCheckoutPageLoaded(CheckoutConfirmPageLoadedEvent $event)
  249.     {
  250.         $salesChannelContext = $event->getSalesChannelContext();
  252.         $customer = $salesChannelContext->getCustomer();
  253.         if ($customer != null) {
  254.             $event->getPage()->addExtension('nimbits_por_customer', $customer);
  255.         }
  256.     }
  258.     public function onCheckoutCartPageLoaded(CheckoutCartPageLoadedEvent $event)
  259.     {
  261.         $salesChannelContext = $event->getSalesChannelContext();
  262.         $salesChannelId = $event->getSalesChannelContext()->getSalesChannel()->getId();
  264.         $cg = $event->getSalesChannelContext()->getCurrentCustomerGroup()->getName();
  266.         $config = $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId());
  268.         $priceOnRequestService = $this->priceOnRequestService;
  269.         $priceOnRequestService->setSalesChannelId($salesChannelId);
  272.         $currentCart = $this->cartService->getCart($salesChannelContext->getToken(), $salesChannelContext);
  274.         $lineitems = $currentCart->getLineItems();
  277.         //iterate cart and apply price on request rules to each item and the cart
  278.         $products = [];
  279.         $productNumbers = [];
  281.         foreach ($lineitems as $item) {
  282.             $payload = $item->getPayload();
  285.             if (!isset($payload["productNumber"])) {
  286.                 continue;
  287.             }
  289.             //xtract children's productNumbers if any
  290.             foreach ($item->getChildren() as $child) {
  291.                 $payloadChild = $child->getPayload();
  293.                 if (!isset($payloadChild["productNumber"])) {
  294.                     continue;
  295.                 }
  296.                 $productNumbers[] = $payloadChild["productNumber"];
  297.             }
  299.             $productNumbers[] = $payload["productNumber"];
  300.         }
  302.         $prods = $this->salesChannelProductRepository->search(
  303.             (new Criteria())
  304.                 ->addFilter(new EqualsAnyFilter('productNumber', $productNumbers)),
  305.             $salesChannelContext
  306.         );
  308.         $prods = $prods->getElements();
  311.         //$product = $this->productDetailRoute->load($prods[$akeys[0]]->getId(), $event->getRequest(),$salesChannelContext, $criteria)->getProduct();
  313.         foreach ($prods as $p) {
  314.             $products[$p->getProductNumber()] = $p;
  315.         }
  318.         //iterate cart and apply price on request ruleset to each item and the cart
  320.         foreach ($lineitems as $item) {
  321.             $payload = $item->getPayload();
  323.             $rulesets = [];
  325.             if (!isset($payload["productNumber"])) {
  326.                 continue;
  327.             }
  329.             foreach ($item->getChildren() as $child) {
  330.                 $payloadChild = $child->getPayload();
  332.                 if (!isset($payloadChild["productNumber"])) {
  333.                     continue;
  334.                 }
  336.                 if (isset($products[$payloadChild["productNumber"]])) {
  337.                     $product = $products[$payloadChild["productNumber"]];
  338.                     $porRuleset = $priceOnRequestService->getPriceOnRequestRules($product, $cg);
  339.                     $rulesets[] = $porRuleset;
  340.                 }
  341.             }
  343.             if (isset($products[$payload["productNumber"]])) {
  344.                 $product = $products[$payload["productNumber"]];
  345.                 $porRuleset = $priceOnRequestService->getPriceOnRequestRules($product, $cg);
  347.                 $rulesets[] = $porRuleset;
  349.             }
  352.             $porRuleset = $priceOnRequestService->sortRulesets($rulesets);
  353.             $item->addExtension('nimbits_por', $porRuleset);
  354.         }
  357.         $checkoutdisabled = $priceOnRequestService->checkForCheckoutDisabled($products, $cg);
  358.         $checkoutdisabled->dontAddByProductNumber = ($event->getRequest()->get('nb_por_nbpn', 0) == 1);
  361.         $event->getPage()->addExtension('nimbits_por', $checkoutdisabled);
  362.     }
  364.     public function onFooterLoaded(FooterPageletLoadedEvent $event)
  366.     {
  367.         $event->getPagelet()->addExtension('nimbitsPriceOnRequestSettings',
  368.             $this->settingsService->getSettingsAsStruct($event->getSalesChannelContext()->getSalesChannel()->getId())
  370.         );
  373.     }
  374. }