custom/plugins/CioBudget/src/Subscriber/AutoChangePaymentMethodSubscriber.php line 90

Open in your IDE?
  1. <?php
  3. namespace CioBudget\Subscriber;
  5. use CioBudget\PaymentHandler\BudgetPayment;
  6. use CioBudget\Service\StoreLoaderService;
  7. use Shopware\Core\Checkout\Cart\Error\ErrorCollection;
  8. use Shopware\Core\Checkout\Cart\SalesChannel\CartService;
  9. use Shopware\Core\Checkout\Customer\Event\CustomerLoginEvent;
  10. use Shopware\Core\Checkout\Payment\Cart\PaymentHandler\DefaultPayment;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  16. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
  17. use Shopware\Core\System\SalesChannel\SalesChannel\ContextSwitchRoute;
  18. use Shopware\Storefront\Event\StorefrontRenderEvent;
  19. use Symfony\Component\DependencyInjection\ContainerInterface;
  20. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. use Symfony\Component\HttpFoundation\RedirectResponse;
  22. use Symfony\Component\Routing\RouterInterface;
  24. class AutoChangePaymentMethodSubscriber implements EventSubscriberInterface
  25. {
  27.     /** values coming from the database(payment_method) after payment method installation */
  28.     const BUDGET_PAYMENT_ID = '420fb71d2ae84fbbb322e55329a3707a';
  30.     private ContainerInterface $container;
  31.     private StoreLoaderService $storeLoaderService;
  32.     private RouterInterface $router;
  34.     public function __construct(ContainerInterface $container, StoreLoaderService $storeLoaderService, RouterInterface $router)
  35.     {
  36.         $this->container = $container;
  37.         $this->storeLoaderService = $storeLoaderService;
  38.         $this->router = $router;
  39.     }
  41.     public static function getSubscribedEvents()
  42.     {
  43.         return [
  44.             CustomerLoginEvent::class => 'onCustomerLoginEvent',
  45.             StorefrontRenderEvent::class => 'onStorefrontRender'
  46.         ];
  47.     }
  49.     public function onCustomerLoginEvent(CustomerLoginEvent $event)
  50.     {
  51.         /** @var EntityRepositoryInterface $customerRepository */
  52.         $customerRepository = $this->container->get('customer.repository');
  54.         $customer = $event->getCustomer();
  56.         /** @var CartService $cartService */
  57.         $cartService = $this->container->get('Shopware\Core\Checkout\Cart\SalesChannel\CartService');
  59.         $cart = $cartService->getCart($event->getContextToken(), $event->getSalesChannelContext());
  61.         /** @var ContextSwitchRoute $contextSwitchRoute */
  62.         $contextSwitchRoute = $this->container->get('Shopware\Core\System\SalesChannel\SalesChannel\ContextSwitchRoute');
  64.         $customerStores = $this->storeLoaderService->getCustomerStores($customer);
  66.         if ($customer && count($customerStores)) {
  67.             $cart->setErrors(new ErrorCollection(array_filter($cart->getErrors()->getElements(), function ($key) {
  68.                 return $key !== 'payment-method-blocked-Budget' && $key !== 'payment-method-blocked-Kostenstelle' && $key !== 'payment-method-blocked-Punkte';
  69.             }, ARRAY_FILTER_USE_KEY)));
  71.             $data = new RequestDataBag([
  72.                 SalesChannelContextService::PAYMENT_METHOD_ID => self::BUDGET_PAYMENT_ID
  73.             ]);
  75.             $customerRepository->update([
  76.                 [
  77.                     'id' => $customer->getId(),
  78.                     'defaultPaymentMethodId' => self::BUDGET_PAYMENT_ID
  79.                 ]
  80.             ], $event->getContext());
  82.             $contextSwitchRoute->switchContext($data, $event->getSalesChannelContext());
  83.         } else {
  84.             $cart->setErrors(new ErrorCollection(array_filter($cart->getErrors()->getElements(), function ($key) {
  85.                 return $key !== 'payment-method-blocked-Budget' && $key !== 'payment-method-blocked-Kostenstelle' && $key !== 'payment-method-blocked-Punkte';
  86.             }, ARRAY_FILTER_USE_KEY)));
  87.         }
  88.     }
  90.     public function onStorefrontRender(StorefrontRenderEvent $event)
  91.     {
  92.         $route = $event->getRequest()->get('_route');
  94.         if (in_array($route, ['frontend.cart.offcanvas', 'frontend.checkout.confirm.page', 'frontend.checkout.cart.page'])) {
  95.             /** @var CartService $cartService */
  96.             $cartService = $this->container->get('Shopware\Core\Checkout\Cart\SalesChannel\CartService');
  97.             $cart = $cartService->getCart($event->getSalesChannelContext()->getToken(), $event->getSalesChannelContext(), CartService::SALES_CHANNEL, false);
  99.             if ($cart->getLineItems()->count() && count($cart->getErrors()->getElements())) {
  100.                 $data = null;
  102.                 if (array_key_exists('payment-method-blocked-Punkte', $cart->getErrors()->getElements())) {
  103.                     $cart->setErrors(new ErrorCollection(array_filter($cart->getErrors()->getElements(), function ($key) {
  104.                         return $key !== 'payment-method-blocked-Punkte';
  105.                     }, ARRAY_FILTER_USE_KEY)));
  107.                     $data = new RequestDataBag([
  108.                         SalesChannelContextService::PAYMENT_METHOD_ID => $this->getPaymentMethodId(DefaultPayment::class, 'Keine Zahlungsdaten erforderlich')
  109.                     ]);
  110.                 }
  112.                 if (array_key_exists('payment-method-blocked-Keine Zahlungsdaten erforderlich', $cart->getErrors()->getElements())) {
  113.                     $cart->setErrors(new ErrorCollection(array_filter($cart->getErrors()->getElements(), function ($key) {
  114.                         return $key !== 'payment-method-blocked-Keine Zahlungsdaten erforderlich';
  115.                     }, ARRAY_FILTER_USE_KEY)));
  117.                     $data = new RequestDataBag([
  118.                         SalesChannelContextService::PAYMENT_METHOD_ID => $this->getPaymentMethodId(BudgetPayment::class)
  119.                     ]);
  120.                 }
  122.                 if (!is_null($data)) {
  123.                     /** @var ContextSwitchRoute $contextSwitchRoute */
  124.                     $contextSwitchRoute = $this->container->get('Shopware\Core\System\SalesChannel\SalesChannel\ContextSwitchRoute');
  125.                     $contextSwitchRoute->switchContext($data, $event->getSalesChannelContext());
  127.                     $response = new RedirectResponse($this->router->generate($route));
  128.                     $response->send();
  129.                 }
  130.             } elseif (!$cart->getLineItems()->count()) {
  131.                 if (array_key_exists('payment-method-blocked-Punkte', $cart->getErrors()->getElements())) {
  132.                     $cart->setErrors(new ErrorCollection(array_filter($cart->getErrors()->getElements(), function ($key) {
  133.                         return $key !== 'payment-method-blocked-Punkte';
  134.                     }, ARRAY_FILTER_USE_KEY)));
  136.                     $data = new RequestDataBag([
  137.                         SalesChannelContextService::PAYMENT_METHOD_ID => $this->getPaymentMethodId(DefaultPayment::class, 'Keine Zahlungsdaten erforderlich')
  138.                     ]);
  140.                     /** @var ContextSwitchRoute $contextSwitchRoute */
  141.                     $contextSwitchRoute = $this->container->get('Shopware\Core\System\SalesChannel\SalesChannel\ContextSwitchRoute');
  142.                     $contextSwitchRoute->switchContext($data, $event->getSalesChannelContext());
  144.                     $response = new RedirectResponse($this->router->generate($route));
  145.                     $response->send();
  146.                 }
  147.             }
  148.         }
  149.     }
  151.     protected function getPaymentMethodId($handlerIdentifier, $distinguishableName = null)
  152.     {
  153.         /** @var EntityRepositoryInterface $paymentRepository */
  154.         $paymentRepository = $this->container->get('payment_method.repository');
  155.         $paymentCriteria = (new Criteria())
  156.             ->addFilter(new EqualsFilter('handlerIdentifier', $handlerIdentifier));
  158.         if ($distinguishableName) {
  159.             $paymentCriteria
  160.                 ->addFilter(new EqualsFilter('name', $distinguishableName))
  161.                 ->addAssociation('payment_method_translation');
  162.         }
  164.         return $paymentRepository->searchIds($paymentCriteria, Context::createDefaultContext())->firstId();
  165.     }
  166. }