src/Repository/UserRepository.php line 47

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\Contract;
  6. use App\Entity\InterventionRequest;
  7. use App\Entity\Reminder\Handler;
  8. use App\Entity\Reminder\Log;
  9. use App\Entity\User;
  10. use App\Service\InterventionRequest\WorkflowPlace;
  11. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use Symfony\Bridge\Doctrine\Security\User\UserLoaderInterface;
  15. /**
  16.  * @method User|null find($id, $lockMode = null, $lockVersion = null)
  17.  * @method User|null findOneBy(array $criteria, array $orderBy = null)
  18.  * @method User[]    findAll()
  19.  * @method User[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  20.  */
  21. class UserRepository extends ServiceEntityRepository implements UserLoaderInterface
  22. {
  23.     public function __construct(ManagerRegistry $registry)
  24.     {
  25.         parent::__construct($registry, User::class);
  26.     }
  28.     /**
  29.      * Used to upgrade (rehash) the user's password automatically over time.
  30.      */
  31.     public function upgradePassword(User $user, string $newHashedPassword): void
  32.     {
  33.         $user->setPassword($newHashedPassword);
  34.         $this->_em->persist($user);
  35.         $this->_em->flush();
  36.     }
  38.     /**
  39.      * On every page this method is called to load the user from session
  40.      * We need here to load authorizations and groups in a single query
  41.      * for perf issues.
  42.      *
  43.      * @throws \Doctrine\ORM\NonUniqueResultException
  44.      *
  45.      * @see UserLoaderInterface
  46.      */
  47.     public function loadUserByIdentifier(string $identifier): ?User
  48.     {
  49.         return $this->createQueryBuilder('u')
  50.             ->leftJoin('u.authorizations', 'ua')
  51.             ->addSelect('ua')
  52.             ->leftJoin('ua.authorization', 'a')
  53.             ->addSelect('a')
  54.             ->leftJoin('u.groups', 'ug')
  55.             ->addSelect('ug')
  56.             ->leftJoin('ug.group', 'g')
  57.             ->addSelect('g')
  58.             ->leftJoin('g.authorizations', 'gga')
  59.             ->addSelect('gga')
  60.             ->leftJoin('gga.authorization', 'ga')
  61.             ->addSelect('ga')
  62.             ->andWhere('u.enabled = 1 AND u.deleted=0')
  63.             ->andWhere('u.email = :val')
  64.             ->setParameter('val', $identifier)
  65.             ->getQuery()
  66.             ->getOneOrNullResult()
  67.             ;
  68.     }
  70.     /** @deprecated since Symfony 5.3 */
  71.     public function loadUserByUsername(string $username): ?User
  72.     {
  73.         return $this->loadUserByIdentifier($username);
  74.     }
  76.     // needed to refresh user by the provider
  78.     /**
  79.      * Refreshes the user after being reloaded from the session.
  80.      *
  81.      * When a user is logged in, at the beginning of each request, the
  82.      * User object is loaded from the session and then this method is
  83.      * called. Your job is to make sure the user's data is still fresh by,
  84.      * for example, re-querying for fresh User data.
  85.      *
  86.      * If your firewall is "stateless: true" (for a pure API), this
  87.      * method is not called.
  88.      *
  89.      * @return User
  90.      */
  91.     public function refreshUser(User $user)
  92.     {
  93.         return $this->createQueryBuilder('u')
  94.             ->leftJoin('u.authorizations', 'ua')
  95.             ->addSelect('ua')
  96.             ->leftJoin('ua.authorization', 'a')
  97.             ->addSelect('a')
  98.             ->leftJoin('u.groups', 'ug')
  99.             ->addSelect('ug')
  100.             ->leftJoin('ug.group', 'g')
  101.             ->addSelect('g')
  102.             ->leftJoin('g.authorizations', 'gga')
  103.             ->addSelect('gga')
  104.             ->leftJoin('gga.authorization', 'ga')
  105.             ->addSelect('ga')
  106.             ->andWhere('u.enabled = 1 AND u.deleted=0')
  107.             ->andWhere('u.id = :val')
  108.             ->setParameter('val', $user->getId())
  109.             ->getQuery()
  110.             ->getOneOrNullResult()
  111.             ;
  112.     }
  114.     public function hasAccess(int $subjectCompanyId, int $userCompanyId): bool
  115.     {
  116.         return $this->getEntityManager()
  117.             ->getRepository(Contract::class)
  118.             ->hasContractBetween($subjectCompanyId, $userCompanyId);
  119.     }
  121.     public function findLateInterventionRequest(Handler $handler)
  122.     {
  123.         $expression = $this->_em->getExpressionBuilder();
  124.         $minDate = (new \DateTimeImmutable())->modify('-2 days');
  125.         $minReminder = (new \DateTimeImmutable())->modify('-1 day');
  127.         return $this
  128.             ->createQueryBuilder('u')
  129.             ->where('u.enabled = 1')
  130.             ->andwhere('u.deleted = 0')
  131.             ->andWhere(
  132.                 $expression->exists(
  133.                     $this->_em
  134.                         ->createQueryBuilder()
  135.                         ->select('i')
  136.                         ->from(InterventionRequest::class, 'i')
  137.                         ->where('i.deleted = 0 and i.enabled = 1')
  138.                         ->andWhere('(i.place = :planning AND i.updatedAt < :minDate)')
  139.                         ->andWhere('intervention_request__available_for__user(i.id, u.id) = true')
  140.                 )
  141.             )
  142.             ->andWhere(
  143.                 $expression->not($expression->exists(
  144.                     $this->_em->getRepository(Log::class)
  145.                     ->createQueryBuilder('l')
  146.                     ->where('l.handler = :handler')
  147.                     ->andWhere('l.createdAt > :minReminder')
  148.                 ))
  149.             )
  150.             ->setParameter('minDate', $minDate)
  151.             ->setParameter('minReminder', $minReminder)
  152.             ->setParameter('handler', $handler)
  153.             ->setParameter('planning', WorkflowPlace::PLANNING)
  154.             ->setMaxResults(50)
  155.             ->getQuery()
  156.             ->getResult()
  157.         ;
  158.     }
  160.     public function getAllUsersForCompany(int $companyId)
  161.     {
  162.         $existingUsers = $this->createQueryBuilder('u')
  163.             ->where('u.externalId IS NOT NULL')
  164.             ->andWhere('u.company = :companyId')
  165.             ->setParameter('companyId', $companyId)
  166.             ->getQuery()
  167.             ->getResult();
  169.         $usersByExternalId = [];
  170.         foreach ($existingUsers as $us) {
  171.             $usersByExternalId[$us->getExternalId()] = $us;
  172.         }
  174.         return $usersByExternalId;
  175.     }
  177.     public function getAllByExternalId(int $companyId)
  178.     {
  179.         $existingUsers = $this->createQueryBuilder('u')
  180.             ->where('u.externalId IS NOT NULL')
  181.             ->andWhere('u.company = :companyId')
  182.             ->setParameter('companyId', $companyId)
  183.             ->getQuery()
  184.             ->getResult();
  186.         $usersByExternalId = [];
  187.         foreach ($existingUsers as $us) {
  188.             $usersByExternalId[$us->getExternalId()] = $us;
  189.         }
  191.         return $usersByExternalId;
  192.     }
  193. }