src/Repository/FlatRepository.php line 1200

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\Flat;
  6. use App\Entity\Building;
  7. use App\Entity\Resident;
  8. use App\Services\FlatService;
  9. use DateTime;
  10. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  11. use Doctrine\ORM\NonUniqueResultException;
  12. use Doctrine\ORM\NoResultException;
  13. use Doctrine\ORM\OptimisticLockException;
  14. use Doctrine\ORM\QueryBuilder;
  15. use Doctrine\Persistence\ManagerRegistry;
  16. use App\Entity\User;
  17. use Doctrine\ORM\Query\Expr\Join;
  18. use PDepend\Util\Coverage\Factory;
  19. use PDepend\Util\Type;
  20. use App\Utils\ApiV2\ListItemsOptions as ListItemsOptionsV2;
  22. /**
  23.  * @method Flat|null find($id, $lockMode = null, $lockVersion = null)
  24.  * @method Flat|null findOneBy(array $criteria, array $orderBy = null)
  25.  * @method Flat[]    findAll()
  26.  * @method Flat[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  27.  */
  28. class FlatRepository extends BaseRepository
  29. {
  30.     /**
  31.      * BuildingRepository constructor.
  32.      *
  33.      * @param ManagerRegistry $registry
  34.      */
  35.     public function __construct(ManagerRegistry $registry)
  36.     {
  37.         $this->entityClass = Flat::class;
  38.         parent::__construct($registry);
  39.     }
  41.     public function flush(): void
  42.     {
  43.         $this->_em->flush();
  44.     }
  46.     /**
  47.      * @param int $buildingId
  48.      *
  49.      * @return array<mixed>
  50.      */
  51.     public function getFlatsByBuildingIdNoUser(int $buildingId): array
  52.     {
  53.         return $this->createQueryBuilder('f')
  54.             ->innerJoin('f.building', 'b')
  55.             ->where('f.building = :building')
  56.             ->andWhere('f.archived = 0')
  57.             ->select([
  58.                 'f.id',
  59.                 'f.displayFlatId',
  60.                 'f.ownerName',
  61.                 'f.ownerLastname',
  62.                 'f.companyName',
  63.                 'f.type',
  64.                 'f.subType',
  65.                 'b.id as buildingId'
  66.             ])
  67.             ->setParameter('building', $buildingId)
  68.             ->getQuery()
  69.             ->getResult();
  70.     }
  72.     /**
  73.      * @param User $user
  74.      * @param Building $building
  75.      * @param int $archived
  76.      * @return array<mixed>
  77.      */
  78.     public function getFlatsByBuilding(User $user, Building $building, int $archived = 0): array
  79.     {
  80.         $query = $this->createQueryBuilder('f')
  81.             ->select('f, u')
  82.             ->innerJoin('f.user', 'u')
  83.             ->where('f.user = :user')
  84.             ->andWhere('f.building = :building');
  85.         if ($archived) {
  86.             $query->andWhere('f.archived = 0');
  87.         }
  88.         return $query
  89.             ->setParameters([
  90.                 'user' => $user,
  91.                 'building' => $building
  92.             ])
  93.             ->orderBy('f.displayFlatId', 'ASC')
  94.             ->getQuery()
  95.             ->getArrayResult();
  96.     }
  98.     /**
  99.      * @param User $user
  100.      * @param Building $building
  101.      * @param int $archived
  102.      * @return array<mixed>
  103.      */
  104.     public function getFlatsByBuildingOrderedById(User $user, Building $building, int $archived = 0): array
  105.     {
  106.         $query = $this->createQueryBuilder('f')
  107.             ->select('f, u')
  108.             ->innerJoin('f.user', 'u')
  109.             ->where('f.user = :user')
  110.             ->andWhere('f.building = :building');
  111.         if ($archived) {
  112.             $query->andWhere('f.archived = 0');
  113.         }
  114.         $query = $query
  115.             ->setParameters([
  116.                 'user' => $user,
  117.                 'building' => $building
  118.             ])
  119.             ->orderBy('f.id', 'ASC')
  120.             ->getQuery()
  121.             ->getArrayResult();
  123.         usort($query, fn($a, $b) => (int) $a['displayFlatId'] <=> (int) $b['displayFlatId']);
  124.         return $query;
  125.     }
  127.     /**
  128.      * @param User $user
  129.      * @param Building $building
  130.      * @param int $archived
  131.      * @return int
  132.      * @throws NoResultException
  133.      * @throws NonUniqueResultException
  134.      */
  135.     public function countFlatsByBuildingWithOccupant(User $user, Building $building, int $archived = 0): int
  136.     {
  137.         return $this->createQueryBuilder('f')
  138.             ->select('count(f.id)')
  139.             ->innerJoin('f.user', 'u')
  140.             ->where('f.user = :user')
  141.             ->andWhere('f.building = :building')
  142.             ->andWhere('f.occupantEmail is not null')
  143.             ->andWhere('f.archived = 0')
  144.             ->setParameters([
  145.                 'user' => $user,
  146.                 'building' => $building
  147.             ])
  148.             ->getQuery()
  149.             ->getSingleScalarResult();
  150.     }
  152.     /**
  153.      * @param User $user
  154.      * @param Building $building
  155.      * @param int $archived
  156.      * @return float|null
  157.      * @throws NoResultException
  158.      * @throws NonUniqueResultException
  159.      */
  160.     public function getFlatsByBuildingOldDebitSum(User $user, Building $building, int $archived = 0): float|null
  161.     {
  162.         $query = $this->createQueryBuilder('f')
  163.             ->select('sum(f.oldDebit) as sumOldDebit')
  164.             ->innerJoin('f.user', 'u')
  165.             ->where('f.user = :user')
  166.             ->andWhere('f.building = :building');
  167.         if ($archived) {
  168.             $query->andWhere('f.archived = 0');
  169.         }
  170.         return $query
  171.             ->setParameters([
  172.                 'user' => $user,
  173.                 'building' => $building
  174.             ])->getQuery()
  175.             ->getSingleScalarResult();
  176.     }
  178.     /**
  179.      * @param User $user
  180.      * @param Building $building
  181.      * @param int $archived
  182.      * @return array<Flat>
  183.      */
  184.     public function getFlatsByBuildingArray(User $user, Building $building, int $archived = 0): array
  185.     {
  186.         $query = $this->createQueryBuilder('f')
  187.             ->select('f, u')
  188.             ->innerJoin('f.user', 'u')
  189.             ->where('f.user = :user')
  190.             ->andWhere('f.building = :building');
  191.         if ($archived) {
  192.             $query->andWhere('f.archived = 0');
  193.         }
  194.         return $query
  195.             ->setParameters([
  196.                 'user' => $user,
  197.                 'building' => $building
  198.             ])
  199.             ->orderBy('f.displayFlatId', 'ASC')
  200.             ->getQuery()
  201.             ->getResult();
  202.     }
  204.     /**
  205.      * @param array<User> $users
  206.      * @param DateTime|null $lastDayOfPreviousMont
  207.      * @return int
  208.      * @throws NoResultException
  209.      * @throws NonUniqueResultException
  210.      */
  211.     public function getActiveFlatsByUser(array $users, DateTime $lastDayOfPreviousMont = null): int
  212.     {
  213.         $query = $this->createQueryBuilder('f')
  214.             ->select('count(f.id)')
  215.             ->leftJoin('f.building', 'b')
  216.             ->where('b.activeStatus = 1')
  217.             ->andWhere('f.user in (:users)')
  218.             ->andWhere('f.archived = 0');
  220.         if (!empty($lastDayOfPreviousMont)) {
  221.             $query->andWhere('f.createdAt < :lastDayOfPreviousMonth')
  222.                 ->setParameter('lastDayOfPreviousMonth', $lastDayOfPreviousMont);
  223.         }
  225.         return $query->setParameter('users', $users)
  226.             ->getQuery()
  227.             ->getSingleScalarResult();
  228.     }
  230.     /**
  231.      * @param int $user
  232.      * @return array<Flat>
  233.      */
  234.     public function getActiveFlatsObjectsByUser(int $user): array
  235.     {
  236.         return $this->createQueryBuilder('f')
  237.             ->leftJoin('f.building', 'b')
  238.             ->where('b.activeStatus = 1')
  239.             ->andWhere('f.user = :user')
  240.             ->andWhere('f.archived = 0')
  241.             ->setParameters([
  242.                 'user' => $user,
  243.             ])
  244.             ->getQuery()
  245.             ->getResult();
  246.     }
  248.     /**
  249.      * @param User $user
  250.      * @param Building $building
  251.      * @return array<Flat>
  252.      */
  253.     public function getActiveFlatsByUserAndBuilding(User $user, Building $building): array
  254.     {
  255.         return $this->createQueryBuilder('f')
  256.             ->where('f.building = :building')
  257.             ->andWhere('f.user = :user')
  258.             ->setParameters([
  259.                 'user' => $user,
  260.                 'building' => $building
  261.             ])
  262.             ->getQuery()
  263.             ->getResult();
  264.     }
  266.     /**
  267.      * @param User $user
  268.      * @return array<Flat>
  269.      */
  270.     public function getActiveFlatsArrayByUser(User $user): array
  271.     {
  272.         return $this->createQueryBuilder('f')
  273.             ->leftJoin('f.building', 'b')
  274.             ->where('b.activeStatus = 1')
  275.             ->andWhere('f.user = :user')
  276.             ->setParameters([
  277.                 'user' => $user,
  278.             ])
  279.             ->getQuery()
  280.             ->getArrayResult();
  281.     }
  283.     /**
  284.      * @param User $user
  285.      * @return int
  286.      * @throws NoResultException
  287.      * @throws NonUniqueResultException
  288.      */
  289.     public function getInactiveFlatsByUser(User $user): int
  290.     {
  291.         return $this->createQueryBuilder('f')
  292.             ->select('count(f.id)')
  293.             ->leftJoin('f.building', 'b')
  294.             ->where('b.activeStatus = 0')
  295.             ->andWhere('f.user = :user')
  296.             ->setParameters([
  297.                 'user' => $user,
  298.             ])
  299.             ->getQuery()
  300.             ->getSingleScalarResult();
  301.     }
  303.     /**
  304.      * @param array<int> $flatIds
  305.      *
  306.      * @return array<Flat>
  307.      */
  308.     public function findByIds(array $flatIds): array
  309.     {
  310.         $qb = $this->createQueryBuilder('f');
  311.         return $qb->where($qb->expr()->in('f.id', $flatIds))
  312.             ->getQuery()
  313.             ->getResult();
  314.     }
  316.     /**
  317.      * @param User $user
  318.      * @param Building $building
  319.      * @param int $archived
  320.      *
  321.      * @return array<Flat>
  322.      */
  323.     public function getFlatsObjByBuilding(User $user, Building $building, int $archived = 0): array
  324.     {
  325.         $query = $this->createQueryBuilder('f')
  326.             ->where('f.user = :user')
  327.             ->andWhere('f.building = :building');
  328.         if ($archived) {
  329.             $query->andWhere('f.archived = 0');
  330.         }
  331.         $query
  332.             ->setParameters([
  333.                 'user' => $user,
  334.                 'building' => $building
  335.             ])
  336.             ->orderBy('f.displayFlatId', 'ASC');
  337.         return $query
  338.             ->getQuery()
  339.             ->getResult();
  340.     }
  342.     /**
  343.      * @param User $user
  344.      * @param Building $building
  345.      * @param string $number
  346.      * @return Flat|null
  347.      * @throws NonUniqueResultException
  348.      */
  349.     public function getFlatsObjByBuildingAndDisplayFlatId(User $user, Building $building, string $number): ?Flat
  350.     {
  351.         return $this->createQueryBuilder('f')
  352.             ->where('f.user = :user')
  353.             ->andWhere('f.building = :building')
  354.             ->andWhere('f.displayFlatId = :number')
  355.             ->setParameters([
  356.                 'user' => $user,
  357.                 'building' => $building,
  358.                 'number' => $number
  359.             ])
  360.             ->getQuery()
  361.             ->getOneOrNullResult();
  362.     }
  364.     /**
  365.      * @param User $user
  366.      * @param int $id
  367.      *
  368.      * @return Flat
  369.      * @throws NonUniqueResultException
  370.      */
  371.     public function getFlatById(User $user, int $id): Flat
  372.     {
  373.         return $this->createQueryBuilder('f')
  374.             ->where('f.user = :user')
  375.             ->andWhere('f.id = :id')
  376.             ->setParameters([
  377.                 'user' => $user,
  378.                 'id' => $id
  379.             ])
  380.             ->getQuery()
  381.             ->getOneOrNullResult();
  382.     }
  384.     /**
  385.      * @param User $user
  386.      * @param array<int> $ids
  387.      *
  388.      * @return array<Flat>
  389.      * @throws NonUniqueResultException
  390.      */
  391.     public function getFlatsById(User $user, array $ids): array
  392.     {
  393.         return $this->createQueryBuilder('f')
  394.             ->where('f.user = :user')
  395.             ->andWhere('f.id IN (:ids)')
  396.             ->setParameters([
  397.                 'user' => $user,
  398.                 'ids' => $ids
  399.             ])
  400.             ->getQuery()
  401.             ->getOneOrNullResult();
  402.     }
  404.     /**
  405.      * @param Building $building
  406.      * @param array<int|string> $ids
  407.      * @param bool|null $exclude
  408.      * @return array<string>
  409.      * @throws NonUniqueResultException
  410.      */
  411.     public function getSumFlatsById(Building $building, array $ids, bool $exclude = null): array
  412.     {
  414.         $query = $this->createQueryBuilder('f')
  415.             ->select('sum(f.members) as totalMembers, sum(f.size) as sizeTotal')
  416.             ->where('f.building = :building')
  417.             ->andWhere('f.archived = 0');
  419.         if ($exclude) {
  420.             $query->andWhere('f.displayFlatId NOT IN (:ids)');
  421.         } else {
  422.             $query->andWhere('f.displayFlatId IN (:ids)');
  423.         }
  425.         $query->setParameters([
  426.             'ids' => $ids,
  427.             'building' => $building
  428.         ]);
  429.         return $query->getQuery()
  430.             ->getOneOrNullResult();
  431.     }
  433.     /**
  434.      * @param array<Flat> $flats
  435.      *
  436.      * @return array<Flat>
  437.      */
  438.     public function assoccFlatArray(array $flats): array
  439.     {
  440.         $ret = [];
  441.         $ret['all'] = 'All';
  442.         /** @var Flat $flat */
  443.         foreach ($flats as $flat) {
  444.             $ret[$flat['displayFlatId']] = $flat['id'];
  445.         }
  447.         return $ret;
  448.     }
  450.     /**
  451.      * @param Building $building
  452.      * @param array<mixed> $flatNumbersComplex
  453.      *
  454.      * @return array<Flat>
  455.      */
  456.     public function getDistinctFlatSizesFiltered(Building $building, array $flatNumbersComplex): array
  457.     {
  458.         $query = $this->createQueryBuilder('f')
  459.             ->select('f.size')
  460.             ->where('f.building = :building');
  462.         if ($flatNumbersComplex['participants'][0] != 0) {
  463.             if ($flatNumbersComplex['excludeFromBill']) {
  464.                 $query->andWhere('f.displayFlatId NOT IN (:flatNumbers)');
  465.             } else {
  466.                 $query->andWhere('f.displayFlatId IN (:flatNumbers)');
  467.             }
  469.             $query->setParameters([
  470.                 'building' => $building,
  471.                 'flatNumbers' => $flatNumbersComplex['participants']
  472.             ]);
  473.         } else {
  474.             $query->setParameters([
  475.                 'building' => $building
  476.             ]);
  477.         }
  480.         $values = $query->distinct()
  481.             ->getQuery()
  482.             ->getArrayResult();
  484.         asort($values);
  485.         return $values;
  486.     }
  488.     /**
  489.      * @return int
  490.      * @throws NoResultException
  491.      * @throws NonUniqueResultException
  492.      */
  493.     public function countFlats(): int
  494.     {
  495.         return (int)$this->createQueryBuilder('f')
  496.             ->select('count(f.id) as sumFlats')
  497.             ->getQuery()
  498.             ->getSingleScalarResult();
  499.     }
  501.     /**
  502.      * @return int
  503.      * @throws NoResultException
  504.      * @throws NonUniqueResultException
  505.      */
  506.     public function countActiveFlats(): int
  507.     {
  508.         return (int)$this->createQueryBuilder('f')
  509.             ->innerJoin('f.building', 'b')
  510.             ->where('b.activeStatus = 1')
  511.             ->select('count(f.id) as sumFlats')
  512.             ->getQuery()
  513.             ->getSingleScalarResult();
  514.     }
  516.     /**
  517.      * @param Building $building
  518.      * @param User $user
  519.      * @return array<string>
  520.      */
  521.     public function getFlatEmails(Building $building, User $user): array
  522.     {
  523.         $emails = $this->createQueryBuilder('f')
  524.             ->select('f.ownerEmail')
  525.             ->where('f.building = :building')
  526.             ->andWhere('f.user = :user')
  527.             ->setParameters([
  528.                 'building' => $building,
  529.                 'user' => $user
  530.             ])
  531.             ->getQuery()
  532.             ->getArrayResult();
  534.         $filteredEmails = [];
  536.         foreach ($emails as $email) {
  537.             if ($email['ownerEmail'] != '') {
  538.                 $filteredEmails[] = $email['ownerEmail'];
  539.             }
  540.         }
  542.         return $filteredEmails;
  543.     }
  545.     /**
  546.      * @param User $user
  547.      * @param Building $building
  548.      * @return float
  549.      * @throws NonUniqueResultException
  550.      */
  551.     public function getBuildingFlatsCurrentDebitSum(User $user, Building $building): float
  552.     {
  553.         return $this->createQueryBuilder('f')
  554.             ->select('sum(f.debit) as currentDebitSum')
  555.             ->where('f.user = :user')
  556.             ->andWhere('f.building = :building')
  557.             ->setParameters([
  558.                 'user' => $user,
  559.                 'building' => $building
  560.             ])
  561.             ->getQuery()
  562.             ->getOneOrNullResult();
  563.     }
  565.     /**
  566.      * @param User $user
  567.      * @param Building $building
  568.      * @return float
  569.      * @throws NonUniqueResultException|NoResultException
  570.      */
  571.     public function getBuildingFlatsCurrentFullDebitSum(User $user, Building $building): float
  572.     {
  573.         return $this->createQueryBuilder('f')
  574.             ->select('sum(f.debit) as currentDebitSum')
  575.             ->where('f.user = :user')
  576.             ->andWhere('f.building = :building')
  577.             ->andWhere('f.archived = 0')
  578.             ->andWhere('f.debit > 0')
  579.             ->setParameters([
  580.                 'user' => $user,
  581.                 'building' => $building
  582.             ])
  583.             ->getQuery()
  584.             ->getSingleScalarResult();
  585.     }
  587.     /**
  588.      * @param Building $building
  589.      * @return array<Flat>
  590.      */
  591.     public function getFlatsWithEmail(Building $building): array
  592.     {
  593.         return $this->createQueryBuilder('f')
  594.             ->andWhere('f.building = :building')
  595.             ->andWhere('f.ownerEmail is not null')
  596.             ->andWhere('f.emailCanBeUsed = 1')
  597.             ->andWhere('f.archived = 0')
  598.             ->setParameters([
  599.                 'building' => $building
  600.             ])
  601.             ->getQuery()
  602.             ->getResult();
  603.     }
  605.     /**
  606.      * @param Building $building
  607.      * @return array<array<string>>
  608.      */
  609.     public function getDistinctOwnerEmails(Building $building): array
  610.     {
  611.         return $this->createQueryBuilder('f')
  612.             ->select('f.ownerEmail, MIN(f.occupantEmail) AS occupantEmail')
  613.             ->andWhere('f.building = :building')
  614.             ->andWhere('f.ownerEmail IS NOT NULL')
  615.             ->andWhere('f.emailCanBeUsed = 1')
  616.             ->andWhere('f.archived = 0')
  617.             ->groupBy('f.ownerEmail')
  618.             ->setParameter('building', $building)
  619.             ->getQuery()
  620.             ->getResult();
  621.     }
  623.     /**
  624.      * @param User $user
  625.      * @param Building $building
  626.      *
  627.      * @return array<Flat>
  628.      */
  629.     public function findFlatsWithDebitByBuilding(User $user, Building $building): array
  630.     {
  631.         return $this->createQueryBuilder('f')
  632.             ->where('f.user = :user')
  633.             ->andWhere('f.building = :building')
  634.             ->andWhere('f.archived = 0')
  635.             ->andWhere('(f.debit + f.oldDebit)<>0 OR f.previousBill is not null')
  636.             ->setParameters([
  637.                 'user' => $user,
  638.                 'building' => $building
  639.             ])
  640.             ->orderBy('f.displayFlatId + 0', 'ASC')
  641.             ->getQuery()
  642.             ->getResult();
  643.     }
  645.     /**
  646.      * @param int $start
  647.      * @param int $limit
  648.      *
  649.      * @return array<mixed>
  650.      */
  651.     public function findFlatsForMoneyLogData(int $start, int $limit): array
  652.     {
  653.         return $this->createQueryBuilder('f')
  654.             ->setFirstResult($start)
  655.             ->setMaxResults($limit)
  656.             ->getQuery()
  657.             ->getResult();
  658.     }
  660.     /**
  661.      * @param Building $building
  662.      * @return int|mixed|string|null
  663.      * @throws NonUniqueResultException
  664.      */
  665.     public function findLastArchiveFlatsByBuilding(Building $building): mixed
  666.     {
  667.         return $this->createQueryBuilder('f')
  668.             ->select('f.displayFlatId')
  669.             ->andWhere('f.building = :building')
  670.             ->andWhere('f.archived = 1')
  671.             ->setParameters([
  672.                 'building' => $building
  673.             ])
  674.             ->orderBy('f.archivedAt', 'DESC')
  675.             ->setMaxResults(1)
  676.             ->getQuery()
  677.             ->getOneOrNullResult();
  678.     }
  680.     /**
  681.      * @param User $user
  682.      * @param Building $building
  683.      * @return string
  684.      * @throws NonUniqueResultException|NoResultException
  685.      */
  686.     public function countArchiveFlatsByBuilding(User $user, Building $building): string
  687.     {
  688.         return $this->createQueryBuilder('f')
  689.             ->select('count(f)')
  690.             ->where('f.user = :user')
  691.             ->andWhere('f.building = :building')
  692.             ->andWhere('f.archived = 1')
  693.             ->setParameters([
  694.                 'user' => $user,
  695.                 'building' => $building
  696.             ])
  697.             ->getQuery()
  698.             ->getSingleScalarResult();
  699.     }
  701.     /**
  702.      * @param Flat $currentFlat
  703.      * @param User $user
  704.      *
  705.      * @return array<Flat>
  706.      */
  707.     public function getArchivedFlatsByCurrentFlat(Flat $currentFlat, User $user): array
  708.     {
  709.         return $this->createQueryBuilder('f')
  710.             ->where('f.user = :user')
  711.             ->andWhere('f.currentFlat = :currentFlat')
  712.             ->andWhere('f.archived = 1')
  713.             ->setParameters([
  714.                 'currentFlat' => $currentFlat,
  715.                 'user' => $user
  716.             ])
  717.             ->getQuery()
  718.             ->getResult();
  719.     }
  721.     /**
  722.      * @param User $user
  723.      * @param Building $building
  724.      *
  725.      * @return array<Flat>
  726.      */
  727.     public function findArchivedFlatsWithDebitByBuilding(User $user, Building $building): array
  728.     {
  729.         return $this->createQueryBuilder('f')
  730.             ->where('f.user = :user')
  731.             ->andWhere('f.building = :building')
  732.             ->andWhere('f.archived = 1')
  733.             ->andWhere('((f.debit + f.previousBill) <> 0) OR (f.oldDebit > 0)')
  734.             ->setParameters([
  735.                 'user' => $user,
  736.                 'building' => $building
  737.             ])
  738.             ->orderBy('f.displayFlatId + 0', 'ASC')
  739.             ->getQuery()
  740.             ->getResult();
  741.     }
  743.     /**
  744.      * @param Building $building
  745.      * @param string $flatNumber
  746.      * @return Flat|null
  747.      * @throws NonUniqueResultException
  748.      */
  749.     public function getFlatByFlatNumber(Building $building, string $flatNumber): ?Flat
  750.     {
  751.         return $this->createQueryBuilder('f')
  752.             ->where('f.building = :building')
  753.             ->andWhere('f.displayFlatId = :flatNumber')
  754.             ->setParameters([
  755.                 'building' => $building,
  756.                 'flatNumber' => $flatNumber
  757.             ])
  758.             ->getQuery()
  759.             ->getOneOrNullResult();
  760.     }
  762.     /**
  763.      * @param User $user
  764.      * @param Building $building
  765.      * @return array<Flat>
  766.      */
  767.     public function getArchivedFlatsObjByBuilding(User $user, Building $building): array
  768.     {
  769.         $query = $this->createQueryBuilder('f')
  770.             ->where('f.user = :user')
  771.             ->andWhere('f.building = :building')
  772.             ->andWhere('f.archived = 1')
  773.             ->setParameters([
  774.                 'user' => $user,
  775.                 'building' => $building
  776.             ])
  777.             ->orderBy('f.displayFlatId', 'ASC');
  778.         return $query
  779.             ->getQuery()
  780.             ->getResult();
  781.     }
  783.     /**
  784.      * @param User $user
  785.      * @param Building $building
  786.      * @return array<Flat>
  787.      */
  788.     public function getArchivedFlatsOrderByArchivedAt(User $user, Building $building): array
  789.     {
  790.         return $this->createQueryBuilder('f')
  791.             ->where('f.user = :user')
  792.             ->andWhere('f.building = :building')
  793.             ->andWhere('f.archived = 1')
  794.             ->setParameters([
  795.                 'user' => $user,
  796.                 'building' => $building
  797.             ])
  798.             ->orderBy('f.archivedAt', 'DESC')
  799.             ->getQuery()
  800.             ->getResult();
  801.     }
  803.     /**
  804.      * @param User $user
  805.      * @param Building $building
  806.      * @return array<Flat>
  807.      */
  808.     public function getFlatsObjectsByBuilding(User $user, Building $building): array
  809.     {
  810.         $query = $this->createQueryBuilder('f')
  811.             ->where('f.user = :user')
  812.             ->andWhere('f.building = :building')
  813.             ->andWhere('f.archived = 0')
  814.             ->setParameters([
  815.                 'user' => $user,
  816.                 'building' => $building
  817.             ])
  818.             ->orderBy('f.displayFlatId', 'ASC');
  819.         return $query
  820.             ->getQuery()
  821.             ->getResult();
  822.     }
  824.     /**
  825.      * @param User $user
  826.      * @param Building $building
  827.      * @param bool $haveEmail
  828.      * @return array<Flat>
  829.      */
  830.     public function getFlatsByEmailForOldDebit(User $user, Building $building, bool $haveEmail): array
  831.     {
  832.         $query = $this->createQueryBuilder('f')
  833.             ->where('f.user = :user')
  834.             ->andWhere('f.building = :building')
  835.             ->andWhere('f.oldDebit > 0')
  836.             ->setParameters([
  837.                 'user' => $user,
  838.                 'building' => $building,
  839.             ]);
  840.         if ($haveEmail) {
  841.             $query->andWhere('f.emailCanBeUsed = 1');
  842.         } else {
  843.             $query->andWhere('f.emailCanBeUsed = 0');
  844.         }
  845.         return $query
  846.             ->orderBy('f.displayFlatId', 'ASC')
  847.             ->getQuery()
  848.             ->getResult();
  849.     }
  851.     /**
  852.      * @param Building $building
  853.      * @return int
  854.      * @throws NoResultException
  855.      * @throws NonUniqueResultException
  856.      */
  857.     public function countFlatsByPhoneNumberForOldDebit(Building $building): int
  858.     {
  859.         return $this->createQueryBuilder('f')
  860.             ->select('COUNT(f.id)')
  861.             ->where('f.building = :building')
  862.             ->andWhere('f.oldDebit > 0')
  863.             ->andWhere('f.ownerPhoneNumber is not null')
  864.             ->setParameters([
  865.                 'building' => $building,
  866.             ])
  867.             ->getQuery()
  868.             ->getSingleScalarResult();
  869.     }
  871.     /**
  872.      * @param Building $building
  873.      * @return array<Flat>
  874.      */
  875.     public function getFlatsByPhoneNumberForOldDebit(Building $building): array
  876.     {
  877.         return  $this->createQueryBuilder('f')
  878.             ->where('f.building = :building')
  879.             ->andWhere('f.oldDebit > 0')
  880.             ->andWhere('f.ownerPhoneNumber is not null')
  881.             ->setParameters([
  882.                 'building' => $building,
  883.             ])
  884.             ->orderBy('f.displayFlatId', 'ASC')
  885.             ->getQuery()
  886.             ->getResult();
  887.     }
  889.     /**
  890.      * @param Building $building
  891.      * @return int
  892.      * @throws NoResultException
  893.      * @throws NonUniqueResultException
  894.      */
  895.     public function countFlatsByPhoneNumberForSendBill(Building $building): int
  896.     {
  897.         return $this->createQueryBuilder('f')
  898.             ->select('COUNT(f.id)')
  899.             ->where('f.building = :building')
  900.             ->andWhere('f.ownerPhoneNumber is not null')
  901.             ->setParameters([
  902.                 'building' => $building,
  903.             ])
  904.             ->getQuery()
  905.             ->getSingleScalarResult();
  906.     }
  908.     /**
  909.      * @param Building $building
  910.      * @return array<Flat>
  911.      */
  912.     public function getFlatsCountByTypeAndBuilding(Building $building): array
  913.     {
  914.         return $this->createQueryBuilder('f', 'f.type')
  915.             ->select('f.type, count(f.type) as sumFlats')
  916.             ->where('f.building = :building')
  917.             ->andWhere('f.archived = 0')
  918.             ->setParameters([
  919.                 'building' => $building,
  920.             ])
  921.             ->groupBy('f.type')
  922.             ->getQuery()
  923.             ->getArrayResult();
  924.     }
  926.     /**
  927.      * @param User $user
  928.      * @param Building $building
  929.      * @return array<Flat>
  930.      */
  931.     public function getFlatsDetailsByBuilding(User $user, Building $building): array
  932.     {
  933.         return $this->createQueryBuilder('f', 'f.displayFlatId')
  934.             ->select(
  935.                 'f.displayFlatId as flatDisplayId,
  936.                 f.members as flatMembers,
  937.                 f.size as flatSize,
  938.                 f.type as flatType'
  939.             )
  940.             ->where('f.user = :user')
  941.             ->andWhere('f.building = :building')
  942.             ->andWhere('f.archived = 0')
  943.             ->setParameters([
  944.                 'user' => $user,
  945.                 'building' => $building
  946.             ])
  947.             ->orderBy('f.displayFlatId', 'ASC')
  948.             ->getQuery()
  949.             ->getArrayResult();
  950.     }
  952.     /**
  953.      * @param User $user
  954.      * @param Building $building
  955.      * @return array
  956.      */
  957.     public function getAllFlatsDetailsByBuilding(User $user, Building $building): array
  958.     {
  959.         return $this->createQueryBuilder('f', 'f.displayFlatId')
  960.             ->select(
  961.                 'f.displayFlatId as flatDisplayId,
  962.                 f.members as flatMembers,
  963.                 f.ownerName as ownerName,
  964.                 f.ownerLastname as ownerLastname,
  965.                 f.companyName as companyName,
  966.                 f.ownerAddress as ownerAddress,
  967.                 f.size as flatSize,
  968.                 f.type as flatType'
  969.             )
  970.             ->where('f.user = :user')
  971.             ->andWhere('f.building = :building')
  972.             ->andWhere('f.archived = 0')
  973.             ->setParameters([
  974.                 'user' => $user,
  975.                 'building' => $building
  976.             ])
  977.             ->orderBy('f.displayFlatId', 'ASC')
  978.             ->getQuery()
  979.             ->getArrayResult();
  980.     }
  982.     /**
  983.      * @param User $user
  984.      * @return array<Flat>
  985.      */
  986.     public function getFlatsByMobileAppUser(User $user): array
  987.     {
  988.         $query = $this->createQueryBuilder('f')
  989.             ->where('f.flatUser = :user')
  990.             ->andWhere('f.archived = 0')
  991.             ->setParameters([
  992.                 'user' => $user,
  993.             ])
  994.             ->orderBy('f.displayFlatId', 'ASC');
  995.         return $query
  996.             ->getQuery()
  997.             ->getResult();
  998.     }
  1000.     /**
  1001.      * @param DateTime $startDate
  1002.      * @param DateTime|null $endDate
  1003.      * @return array<mixed>
  1004.      */
  1005.     public function getFlatImportReviewByDate(DateTime $startDate, ?DateTime $endDate): array
  1006.     {
  1007.         $result = $this->createQueryBuilder('f')
  1008.             ->select('count(f.id) as flatNumber, u.email as user')
  1009.             ->innerJoin('f.user', 'u', Join::WITH, 'f.user = u.id')
  1010.             ->where('f.createdAt >= :startDate')
  1011.             ->groupBy('user')
  1012.             ->setParameters([
  1013.                 'startDate' => $startDate,
  1014.             ]);
  1016.         if ($endDate) {
  1017.             $result
  1018.                 ->andWhere('f.createdAt <= :endDate')
  1019.                 ->setParameter('endDate', $endDate);
  1020.         }
  1022.         return $result
  1023.             ->getQuery()
  1024.             ->getResult();
  1025.     }
  1027.     /**
  1028.      * @param User $user
  1029.      * @param Building $building
  1030.      * @param int $archived
  1031.      * @return array<Flat>
  1032.      */
  1033.     public function getActiveFlatsByUserAndBuildingAndDebit(User $user, Building $building, int $archived): array
  1034.     {
  1035.         return $this->createQueryBuilder('f')
  1036.             ->where('f.building = :building')
  1037.             ->andWhere('f.user =:user')
  1038.             ->andWhere('(f.debit + f.previousBill) > 0')
  1039.             ->andWhere('f.archived = :archived')
  1040.             ->setParameters([
  1041.                 'user' => $user,
  1042.                 'building' => $building,
  1043.                 'archived' => $archived
  1044.             ])
  1045.             ->getQuery()
  1046.             ->getResult();
  1047.     }
  1049.     /**
  1050.      * @param Building $building
  1051.      * @return float
  1052.      * @throws NoResultException
  1053.      * @throws NonUniqueResultException
  1054.      */
  1055.     public function calculateBuildingSize(Building $building): float
  1056.     {
  1057.         return $this->createQueryBuilder('f')
  1058.             ->select('sum(f.size)')
  1059.             ->where('f.building = :building')
  1060.             ->andWhere('f.archived = 0')
  1061.             ->setParameters([
  1062.                 'building' => $building
  1063.             ])
  1064.             ->getQuery()
  1065.             ->getSingleScalarResult();
  1066.     }
  1068.     /**
  1069.      * @param Building $building
  1070.      * @return array<Flat>
  1071.      */
  1072.     public function getFlatsWithActiveEmailForDictionary(Building $building): array
  1073.     {
  1074.         $emails = $this->createQueryBuilder('f')
  1075.             ->select('f.ownerEmail')
  1076.             ->where('f.building = :building')
  1077.             ->andWhere('f.emailCanBeUsed = 1')
  1078.             ->setParameter('building', $building)
  1079.             ->getQuery()
  1080.             ->getArrayResult();
  1082.         $filteredEmails = [];
  1084.         foreach ($emails as $email) {
  1085.             if ($email['ownerEmail'] != '') {
  1086.                 if (!in_array($email['ownerEmail'], $filteredEmails)) {
  1087.                     $filteredEmails[] = $email['ownerEmail'];
  1088.                 }
  1089.             }
  1090.         }
  1092.         return $filteredEmails;
  1093.     }
  1095.     /**
  1096.      * @param Building $building
  1097.      * @param User $user
  1098.      * @return array<Flat>
  1099.      */
  1100.     public function findFlatByOwner(Building $building, User $user): array
  1101.     {
  1102.         return $this->createQueryBuilder('f')
  1103.             ->select('f.ownerName, f.ownerLastname, f.displayFlatId, f.type, f.companyName, f.type')
  1104.             ->where('f.building = :building')
  1105.             ->andWhere('f.user = :user')
  1106.             ->andWhere('f.archived = 0')
  1107.             ->setParameters([
  1108.                 'user' => $user,
  1109.                 'building' => $building
  1110.             ])
  1111.             ->getQuery()
  1112.             ->getResult();
  1113.     }
  1115.     /**
  1116.      * @return array<Flat>
  1117.      */
  1118.     public function getAllArchivedFlats(): array
  1119.     {
  1120.         return $this->createQueryBuilder('f')
  1121.             ->where('f.archived = 1')
  1122.             ->getQuery()
  1123.             ->getResult();
  1124.     }
  1126.     /**
  1127.      * @param User $user
  1128.      * @param Building $building
  1129.      * @return array<mixed>|null
  1130.      * @throws NonUniqueResultException
  1131.      */
  1132.     public function findFlatsBillDebitAndPreviousBillSum(User $user, Building $building): ?array
  1133.     {
  1134.         return $this->createQueryBuilder('f')
  1135.             ->select('(sum(f.debit + f.previousBill)) as billSum')
  1136.             ->where('f.user = :user')
  1137.             ->andWhere('f.building = :building')
  1138.             ->andWhere('f.archived = 0')
  1139.             ->setParameters([
  1140.                 'user' => $user,
  1141.                 'building' => $building
  1142.             ])
  1143.             ->getQuery()
  1144.             ->getOneOrNullResult();
  1145.     }
  1147.     /**
  1148.      * @param User $user
  1149.      * @param Building $building
  1150.      * @return array<mixed>|null
  1151.      * @throws NonUniqueResultException
  1152.      */
  1153.     public function findFlatsBillDebitAndPreviousBillSumReport(User $user, Building $building): ?array
  1154.     {
  1155.         return $this->createQueryBuilder('f')
  1156.             ->select('(sum(f.debit + f.previousBill)) as billSum')
  1157.             ->where('f.user = :user')
  1158.             ->andWhere('f.building = :building')
  1159.             ->andWhere('f.archived = 0')
  1160.             ->andWhere('(f.debit + f.previousBill) > 0')
  1161.             ->setParameters([
  1162.                 'user' => $user,
  1163.                 'building' => $building
  1164.             ])
  1165.             ->getQuery()
  1166.             ->getOneOrNullResult();
  1167.     }
  1169.     /**
  1170.      * @param array<User> $users
  1171.      * @return array<Flat>
  1172.      */
  1173.     public function findFlatsForInvoice(array $users): array
  1174.     {
  1175.         return $this->createQueryBuilder('f')
  1176.             ->where('f.eInvoice = true')
  1177.             ->andwhere('f.user IN (:users)')
  1178.             ->andWhere('f.archived = 0')
  1179.             ->setParameters([
  1180.                 'users' => $users
  1181.             ])
  1182.             ->getQuery()
  1183.             ->getResult();
  1184.     }
  1186.     /**
  1187.      * @param Building $building
  1188.      * @param ListItemsOptionsV2 $options
  1189.      * @return array<Flat>
  1190.      */
  1191.     public function getFlatsByBuildingPaginated(Building $building, ListItemsOptionsV2 $options): array
  1192.     {
  1193.         return $this->createQueryBuilder('f')
  1194.             ->where('f.building = :building')
  1195.             ->andWhere('f.archived = 0')
  1196.             ->orderBy('f.' . $options->getOrderByColumn(), $options->getOrderByDirection())
  1197.             ->setParameter('building', $building)
  1198.             ->setMaxResults($options->getLimit())
  1199.             ->setFirstResult($options->getOffset())
  1200.             ->getQuery()
  1201.             ->getResult();
  1202.     }
  1204.     /**
  1205.      * @param Building $building
  1206.      * @return int
  1207.      * @throws NoResultException
  1208.      * @throws NonUniqueResultException
  1209.      */
  1210.     public function countFlatsByBuildingPaginated(Building $building): int
  1211.     {
  1212.         return $this->createQueryBuilder('f')
  1213.             ->select('count(f.id) as sumFlats')
  1214.             ->where('f.building = :building')
  1215.             ->andWhere('f.archived = 0')
  1216.             ->setParameter('building', $building)
  1217.             ->getQuery()
  1218.             ->getSingleScalarResult();
  1219.     }
  1221.     /**
  1222.      * @param int $limit
  1223.      * @param int $offset
  1224.      * @return array<int, array<string, int>>
  1225.      */
  1226.     public function getAllFlats(int $limit, int $offset): array
  1227.     {
  1228.         return $this->createQueryBuilder('f')
  1229.             ->select('f.id')
  1230.             ->orderBy('f.id')
  1231.             ->setMaxResults($limit)
  1232.             ->setFirstResult($offset)
  1233.             ->getQuery()
  1234.             ->getArrayResult();
  1235.     }
  1237.     /**
  1238.      * @param array<User> $users
  1239.      * @return int
  1240.      * @throws NoResultException
  1241.      * @throws NonUniqueResultException
  1242.      */
  1243.     public function countFlatsForInvoice(array $users): int
  1244.     {
  1245.         return $this->createQueryBuilder('f')
  1246.             ->select('count(f.id) as sumFlats')
  1247.             ->andwhere('f.user IN (:users)')
  1248.             ->andWhere('f.eInvoice = true')
  1249.             ->setParameter('users', $users)
  1250.             ->getQuery()
  1251.             ->getSingleScalarResult();
  1252.     }
  1254.     /**
  1255.      * @param array<User> $users
  1256.      * @return int
  1257.      * @throws NoResultException
  1258.      * @throws NonUniqueResultException
  1259.      */
  1260.     public function countFlatsForPrintBill(array $users): int
  1261.     {
  1262.         return $this->createQueryBuilder('f')
  1263.             ->select('count(f.id) as sumFlats')
  1264.             ->andwhere('f.user IN (:users)')
  1265.             ->andWhere('f.printBill = true')
  1266.             ->setParameter('users', $users)
  1267.             ->getQuery()
  1268.             ->getSingleScalarResult();
  1269.     }
  1271.     /**
  1272.      * @param Building $building
  1273.      * @param int $limit
  1274.      * @param int $offset
  1275.      * @return array<Flat>
  1276.      */
  1277.     public function getAllFlatsByBuilding(Building $building, int $limit, int $offset): array
  1278.     {
  1279.         return $this->createQueryBuilder('f')
  1280.             ->where('f.building = :building')
  1281.             ->andWhere('f.archived = 0')
  1282.             ->orderBy('f.id')
  1283.             ->setParameter('building', $building)
  1284.             ->setMaxResults($limit)
  1285.             ->setFirstResult($offset)
  1286.             ->getQuery()
  1287.             ->getResult();
  1288.     }
  1290.     /**
  1291.      * @param Resident $resident
  1292.      * @return array<Flat>
  1293.      */
  1294.     public function getAllFlatsByResident(Resident $resident): array
  1295.     {
  1296.         return $this->createQueryBuilder('f')
  1297.             ->where('f.resident = :resident')
  1298.             ->andWhere('f.archived = 0')
  1299.             ->orderBy('f.id')
  1300.             ->setParameter('resident', $resident)
  1301.             ->getQuery()
  1302.             ->getResult();
  1303.     }
  1305.     /**
  1306.      * @param int $buildingId
  1307.      * @return array<Flat>
  1308.      */
  1309.     public function findFlatsByBuildingAndOwnerPhoneNumber(int $buildingId): array
  1310.     {
  1311.         return $this->createQueryBuilder('f')
  1312.             ->where('f.building = :buildingId')
  1313.             ->andWhere('f.ownerPhoneNumber IS NOT NULL')
  1314.             ->setParameter('buildingId', $buildingId)
  1315.             ->orderBy('f.displayFlatId', 'ASC')
  1316.             ->getQuery()
  1317.             ->getResult();
  1318.     }
  1320.     /**
  1321.      * @param array $searchParams
  1322.      * @param int|null $start
  1323.      * @param int|null $limit
  1324.      * @param array $order
  1325.      * @param string|null $search
  1326.      * @return array<mixed>
  1327.      */
  1328.     public function findFlatsForDatatable(
  1329.         array $searchParams,
  1330.         ?int $start,
  1331.         ?int $limit,
  1332.         array $order,
  1333.         string $search = null
  1334.     ): array {
  1335.         $query = $this->createQueryBuilder('f')
  1336.             ->select(
  1337.                 'f.id,
  1338.                 f.displayFlatId,
  1339.                 f.size,
  1340.                 f.ownerName,
  1341.                 f.ownerLastname,
  1342.                 f.companyName,
  1343.                 f.ownerPhoneNumber,
  1344.                 f.debit,
  1345.                 f.previousBill,
  1346.                 f.type,
  1347.                 f.subType,
  1348.                 f.oldDebit,
  1349.                 f.ownerEmail,
  1350.                 f.emailCanBeUsed,
  1351.                 b.address,
  1352.                 b.id as buildingId'
  1353.             )
  1354.             ->innerJoin('f.building', 'b')
  1355.             ->where('b.activeStatus = 1')
  1356.             ->andWhere('f.user IN (:users)')
  1357.             ->andWhere('f.archived = 0')
  1358.             ->setParameter('users', $searchParams['users'])
  1359.             ->setMaxResults($limit)
  1360.             ->setFirstResult($start);
  1362.         if ($order['column'] === 'address') {
  1363.             $query->orderBy('b.address', $order['dir']);
  1364.         } else {
  1365.             $query->orderBy('f.' . $order['column'], $order['dir']);
  1366.         }
  1368.         if ($search) {
  1369.             $query->andWhere(
  1370.                 'f.ownerName LIKE :search OR
  1371.                 f.ownerLastname LIKE :search OR
  1372.                 f.displayFlatId LIKE :search OR
  1373.                 f.ownerPhoneNumber LIKE :search OR
  1374.                 f.ownerEmail LIKE :search OR
  1375.                 b.address LIKE :search'
  1376.             );
  1377.             $query->setParameter('search', '%' . $search . '%');
  1378.         }
  1380.         return $query
  1381.             ->getQuery()
  1382.             ->getArrayResult();
  1383.     }
  1385.     /**
  1386.      * @param array $searchParams
  1387.      * @param string|null $search
  1388.      * @return int
  1389.      * @throws NoResultException
  1390.      * @throws NonUniqueResultException
  1391.      */
  1392.     public function findFlatsForDatatableCount(array $searchParams, string $search = null): int
  1393.     {
  1394.         $qb = $this->createQueryBuilder('f')
  1395.             ->select('COUNT(f.id)')
  1396.             ->innerJoin('f.building', 'b')
  1397.             ->where('b.activeStatus = 1')
  1398.             ->andWhere('f.user IN (:users)')
  1399.             ->andWhere('f.archived = 0')
  1400.             ->setParameter('users', $searchParams['users']);
  1402.         if ($search) {
  1403.             $qb->andWhere(
  1404.                 'f.ownerName LIKE :search OR
  1405.                 f.ownerLastname LIKE :search OR
  1406.                 f.displayFlatId LIKE :search OR
  1407.                 f.ownerPhoneNumber LIKE :search OR
  1408.                 f.ownerEmail LIKE :search OR
  1409.                 b.address LIKE :search'
  1410.             )
  1411.                 ->setParameter('search', '%' . $search . '%');
  1412.         }
  1414.         return (int) $qb->getQuery()->getSingleScalarResult();
  1415.     }
  1417. }