vendor/shopware/core/System/SalesChannel/SalesChannel/ContextSwitchRoute.php line 123

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\System\SalesChannel\SalesChannel;
  5. use Shopware\Core\Checkout\Cart\CartException;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Validation\EntityExists;
  9. use Shopware\Core\Framework\Log\Package;
  10. use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
  11. use Shopware\Core\Framework\Validation\DataBag\RequestDataBag;
  12. use Shopware\Core\Framework\Validation\DataValidationDefinition;
  13. use Shopware\Core\Framework\Validation\DataValidator;
  14. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextPersister;
  15. use Shopware\Core\System\SalesChannel\Context\SalesChannelContextService;
  16. use Shopware\Core\System\SalesChannel\ContextTokenResponse;
  17. use Shopware\Core\System\SalesChannel\Event\SalesChannelContextSwitchEvent;
  18. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  19. use Symfony\Component\Routing\Annotation\Route;
  20. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  22. #[Route(defaults: ['_routeScope' => ['store-api']])]
  23. #[Package('core')]
  24. class ContextSwitchRoute extends AbstractContextSwitchRoute
  25. {
  26.     private const SHIPPING_METHOD_ID = SalesChannelContextService::SHIPPING_METHOD_ID;
  27.     private const PAYMENT_METHOD_ID = SalesChannelContextService::PAYMENT_METHOD_ID;
  28.     private const BILLING_ADDRESS_ID = SalesChannelContextService::BILLING_ADDRESS_ID;
  29.     private const SHIPPING_ADDRESS_ID = SalesChannelContextService::SHIPPING_ADDRESS_ID;
  30.     private const COUNTRY_ID = SalesChannelContextService::COUNTRY_ID;
  31.     private const STATE_ID = SalesChannelContextService::COUNTRY_STATE_ID;
  32.     private const CURRENCY_ID = SalesChannelContextService::CURRENCY_ID;
  33.     private const LANGUAGE_ID = SalesChannelContextService::LANGUAGE_ID;
  35.     /**
  36.      * @var SalesChannelContextPersister
  37.      */
  38.     protected $contextPersister;
  40.     /**
  41.      * @var DataValidator
  42.      */
  43.     protected $validator;
  45.     /**
  46.      * @internal
  47.      */
  48.     public function __construct(
  49.         DataValidator $validator,
  50.         SalesChannelContextPersister $contextPersister,
  51.         private readonly EventDispatcherInterface $eventDispatcher
  52.     ) {
  53.         $this->contextPersister = $contextPersister;
  54.         $this->validator = $validator;
  55.     }
  57.     public function getDecorated(): AbstractContextSwitchRoute
  58.     {
  59.         throw new DecorationPatternException(self::class);
  60.     }
  62.     #[Route(path: '/store-api/context', name: 'store-api.switch-context', methods: ['PATCH'])]
  63.     public function switchContext(RequestDataBag $data, SalesChannelContext $context): ContextTokenResponse
  64.     {
  65.         $definition = new DataValidationDefinition('context_switch');
  67.         $parameters = $data->only(
  68.             self::SHIPPING_METHOD_ID,
  69.             self::PAYMENT_METHOD_ID,
  70.             self::BILLING_ADDRESS_ID,
  71.             self::SHIPPING_ADDRESS_ID,
  72.             self::COUNTRY_ID,
  73.             self::STATE_ID,
  74.             self::CURRENCY_ID,
  75.             self::LANGUAGE_ID
  76.         );
  78.         $addressCriteria = new Criteria();
  79.         if ($context->getCustomer()) {
  80.             $addressCriteria->addFilter(new EqualsFilter('customer_address.customerId', $context->getCustomer()->getId()));
  81.         } else {
  82.             // do not allow to set address ids if the customer is not logged in
  83.             if (isset($parameters[self::SHIPPING_ADDRESS_ID])) {
  84.                 throw CartException::customerNotLoggedIn();
  85.             }
  87.             if (isset($parameters[self::BILLING_ADDRESS_ID])) {
  88.                 throw CartException::customerNotLoggedIn();
  89.             }
  90.         }
  92.         $currencyCriteria = new Criteria();
  93.         $currencyCriteria->addFilter(
  94.             new EqualsFilter('currency.salesChannels.id', $context->getSalesChannel()->getId())
  95.         );
  97.         $languageCriteria = new Criteria();
  98.         $languageCriteria->addFilter(
  99.             new EqualsFilter('language.salesChannels.id', $context->getSalesChannel()->getId())
  100.         );
  102.         $paymentMethodCriteria = new Criteria();
  103.         $paymentMethodCriteria->addFilter(
  104.             new EqualsFilter('payment_method.salesChannels.id', $context->getSalesChannel()->getId())
  105.         );
  107.         $shippingMethodCriteria = new Criteria();
  108.         $shippingMethodCriteria->addFilter(
  109.             new EqualsFilter('shipping_method.salesChannels.id', $context->getSalesChannel()->getId())
  110.         );
  112.         $definition
  113.             ->add(self::LANGUAGE_ID, new EntityExists(['entity' => 'language', 'context' => $context->getContext(), 'criteria' => $languageCriteria]))
  114.             ->add(self::CURRENCY_ID, new EntityExists(['entity' => 'currency', 'context' => $context->getContext(), 'criteria' => $currencyCriteria]))
  115.             ->add(self::SHIPPING_METHOD_ID, new EntityExists(['entity' => 'shipping_method', 'context' => $context->getContext(), 'criteria' => $shippingMethodCriteria]))
  116.             ->add(self::PAYMENT_METHOD_ID, new EntityExists(['entity' => 'payment_method', 'context' => $context->getContext(), 'criteria' => $paymentMethodCriteria]))
  117.             ->add(self::BILLING_ADDRESS_ID, new EntityExists(['entity' => 'customer_address', 'context' => $context->getContext(), 'criteria' => $addressCriteria]))
  118.             ->add(self::SHIPPING_ADDRESS_ID, new EntityExists(['entity' => 'customer_address', 'context' => $context->getContext(), 'criteria' => $addressCriteria]))
  119.             ->add(self::COUNTRY_ID, new EntityExists(['entity' => 'country', 'context' => $context->getContext()]))
  120.             ->add(self::STATE_ID, new EntityExists(['entity' => 'country_state', 'context' => $context->getContext()]))
  121.         ;
  123.         $this->validator->validate($parameters, $definition);
  125.         $customer = $context->getCustomer();
  126.         $this->contextPersister->save(
  127.             $context->getToken(),
  128.             $parameters,
  129.             $context->getSalesChannel()->getId(),
  130.             $customer && empty($context->getPermissions()) ? $customer->getId() : null
  131.         );
  133.         // Language was switched - Check new Domain
  134.         $changeUrl = $this->checkNewDomain($parameters, $context);
  136.         $event = new SalesChannelContextSwitchEvent($context, $data);
  137.         $this->eventDispatcher->dispatch($event);
  139.         return new ContextTokenResponse($context->getToken(), $changeUrl);
  140.     }
  142.     /**
  143.      * @param array<mixed> $parameters
  144.      */
  145.     private function checkNewDomain(array $parameters, SalesChannelContext $context): ?string
  146.     {
  147.         if (
  148.             !isset($parameters[self::LANGUAGE_ID])
  149.             || $parameters[self::LANGUAGE_ID] === $context->getLanguageId()
  150.         ) {
  151.             return null;
  152.         }
  154.         $domains = $context->getSalesChannel()->getDomains();
  155.         if ($domains === null) {
  156.             return null;
  157.         }
  159.         $langDomain = $domains->filterByProperty('languageId', $parameters[self::LANGUAGE_ID])->first();
  160.         if ($langDomain === null) {
  161.             return null;
  162.         }
  164.         return $langDomain->getUrl();
  165.     }
  166. }