src/CompanyGroupBundle/Controller/SuperAdminDashboardController.php line 37

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 Symfony\Bundle\FrameworkBundle\Controller\Controller;
  9. use Symfony\Component\HttpFoundation\Request;
  11. class SuperAdminDashboardController extends Controller
  12. {
  13.     public function indexAction(Request $request)
  14.     {
  15.         if (!$this->canAccessSuperAdminDashboard($request)) {
  16.             return $this->redirectToRoute('dashboard');
  17.         }
  19.         $service = $this->get('app.admin_dashboard_service');
  20.         $metrics = $service->getMetrics();
  21.         $companies = $service->listCompanies(12, 0, []);
  22.         $usageSummary = $service->getUsageSummary(30);
  23.         $alerts = $service->getAlerts();
  25.         $chartData = $this->buildChartData($usageSummary);
  27.         return $this->render('@CompanyGroup/pages/super_admin_command_center.html.twig', [
  28.             'page_title' => 'Super Admin Command Center',
  29.             'metrics' => $metrics,
  30.             'companies' => $companies,
  31.             'usage_summary' => $usageSummary,
  32.             'alerts' => $alerts,
  33.             'chart_data' => $chartData,
  34.         ]);
  35.     }
  37.     public function companyListAction(Request $request)
  38.     {
  39.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  40.         if ($systemType !== '_CENTRAL_') {
  41.             return $this->redirectToRoute('dashboard');
  42.         }
  44.         if (!$this->canAccessSuperAdminDashboard($request)) {
  45.             return $this->redirectToRoute('dashboard');
  46.         }
  48.         $page = max(1, (int)$request->query->get('page', 1));
  49.         $limit = 25;
  50.         $offset = ($page - 1) * $limit;
  51.         $filters = array(
  52.             'search' => trim((string)$request->query->get('q', '')),
  53.             'status' => trim((string)$request->query->get('status', '')),
  54.         );
  56.         $service = $this->get('app.admin_dashboard_service');
  57.         $companies = $service->listCompanies($limit, $offset, $filters);
  58.         $total = $this->countCompaniesForAdminList($filters);
  59.         $totalPages = max(1, (int)ceil($total / $limit));
  60.         $summary = $this->getCompanyListSummary();
  62.         return $this->render('@CompanyGroup/pages/admin/companies/list_companies.html.twig', array(
  63.             'page_title' => 'Companies',
  64.             'companies' => $companies,
  65.             'filters' => $filters,
  66.             'summary' => $summary,
  67.             'total' => $total,
  68.             'currentPage' => $page,
  69.             'totalPages' => $totalPages,
  70.         ));
  71.     }
  73.     public function companyViewAction(Request $request, $appId)
  74.     {
  75.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  76.         if ($systemType !== '_CENTRAL_') {
  77.             return $this->redirectToRoute('dashboard');
  78.         }
  80.         if (!$this->canAccessSuperAdminDashboard($request)) {
  81.             return $this->redirectToRoute('dashboard');
  82.         }
  84.         $service = $this->get('app.admin_dashboard_service');
  85.         $company = $service->getCompanyByAppId((int)$appId);
  86.         if (!$company) {
  87.             throw $this->createNotFoundException('Company appId #' . (int)$appId . ' not found.');
  88.         }
  90.         $em = $this->getDoctrine()->getManager('company_group');
  91.         $companyEntity = $em->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')->findOneBy(array(
  92.             'appId' => (int)$appId,
  93.         ));
  94.         $enabledModuleIds = $companyEntity ? $this->parseCompanyModuleIdList($companyEntity->getEnabledModuleIdList()) : array();
  95.         if (empty($enabledModuleIds)) {
  96.             $enabledModuleIds = $this->getDefaultEnabledCompanyModuleIds();
  97.         }
  99.         return $this->render('@CompanyGroup/pages/admin/companies/view_company.html.twig', array(
  100.             'page_title' => 'Company Details',
  101.             'company' => $company,
  102.             'company_entity' => $companyEntity,
  103.             'enabled_count' => count($enabledModuleIds),
  104.             'module_count' => count(ModuleConstant::$moduleList),
  105.         ));
  106.     }
  108.     private function canAccessSuperAdminDashboard(Request $request)
  109.     {
  110.         $session = $request->getSession();
  111.         $userId = (int) $session->get(UserConstants::USER_ID, 0);
  113.         if ($userId <= 0) {
  114.             return false;
  115.         }
  117.         $userType = (int) $session->get(UserConstants::USER_TYPE, 0);
  118.         $isBuddybeeAdmin = (int) $session->get(UserConstants::IS_BUDDYBEE_ADMIN, 0);
  119.         $allModuleAccess = (int) $session->get(UserConstants::ALL_MODULE_ACCESS_FLAG, 0);
  120.         $allowedTypes = [
  121.             UserConstants::USER_TYPE_SYSTEM,
  122.             UserConstants::USER_TYPE_MANAGEMENT_USER,
  123.             UserConstants::USER_TYPE_GENERAL,
  124.         ];
  126.         return $isBuddybeeAdmin === 1 || $allModuleAccess === 1 || in_array($userType, $allowedTypes, true);
  127.     }
  129.     private function countCompaniesForAdminList(array $filters)
  130.     {
  131.         $conn = $this->getDoctrine()->getManager('company_group')->getConnection();
  132.         $where = array();
  133.         $params = array();
  135.         if (!empty($filters['search'])) {
  136.             $where[] = '(name LIKE :search OR CAST(app_id AS CHAR) LIKE :search OR email LIKE :search)';
  137.             $params['search'] = '%' . $filters['search'] . '%';
  138.         }
  140.         if (!empty($filters['status'])) {
  141.             $where[] = 'company_status = :companyStatus';
  142.             $params['companyStatus'] = $filters['status'];
  143.         }
  145.         $sql = 'SELECT COUNT(*) FROM company_group';
  146.         if (!empty($where)) {
  147.             $sql .= ' WHERE ' . implode(' AND ', $where);
  148.         }
  150.         return (int)$conn->fetchOne($sql, $params);
  151.     }
  153.     private function getCompanyListSummary()
  154.     {
  155.         $conn = $this->getDoctrine()->getManager('company_group')->getConnection();
  157.         return array(
  158.             'all' => (int)$conn->fetchOne('SELECT COUNT(*) FROM company_group'),
  159.             'active' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'active'"),
  160.             'trial' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'trial'"),
  161.             'suspended' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'suspended'"),
  162.             'expired' => (int)$conn->fetchOne("SELECT COUNT(*) FROM company_group WHERE company_status = 'expired'"),
  163.             'enabled' => (int)$conn->fetchOne('SELECT COUNT(*) FROM company_group WHERE active = 1'),
  164.             'disabled' => (int)$conn->fetchOne('SELECT COUNT(*) FROM company_group WHERE active = 0'),
  165.         );
  166.     }
  168.     public function companySettingsAction(Request $request, $appId)
  169.     {
  170.         $systemType = $this->container->hasParameter('system_type') ? $this->container->getParameter('system_type') : '_ERP_';
  171.         if ($systemType !== '_CENTRAL_') {
  172.             return $this->redirectToRoute('dashboard');
  173.         }
  175.         if (!$this->canAccessSuperAdminDashboard($request)) {
  176.             return $this->redirectToRoute('dashboard');
  177.         }
  179.         $appId = (int)$appId;
  180.         $em = $this->getDoctrine()->getManager('company_group');
  181.         $company = $em->getRepository('CompanyGroupBundle\\Entity\\CompanyGroup')->findOneBy(array(
  182.             'appId' => $appId,
  183.         ));
  185.         if (!$company) {
  186.             throw $this->createNotFoundException('Company appId #' . $appId . ' not found.');
  187.         }
  189.         if ($request->isMethod('POST')) {
  190.             $company->setName($request->request->get('name', $company->getName()));
  191.             $company->setAddress($request->request->get('address', $company->getAddress()));
  192.             $company->setShippingAddress($request->request->get('shippingAddress', $company->getShippingAddress()));
  193.             $company->setBillingAddress($request->request->get('billingAddress', $company->getBillingAddress()));
  194.             $company->setMotto($request->request->get('motto', $company->getMotto()));
  195.             $company->setInvoiceFooter($request->request->get('invoiceFooter', $company->getInvoiceFooter()));
  196.             $company->setGeneralFooter($request->request->get('generalFooter', $company->getGeneralFooter()));
  197.             $company->setCompanyDescription($request->request->get('companyDescription', $company->getCompanyDescription()));
  198.             $company->setCompanyStatus($request->request->get('companyStatus', $company->getCompanyStatus()));
  199.             $company->setPackageType($request->request->get('packageType', $company->getPackageType()));
  200.             $company->setActive((int)$request->request->get('active', 0));
  201.             $company->setReadOnlyMode((int)$request->request->get('readOnlyMode', 0));
  202.             $company->setAdminUserAllowed((int)$request->request->get('adminUserAllowed', 0));
  203.             $company->setUserAllowed((int)$request->request->get('userAllowed', 0));
  204.             $company->setSubscriptionMonth((int)$request->request->get('subscriptionMonth', 0));
  205.             $company->setCurrentSubscriptionPackageId((int)$request->request->get('currentSubscriptionPackageId', 0));
  206.             $company->setBillingAmount((int)$request->request->get('billingAmount', 0));
  208.             $usageValidUptoDate = $this->dateFromForm($request->request->get('usageValidUptoDate', ''));
  209.             $company->setUsageValidUptoDate($usageValidUptoDate);
  210.             $company->setUsageValidUptoDateTs($usageValidUptoDate ? $usageValidUptoDate->format('U') : 0);
  212.             $subscriptionExpiry = $this->dateFromForm($request->request->get('subscriptionExpiry', ''));
  213.             $company->setSubscriptionExpiry($subscriptionExpiry);
  215.             $moduleIds = $request->request->get('moduleIds', array());
  216.             if (!is_array($moduleIds)) {
  217.                 $moduleIds = array();
  218.             }
  220.             $validModuleIds = array();
  221.             foreach (ModuleConstant::$moduleList as $module) {
  222.                 $validModuleIds[(int)$module['id']] = true;
  223.             }
  225.             $enabledModuleIds = array();
  226.             foreach ($moduleIds as $moduleId) {
  227.                 $moduleId = (int)$moduleId;
  228.                 if ($moduleId > 0 && isset($validModuleIds[$moduleId])) {
  229.                     $enabledModuleIds[$moduleId] = $moduleId;
  230.                 }
  231.             }
  233.             ksort($enabledModuleIds);
  234.             $company->setEnabledModuleIdList(implode(',', array_values($enabledModuleIds)));
  235.             $em->flush();
  237.             $companySyncResult = $this->syncCompanySettingsToErp($em, $company);
  238.             $syncResult = $this->forceCompanyRouteSync($company);
  239.             if ($companySyncResult['success'] && $syncResult['success']) {
  240.                 $this->addFlash('success', 'Company settings were saved and synced to ERP.');
  241.             } else {
  242.                 $this->addFlash('warning', 'Company settings were saved, but ERP sync needs attention. Company sync: ' . $companySyncResult['message'] . ' Route sync: ' . $syncResult['message']);
  243.             }
  245.             return $this->redirectToRoute('admin_company_settings', array(
  246.                 'appId' => $appId,
  247.             ));
  248.         }
  250.         $enabledModuleIds = $this->parseCompanyModuleIdList($company->getEnabledModuleIdList());
  251.         if (empty($enabledModuleIds)) {
  252.             $enabledModuleIds = $this->getDefaultEnabledCompanyModuleIds();
  253.         }
  255.         $enabledLookup = array_fill_keys($enabledModuleIds, true);
  256.         $groupedModules = $this->buildGroupedModuleList();
  258.         return $this->render('@CompanyGroup/pages/admin/companies/module_settings.html.twig', array(
  259.             'page_title' => 'Company Settings',
  260.             'company' => $company,
  261.             'grouped_modules' => $groupedModules,
  262.             'enabled_lookup' => $enabledLookup,
  263.             'enabled_count' => count($enabledLookup),
  264.             'module_count' => count(ModuleConstant::$moduleList),
  265.         ));
  266.     }
  268.     public function companyModuleSettingsAction(Request $request, $appId)
  269.     {
  270.         return $this->companySettingsAction($request, $appId);
  271.     }
  273.     private function dateFromForm($value)
  274.     {
  275.         $value = trim((string)$value);
  276.         if ($value === '') {
  277.             return null;
  278.         }
  280.         try {
  281.             return new \DateTime($value);
  282.         } catch (\Exception $e) {
  283.             return null;
  284.         }
  285.     }
  287.     private function syncCompanySettingsToErp($em, $company)
  288.     {
  289.         $response = MiscActions::updateCompanyToErpServer($em, (int)$company->getAppId(), $this->container->getParameter('kernel.root_dir'));
  290.         if (isset($response['success']) && $response['success'] === true) {
  291.             return array(
  292.                 'success' => true,
  293.                 'message' => isset($response['message']) ? $response['message'] : 'Synced.',
  294.             );
  295.         }
  297.         return array(
  298.             'success' => false,
  299.             'message' => isset($response['message']) ? $response['message'] : 'Company metadata sync was not confirmed.',
  300.         );
  301.     }
  303.     private function parseCompanyModuleIdList($moduleIdList)
  304.     {
  305.         $moduleIdList = trim((string)$moduleIdList);
  306.         if ($moduleIdList === '') {
  307.             return array();
  308.         }
  310.         $decoded = json_decode($moduleIdList, true);
  311.         $rawList = is_array($decoded) ? $decoded : explode(',', $moduleIdList);
  312.         $cleanList = array();
  313.         foreach ($rawList as $moduleId) {
  314.             $moduleId = (int)$moduleId;
  315.             if ($moduleId > 0) {
  316.                 $cleanList[$moduleId] = $moduleId;
  317.             }
  318.         }
  320.         return array_values($cleanList);
  321.     }
  323.     private function getDefaultEnabledCompanyModuleIds()
  324.     {
  325.         $moduleIds = array();
  326.         foreach (ModuleConstant::$moduleList as $module) {
  327.             if ((int)(isset($module['defaultEnabledForCompany']) ? $module['defaultEnabledForCompany'] : 0) === 1) {
  328.                 $moduleIds[] = (int)$module['id'];
  329.             }
  330.         }
  332.         return $moduleIds;
  333.     }
  335.     private function buildGroupedModuleList()
  336.     {
  337.         $groups = array();
  338.         foreach (ModuleConstant::$parentModuleList as $parentModule) {
  339.             $groups[(int)$parentModule['id']] = array(
  340.                 'parent' => $parentModule,
  341.                 'modules' => array(),
  342.             );
  343.         }
  345.         foreach (ModuleConstant::$moduleList as $module) {
  346.             $parentId = (int)$module['parentId'];
  347.             if (!isset($groups[$parentId])) {
  348.                 $groups[$parentId] = array(
  349.                     'parent' => array(
  350.                         'id' => $parentId,
  351.                         'name' => 'Other',
  352.                     ),
  353.                     'modules' => array(),
  354.                 );
  355.             }
  356.             $groups[$parentId]['modules'][] = $module;
  357.         }
  359.         foreach ($groups as $parentId => $group) {
  360.             if (empty($group['modules'])) {
  361.                 unset($groups[$parentId]);
  362.             }
  363.         }
  365.         return $groups;
  366.     }
  368.     private function forceCompanyRouteSync($company)
  369.     {
  370.         $serverAddress = rtrim((string)$company->getCompanyGroupServerAddress(), '/');
  371.         if ($serverAddress === '') {
  372.             return array(
  373.                 'success' => false,
  374.                 'message' => 'ERP server address is not configured.',
  375.             );
  376.         }
  378.         $curl = curl_init();
  379.         curl_setopt_array($curl, array(
  380.             CURLOPT_RETURNTRANSFER => 1,
  381.             CURLOPT_POST => 1,
  382.             CURLOPT_URL => $serverAddress . '/update_route_company_wise',
  383.             CURLOPT_CONNECTTIMEOUT => 10,
  384.             CURLOPT_SSL_VERIFYPEER => false,
  385.             CURLOPT_SSL_VERIFYHOST => false,
  386.             CURLOPT_POSTFIELDS => http_build_query(array(
  387.                 'appId' => (int)$company->getAppId(),
  388.             )),
  389.         ));
  391.         $response = curl_exec($curl);
  392.         $error = curl_error($curl);
  393.         curl_close($curl);
  395.         if ($error) {
  396.             return array(
  397.                 'success' => false,
  398.                 'message' => $error,
  399.             );
  400.         }
  402.         return array(
  403.             'success' => true,
  404.             'message' => (string)$response,
  405.         );
  406.     }
  408.     private function buildChartData(array $usageSummary)
  409.     {
  410.         $activityTrend = $usageSummary['activity_trend'] ?? [];
  411.         $usageTrend = $usageSummary['usage_trend'] ?? [];
  412.         $revenueTrend = $usageSummary['revenue_trend'] ?? [];
  414.         $activityByDay = [];
  415.         foreach ($activityTrend as $row) {
  416.             $day = (string) ($row['day'] ?? '');
  417.             if ($day === '') {
  418.                 continue;
  419.             }
  420.             if (!isset($activityByDay[$day])) {
  421.                 $activityByDay[$day] = 0;
  422.             }
  423.             $activityByDay[$day] += (int) ($row['total'] ?? 0);
  424.         }
  426.         $usageByDay = [];
  427.         foreach ($usageTrend as $row) {
  428.             $day = (string) ($row['day'] ?? '');
  429.             if ($day === '') {
  430.                 continue;
  431.             }
  432.             if (!isset($usageByDay[$day])) {
  433.                 $usageByDay[$day] = 0;
  434.             }
  435.             $usageByDay[$day] += (int) ($row['total'] ?? 0);
  436.         }
  438.         $revenueByDay = [];
  439.         foreach ($revenueTrend as $row) {
  440.             $day = (string) ($row['day'] ?? '');
  441.             if ($day === '') {
  442.                 continue;
  443.             }
  444.             $revenueByDay[$day] = (float) ($row['total'] ?? 0);
  445.         }
  447.         $labels = array_values(array_unique(array_merge(
  448.             array_keys($activityByDay),
  449.             array_keys($usageByDay),
  450.             array_keys($revenueByDay)
  451.         )));
  452.         sort($labels);
  454.         $activitySeries = [];
  455.         $usageSeries = [];
  456.         $revenueSeries = [];
  458.         foreach ($labels as $label) {
  459.             $activitySeries[] = (int) ($activityByDay[$label] ?? 0);
  460.             $usageSeries[] = (int) ($usageByDay[$label] ?? 0);
  461.             $revenueSeries[] = (float) ($revenueByDay[$label] ?? 0);
  462.         }
  464.         return [
  465.             'labels' => $labels,
  466.             'activity_series' => $activitySeries,
  467.             'usage_series' => $usageSeries,
  468.             'revenue_series' => $revenueSeries,
  469.         ];
  470.     }
  471. }