vendor/shopware/administration/Controller/UserConfigController.php line 49

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Administration\Controller;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Defaults;
  7. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  8. use Shopware\Core\Framework\Api\Context\Exception\InvalidContextSourceException;
  9. use Shopware\Core\Framework\Api\Controller\Exception\ExpectedUserHttpException;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\MultiInsertQueryQueue;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\DataAbstractionLayer\FieldSerializer\JsonFieldSerializer;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Shopware\Core\Framework\Log\Package;
  18. use Shopware\Core\Framework\Routing\Annotation\RouteScope;
  19. use Shopware\Core\Framework\Routing\Annotation\Since;
  20. use Shopware\Core\Framework\Uuid\Uuid;
  21. use Shopware\Core\System\User\Aggregate\UserConfig\UserConfigDefinition;
  22. use Shopware\Core\System\User\Aggregate\UserConfig\UserConfigEntity;
  23. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  24. use Symfony\Component\HttpFoundation\JsonResponse;
  25. use Symfony\Component\HttpFoundation\Request;
  26. use Symfony\Component\HttpFoundation\Response;
  27. use Symfony\Component\Routing\Annotation\Route;
  29. #[Package('system-settings')]
  30. class UserConfigController extends AbstractController
  31. {
  32.     private EntityRepositoryInterface $userConfigRepository;
  34.     private Connection $connection;
  36.     /**
  37.      * @internal
  38.      */
  39.     public function __construct(EntityRepositoryInterface $userConfigRepository, Connection $connection)
  40.     {
  41.         $this->userConfigRepository = $userConfigRepository;
  42.         $this->connection = $connection;
  43.     }
  45.     /**
  46.      * @Since("6.4.5.0")
  47.      * @Route("/api/_info/config-me", name="api.config_me.get", defaults={"auth_required"=true, "_routeScope"={"administration"}}, methods={"GET"})
  48.      */
  49.     public function getConfigMe(Context $context, Request $request): Response
  50.     {
  51.         $userConfigs = $this->getOwnUserConfig($context, $request->query->all('keys'));
  52.         $data = [];
  53.         /** @var UserConfigEntity $userConfig */
  54.         foreach ($userConfigs as $userConfig) {
  55.             $data[$userConfig->getKey()] = $userConfig->getValue();
  56.         }
  58.         return new JsonResponse(['data' => $data]);
  59.     }
  61.     /**
  62.      * @Since("6.4.5.0")
  63.      * @Route("/api/_info/config-me", name="api.config_me.update", defaults={"auth_required"=true, "_routeScope"={"administration"}}, methods={"POST"})
  64.      */
  65.     public function updateConfigMe(Context $context, Request $request): Response
  66.     {
  67.         $postUpdateConfigs = $request->request->all();
  69.         if (empty($postUpdateConfigs)) {
  70.             return new JsonResponse(null, Response::HTTP_NO_CONTENT);
  71.         }
  73.         $this->massUpsert($context, $postUpdateConfigs);
  75.         return new JsonResponse(null, Response::HTTP_NO_CONTENT);
  76.     }
  78.     private function getOwnUserConfig(Context $context, array $keys): array
  79.     {
  80.         $userId = $this->getUserId($context);
  82.         $criteria = new Criteria();
  83.         $criteria->addFilter(new EqualsFilter('userId', $userId));
  84.         if (!empty($keys)) {
  85.             $criteria->addFilter(new EqualsAnyFilter('key', $keys));
  86.         }
  88.         return $this->userConfigRepository->search($criteria, $context)->getElements();
  89.     }
  91.     private function getUserId(Context $context): string
  92.     {
  93.         if (!$context->getSource() instanceof AdminApiSource) {
  94.             throw new InvalidContextSourceException(AdminApiSource::class, \get_class($context->getSource()));
  95.         }
  97.         $userId = $context->getSource()->getUserId();
  98.         if (!$userId) {
  99.             throw new ExpectedUserHttpException();
  100.         }
  102.         return $userId;
  103.     }
  105.     private function massUpsert(Context $context, array $postUpdateConfigs): void
  106.     {
  107.         $userId = $this->getUserId($context);
  108.         $userConfigs = $this->getOwnUserConfig($context, array_keys($postUpdateConfigs));
  109.         $userConfigsGroupByKey = [];
  111.         /** @var UserConfigEntity $userConfig */
  112.         foreach ($userConfigs as $userConfig) {
  113.             $userConfigsGroupByKey[$userConfig->getKey()] = $userConfig->getId();
  114.         }
  116.         $queue = new MultiInsertQueryQueue($this->connection, 250, false, true);
  117.         foreach ($postUpdateConfigs as $key => $value) {
  118.             $data = [
  119.                 'value' => JsonFieldSerializer::encodeJson($value),
  120.                 'user_id' => Uuid::fromHexToBytes($userId),
  121.                 'key' => $key,
  122.                 'id' => Uuid::randomBytes(),
  123.                 'created_at' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  124.             ];
  125.             if (\array_key_exists($key, $userConfigsGroupByKey)) {
  126.                 $data['id'] = Uuid::fromHexToBytes($userConfigsGroupByKey[$key]);
  127.             }
  129.             $queue->addInsert(UserConfigDefinition::ENTITY_NAME, $data);
  130.         }
  132.         $queue->execute();
  133.     }
  134. }