src/DataProvider/UserCollectionDataProvider.php line 14

Open in your IDE?
  1. <?php
  3. namespace App\DataProvider;
  5. use App\Entity\User;
  6. use App\Service\EsCache;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use ApiPlatform\Doctrine\Orm\Util\QueryNameGenerator;
  9. use ApiPlatform\Core\DataProvider\RestrictedDataProviderInterface;
  10. use ApiPlatform\Core\DataProvider\ContextAwareCollectionDataProviderInterface;
  12. final class UserCollectionDataProvider implements ContextAwareCollectionDataProviderInterface, RestrictedDataProviderInterface
  13. {
  14.     public function __construct(private EntityManagerInterface $_em, private $collectionExtensions = [], private EsCache $esCache)
  15.     {}
  17.     public function supports(string $resourceClass, string $operationName = null, array $context = []): bool
  18.     {
  19.         return User::class === $resourceClass && $operationName === 'get_for_assign_with_group';
  20.     }
  22.     public function getCollection(string $resourceClass, string $operationName = null, array $context = []): iterable
  23.     {
  24.         $queryBuilder = $this->_em->getRepository(User::class)->createQueryBuilder('x');
  25.         $queryNameGenerator = new QueryNameGenerator();   
  27.         foreach ($this->collectionExtensions as $extension) {
  28.             $extension->applyToCollection($queryBuilder, $queryNameGenerator, $resourceClass, $operationName, $context);
  29.         }
  30.         $users = $queryBuilder->getQuery()->getResult();
  32.         $cond = ' WHERE client_id = '.$this->esCache->getClient()->getId().' AND is_generated = 0';
  33.         if (isset($context['filters']['user_name_search']) && strlen($context['filters']['user_name_search']) > 0) {
  34.             $cond .= ' AND name LIKE "%'.$context['filters']['user_name_search'].'%"';
  35.         }
  37.         $query = 'SELECT id, name as firstName, "" as lastName, "" as company, "" as jobTitle, "" as country, "" as imageName, "group" as type FROM user_group'.$cond;
  38.         $statement = $this->_em->getConnection()->prepare($query);
  39.         $userGroups = $statement->executeQuery()->fetchAllAssociative();
  41.         return [...$users, ...$userGroups];
  42.     }
  43. }