src/Repository/UserRepository.php line 24

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\User;
  6. use App\Model\UserFilter;
  7. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  8. use Doctrine\ORM\Query\Expr;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use Symfony\Component\Security\Core\Exception\UnsupportedUserException;
  11. use Symfony\Component\Security\Core\User\PasswordUpgraderInterface;
  12. use Symfony\Component\Security\Core\User\UserInterface;
  14. /**
  15.  * @method User|null find($id, $lockMode = null, $lockVersion = null)
  16.  * @method User|null findOneBy(array $criteria, array $orderBy = null)
  17.  * @method User[]    findAll()
  18.  * @method User[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  19.  *
  20.  * @extends ServiceEntityRepository<User>
  21.  */
  22. class UserRepository extends ServiceEntityRepository implements PasswordUpgraderInterface
  23. {
  24.     public function __construct(ManagerRegistry $registry)
  25.     {
  26.         parent::__construct($registry, User::class);
  27.     }
  29.     /**
  30.      * Used to upgrade (rehash) the user's password automatically over time.
  31.      */
  32.     public function upgradePassword(UserInterface $user, string $newEncodedPassword): void
  33.     {
  34.         if (!$user instanceof User) {
  35.             throw new UnsupportedUserException(sprintf('Instances of "%s" are not supported.', \get_class($user)));
  36.         }
  38.         $user->setPassword($newEncodedPassword);
  39.         $this->_em->persist($user);
  40.         $this->_em->flush();
  41.     }
  43.     /**
  44.      * @return array<User>|null
  45.      */
  46.     public function findByFilter(UserFilter $filter): ?array
  47.     {
  48.         $queryBuilder = $this->createQueryBuilder('user');
  49.         if (null !== $filter->getShift()) {
  50.             $queryBuilder->andWhere('user.shift = :shift')->setParameter(':shift', $filter->getShift());
  51.         }
  52.         if (null !== $filter->getDepartment()) {
  53.             $queryBuilder->andWhere('user.department = :department')->setParameter(':department', $filter->getDepartment());
  54.         }
  55.         if (count($filter->getCountries()) > 0) {
  56.             $queryBuilder->innerJoin('user.countries', 'countries', Expr\Join::WITH)
  57.                 ->andWhere('countries in (:c)')
  58.             ->setParameter(':c', $filter->getCountries());
  59.         }
  60.         $roles = $filter->getRoles();
  61.         if (count($roles) > 0) {
  62.             foreach ($roles as $role) {
  63.                 $queryBuilder->andWhere("JSONB_CONTAINS(user.roles, '[\"$role\"]') = true");
  64.             }
  65.         }
  67.         return $queryBuilder->getQuery()->getResult();
  68.     }
  69. }