src/CompanyGroupBundle/Controller/SuperAdminDashboardController.php line 84

Open in your IDE?
  1. <?php
  3. namespace CompanyGroupBundle\Controller;
  5. use ApplicationBundle\Constants\ModuleConstant;
  6. use ApplicationBundle\Modules\System\MiscActions;
  7. use ApplicationBundle\Modules\Authentication\Constants\UserConstants;
  8. use ApplicationBundle\Command\Support\FleetHealthVerdict;
  9. use ApplicationBundle\Helper\EbBridgeConfig;
  10. use ApplicationBundle\Modules\Api\Support\EbBridgeVerifier;
  11. use CompanyGroupBundle\Entity\EnergyBridgeSiteLink;
  12. use Symfony\Bundle\FrameworkBundle\Controller\Controller;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpFoundation\JsonResponse;
  16. class SuperAdminDashboardController extends Controller
  17. {
  18.     public function indexAction(Request $request)
  19.     {
  20.         if (!$this->canAccessSuperAdminDashboard($request)) {
  21.             return $this->redirectToRoute('dashboard');
  22.         }
  24.         $service = $this->get('app.admin_dashboard_service');
  25.         $metrics = $service->getMetrics();
  26.         $companies = $service->listCompanies(12, 0, []);
  27.         $usageSummary = $service->getUsageSummary(30);
  28.         $alerts = $service->getAlerts();
  30.         $chartData = $this->buildChartData($usageSummary);
  32.         return $this->render('@CompanyGroup/pages/super_admin_command_center.html.twig', [
  33.             'page_title' => 'Super Admin Command Center',
  34.             'metrics' => $metrics,
  35.             'companies' => $companies,
  36.             'usage_summary' => $usageSummary,
  37.             'alerts' => $alerts,
  38.             'chart_data' => $chartData,
  39.         ]);
  40.     }
  42.     public function companyListAction(Request $request)
  43.     {
  44.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  45.         if ($systemType !== '_CENTRAL_') {
  46.             return $this->redirectToRoute('dashboard');
  47.         }
  49.         if (!$this->canAccessSuperAdminDashboard($request)) {
  50.             return $this->redirectToRoute('dashboard');
  51.         }
  53.         $page = max(1, (int)$request->query->get('page', 1));
  54.         $limit = 25;
  55.         $offset = ($page - 1) * $limit;
  56.         $filters = array(
  57.             'search' => trim((string)$request->query->get('q', '')),
  58.             'status' => trim((string)$request->query->get('status', '')),
  59.         );
  61.         $service = $this->get('app.admin_dashboard_service');
  62.         $companies = $service->listCompanies($limit, $offset, $filters);
  63.         $total = $this->countCompaniesForAdminList($filters);
  64.         $totalPages = max(1, (int)ceil($total / $limit));
  65.         $summary = $this->getCompanyListSummary();
  67.         return $this->render('@CompanyGroup/pages/admin/companies/list_companies.html.twig', array(
  68.             'page_title' => 'Companies',
  69.             'companies' => $companies,
  70.             'filters' => $filters,
  71.             'summary' => $summary,
  72.             'total' => $total,
  73.             'currentPage' => $page,
  74.             'totalPages' => $totalPages,
  75.         ));
  76.     }
  78.     /**
  79.      * L4 — Fleet health dashboard: 100 tenants at a glance. Reads the central snapshots the
  80.      * collector wrote (never live-queries tenant DBs) and renders one green/amber/red row per
  81.      * tenant, red-first. Every central read is guarded so the page renders even before the
  82.      * fleet_health_snapshot / tenant_schema_state / cron_cycle_run tables are migrated.
  83.      */
  84.     public function fleetHealthAction(Request $request)
  85.     {
  86.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  87.         if ($systemType !== '_CENTRAL_') {
  88.             return $this->redirectToRoute('dashboard');
  89.         }
  90.         if (!$this->canAccessSuperAdminDashboard($request)) {
  91.             return $this->redirectToRoute('dashboard');
  92.         }
  94.         $cem = $this->getDoctrine()->getManager('company_group');
  95.         $now = time();
  96.         $graceDays = $this->container->hasParameter('subscription_grace_days')
  97.             ? (int) $this->container->getParameter('subscription_grace_days') : 7;
  99.         $tenants = array();
  100.         try {
  101.             foreach ($cem->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')->findBy(array('active' => 1)) as $g) {
  102.                 if (!$g->getDbName()) { continue; }
  103.                 $tenants[(int) $g->getAppId()] = array('appId' => (int) $g->getAppId(), 'name' => $g->getName(), 'dbName' => $g->getDbName());
  104.             }
  105.         } catch (\Throwable $e) { /* central unreachable */ }
  107.         $snaps = array();
  108.         try { foreach ($cem->getRepository('CompanyGroupBundle\\Entity\\FleetHealthSnapshot')->findAll() as $s) { $snaps[(int) $s->getAppId()] = $s; } } catch (\Throwable $e) {}
  109.         $schema = array();
  110.         try { foreach ($cem->getRepository('CompanyGroupBundle\\Entity\\TenantSchemaState')->findAll() as $s) { $schema[(int) $s->getAppId()] = $s; } } catch (\Throwable $e) {}
  112.         // Latest fan-out cron cycle (fleet-wide), latest fleet-migrate report, recent alerts.
  113.         $lastCron = null; $lastMigrate = null; $alerts = array();
  114.         try {
  115.             foreach ($cem->getRepository('CompanyGroupBundle\\Entity\\CronCycleRun')->findBy(array(), array('finishedAt' => 'DESC'), 30) as $c) {
  116.                 if ($c->getCommand() === 'fleet-migrate') { if ($lastMigrate === null) { $lastMigrate = $c; } }
  117.                 elseif ($lastCron === null) { $lastCron = $c; }
  118.                 if ($c->getAlert() && count($alerts) < 8) { $alerts[] = $c; }
  119.             }
  120.         } catch (\Throwable $e) {}
  121.         $cronAgeSec = null; $cronLastFailed = false;
  122.         if ($lastCron && $lastCron->getFinishedAt() instanceof \DateTimeInterface) {
  123.             $cronAgeSec = $now - (int) $lastCron->getFinishedAt()->format('U');
  124.             $cronLastFailed = ((int) $lastCron->getFailedCount() + (int) $lastCron->getTimedOutCount()) > 0;
  125.         }
  127.         // FE1 — recent red-finding alerts (pre-schema-safe: table missing → empty panel).
  128.         $fleetAlerts = array();
  129.         try {
  130.             $fleetAlerts = $cem->getRepository('CompanyGroupBundle\\Entity\\PlatformFleetAlert')
  131.                 ->findBy(array(), array('id' => 'DESC'), 10);
  132.         } catch (\Throwable $e) {}
  134.         $rows = array();
  135.         $counts = array('ok' => 0, 'warn' => 0, 'fail' => 0, 'unknown' => 0);
  136.         $oldest = null;
  137.         foreach ($tenants as $appId => $t) {
  138.             $s = isset($snaps[$appId]) ? $snaps[$appId] : null;
  139.             $sc = isset($schema[$appId]) ? $schema[$appId] : null;
  140.             $collectedTs = ($s && $s->getCollectedAt() instanceof \DateTimeInterface) ? (int) $s->getCollectedAt()->format('U') : 0;
  141.             $facts = array(
  142.                 'collectedAtTs' => $collectedTs, 'collectError' => $s ? $s->getCollectError() : null,
  143.                 'tbBalanced' => $s ? $s->getTbBalanced() : null, 'tbDiff' => $s ? $s->getTbDiff() : null,
  144.                 'auditChainOk' => $s ? $s->getAuditChainOk() : null, 'auditChainBreaks' => $s ? (int) $s->getAuditChainBreaks() : 0,
  145.                 'unbalancedVouchers' => $s ? $s->getUnbalancedVouchers() : null,
  146.                 'markerUncovered' => $s ? $s->getMarkerUncovered() : null,
  147.                 'schemaStatus' => $sc ? $sc->getStatus() : null,
  148.                 'cronAgeSec' => $cronAgeSec, 'cronLastFailed' => $cronLastFailed,
  149.                 'subscriptionExpiryTs' => $s ? (int) $s->getSubscriptionExpiryTs() : 0, 'graceDays' => $graceDays,
  150.                 'activityLogRows' => $s ? $s->getActivityLogRows() : null,
  151.                 'jsErrorsToday' => $s ? $s->getJsErrorsToday() : null,
  152.                 'smokeChecked' => $s ? $s->getSmokeChecked() : null,
  153.                 'smokeFailed' => $s ? $s->getSmokeFailed() : null,
  154.                 'smokeAssertFail' => $s ? $s->getSmokeAssertFail() : null,
  155.             );
  156.             $v = FleetHealthVerdict::evaluate($facts, $now);
  157.             $counts[$v['overall']] = (isset($counts[$v['overall']]) ? $counts[$v['overall']] : 0) + 1;
  158.             if ($collectedTs > 0 && ($oldest === null || $collectedTs < $oldest)) { $oldest = $collectedTs; }
  159.             // FE3 — 7-day JS-error trend (collector-computed JSON; null pre-migration).
  160.             $jsTrend = null;
  161.             if ($s && $s->getJsErrors7d()) {
  162.                 $decoded = json_decode((string) $s->getJsErrors7d(), true);
  163.                 if (is_array($decoded) && isset($decoded['c']) && is_array($decoded['c']) && !empty($decoded['c'])) {
  164.                     $trendCounts = array_map('intval', $decoded['c']);
  165.                     $jsTrend = array('counts' => $trendCounts,
  166.                         'dates' => isset($decoded['d']) && is_array($decoded['d']) ? $decoded['d'] : array(),
  167.                         'max' => max(1, max($trendCounts)));
  168.                 }
  169.             }
  170.             $rows[] = array('t' => $t, 'verdict' => $v, 'dbSizeMb' => $s ? $s->getDbSizeMb() : null,
  171.                 'collectedTs' => $collectedTs, 'schemaVersion' => $sc ? substr((string) $sc->getCurrentVersion(), 0, 10) : null,
  172.                 'jsTrend' => $jsTrend, 'jsToday' => $s ? $s->getJsErrorsToday() : null);
  173.         }
  175.         // Red-first: fail > warn > unknown > ok.
  176.         $rank = array('fail' => 0, 'warn' => 1, 'unknown' => 2, 'ok' => 3);
  177.         usort($rows, function ($a, $b) use ($rank) {
  178.             $ra = isset($rank[$a['verdict']['overall']]) ? $rank[$a['verdict']['overall']] : 9;
  179.             $rb = isset($rank[$b['verdict']['overall']]) ? $rank[$b['verdict']['overall']] : 9;
  180.             if ($ra !== $rb) { return $ra - $rb; }
  181.             return $a['t']['appId'] - $b['t']['appId'];
  182.         });
  184.         return $this->render('@CompanyGroup/pages/admin/fleet_health.html.twig', array(
  185.             'page_title' => 'Fleet Health',
  186.             'rows' => $rows,
  187.             'counts' => $counts,
  188.             'tenantCount' => count($tenants),
  189.             'oldestAgeSec' => $oldest ? ($now - $oldest) : null,
  190.             'lastCron' => $lastCron,
  191.             'lastMigrate' => $lastMigrate,
  192.             'alerts' => $alerts,
  193.             'fleetAlerts' => $fleetAlerts,
  194.             'checkKeys' => array('tb' => 'TB', 'chain' => 'Chain', 'vouchers' => 'Vouchers', 'markers' => 'Markers',
  195.                 'schema' => 'Schema', 'cron' => 'Cron', 'subscription' => 'Subscription', 'smoke' => 'Smoke',
  196.                 'jserrors' => 'JS Err', 'activity' => 'Activity', 'snapshot' => 'Snapshot'),
  197.         ));
  198.     }
  200.     /** L4 — re-collect ONE tenant on demand (out-of-process, so the web connection is untouched). */
  201.     public function fleetHealthRefreshAction(Request $request, $appId)
  202.     {
  203.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  204.         if ($systemType !== '_CENTRAL_' || !$this->canAccessSuperAdminDashboard($request)) {
  205.             return $this->redirectToRoute('dashboard');
  206.         }
  207.         try {
  208.             $projectDir = $this->container->hasParameter('kernel.project_dir')
  209.                 ? $this->container->getParameter('kernel.project_dir') : dirname($this->container->getParameter('kernel.root_dir'));
  210.             $env = $this->container->getParameter('kernel.environment');
  211.             $p = new \Symfony\Component\Process\Process(array(
  212.                 PHP_BINARY, $projectDir . '/bin/console', 'inno:for-each-tenant', 'inno:fleet-health-collect',
  213.                 '--only=' . (int) $appId, '--env=' . $env, '--no-interaction'), $projectDir, null, null, 120);
  214.             $p->run();
  215.             $this->addFlash('success', 'Re-collected tenant ' . (int) $appId . '.');
  216.         } catch (\Throwable $e) {
  217.             $this->addFlash('error', 'Refresh failed: ' . $e->getMessage());
  218.         }
  219.         return $this->redirectToRoute('fleet_health');
  220.     }
  222.     public function companyViewAction(Request $request, $appId)
  223.     {
  224.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  225.         if ($systemType !== '_CENTRAL_') {
  226.             return $this->redirectToRoute('dashboard');
  227.         }
  229.         if (!$this->canAccessSuperAdminDashboard($request)) {
  230.             return $this->redirectToRoute('dashboard');
  231.         }
  233.         $service = $this->get('app.admin_dashboard_service');
  234.         $company = $service->getCompanyByAppId((int)$appId);
  235.         if (!$company) {
  236.             throw $this->createNotFoundException('Company appId #' . (int)$appId . ' not found.');
  237.         }
  239.         $em = $this->getDoctrine()->getManager('company_group');
  240.         $companyEntity = $em->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')->findOneBy(array(
  241.             'appId' => (int)$appId,
  242.         ));
  243.         $enabledModuleIds = $companyEntity ? $this->parseCompanyModuleIdList($companyEntity->getEnabledModuleIdList()) : array();
  244.         if (empty($enabledModuleIds)) {
  245.             $enabledModuleIds = $this->getDefaultEnabledCompanyModuleIds();
  246.         }
  248.         return $this->render('@CompanyGroup/pages/admin/companies/view_company.html.twig', array(
  249.             'page_title' => 'Company Details',
  250.             'company' => $company,
  251.             'company_entity' => $companyEntity,
  252.             'enabled_count' => count($enabledModuleIds),
  253.             'module_count' => count(ModuleConstant::$moduleList),
  254.         ));
  255.     }
  257.     private function canAccessSuperAdminDashboard(Request $request)
  258.     {
  259.         $session = $request->getSession();
  260.         $userId = (int) $session->get(UserConstants::USER_ID, 0);
  262.         if ($userId <= 0) {
  263.             return false;
  264.         }
  266.         $userType = (int) $session->get(UserConstants::USER_TYPE, 0);
  267.         $isBuddybeeAdmin = (int) $session->get(UserConstants::IS_BUDDYBEE_ADMIN, 0);
  268.         $allModuleAccess = (int) $session->get(UserConstants::ALL_MODULE_ACCESS_FLAG, 0);
  269.         $allowedTypes = [
  270.             UserConstants::USER_TYPE_SYSTEM,
  271.             UserConstants::USER_TYPE_MANAGEMENT_USER,
  272.             UserConstants::USER_TYPE_GENERAL,
  273.         ];
  275.         return $isBuddybeeAdmin === 1 || $allModuleAccess === 1 || in_array($userType, $allowedTypes, true);
  276.     }
  278.     private function countCompaniesForAdminList(array $filters)
  279.     {
  280.         $conn = $this->getDoctrine()->getManager('company_group')->getConnection();
  281.         $where = array();
  282.         $params = array();
  284.         if (!empty($filters['search'])) {
  285.             $where[] = '(name LIKE :search OR CAST(app_id AS CHAR) LIKE :search OR email LIKE :search)';
  286.             $params['search'] = '%' . $filters['search'] . '%';
  287.         }
  289.         if (!empty($filters['status'])) {
  290.             $where[] = 'company_status = :companyStatus';
  291.             $params['companyStatus'] = $filters['status'];
  292.         }
  294.         $sql = 'SELECT COUNT(*) FROM company_group';
  295.         if (!empty($where)) {
  296.             $sql .= ' WHERE ' . implode(' AND ', $where);
  297.         }
  299.         return (int)$conn->fetchOne($sql, $params);
  300.     }
  302.     private function getCompanyListSummary()
  303.     {
  304.         $conn = $this->getDoctrine()->getManager('company_group')->getConnection();
  306.         return array(
  307.             'all' => (int)$conn->fetchOne('SELECT COUNT(*) FROM company_group'),
  308.             'active' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'active'"),
  309.             'trial' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'trial'"),
  310.             'suspended' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'suspended'"),
  311.             'expired' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'expired'"),
  312.             'enabled' => (int)$conn->fetchOne('SELECT COUNT(*) FROM company_group WHERE active = 1'),
  313.             'disabled' => (int)$conn->fetchOne('SELECT COUNT(*) FROM company_group WHERE active = 0'),
  314.         );
  315.     }
  317.     public function companySettingsAction(Request $request, $appId)
  318.     {
  319.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  320.         if ($systemType !== '_CENTRAL_') {
  321.             return $this->redirectToRoute('dashboard');
  322.         }
  324.         if (!$this->canAccessSuperAdminDashboard($request)) {
  325.             return $this->redirectToRoute('dashboard');
  326.         }
  328.         $appId = (int)$appId;
  329.         $em = $this->getDoctrine()->getManager('company_group');
  330.         $company = $em->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')->findOneBy(array(
  331.             'appId' => $appId,
  332.         ));
  334.         if (!$company) {
  335.             throw $this->createNotFoundException('Company appId #' . $appId . ' not found.');
  336.         }
  338.         if ($request->isMethod('POST')) {
  339.             $company->setName($request->request->get('name', $company->getName()));
  340.             $company->setAddress($request->request->get('address', $company->getAddress()));
  341.             $company->setShippingAddress($request->request->get('shippingAddress', $company->getShippingAddress()));
  342.             $company->setBillingAddress($request->request->get('billingAddress', $company->getBillingAddress()));
  343.             $company->setMotto($request->request->get('motto', $company->getMotto()));
  344.             $company->setInvoiceFooter($request->request->get('invoiceFooter', $company->getInvoiceFooter()));
  345.             $company->setGeneralFooter($request->request->get('generalFooter', $company->getGeneralFooter()));
  346.             $company->setCompanyDescription($request->request->get('companyDescription', $company->getCompanyDescription()));
  347.             $company->setCompanyStatus($request->request->get('companyStatus', $company->getCompanyStatus()));
  348.             $company->setPackageType($request->request->get('packageType', $company->getPackageType()));
  349.             $company->setActive((int)$request->request->get('active', 0));
  350.             $company->setReadOnlyMode((int)$request->request->get('readOnlyMode', 0));
  351.             $company->setAdminUserAllowed((int)$request->request->get('adminUserAllowed', 0));
  352.             $company->setUserAllowed((int)$request->request->get('userAllowed', 0));
  353.             $company->setSubscriptionMonth((int)$request->request->get('subscriptionMonth', 0));
  354.             $company->setCurrentSubscriptionPackageId((int)$request->request->get('currentSubscriptionPackageId', 0));
  355.             $company->setBillingAmount((int)$request->request->get('billingAmount', 0));
  357.             $usageValidUptoDate = $this->dateFromForm($request->request->get('usageValidUptoDate', ''));
  358.             $company->setUsageValidUptoDate($usageValidUptoDate);
  359.             $company->setUsageValidUptoDateTs($usageValidUptoDate ? $usageValidUptoDate->format('U') : 0);
  361.             $subscriptionExpiry = $this->dateFromForm($request->request->get('subscriptionExpiry', ''));
  362.             $company->setSubscriptionExpiry($subscriptionExpiry);
  364.             $moduleIds = $request->request->get('moduleIds', array());
  365.             if (!is_array($moduleIds)) {
  366.                 $moduleIds = array();
  367.             }
  369.             $validModuleIds = array();
  370.             foreach (ModuleConstant::$moduleList as $module) {
  371.                 $validModuleIds[(int)$module['id']] = true;
  372.             }
  374.             $enabledModuleIds = array();
  375.             foreach ($moduleIds as $moduleId) {
  376.                 $moduleId = (int)$moduleId;
  377.                 if ($moduleId > 0 && isset($validModuleIds[$moduleId])) {
  378.                     $enabledModuleIds[$moduleId] = $moduleId;
  379.                 }
  380.             }
  382.             ksort($enabledModuleIds);
  383.             $company->setEnabledModuleIdList(implode(',', array_values($enabledModuleIds)));
  384.             $em->flush();
  386.             $companySyncResult = $this->syncCompanySettingsToErp($em, $company);
  387.             $syncResult = $this->forceCompanyRouteSync($company);
  388.             if ($companySyncResult['success'] && $syncResult['success']) {
  389.                 $this->addFlash('success', 'Company settings were saved and synced to ERP.');
  390.             } else {
  391.                 $this->addFlash('warning', 'Company settings were saved, but ERP sync needs attention. Company sync: ' . $companySyncResult['message'] . ' Route sync: ' . $syncResult['message']);
  392.             }
  394.             return $this->redirectToRoute('admin_company_settings', array(
  395.                 'appId' => $appId,
  396.             ));
  397.         }
  399.         $enabledModuleIds = $this->parseCompanyModuleIdList($company->getEnabledModuleIdList());
  400.         if (empty($enabledModuleIds)) {
  401.             $enabledModuleIds = $this->getDefaultEnabledCompanyModuleIds();
  402.         }
  404.         $enabledLookup = array_fill_keys($enabledModuleIds, true);
  405.         $groupedModules = $this->buildGroupedModuleList();
  407.         return $this->render('@CompanyGroup/pages/admin/companies/module_settings.html.twig', array(
  408.             'page_title' => 'Company Settings',
  409.             'company' => $company,
  410.             'grouped_modules' => $groupedModules,
  411.             'enabled_lookup' => $enabledLookup,
  412.             'enabled_count' => count($enabledLookup),
  413.             'module_count' => count(ModuleConstant::$moduleList),
  414.         ));
  415.     }
  417.     public function companyModuleSettingsAction(Request $request, $appId)
  418.     {
  419.         return $this->companySettingsAction($request, $appId);
  420.     }
  422.     private function dateFromForm($value)
  423.     {
  424.         $value = trim((string)$value);
  425.         if ($value === '') {
  426.             return null;
  427.         }
  429.         try {
  430.             return new \DateTime($value);
  431.         } catch (\Exception $e) {
  432.             return null;
  433.         }
  434.     }
  436.     private function syncCompanySettingsToErp($em, $company)
  437.     {
  438.         $response = MiscActions::updateCompanyToErpServer($em, (int)$company->getAppId(), $this->container->getParameter('kernel.root_dir'));
  439.         if (isset($response['success']) && $response['success'] === true) {
  440.             return array(
  441.                 'success' => true,
  442.                 'message' => isset($response['message']) ? $response['message'] : 'Synced.',
  443.             );
  444.         }
  446.         return array(
  447.             'success' => false,
  448.             'message' => isset($response['message']) ? $response['message'] : 'Company metadata sync was not confirmed.',
  449.         );
  450.     }
  452.     private function parseCompanyModuleIdList($moduleIdList)
  453.     {
  454.         $moduleIdList = trim((string)$moduleIdList);
  455.         if ($moduleIdList === '') {
  456.             return array();
  457.         }
  459.         $decoded = json_decode($moduleIdList, true);
  460.         $rawList = is_array($decoded) ? $decoded : explode(',', $moduleIdList);
  461.         $cleanList = array();
  462.         foreach ($rawList as $moduleId) {
  463.             $moduleId = (int)$moduleId;
  464.             if ($moduleId > 0) {
  465.                 $cleanList[$moduleId] = $moduleId;
  466.             }
  467.         }
  469.         return array_values($cleanList);
  470.     }
  472.     private function getDefaultEnabledCompanyModuleIds()
  473.     {
  474.         $moduleIds = array();
  475.         foreach (ModuleConstant::$moduleList as $module) {
  476.             if ((int)(isset($module['defaultEnabledForCompany']) ? $module['defaultEnabledForCompany'] : 0) === 1) {
  477.                 $moduleIds[] = (int)$module['id'];
  478.             }
  479.         }
  481.         return $moduleIds;
  482.     }
  484.     private function buildGroupedModuleList()
  485.     {
  486.         $groups = array();
  487.         foreach (ModuleConstant::$parentModuleList as $parentModule) {
  488.             $groups[(int)$parentModule['id']] = array(
  489.                 'parent' => $parentModule,
  490.                 'modules' => array(),
  491.             );
  492.         }
  494.         foreach (ModuleConstant::$moduleList as $module) {
  495.             $parentId = (int)$module['parentId'];
  496.             if (!isset($groups[$parentId])) {
  497.                 $groups[$parentId] = array(
  498.                     'parent' => array(
  499.                         'id' => $parentId,
  500.                         'name' => 'Other',
  501.                     ),
  502.                     'modules' => array(),
  503.                 );
  504.             }
  505.             $groups[$parentId]['modules'][] = $module;
  506.         }
  508.         foreach ($groups as $parentId => $group) {
  509.             if (empty($group['modules'])) {
  510.                 unset($groups[$parentId]);
  511.             }
  512.         }
  514.         return $groups;
  515.     }
  517.     private function forceCompanyRouteSync($company)
  518.     {
  519.         $serverAddress = rtrim((string)$company->getCompanyGroupServerAddress(), '/');
  520.         if ($serverAddress === '') {
  521.             return array(
  522.                 'success' => false,
  523.                 'message' => 'ERP server address is not configured.',
  524.             );
  525.         }
  527.         $curl = curl_init();
  528.         curl_setopt_array($curl, array(
  529.             CURLOPT_RETURNTRANSFER => 1,
  530.             CURLOPT_POST => 1,
  531.             CURLOPT_URL => $serverAddress . '/update_route_company_wise',
  532.             CURLOPT_CONNECTTIMEOUT => 10,
  533.             CURLOPT_SSL_VERIFYPEER => false,
  534.             CURLOPT_SSL_VERIFYHOST => false,
  535.             CURLOPT_POSTFIELDS => http_build_query(array(
  536.                 'appId' => (int)$company->getAppId(),
  537.             )),
  538.         ));
  540.         $response = curl_exec($curl);
  541.         $error = curl_error($curl);
  542.         curl_close($curl);
  544.         if ($error) {
  545.             return array(
  546.                 'success' => false,
  547.                 'message' => $error,
  548.             );
  549.         }
  551.         return array(
  552.             'success' => true,
  553.             'message' => (string)$response,
  554.         );
  555.     }
  557.     private function buildChartData(array $usageSummary)
  558.     {
  559.         $activityTrend = $usageSummary['activity_trend'] ?? [];
  560.         $usageTrend = $usageSummary['usage_trend'] ?? [];
  561.         $revenueTrend = $usageSummary['revenue_trend'] ?? [];
  563.         $activityByDay = [];
  564.         foreach ($activityTrend as $row) {
  565.             $day = (string) ($row['day'] ?? '');
  566.             if ($day === '') {
  567.                 continue;
  568.             }
  569.             if (!isset($activityByDay[$day])) {
  570.                 $activityByDay[$day] = 0;
  571.             }
  572.             $activityByDay[$day] += (int) ($row['total'] ?? 0);
  573.         }
  575.         $usageByDay = [];
  576.         foreach ($usageTrend as $row) {
  577.             $day = (string) ($row['day'] ?? '');
  578.             if ($day === '') {
  579.                 continue;
  580.             }
  581.             if (!isset($usageByDay[$day])) {
  582.                 $usageByDay[$day] = 0;
  583.             }
  584.             $usageByDay[$day] += (int) ($row['total'] ?? 0);
  585.         }
  587.         $revenueByDay = [];
  588.         foreach ($revenueTrend as $row) {
  589.             $day = (string) ($row['day'] ?? '');
  590.             if ($day === '') {
  591.                 continue;
  592.             }
  593.             $revenueByDay[$day] = (float) ($row['total'] ?? 0);
  594.         }
  596.         $labels = array_values(array_unique(array_merge(
  597.             array_keys($activityByDay),
  598.             array_keys($usageByDay),
  599.             array_keys($revenueByDay)
  600.         )));
  601.         sort($labels);
  603.         $activitySeries = [];
  604.         $usageSeries = [];
  605.         $revenueSeries = [];
  607.         foreach ($labels as $label) {
  608.             $activitySeries[] = (int) ($activityByDay[$label] ?? 0);
  609.             $usageSeries[] = (int) ($usageByDay[$label] ?? 0);
  610.             $revenueSeries[] = (float) ($revenueByDay[$label] ?? 0);
  611.         }
  613.         return [
  614.             'labels' => $labels,
  615.             'activity_series' => $activitySeries,
  616.             'usage_series' => $usageSeries,
  617.             'revenue_series' => $revenueSeries,
  618.         ];
  619.     }
  621.     // ── EB0-UI — Energy⇄Business Bridge monitor + site-link admin ────────────────────────────────
  622.     // "My sites ↔ bridge status" for the owner: watch events land, see Own vs Customer, and map an
  623.     // unlinked site to a tenant + customer without hand-typing ids. Read-only over the CENTRAL bridge
  624.     // tables (+ a tenant-scoped AccClients search for the customer picker). No business action here.
  626.     public function energyBridgeAction(Request $request)
  627.     {
  628.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  629.         if ($systemType !== '_CENTRAL_') { return $this->redirectToRoute('dashboard'); }
  630.         if (!$this->canAccessSuperAdminDashboard($request)) { return $this->redirectToRoute('dashboard'); }
  632.         $cem = $this->getDoctrine()->getManager('company_group');
  634.         // Tenant directory (appId → name) for display + the picker.
  635.         $tenants = array();
  636.         try {
  637.             foreach ($cem->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')->findBy(array('active' => 1)) as $g) {
  638.                 if (!$g->getDbName()) { continue; }
  639.                 $tenants[(int) $g->getAppId()] = $g->getName();
  640.             }
  641.         } catch (\Throwable $e) { /* central unreachable */ }
  643.         // Site-link map + recent events. Pre-schema-safe: if the tables aren't migrated yet, degrade
  644.         // to an empty view with a notice rather than 500 (same discipline as the fleet-health page).
  645.         $links = array(); $events = array(); $schemaReady = true;
  646.         try {
  647.             foreach ($cem->getRepository('CompanyGroupBundle\\Entity\\EnergyBridgeSiteLink')->findBy(array(), array('siteUid' => 'ASC')) as $l) {
  648.                 $links[(string) $l->getSiteUid()] = array(
  649.                     'siteUid' => $l->getSiteUid(), 'appId' => (int) $l->getAppId(),
  650.                     'tenant' => isset($tenants[(int) $l->getAppId()]) ? $tenants[(int) $l->getAppId()] : ('app ' . $l->getAppId()),
  651.                     'linkType' => $l->getLinkType() ?: 'self', 'customerId' => $l->getCustomerId(),
  652.                     'projectId' => $l->getProjectId(), 'note' => $l->getNote(),
  653.                 );
  654.             }
  655.             $qb = $cem->getRepository('CompanyGroupBundle\\Entity\\EnergyBridgeEvent')
  656.                 ->createQueryBuilder('e')->orderBy('e.id', 'DESC')->setMaxResults(60);
  657.             foreach ($qb->getQuery()->getResult() as $e) {
  658.                 $events[] = array(
  659.                     'eventId' => $e->getEventId(), 'eventType' => $e->getEventType(),
  660.                     'siteUid' => $e->getSiteUid(), 'appId' => (int) $e->getAppId(),
  661.                     'tenant' => $e->getAppId() && isset($tenants[(int) $e->getAppId()]) ? $tenants[(int) $e->getAppId()] : null,
  662.                     'linkType' => $e->getLinkType(), 'status' => $e->getStatus(),
  663.                     'receivedAt' => $e->getReceivedAt(), 'correlationId' => $e->getCorrelationId(),
  664.                 );
  665.             }
  666.         } catch (\Throwable $e) { $schemaReady = false; }
  668.         // KPIs.
  669.         $today = (new \DateTime())->format('Y-m-d');
  670.         $kpi = array('total' => count($events), 'unlinked' => 0, 'pending' => 0, 'today' => 0, 'lastReceived' => null, 'linkedSites' => count($links));
  671.         $unlinkedSites = array();
  672.         foreach ($events as $e) {
  673.             if ($e['status'] === 'unlinked') {
  674.                 $kpi['unlinked']++;
  675.                 if ($e['siteUid'] !== null && $e['siteUid'] !== '' && !isset($links[(string) $e['siteUid']])) {
  676.                     $unlinkedSites[(string) $e['siteUid']] = true;
  677.                 }
  678.             }
  679.             if ($e['status'] === 'pending') { $kpi['pending']++; }
  680.             if ($e['receivedAt'] instanceof \DateTime) {
  681.                 if ($kpi['lastReceived'] === null || $e['receivedAt'] > $kpi['lastReceived']) { $kpi['lastReceived'] = $e['receivedAt']; }
  682.                 if ($e['receivedAt']->format('Y-m-d') === $today) { $kpi['today']++; }
  683.             }
  684.         }
  686.         return $this->render('@CompanyGroup/pages/admin/energy_bridge.html.twig', array(
  687.             'configured' => EbBridgeConfig::isConfigured(),
  688.             'schemaReady' => $schemaReady,
  689.             'tenants' => $tenants,
  690.             'links' => array_values($links),
  691.             'events' => $events,
  692.             'kpi' => $kpi,
  693.             'unlinkedSites' => array_keys($unlinkedSites),
  694.         ));
  695.     }
  697.     /** Create/update a site-link from the admin form (mirrors inno:energy-site-link). */
  698.     public function energyBridgeLinkAction(Request $request)
  699.     {
  700.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  701.         if ($systemType !== '_CENTRAL_') { return $this->redirectToRoute('dashboard'); }
  702.         if (!$this->canAccessSuperAdminDashboard($request)) { return $this->redirectToRoute('dashboard'); }
  704.         $siteUid = trim((string) $request->request->get('siteUid', ''));
  705.         $appId = (int) $request->request->get('appId', 0);
  706.         $customerId = (int) $request->request->get('customerId', 0);
  707.         $projectId = (int) $request->request->get('projectId', 0);
  708.         $note = trim((string) $request->request->get('note', ''));
  710.         if ($siteUid === '' || $appId <= 0) {
  711.             $this->addFlash('error', 'Site UID and tenant are required to map a site.');
  712.             return $this->redirectToRoute('energy_bridge_monitor');
  713.         }
  715.         try {
  716.             $cem = $this->getDoctrine()->getManager('company_group');
  717.             $link = $cem->getRepository('CompanyGroupBundle\\Entity\\EnergyBridgeSiteLink')->findOneBy(array('siteUid' => $siteUid));
  718.             $now = new \DateTime();
  719.             if ($link === null) {
  720.                 $link = new EnergyBridgeSiteLink();
  721.                 $link->setSiteUid($siteUid);
  722.                 $link->setCreatedAt($now);
  723.             }
  724.             $link->setAppId($appId);
  725.             $link->setCustomerId($customerId > 0 ? $customerId : null);
  726.             $link->setProjectId($projectId > 0 ? $projectId : null);
  727.             $link->setNote($note !== '' ? $note : null);
  728.             // A customer chosen → this is a client PPA site; none → our own site.
  729.             $link->setLinkType(EbBridgeVerifier::linkTypeForCustomer($customerId));
  730.             $link->setUpdatedAt($now);
  731.             $cem->persist($link);
  732.             $cem->flush();
  733.             $this->addFlash('success', sprintf('Mapped site %s → app %d (%s).', $siteUid, $appId,
  734.                 $link->getLinkType() === 'customer' ? 'customer' : 'own site'));
  735.         } catch (\Throwable $e) {
  736.             $this->addFlash('error', 'Could not save the site link (is the central schema migrated?): ' . $e->getMessage());
  737.         }
  738.         return $this->redirectToRoute('energy_bridge_monitor');
  739.     }
  741.     /**
  742.      * AJAX: search a specific tenant's customers (AccClients) so the owner never hand-types a
  743.      * customer id. Switches the default connection to that tenant for this request only.
  744.      */
  745.     public function energyBridgeCustomerSearchAction(Request $request)
  746.     {
  747.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  748.         if ($systemType !== '_CENTRAL_' || !$this->canAccessSuperAdminDashboard($request)) {
  749.             return new JsonResponse(array('results' => array(), 'error' => 'forbidden'), 403);
  750.         }
  751.         $appId = (int) $request->query->get('appId', 0);
  752.         $q = trim((string) $request->query->get('q', ''));
  753.         if ($appId <= 0) { return new JsonResponse(array('results' => array())); }
  755.         try {
  756.             $cfg = $this->get('app.tenant_db_config_resolver')->resolveByAppId($appId);
  757.             $this->get('application_connector')->resetConnection('default', $cfg['dbName'], $cfg['dbUser'], $cfg['dbPassword'], $cfg['dbHost'], true);
  758.             $conn = $this->getDoctrine()->getManager()->getConnection();
  759.             $rows = $conn->fetchAll(
  760.                 'SELECT client_id, client_name FROM acc_clients WHERE client_name LIKE :q ORDER BY client_name LIMIT 20',
  761.                 array('q' => '%' . $q . '%'));
  762.             $results = array();
  763.             foreach ($rows as $r) {
  764.                 $results[] = array('id' => (int) $r['client_id'], 'name' => (string) $r['client_name']);
  765.             }
  766.             return new JsonResponse(array('results' => $results));
  767.         } catch (\Throwable $e) {
  768.             return new JsonResponse(array('results' => array(), 'error' => 'tenant unreachable'));
  769.         }
  770.     }
  771. }