src/Controller/DashboardController.php line 25

  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\Habitat;
  6. use App\Entity\Incident;
  7. use App\Entity\Location;
  8. use App\Entity\Log;
  9. use App\Entity\Payment;
  10. use App\Entity\Reservation;
  11. use App\Entity\User;
  12. use App\Repository\SubscriptionRepository;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Doctrine\Persistence\ManagerRegistry;
  15. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  18. use Symfony\Component\HttpFoundation\Response;
  19. use Symfony\Component\Routing\Annotation\Route;
  21. #[Route('/admin/dashboard')]
  22. class DashboardController extends AbstractController
  23. {
  24.     #[Route('/', name: 'app_dashboard')]
  25.     public function index(RequestStack $requestStack, SubscriptionRepository $subscriptionRepository, EntityManagerInterface $entityManager): Response {
  26.         $user = $this->getUser();
  27.         if (!$user instanceof User) {
  28.             return $this->redirectToRoute('app_logout');
  29.         }
  31.         $this->syncExpiredSubscriptions($subscriptionRepository, $entityManager);
  33.         $show = $requestStack->getSession()->get('dashboard-overview', 'long_term');
  34.         $subscriptionRenewalData = $this->resolveSubscriptionRenewalCardData($user, $subscriptionRepository);
  36.         return $this->render('dashboard/index.html.twig', array_merge([
  37.             'user' => $user,
  38.             'show' => $show
  39.         ], $subscriptionRenewalData));
  40.     }
  42.     #[Route('/view/{show}', name: 'start.dashboard.toggle.view', methods: ['GET'])]
  43.     public function indexActionToggle(RequestStack $requestStack, string $show, ManagerRegistry $doctrine): Response
  44.     {
  45.         $em = $doctrine->getManager();
  46.         $authUser = $this->getUser();
  47.         if (!$authUser) {
  48.             return $this->redirectToRoute('app_logout');
  49.         }
  50.         if ('long_term' === $show) {
  51.             $requestStack->getSession()->set('dashboard-overview', 'long_term');
  52.             $authUser->setMode('long_term');
  53.         } else {
  54.             $requestStack->getSession()->set('dashboard-overview', 'short_term');
  55.             $authUser->setMode('short_term');
  57.         }
  58.         $em->flush();
  59.         return $this->forward('App\Controller\DashboardController::index');
  60.     }
  63.     /**
  64.      * Gets the reservation overview.
  65.      * @throws \JsonException
  66.      */
  67.     #[Route('/mode', name: 'dashboard.get.mode', methods: ['GET'])]
  68.     public function getModeAction(
  69.         ManagerRegistry $doctrine,
  70.         RequestStack $requestStack,
  71.         Request $request,
  72.         SubscriptionRepository $subscriptionRepository
  73.     ): Response
  74.     {
  75.         $mode = $request->query->get('mode', 'long_term');
  76.         if ('long_term' === $mode) {
  77.             return $this->_handleLongTermRequest($doctrine, $requestStack, $request, $subscriptionRepository);
  78.         } else {
  79.             return $this->_handleShortTermRequest($doctrine, $requestStack, $request, $subscriptionRepository);
  80.         }
  81.     }
  83.     /**
  84.      * Displays the regular Long Term overview based on a user long term mode.
  85.      */
  86.     private function _handleLongTermRequest(
  87.         ManagerRegistry $doctrine,
  88.         RequestStack $requestStack,
  89.         Request $request,
  90.         SubscriptionRepository $subscriptionRepository
  91.     ): Response {
  92.         $em = $doctrine->getManager();
  94.         $user = $this->getUser();
  95.         if (!$user instanceof User) {
  96.             return $this->redirectToRoute('app_logout');
  97.         }
  99.         $entreprise = $user->getEntreprise();
  100.         if (!$entreprise || !$entreprise->getId()) {
  101.             return $this->redirectToRoute('app_logout');
  102.         }
  104.         if (!$user->getMode()) {
  105.             $user->setMode('light');
  106.             $em->flush();
  107.         }
  109.         $requestStack->getSession()->remove('location-details-overview');
  111.         $now = new \DateTimeImmutable();
  112.         $currentYear = (int) $now->format('Y');
  113.         $previousYear = $currentYear - 1;
  114.         $lastTwoMonthDate = $now->modify('-2 months');
  115.         $lastOneMonthDate = $now->modify('-1 month');
  116.         $lastTwoMonth = (int) $lastTwoMonthDate->format('n');
  117.         $lastOneMonth = (int) $lastOneMonthDate->format('n');
  118.         $yearLastTwo = (int) $lastTwoMonthDate->format('Y');
  119.         $yearLastOne = (int) $lastOneMonthDate->format('Y');
  120.         $entrepriseId = (int) $entreprise->getId();
  122.         $paymentRepo = $em->getRepository(Payment::class);
  124.         // Invoice counts grouped by paid status (single query).
  125.         $invoiceRows = $em->createQueryBuilder()
  126.             ->select('p.paid AS paidStatus, COUNT(p.id) AS total')
  127.             ->from(Payment::class, 'p')
  128.             ->join('p.marchand', 'm')
  129.             ->andWhere('m.id = :marchand')
  130.             ->setParameter('marchand', $entrepriseId)
  131.             ->groupBy('p.paid')
  132.             ->getQuery()
  133.             ->getArrayResult();
  134.         $invoicePaidCount = 0;
  135.         $invoiceUnpaidCount = 0;
  136.         foreach ($invoiceRows as $row) {
  137.             $isPaid = filter_var((string) ($row['paidStatus'] ?? ''), FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE);
  138.             if ($isPaid === null) {
  139.                 $isPaid = ((int) ($row['paidStatus'] ?? 0)) === 1;
  140.             }
  141.             if ($isPaid) {
  142.                 $invoicePaidCount = (int) ($row['total'] ?? 0);
  143.             } else {
  144.                 $invoiceUnpaidCount = (int) ($row['total'] ?? 0);
  145.             }
  146.         }
  148.         // Active leases count.
  149.         $totalLoyers = (int) $em->createQueryBuilder()
  150.             ->select('COUNT(l.id)')
  151.             ->from(Location::class, 'l')
  152.             ->join('l.marchand', 'm')
  153.             ->andWhere('m.id = :marchand')
  154.             ->andWhere('l.occuper = :occupied')
  155.             ->setParameter('marchand', $entrepriseId)
  156.             ->setParameter('occupied', true)
  157.             ->getQuery()
  158.             ->getSingleScalarResult();
  160.         // Habitat occupation counts grouped (single query).
  161.         $habitatRows = $em->createQueryBuilder()
  162.             ->select('h.occuper AS occupiedStatus, COUNT(h.id) AS total')
  163.             ->from(Habitat::class, 'h')
  164.             ->join('h.marchand', 'm')
  165.             ->andWhere('m.id = :marchand')
  166.             ->setParameter('marchand', $entrepriseId)
  167.             ->groupBy('h.occuper')
  168.             ->getQuery()
  169.             ->getArrayResult();
  170.         $habitatEnBail = 0;
  171.         $habitatLibre = 0;
  172.         foreach ($habitatRows as $row) {
  173.             $isOccupied = filter_var((string) ($row['occupiedStatus'] ?? ''), FILTER_VALIDATE_BOOLEAN, FILTER_NULL_ON_FAILURE);
  174.             if ($isOccupied === null) {
  175.                 $isOccupied = ((int) ($row['occupiedStatus'] ?? 0)) === 1;
  176.             }
  177.             if ($isOccupied) {
  178.                 $habitatEnBail = (int) ($row['total'] ?? 0);
  179.             } else {
  180.                 $habitatLibre = (int) ($row['total'] ?? 0);
  181.             }
  182.         }
  184.         // Incident totals and pending grouped (single query).
  185.         $incidentRows = $em->createQueryBuilder()
  186.             ->select('i.process AS processStatus, COUNT(i.id) AS total')
  187.             ->from(Incident::class, 'i')
  188.             ->join('i.marchand', 'm')
  189.             ->andWhere('m.id = :marchand')
  190.             ->setParameter('marchand', $entrepriseId)
  191.             ->groupBy('i.process')
  192.             ->getQuery()
  193.             ->getArrayResult();
  194.         $nbIncidents = 0;
  195.         $pendingIncidents = 0;
  196.         foreach ($incidentRows as $row) {
  197.             $count = (int) ($row['total'] ?? 0);
  198.             $nbIncidents += $count;
  200.             $status = (string) ($row['processStatus'] ?? '');
  201.             if ($status === '1' || $status === 'true') {
  202.                 $pendingIncidents = $count;
  203.             }
  204.         }
  206.         // Monthly aggregates for current/previous years (single query for charts + percentages).
  207.         $monthlyRows = $em->createQueryBuilder()
  208.             ->select('p.year AS yearValue, p.month AS monthValue')
  209.             ->addSelect('SUM(p.totalAmount) AS baseTotal')
  210.             ->addSelect('SUM(CASE WHEN p.paid = true THEN p.totalAmount ELSE 0 END) AS paidTotal')
  211.             ->addSelect('SUM(CASE WHEN p.paid = true THEN 1 ELSE 0 END) AS paidCount')
  212.             ->from(Payment::class, 'p')
  213.             ->join('p.marchand', 'm')
  214.             ->andWhere('m.id = :marchand')
  215.             ->andWhere('p.year IN (:years)')
  216.             ->setParameter('marchand', $entrepriseId)
  217.             ->setParameter('years', [(string) $previousYear, (string) $currentYear])
  218.             ->groupBy('p.year, p.month')
  219.             ->getQuery()
  220.             ->getArrayResult();
  222.         $monthlyIndex = [];
  223.         foreach ($monthlyRows as $row) {
  224.             $year = (int) ($row['yearValue'] ?? 0);
  225.             $month = (int) ($row['monthValue'] ?? 0);
  226.             if ($year <= 0 || $month < 1 || $month > 12) {
  227.                 continue;
  228.             }
  230.             $monthlyIndex[$year][$month] = [
  231.                 'baseTotal' => (float) ($row['baseTotal'] ?? 0),
  232.                 'paidTotal' => (float) ($row['paidTotal'] ?? 0),
  233.                 'paidCount' => (int) ($row['paidCount'] ?? 0),
  234.             ];
  235.         }
  237.         $ptageLast = [];
  238.         $ptageCurrent = [];
  239.         foreach (range(1, 12) as $month) {
  240.             $ptageLast[] = (float) ($monthlyIndex[$previousYear][$month]['paidTotal'] ?? 0.0);
  241.             $ptageCurrent[] = (float) ($monthlyIndex[$currentYear][$month]['paidTotal'] ?? 0.0);
  242.         }
  244.         $countLastTwo = (int) ($monthlyIndex[$yearLastTwo][$lastTwoMonth]['paidCount'] ?? 0);
  245.         $countLastOne = (int) ($monthlyIndex[$yearLastOne][$lastOneMonth]['paidCount'] ?? 0);
  247.         $pourcentageLastTwoMonth = $totalLoyers > 0 ? round(($countLastTwo / $totalLoyers) * 100, 1) : 0.0;
  248.         $pourcentageLastOneMonth = $totalLoyers > 0 ? round(($countLastOne / $totalLoyers) * 100, 1) : 0.0;
  250.         $baseLastTwo = (float) ($monthlyIndex[$yearLastTwo][$lastTwoMonth]['baseTotal'] ?? 0.0);
  251.         $paidLastTwo = (float) ($monthlyIndex[$yearLastTwo][$lastTwoMonth]['paidTotal'] ?? 0.0);
  252.         $PaymentAmountLastTwoMonth = $baseLastTwo > 0 ? round(($paidLastTwo / $baseLastTwo) * 100, 1) : 0.0;
  254.         $baseLastOne = (float) ($monthlyIndex[$yearLastOne][$lastOneMonth]['baseTotal'] ?? 0.0);
  255.         $paidLastOne = (float) ($monthlyIndex[$yearLastOne][$lastOneMonth]['paidTotal'] ?? 0.0);
  256.         $PaymentAmountLastOneMonth = $baseLastOne > 0 ? round(($paidLastOne / $baseLastOne) * 100, 1) : 0.0;
  258.         // Recent unpaid payments / logs.
  259.         $marchand = (int) $request->query->get('marchand', (string) $entrepriseId);
  260.         if ($marchand !== $entrepriseId) {
  261.             $marchand = $entrepriseId;
  262.         }
  264.         $recentUnpaid = $paymentRepo->findBy(
  265.             ['marchand' => $marchand, 'paid' => false],
  266.             ['id' => 'DESC'],
  267.             4
  268.         );
  270.         $logs = $em->getRepository(Log::class)->findBy(
  271.             ['marchand' => $marchand],
  272.             ['id' => 'DESC'],
  273.             5
  274.         );
  276.         $subscriptionRenewalData = $this->resolveSubscriptionRenewalCardData($user, $subscriptionRepository);
  278.         return $this->render('dashboard/long_term.html.twig', array_merge([
  279.             'habitatEnBail'             => $habitatEnBail,
  280.             'habitatLibre'              => $habitatLibre,
  281.             'invoiceUnpaid'             => $invoiceUnpaidCount,
  282.             'invoicePaid'               => $invoicePaidCount,
  283.             'paymentList'               => $recentUnpaid,
  285.             'ptageCurrent'              => json_encode($ptageCurrent, JSON_THROW_ON_ERROR),
  286.             'ptageLast'                 => json_encode($ptageLast, JSON_THROW_ON_ERROR),
  288.             'lastYear'                  => $previousYear,
  289.             'currentYear'               => $currentYear,
  290.             'pourcentage'               => $pourcentageLastOneMonth,
  291.             'pourcentageLastMonth'      => $pourcentageLastTwoMonth,
  292.             'lastTwoMonth'              => $this->processMonth((string) $lastTwoMonth),
  293.             'lastOneMonth'              => $this->processMonth((string) $lastOneMonth),
  294.             'PaymentAmountLastTwoMonth' => $PaymentAmountLastTwoMonth,
  295.             'PaymentAmountLastOneMonth' => $PaymentAmountLastOneMonth,
  296.             'NbreIncident'              => $nbIncidents,
  297.             'PendingIncide'             => $pendingIncidents,
  298.             'logs' => $logs,
  299.         ], $subscriptionRenewalData));
  300.     }
  304.     /**
  305.      * Displays the regular Short Term overview based on a user short term mode.
  306.      */
  307.     private function _handleShortTermRequest(
  308.         ManagerRegistry $doctrine,
  309.         RequestStack $requestStack,
  310.         Request $request,
  311.         SubscriptionRepository $subscriptionRepository
  312.     ): Response {
  314.         $em = $doctrine->getManager();
  315.         $user = $this->getUser();
  316.         if (!$user instanceof User) {
  317.             return $this->redirectToRoute('app_logout');
  318.         }
  319.         $entreprise = $user->getEntreprise();
  320.         if (!$entreprise || !$entreprise->getId()) {
  321.             return $this->redirectToRoute('app_logout');
  322.         }
  324.         $habitats = $em->getRepository(Habitat::class);
  325.         $incidentRepo = $em->getRepository(Incident::class);
  327.         // Read optional filters (dates, status, term, property, marchand…)
  328.         $filters = [
  329.             'from'          => $request->query->get('from') ? new \DateTimeImmutable($request->query->get('from')) : null,
  330.             'to'            => $request->query->get('to')   ? new \DateTimeImmutable($request->query->get('to'))   : null,
  331.             'status'        => $request->query->get('status', 'all'),
  332.             'term'          => $request->query->get('term', 'all'),
  333.             'propertyId'    => $request->query->getInt('propertyId') ?: null,
  334.             'marchandId'    => $request->query->getInt('marchandId') ?: null,
  335.             'currencySymbol'=> '$', // or derive from your tenant/company settings
  336.         ];
  338.         $reservations = $em->getRepository(Reservation::class);
  340.         $totalUnits = $habitats->countActive($entreprise->getId()); // for occupancy rate
  341.         $data = $reservations->dashboardData($filters, $totalUnits, $entreprise->getId());
  342.         $pendingIncidents  = \count($incidentRepo->findBy(['marchand' => $entreprise, 'process' => '1']));
  343.         $subscriptionRenewalData = $this->resolveSubscriptionRenewalCardData($user, $subscriptionRepository);
  346.         return $this->render('dashboard/short_term.html.twig', array_merge([
  348.             'stats'  => $data['stats'],
  349.             'series' => $data['series'],
  350.             'table'  => $data['table'],
  351.             'lists'  => $data['lists'],
  352.             'filters'=> $filters,
  353.             'currentYear' => date('Y'),
  354.             'currentMonth' =>  $this->processMonth(date('n')),
  355.             'PendingIncide' => $pendingIncidents
  357.         ], $subscriptionRenewalData));
  358.     }
  360.     private function resolveSubscriptionRenewalCardData(
  361.         User $user,
  362.         SubscriptionRepository $subscriptionRepository
  363.     ): array {
  364.         $default = [
  365.             'showSubscriptionRenewalCard' => false,
  366.             'subscriptionPackageName' => null,
  367.             'subscriptionStartAt' => null,
  368.             'subscriptionEndAt' => null,
  369.         ];
  371.         $entreprise = $user->getEntreprise();
  372.         if (!$entreprise) {
  373.             return $default;
  374.         }
  376.         $subscriptions = $subscriptionRepository->findBy(
  377.             ['entreprise' => $entreprise],
  378.             ['endAt' => 'DESC', 'id' => 'DESC']
  379.         );
  380.         if (!$subscriptions) {
  381.             return $default;
  382.         }
  384.         $now = new \DateTimeImmutable();
  386.         $subscription = null;
  387.         foreach ($subscriptions as $candidate) {
  388.             $candidateStartAt = $candidate->getStartAt();
  389.             $candidateEndAt = $candidate->getEndAt();
  390.             if (
  391.                 $candidateStartAt instanceof \DateTimeInterface
  392.                 && $candidateEndAt instanceof \DateTimeInterface
  393.                 && $candidateStartAt <= $now
  394.                 && $candidateEndAt >= $now
  395.             ) {
  396.                 $subscription = $candidate;
  397.                 break;
  398.             }
  399.         }
  401.         if ($subscription === null) {
  402.             $subscription = $subscriptions[0];
  403.         }
  405.         $packageName = trim((string) ($subscription->getPackage()?->getName() ?? ''));
  406.         if ($packageName !== '' && strcasecmp($packageName, 'Essai') === 0) {
  407.             return $default;
  408.         }
  410.         $startAt = $subscription->getStartAt();
  411.         $endAt = $subscription->getEndAt();
  413.         $isValidByDates =
  414.             $startAt instanceof \DateTimeInterface
  415.             && $endAt instanceof \DateTimeInterface
  416.             && $startAt <= $now
  417.             && $endAt >= $now;
  418.         $isValid = $isValidByDates && $subscription->isStatus() === true;
  420.         if ($isValid) {
  421.             return $default;
  422.         }
  424.         return [
  425.             'showSubscriptionRenewalCard' => true,
  426.             'subscriptionPackageName' => $packageName !== '' ? $packageName : null,
  427.             'subscriptionStartAt' => $startAt,
  428.             'subscriptionEndAt' => $endAt,
  429.         ];
  430.     }
  432.     /**
  433.      * French month label from numeric month.
  434.      */
  435.     public function processMonth(string $month): string
  436.     {
  437.         return match ($month) {
  438.             '2'  => 'Février',
  439.             '3'  => 'Mars',
  440.             '4'  => 'Avril',
  441.             '5'  => 'Mai',
  442.             '6'  => 'Juin',
  443.             '7'  => 'Juillet',
  444.             '8'  => 'Août',
  445.             '9'  => 'Septembre',
  446.             '10' => 'Octobre',
  447.             '11' => 'Novembre',
  448.             '12' => 'Décembre',
  449.             default => 'Janvier',
  450.         };
  451.     }
  453.     private function syncExpiredSubscriptions(
  454.         SubscriptionRepository $subscriptionRepository,
  455.         EntityManagerInterface $entityManager
  456.     ): void
  457.     {
  458.         $now = new \DateTimeImmutable();
  459.         $expiredSubscriptions = $subscriptionRepository->findExpiredActiveSubscriptions($now);
  460.         if (!$expiredSubscriptions) {
  461.             return;
  462.         }
  464.         $entreprisesToCheck = [];
  465.         foreach ($expiredSubscriptions as $subscription) {
  466.             $subscription->setStatus(false);
  468.             $entreprise = $subscription->getEntreprise();
  469.             if ($entreprise) {
  470.                 $key = $entreprise->getId() ?? spl_object_id($entreprise);
  471.                 $entreprisesToCheck[$key] = $entreprise;
  472.             }
  473.         }
  475.         foreach ($entreprisesToCheck as $entreprise) {
  476.             if (!$subscriptionRepository->hasActiveSubscriptionForEntreprise($entreprise, $now)) {
  477.                 $entreprise->setStatus(false);
  478.             }
  479.         }
  481.         $entityManager->flush();
  482.     }
  483. }