src/ApplicationBundle/Controller/TaskDashboardController.php line 360

Open in your IDE?
  1. <?php
  3. namespace ApplicationBundle\Controller;
  5. use ApplicationBundle\Interfaces\SessionCheckInterface;
  6. use ApplicationBundle\Modules\Authentication\Constants\UserConstants;
  7. use Doctrine\DBAL\Connection;
  8. use Symfony\Component\HttpFoundation\Request;
  9. use ApplicationBundle\Service\NotificationService;
  11. class TaskDashboardController extends GenericController implements SessionCheckInterface
  12. {
  13.     private function getCompanyId(Request $request): int
  14.     {
  15.         return (int) $request->getSession()->get(UserConstants::USER_COMPANY_ID, 0);
  16.     }
  18.     private function getEmployeeId(Request $request): int
  19.     {
  20.         return (int) $request->getSession()->get(UserConstants::USER_EMPLOYEE_ID, 0);
  21.     }
  23.     private function isAdminOverride(Request $request): bool
  24.     {
  25.         $session = $request->getSession();
  27.         return
  28.             (int) $session->get(UserConstants::USER_TYPE) === UserConstants::USER_TYPE_SYSTEM ||
  29.             (int) $session->get(UserConstants::IS_BUDDYBEE_ADMIN, 0) === 1;
  30.     }
  32.     private function isManagerScope(Request $request): bool
  33.     {
  34.         $session = $request->getSession();
  36.         return
  37.             $this->isAdminOverride($request) ||
  38.             (int) $session->get(UserConstants::USER_TYPE) === UserConstants::USER_TYPE_MANAGEMENT_USER;
  39.     }
  41.     private function notificationService(): NotificationService
  42.     {
  43.         return $this->get('app.notification_service');
  44.     }
  46.     private function buildTaskAlerts(Request $request, string $dashboardType): array
  47.     {
  48.         $companyId = $this->getCompanyId($request);
  49.         $employeeId = $this->getEmployeeId($request);
  50.         $service = $this->notificationService();
  51.         $alerts = [];
  53.         if ($dashboardType === 'reviewer') {
  54.             $outWarning = $service->getUserTaskOutWarnings($employeeId, $companyId);
  55.             $reviewerPending = $service->getReviewerPendingTasks($employeeId, $companyId);
  56.             $overdue = $service->getOverdueReviews($companyId, '/tasks/review?filter=overdue');
  58.             foreach ([$overdue, $reviewerPending, $outWarning] as $alert) {
  59.                 if (!empty($alert['hasAlert'])) {
  60.                     $alerts[] = $alert;
  61.                 }
  62.             }
  63.         } elseif ($dashboardType === 'my') {
  64.             $outWarning = $service->getUserTaskOutWarnings($employeeId, $companyId);
  65.             $rejected = $service->getRejectedTasks($employeeId, $companyId);
  67.             foreach ([$rejected, $outWarning] as $alert) {
  68.                 if (!empty($alert['hasAlert'])) {
  69.                     $alerts[] = $alert;
  70.                 }
  71.             }
  72.         } elseif ($dashboardType === 'manager') {
  73.             $overdue = $service->getOverdueReviews($companyId, '/tasks/manager?filter=overdue');
  74.             if (!empty($overdue['hasAlert'])) {
  75.                 $alerts[] = $overdue;
  76.             }
  77.         }
  79.         usort($alerts, static function (array $left, array $right): int {
  80.             $priorityCompare = ((int) ($left['priority'] ?? 99)) <=> ((int) ($right['priority'] ?? 99));
  81.             if ($priorityCompare !== 0) {
  82.                 return $priorityCompare;
  83.             }
  85.             return ((int) ($right['count'] ?? 0)) <=> ((int) ($left['count'] ?? 0));
  86.         });
  88.         return array_slice($alerts, 0, 3);
  89.     }
  91.     private function getDashboardFilter(Request $request, string $dashboardType): string
  92.     {
  93.         $filter = trim((string) $request->query->get('filter', ''));
  95.         $allowed = [
  96.             'reviewer' => ['overdue', 'pending'],
  97.             'my' => ['active', 'rejected'],
  98.             'manager' => ['overdue', 'non_compliant'],
  99.         ];
  101.         if (!isset($allowed[$dashboardType])) {
  102.             return '';
  103.         }
  105.         if ($filter === '' || !in_array($filter, $allowed[$dashboardType], true)) {
  106.             return '';
  107.         }
  109.         return $filter;
  110.     }
  112.     private function applyDashboardFilter(array $rows, string $dashboardType, string $filter): array
  113.     {
  114.         if ($filter === '') {
  115.             return $rows;
  116.         }
  118.         return array_values(array_filter($rows, static function (array $row) use ($dashboardType, $filter): bool {
  119.             $state = (string) ($row['currentState'] ?? '');
  120.             $submittedAgeHours = (int) ($row['submittedAgeHours'] ?? 0);
  122.             if ($dashboardType === 'reviewer') {
  123.                 if ($filter === 'overdue') {
  124.                     return $submittedAgeHours >= 48;
  125.                 }
  127.                 return $state === 'submitted';
  128.             }
  130.             if ($dashboardType === 'my') {
  131.                 if ($filter === 'rejected') {
  132.                     return $state === 'rejected';
  133.                 }
  135.                 return in_array($state, ['created', 'in_progress'], true);
  136.             }
  138.             if ($dashboardType === 'manager') {
  139.                 if ($filter === 'non_compliant') {
  140.                     return false;
  141.                 }
  143.                 return $submittedAgeHours >= 48;
  144.             }
  146.             return true;
  147.         }));
  148.     }
  150.     private function summarizeAlerts(array $alerts): array
  151.     {
  152.         return $alerts;
  153.     }
  155.     private function formatHoursSince($submittedAt): string
  156.     {
  157.         if (empty($submittedAt)) {
  158.             return 'N/A';
  159.         }
  161.         try {
  162.             $submitted = new \DateTime((string) $submittedAt);
  163.         } catch (\Exception $e) {
  164.             return 'N/A';
  165.         }
  167.         $diff = (new \DateTime())->diff($submitted);
  168.         $hours = ((int) $diff->days * 24) + (int) $diff->h;
  170.         if ($hours >= 48) {
  171.             return round($hours / 24, 1) . 'd';
  172.         }
  174.         return $hours . 'h';
  175.     }
  177.     private function fetchLatestLogMap(Connection $conn, array $planningItemIds, ?string $logType = null): array
  178.     {
  179.         $planningItemIds = array_values(array_unique(array_filter(array_map('intval', $planningItemIds))));
  180.         if (empty($planningItemIds)) {
  181.             return [];
  182.         }
  184.         $sql = 'SELECT t.* FROM task_log t WHERE t.planning_item_id IN (' . implode(',', $planningItemIds) . ')';
  185.         if ($logType !== null) {
  186.             $sql .= ' AND t.log_type = ' . $conn->quote($logType);
  187.         }
  188.         $sql .= ' ORDER BY t.id DESC';
  190.         $rows = $conn->fetchAllAssociative($sql);
  191.         $map = [];
  192.         foreach ($rows as $row) {
  193.             $planningItemId = (int) ($row['planning_item_id'] ?? 0);
  194.             if ($planningItemId === 0 || isset($map[$planningItemId])) {
  195.                 continue;
  196.             }
  197.             $map[$planningItemId] = $row;
  198.         }
  200.         return $map;
  201.     }
  203.     private function baseTaskQuery(Connection $conn, int $companyId)
  204.     {
  205.         $qb = $conn->createQueryBuilder();
  206.         $qb->from('planning_item', 'p')
  207.             ->leftJoin('p', 'employee', 'e', 'e.employee_id = p.assigned_to AND p.assigned_to_type = 1')
  208.             ->leftJoin('p', 'sys_user', 'u', 'u.user_id = p.assigned_to AND p.assigned_to_type = 2')
  209.             ->leftJoin('p', 'employee', 'r', 'r.employee_id = p.reviewer_id')
  210.             ->leftJoin('p', 'project', 'pr', 'pr.project_id = p.project_id')
  211.             ->select(
  212.                 'p.id AS planningItemId',
  213.                 'p.item_alias AS taskTitle',
  214.                 'p.project_id AS projectId',
  215.                 'p.task_context_type AS taskContextType',
  216.                 'p.current_state AS currentState',
  217.                 'p.review_status AS reviewStatus',
  218.                 'p.reviewer_id AS reviewerId',
  219.                 'p.assigned_to AS assignedTo',
  220.                 'p.assigned_to_type AS assignedToType',
  221.                 'p.completion_percentage AS completionPercentage',
  222.                 'p.submitted_at AS submittedAt',
  223.                 'p.approved_at AS approvedAt',
  224.                 'p.rejected_at AS rejectedAt',
  225.                 'p.expected_output AS expectedOutput',
  226.                 'p.kpi_counted AS kpiCounted',
  227.                 'COALESCE(NULLIF(pr.project_name, \'\'), \'General\') AS projectName',
  228.                 'COALESCE(NULLIF(e.name, \'\'), NULLIF(u.name, \'\'), CONCAT(COALESCE(e.first_name, \'\'), \' \', COALESCE(e.last_name, \'\')), CONCAT(\'User #\', p.assigned_to)) AS assignedName',
  229.                 'COALESCE(NULLIF(r.name, \'\'), CONCAT(COALESCE(r.first_name, \'\'), \' \', COALESCE(r.last_name, \'\')), CONCAT(\'Employee #\', p.reviewer_id)) AS reviewerName',
  230.                 'TIMESTAMPDIFF(HOUR, p.submitted_at, NOW()) AS submittedAgeHours'
  231.             )
  232.             ->where('p.company_id = :companyId')
  233.             ->setParameter('companyId', $companyId);
  235.         return $qb;
  236.     }
  238.     private function decorateRows(array $rows, array $latestLogs = []): array
  239.     {
  240.         foreach ($rows as &$row) {
  241.             $planningItemId = (int) ($row['planningItemId'] ?? 0);
  242.             $log = $latestLogs[$planningItemId] ?? [];
  244.             $row['submissionEvidenceExists'] = !empty(trim((string) ($log['evidence_files'] ?? '')));
  245.             $row['submissionWorkCompleted'] = (string) ($log['work_completed'] ?? '');
  246.             $row['submissionEvidenceFiles'] = (string) ($log['evidence_files'] ?? '');
  247.             $row['submissionEvidenceNote'] = (string) ($log['evidence_note'] ?? '');
  248.             $row['submissionBlockerDetail'] = (string) ($log['blocker_detail'] ?? '');
  249.             $row['submissionNextAction'] = (string) ($log['next_action'] ?? '');
  250.             $row['submissionReviewDecision'] = (string) ($log['review_decision'] ?? '');
  251.             $row['submissionReviewComment'] = (string) ($log['review_comment'] ?? '');
  252.             $row['latestActivityType'] = (string) ($log['log_type'] ?? '');
  253.             $row['latestActivityAt'] = (string) ($log['created_at'] ?? '');
  254.             $row['latestActivityLabel'] = ucfirst(str_replace('_', ' ', (string) ($log['log_type'] ?? 'session')));
  255.             $row['submittedAgeLabel'] = $this->formatHoursSince($row['submittedAt'] ?? null);
  256.             $row['stateLabel'] = $this->buildStateLabel($row);
  257.             $row['stateClass'] = $this->buildStateClass($row);
  258.         }
  259.         unset($row);
  261.         return $rows;
  262.     }
  264.     private function buildStateLabel(array $row): string
  265.     {
  266.         $state = (string) ($row['currentState'] ?? '');
  267.         $review = (string) ($row['reviewStatus'] ?? '');
  268.         $progress = (int) ($row['completionPercentage'] ?? 0);
  270.         if ($state === 'approved' || $review === 'approved' || (int) ($row['kpiCounted'] ?? 0) === 1) {
  271.             return 'KPI Counted';
  272.         }
  274.         if ($state === 'submitted' || $review === 'pending') {
  275.             return 'Work Finished (Pending Approval)';
  276.         }
  278.         if ($state === 'rejected' || $review === 'rejected') {
  279.             return 'Rework Needed';
  280.         }
  282.         if ($progress >= 100) {
  283.             return 'Work Finished (Pending Approval)';
  284.         }
  286.         if ($state === 'in_progress') {
  287.             return 'In Progress';
  288.         }
  290.         return 'Created';
  291.     }
  293.     private function buildStateClass(array $row): string
  294.     {
  295.         $state = (string) ($row['currentState'] ?? '');
  296.         $review = (string) ($row['reviewStatus'] ?? '');
  297.         $progress = (int) ($row['completionPercentage'] ?? 0);
  299.         if ($state === 'approved' || $review === 'approved' || (int) ($row['kpiCounted'] ?? 0) === 1) {
  300.             return 'is-approved';
  301.         }
  303.         if ($state === 'submitted' || $review === 'pending' || $progress >= 100) {
  304.             return 'is-submitted';
  305.         }
  307.         if ($state === 'rejected' || $review === 'rejected') {
  308.             return 'is-rejected';
  309.         }
  311.         return 'is-progress';
  312.     }
  314.     public function reviewerDashboardAction(Request $request)
  315.     {
  316.         $em = $this->getDoctrine()->getManager();
  317.         $conn = $em->getConnection();
  318.         $companyId = $this->getCompanyId($request);
  319.         $currentEmployeeId = $this->getEmployeeId($request);
  320.         $isOverride = $this->isAdminOverride($request);
  322.         $qb = $this->baseTaskQuery($conn, $companyId)
  323.             ->andWhere('p.current_state = :submittedState')
  324.             ->andWhere('p.review_status = :pendingReview')
  325.             ->setParameter('submittedState', 'submitted')
  326.             ->setParameter('pendingReview', 'pending')
  327.             ->orderBy('p.submitted_at', 'ASC')
  328.             ->addOrderBy('p.id', 'DESC');
  330.         if (!$isOverride) {
  331.             $qb->andWhere('p.reviewer_id = :reviewerId')
  332.                 ->setParameter('reviewerId', $currentEmployeeId);
  333.         }
  335.         $tasks = $qb->executeQuery()->fetchAllAssociative();
  336.         $latestLogs = $this->fetchLatestLogMap($conn, array_column($tasks, 'planningItemId'), 'submission');
  337.         $tasks = $this->decorateRows($tasks, $latestLogs);
  338.         $filter = $this->getDashboardFilter($request, 'reviewer');
  339.         $tasks = $this->applyDashboardFilter($tasks, 'reviewer', $filter);
  341.         foreach ($tasks as &$task) {
  342.             $task['isOverdueReview'] = (int) ($task['submittedAgeHours'] ?? 0) >= 48;
  343.         }
  344.         unset($task);
  346.         return $this->render('@Application/pages/tasks/dashboard_reviewer.html.twig', [
  347.             'page_title' => 'Reviewer Dashboard',
  348.             'currentEmployeeId' => $currentEmployeeId,
  349.             'isAdminOverride' => $isOverride,
  350.             'activeFilter' => $filter,
  351.             'tasks' => $tasks,
  352.             'pendingCount' => count($tasks),
  353.             'overdueCount' => count(array_filter($tasks, static function ($row) {
  354.                 return !empty($row['isOverdueReview']);
  355.             })),
  356.             'taskAlerts' => $this->buildTaskAlerts($request, 'reviewer'),
  357.         ]);
  358.     }
  360.     public function myTasksDashboardAction(Request $request)
  361.     {
  362.         $em = $this->getDoctrine()->getManager();
  363.         $conn = $em->getConnection();
  364.         $companyId = $this->getCompanyId($request);
  365.         $currentEmployeeId = $this->getEmployeeId($request);
  367.         $qb = $this->baseTaskQuery($conn, $companyId)
  368.             ->andWhere('p.assigned_to = :assignedTo')
  369.             ->andWhere('p.assigned_to_type = 1')
  370.             ->setParameter('assignedTo', $currentEmployeeId)
  371.             ->orderBy('p.updated_at', 'DESC')
  372.             ->addOrderBy('p.id', 'DESC');
  374.         $tasks = $qb->executeQuery()->fetchAllAssociative();
  375.         $latestLogs = $this->fetchLatestLogMap($conn, array_column($tasks, 'planningItemId'));
  376.         $tasks = $this->decorateRows($tasks, $latestLogs);
  377.         $filter = $this->getDashboardFilter($request, 'my');
  378.         $tasks = $this->applyDashboardFilter($tasks, 'my', $filter);
  380.         $sections = [
  381.             'in_progress' => [],
  382.             'submitted' => [],
  383.             'rejected' => [],
  384.             'approved' => [],
  385.         ];
  387.         foreach ($tasks as $task) {
  388.             $state = (string) ($task['currentState'] ?? 'created');
  389.             if (!isset($sections[$state])) {
  390.                 $sections['in_progress'][] = $task;
  391.                 continue;
  392.             }
  393.             $sections[$state][] = $task;
  394.         }
  396.         return $this->render('@Application/pages/tasks/dashboard_my_tasks.html.twig', [
  397.             'page_title' => 'My Tasks',
  398.             'currentEmployeeId' => $currentEmployeeId,
  399.             'activeFilter' => $filter,
  400.             'sections' => $sections,
  401.             'totalTasks' => count($tasks),
  402.             'taskAlerts' => $this->buildTaskAlerts($request, 'my'),
  403.         ]);
  404.     }
  406.     public function managerDashboardAction(Request $request)
  407.     {
  408.         $em = $this->getDoctrine()->getManager();
  409.         $conn = $em->getConnection();
  410.         $companyId = $this->getCompanyId($request);
  411.         $currentEmployeeId = $this->getEmployeeId($request);
  412.         $isOverride = $this->isAdminOverride($request);
  414.         $pendingQb = $this->baseTaskQuery($conn, $companyId)
  415.             ->andWhere('p.current_state = :submittedState')
  416.             ->andWhere('p.review_status = :pendingReview')
  417.             ->setParameter('submittedState', 'submitted')
  418.             ->setParameter('pendingReview', 'pending')
  419.             ->orderBy('p.submitted_at', 'ASC')
  420.             ->addOrderBy('p.id', 'DESC');
  421.         $pendingTasks = $pendingQb->executeQuery()->fetchAllAssociative();
  422.         $pendingLogs = $this->fetchLatestLogMap($conn, array_column($pendingTasks, 'planningItemId'), 'submission');
  423.         $pendingTasks = $this->decorateRows($pendingTasks, $pendingLogs);
  424.         $managerFilter = $this->getDashboardFilter($request, 'manager');
  425.         $pendingTasks = $this->applyDashboardFilter($pendingTasks, 'manager', $managerFilter);
  426.         foreach ($pendingTasks as &$task) {
  427.             $task['isOverdueReview'] = (int) ($task['submittedAgeHours'] ?? 0) >= 48;
  428.         }
  429.         unset($task);
  431.         $todayStart = (new \DateTime('today'))->format('Y-m-d 00:00:00');
  432.         $todayEnd = (new \DateTime('today'))->format('Y-m-d 23:59:59');
  433.         $todayStartEpoch = (new \DateTime('today'))->getTimestamp();
  434.         $nowEpoch = time();
  435.         $fortyEightHoursAgo = (new \DateTime('-48 hours'))->format('Y-m-d H:i:s');
  437.         $submittedToday = (int) $conn->fetchOne(
  438.             'SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND submitted_at BETWEEN :startTs AND :endTs',
  439.             [
  440.                 'companyId' => $companyId,
  441.                 'startTs' => $todayStart,
  442.                 'endTs' => $todayEnd,
  443.             ]
  444.         );
  445.         $approvedToday = (int) $conn->fetchOne(
  446.             'SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND approved_at BETWEEN :startTs AND :endTs',
  447.             [
  448.                 'companyId' => $companyId,
  449.                 'startTs' => $todayStart,
  450.                 'endTs' => $todayEnd,
  451.             ]
  452.         );
  453.         $rejectedToday = (int) $conn->fetchOne(
  454.             'SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND rejected_at BETWEEN :startTs AND :endTs',
  455.             [
  456.                 'companyId' => $companyId,
  457.                 'startTs' => $todayStart,
  458.                 'endTs' => $todayEnd,
  459.             ]
  460.         );
  461.         $pendingReviews = (int) $conn->fetchOne(
  462.             "SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND current_state = 'submitted' AND review_status = 'pending'",
  463.             ['companyId' => $companyId]
  464.         );
  465.         $overdueReviews = (int) $conn->fetchOne(
  466.             "SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND current_state = 'submitted' AND review_status = 'pending' AND submitted_at <= :deadline",
  467.             [
  468.                 'companyId' => $companyId,
  469.                 'deadline' => $fortyEightHoursAgo,
  470.             ]
  471.         );
  472.         $todayInProgress = (int) $conn->fetchOne(
  473.             "SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND current_state IN ('created', 'in_progress')",
  474.             ['companyId' => $companyId]
  475.         );
  476.         $systemSubmitted = (int) $conn->fetchOne(
  477.             "SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND current_state = 'submitted'",
  478.             ['companyId' => $companyId]
  479.         );
  480.         $systemRejected = (int) $conn->fetchOne(
  481.             "SELECT COUNT(*) FROM planning_item WHERE company_id = :companyId AND current_state = 'rejected'",
  482.             ['companyId' => $companyId]
  483.         );
  485.         $reviewMetricsSql = "
  486.             SELECT
  487.                 AVG(CASE
  488.                     WHEN p.review_status = 'approved' AND p.approved_at IS NOT NULL AND p.submitted_at IS NOT NULL
  489.                     THEN TIMESTAMPDIFF(HOUR, p.submitted_at, p.approved_at)
  490.                     ELSE NULL
  491.                 END) AS avgReviewTimeHours,
  492.                 SUM(CASE WHEN p.current_state = 'submitted' AND p.review_status = 'pending' AND p.submitted_at <= :deadline THEN 1 ELSE 0 END) AS overdueReviewCount,
  493.                 SUM(CASE WHEN p.review_status = 'approved' THEN 1 ELSE 0 END) AS approvedReviewCount,
  494.                 SUM(CASE WHEN p.review_status = 'rejected' THEN 1 ELSE 0 END) AS rejectedReviewCount
  495.             FROM planning_item p
  496.             WHERE p.company_id = :companyId
  497.         ";
  498.         $reviewMetrics = $conn->fetchAssociative($reviewMetricsSql, [
  499.             'companyId' => $companyId,
  500.             'deadline' => $fortyEightHoursAgo,
  501.         ]) ?: [];
  502.         $avgReviewTimeHours = isset($reviewMetrics['avgReviewTimeHours']) ? round((float) $reviewMetrics['avgReviewTimeHours'], 1) : 0;
  503.         $reviewDecisionTotal = (int) ($reviewMetrics['approvedReviewCount'] ?? 0) + (int) ($reviewMetrics['rejectedReviewCount'] ?? 0);
  504.         $rejectionRate = $reviewDecisionTotal > 0
  505.             ? round(((int) ($reviewMetrics['rejectedReviewCount'] ?? 0) / $reviewDecisionTotal) * 100, 1)
  506.             : 0;
  507.         $reviewSpeedBadge = 'On Track';
  508.         $reviewSpeedClass = 'is-approved';
  509.         if ($avgReviewTimeHours > 48) {
  510.             $reviewSpeedBadge = 'Critical Delay';
  511.             $reviewSpeedClass = 'is-rejected';
  512.         } elseif ($avgReviewTimeHours > 24) {
  513.             $reviewSpeedBadge = 'Slow Review System';
  514.             $reviewSpeedClass = 'is-submitted';
  515.         }
  517.         $systemHealth = [
  518.             'inProgress' => $todayInProgress,
  519.             'submitted' => $systemSubmitted,
  520.             'overdue' => (int) ($reviewMetrics['overdueReviewCount'] ?? 0),
  521.             'rejected' => $systemRejected,
  522.         ];
  524.         $openSessionsSql = "
  525.             SELECT
  526.                 t.id AS taskLogId,
  527.                 t.user_id AS userId,
  528.                 t.planning_item_id AS planningItemId,
  529.                 t.actual_start_ts AS actualStartTs,
  530.                 p.item_alias AS taskTitle,
  531.                 COALESCE(NULLIF(e.name, ''), u.name, CONCAT('User #', t.user_id)) AS userName
  532.             FROM task_log t
  533.             LEFT JOIN planning_item p ON p.id = t.planning_item_id
  534.             LEFT JOIN sys_user u ON u.user_id = t.user_id
  535.             LEFT JOIN employee e ON e.user_id = t.user_id
  536.             WHERE p.company_id = :companyId
  537.               AND t.working_status = 1
  538.               AND t.actual_start_ts BETWEEN :todayStartEpoch AND :nowEpoch
  539.             ORDER BY t.actual_start_ts DESC, t.id DESC
  540.         ";
  541.         $openSessions = $conn->fetchAllAssociative($openSessionsSql, [
  542.             'companyId' => $companyId,
  543.             'todayStartEpoch' => $todayStartEpoch,
  544.             'nowEpoch' => $nowEpoch,
  545.         ]);
  546.         foreach ($openSessions as &$sessionRow) {
  547.             $startTs = (int) ($sessionRow['actualStartTs'] ?? 0);
  548.             $sessionRow['openHours'] = $startTs > 0 ? round(((time() - $startTs) / 3600), 1) : 0;
  549.         }
  550.         unset($sessionRow);
  552.         $nonCompliantUsers = [];
  553.         foreach ($openSessions as $sessionRow) {
  554.             $userId = (int) ($sessionRow['userId'] ?? 0);
  555.             if ($userId === 0) {
  556.                 continue;
  557.             }
  559.             if (!isset($nonCompliantUsers[$userId])) {
  560.                 $nonCompliantUsers[$userId] = [
  561.                     'userId' => $userId,
  562.                     'userName' => $sessionRow['userName'] ?? ('User #' . $userId),
  563.                     'activeSessions' => 0,
  564.                     'oldestStartTs' => (int) ($sessionRow['actualStartTs'] ?? 0),
  565.                     'oldestLabel' => $sessionRow['actualStartTs'] ? date('Y-m-d H:i', (int) $sessionRow['actualStartTs']) : 'N/A',
  566.                     'openHours' => 0,
  567.                 ];
  568.             }
  570.             $nonCompliantUsers[$userId]['activeSessions']++;
  571.             $startTs = (int) ($sessionRow['actualStartTs'] ?? 0);
  572.             if ($startTs > 0 && ($nonCompliantUsers[$userId]['oldestStartTs'] === 0 || $startTs < $nonCompliantUsers[$userId]['oldestStartTs'])) {
  573.                 $nonCompliantUsers[$userId]['oldestStartTs'] = $startTs;
  574.                 $nonCompliantUsers[$userId]['oldestLabel'] = date('Y-m-d H:i', $startTs);
  575.             }
  576.         }
  578.         foreach ($nonCompliantUsers as &$userRow) {
  579.             $userRow['openHours'] = $userRow['oldestStartTs'] > 0 ? round(((time() - $userRow['oldestStartTs']) / 3600), 1) : 0;
  580.         }
  581.         unset($userRow);
  582.         $nonCompliantUsers = array_values($nonCompliantUsers);
  584.         return $this->render('@Application/pages/tasks/dashboard_manager.html.twig', [
  585.             'page_title' => 'Manager Dashboard',
  586.             'currentEmployeeId' => $currentEmployeeId,
  587.             'isAdminOverride' => $isOverride,
  588.             'activeFilter' => $managerFilter,
  589.             'pendingTasks' => $pendingTasks,
  590.             'submittedToday' => $submittedToday,
  591.             'approvedToday' => $approvedToday,
  592.             'rejectedToday' => $rejectedToday,
  593.             'pendingReviews' => $pendingReviews,
  594.             'overdueReviews' => $overdueReviews,
  595.             'openSessions' => $openSessions,
  596.             'nonCompliantUsers' => $nonCompliantUsers,
  597.             'managerFilter' => $managerFilter,
  598.             'avgReviewTimeHours' => $avgReviewTimeHours,
  599.             'rejectionRate' => $rejectionRate,
  600.             'reviewSpeedBadge' => $reviewSpeedBadge,
  601.             'reviewSpeedClass' => $reviewSpeedClass,
  602.             'funnelCounts' => [
  603.                 'inProgress' => $todayInProgress,
  604.                 'submitted' => $systemSubmitted,
  605.                 'approved' => (int) ($reviewMetrics['approvedReviewCount'] ?? 0),
  606.                 'rejected' => $systemRejected,
  607.             ],
  608.             'systemHealth' => $systemHealth,
  609.             'taskAlerts' => $this->buildTaskAlerts($request, 'manager'),
  610.         ]);
  611.     }
  613.     public function kpiDashboardAction(Request $request)
  614.     {
  615.         $em = $this->getDoctrine()->getManager();
  616.         $conn = $em->getConnection();
  617.         $companyId = $this->getCompanyId($request);
  619.         $sql = "
  620.             SELECT
  621.                 p.assigned_to AS assignedTo,
  622.                 p.assigned_to_type AS assignedToType,
  623.                 COALESCE(NULLIF(e.name, ''), NULLIF(u.name, ''), CONCAT(COALESCE(e.first_name, ''), ' ', COALESCE(e.last_name, '')), CONCAT('User #', p.assigned_to)) AS userName,
  624.                 COUNT(*) AS totalTasks,
  625.                 SUM(CASE WHEN p.current_state = 'submitted' THEN 1 ELSE 0 END) AS submittedTasks,
  626.                 SUM(CASE WHEN p.review_status = 'approved' THEN 1 ELSE 0 END) AS approvedTasks,
  627.                 SUM(CASE WHEN p.review_status = 'rejected' THEN 1 ELSE 0 END) AS rejectedTasks,
  628.                 SUM(CASE WHEN p.review_status = 'approved' AND COALESCE(p.kpi_counted, 0) = 1 THEN 1 ELSE 0 END) AS kpiCountedTasks
  629.             FROM planning_item p
  630.             LEFT JOIN employee e ON e.employee_id = p.assigned_to AND p.assigned_to_type = 1
  631.             LEFT JOIN sys_user u ON u.user_id = p.assigned_to AND p.assigned_to_type = 2
  632.             WHERE p.company_id = :companyId
  633.             GROUP BY
  634.                 p.assigned_to,
  635.                 p.assigned_to_type,
  636.                 e.employee_id,
  637.                 e.name,
  638.                 e.first_name,
  639.                 e.last_name,
  640.                 u.user_id,
  641.                 u.name
  643.             ORDER BY approvedTasks DESC, submittedTasks DESC, totalTasks DESC
  644.         ";
  645.         $rows = $conn->fetchAllAssociative($sql, ['companyId' => $companyId]);
  647.         $totals = [
  648.             'submitted' => 0,
  649.             'approved' => 0,
  650.             'rejected' => 0,
  651.             'kpiCounted' => 0,
  652.             'total' => 0,
  653.         ];
  655.         foreach ($rows as &$row) {
  656.             $row['submittedTasks'] = (int) ($row['submittedTasks'] ?? 0);
  657.             $row['approvedTasks'] = (int) ($row['approvedTasks'] ?? 0);
  658.             $row['rejectedTasks'] = (int) ($row['rejectedTasks'] ?? 0);
  659.             $row['kpiCountedTasks'] = (int) ($row['kpiCountedTasks'] ?? 0);
  660.             $row['totalTasks'] = (int) ($row['totalTasks'] ?? 0);
  661.             $decisions = max($row['approvedTasks'] + $row['rejectedTasks'], 0);
  662.             $row['approvalRate'] = $decisions > 0 ? round(($row['approvedTasks'] / $decisions) * 100, 1) : 0;
  664.             $totals['submitted'] += $row['submittedTasks'];
  665.             $totals['approved'] += $row['approvedTasks'];
  666.             $totals['rejected'] += $row['rejectedTasks'];
  667.             $totals['kpiCounted'] += $row['kpiCountedTasks'];
  668.             $totals['total'] += $row['totalTasks'];
  669.         }
  670.         unset($row);
  672.         $totals['approvalRate'] = ($totals['approved'] + $totals['rejected']) > 0
  673.             ? round(($totals['approved'] / ($totals['approved'] + $totals['rejected'])) * 100, 1)
  674.             : 0;
  676.         return $this->render('@Application/pages/tasks/dashboard_kpi.html.twig', [
  677.             'page_title' => 'Basic KPI Dashboard',
  678.             'rows' => $rows,
  679.             'totals' => $totals,
  680.             'taskAlerts' => [],
  681.         ]);
  682.     }
  683. }