type = $type; $this->rootType = !empty($rootType) ? $rootType : $type; $this->id = $id; $this->rootID = !empty($rootID) ? $rootID : $id; $this->serverID = $serverID; $this->childrenMethod = $childrenMethod; $this->access = $access; $userGroupsACL = users_get_groups(false, $this->access); $this->userGroupsACL = empty($userGroupsACL) ? false : $userGroupsACL; $this->userGroups = $this->userGroupsACL; $this->userGroupsArray = array_keys($this->userGroups); global $config; include_once($config['homedir']."/include/functions_servers.php"); include_once($config['homedir']."/include/functions_modules.php"); require_once($config['homedir']."/include/functions_tags.php"); enterprise_include_once("include/functions_agents.php"); if (is_metaconsole()) enterprise_include_once("meta/include/functions_ui_meta.php"); $this->acltags = tags_get_user_groups_and_tags($config['id_user'], $this->access); } public function setFilter($filter) { // There is not module filter in metaconsole. if (is_metaconsole()) { $filter['searchModule'] = ""; $filter['statusModule'] = self::TV_DEFAULT_AGENT_STATUS; } $this->filter = $filter; } protected function getEmptyModuleFilterStatus() { return ( !isset($this->filter['statusModule']) || $this->filter['statusModule'] == -1 ); } protected function getModuleSearchFilter() { if (empty($this->filter['searchModule'])) { return ""; } return " AND tam.nombre LIKE '%".$this->filter['searchModule']."%' "; } protected function getAgentSearchFilter() { if (empty($this->filter['searchAgent'])) return ""; return " AND LOWER(ta.alias) LIKE LOWER('%".$this->filter['searchAgent']."%')"; } protected function getAgentStatusFilter ($status = self::TV_DEFAULT_AGENT_STATUS) { if ($status == self::TV_DEFAULT_AGENT_STATUS) $status = $this->filter['statusAgent']; $agent_status_filter = ""; switch ($status) { case AGENT_STATUS_ALL: break; case AGENT_STATUS_NOT_INIT: $agent_status_filter = " AND (ta.total_count = 0 OR ta.total_count = ta.notinit_count) "; break; case AGENT_STATUS_CRITICAL: $agent_status_filter = " AND ta.critical_count > 0 "; break; case AGENT_STATUS_WARNING: $agent_status_filter = " AND (ta.critical_count = 0 AND ta.warning_count > 0) "; break; case AGENT_STATUS_UNKNOWN: $agent_status_filter = " AND (ta.critical_count = 0 AND ta.warning_count = 0 AND ta.unknown_count > 0) "; break; case AGENT_STATUS_NORMAL: $agent_status_filter = " AND (ta.critical_count = 0 AND ta.warning_count = 0 AND ta.unknown_count = 0 AND ta.normal_count > 0) "; break; } return $agent_status_filter; } protected function getFirstLevelFields() { $fields = array ( "g AS " . $this->L1fieldName, "SUM(x_critical) AS total_critical_count", "SUM(x_warning) AS total_warning_count", "SUM(x_normal) AS total_normal_count", "SUM(x_unknown) AS total_unknown_count", "SUM(x_not_init) AS total_not_init_count", "SUM(x_alerts) AS total_alerts_count", "SUM(x_total) AS total_count" ); return implode(",", array_merge($fields, $this->L1extraFields)); } protected function getFirstLevelFieldsInside() { return array( 'warning' => array( 'header' => "0 AS x_critical, SUM(total) AS x_warning, 0 AS x_normal, 0 AS x_unknown, 0 AS x_not_init, 0 AS x_alerts, 0 AS x_total, g", 'condition' => "AND ta.warning_count > 0 AND ta.critical_count = 0" ), 'critical' => array( 'header' => "SUM(total) AS x_critical, 0 AS x_warning, 0 AS x_normal, 0 AS x_unknown, 0 AS x_not_init, 0 AS x_alerts, 0 AS x_total, g", 'condition' => "AND ta.critical_count > 0" ), 'normal' => array( 'header' => "0 AS x_critical, 0 AS x_warning, SUM(total) AS x_normal, 0 AS x_unknown, 0 AS x_not_init, 0 AS x_alerts, 0 AS x_total, g", 'condition' => "AND ta.critical_count = 0 AND ta.warning_count = 0 AND ta.unknown_count = 0 AND ta.normal_count > 0" ), 'unknown' => array( 'header' => "0 AS x_critical, 0 AS x_warning, 0 AS x_normal, SUM(total) AS x_unknown, 0 AS x_not_init, 0 AS x_alerts, 0 AS x_total, g", 'condition' => "AND ta.critical_count = 0 AND ta.warning_count = 0 AND ta.unknown_count > 0" ), 'not_init' => array( 'header' => "0 AS x_critical, 0 AS x_warning, 0 AS x_normal, 0 AS x_unknown, SUM(total) AS x_not_init, 0 AS x_alerts, 0 AS x_total, g", 'condition' => $this->filter['show_not_init_agents'] ? "AND ta.total_count = ta.notinit_count" : " AND 1=0" ), 'alerts' => array( 'header' => "0 AS x_critical, 0 AS x_warning, 0 AS x_normal, 0 AS x_unknown, 0 AS x_not_init, SUM(total) AS x_alerts, 0 AS x_total, g", 'condition' => "AND ta.fired_count > 0" ), 'total' => array( 'header' => "0 AS x_critical, 0 AS x_warning, 0 AS x_normal, 0 AS x_unknown, 0 AS x_not_init, 0 AS x_alerts, SUM(total) AS x_total, g", 'condition' => $this->filter['show_not_init_agents'] ? "" : "AND ta.total_count <> ta.notinit_count" ) ); } protected function getInnerOrLeftJoin () { return $this->filter['show_not_init_agents'] ? "LEFT" : "INNER"; } protected function getModuleStatusFilter () { $show_init_condition = ($this->filter['show_not_init_agents']) ? "" : " AND ta.notinit_count <> ta.total_count"; if ($this->getEmptyModuleFilterStatus()) { return $show_init_condition; } $field_filter = modules_get_counter_by_states($this->filter['statusModule']); if ($field_filter === false) return " AND 1=0"; return "AND ta.$field_filter > 0" . $show_init_condition; } // FIXME: Separate and condition from inner join protected function getTagJoin () { // $parent is the agent id $group_id = (int) db_get_value('id_grupo', 'tagente', 'id_agente', $this->id); $tag_join = ''; if (empty($group_id)) { // ACL error, this will restrict the module search $tag_join = 'INNER JOIN ttag_module tta ON 1=0'; } else if (!empty($this->acltags) && isset($this->acltags[$group_id])) { $tags_str = $this->acltags[$group_id]; if (!empty($tags_str)) { $tag_join = sprintf('INNER JOIN ttag_module ttm ON tam.id_agente_modulo = ttm.id_agente_modulo AND ttm.id_tag IN (%s)', $tags_str); } } return $tag_join; } protected function getModuleStatusFilterFromTestado ($state = false, $without_ands = false) { $selected_status = ($state !== false && $state !== self::TV_DEFAULT_AGENT_STATUS) ? $state : $this->filter['statusModule']; $filter = array(); switch ($selected_status) { case AGENT_MODULE_STATUS_CRITICAL_ALERT: case AGENT_MODULE_STATUS_CRITICAL_BAD: $filter[] = "( tae.estado = ".AGENT_MODULE_STATUS_CRITICAL_ALERT." OR tae.estado = ".AGENT_MODULE_STATUS_CRITICAL_BAD." )"; break; case AGENT_MODULE_STATUS_WARNING_ALERT: case AGENT_MODULE_STATUS_WARNING: $filter[] = "( tae.estado = ".AGENT_MODULE_STATUS_WARNING_ALERT." OR tae.estado = ".AGENT_MODULE_STATUS_WARNING." )"; break; case AGENT_MODULE_STATUS_UNKNOWN: $filter[] = "tae.estado = ".AGENT_MODULE_STATUS_UNKNOWN." "; break; case AGENT_MODULE_STATUS_NO_DATA: case AGENT_MODULE_STATUS_NOT_INIT: $filter[] = "( tae.estado = ".AGENT_MODULE_STATUS_NO_DATA." OR tae.estado = ".AGENT_MODULE_STATUS_NOT_INIT." )"; break; case AGENT_MODULE_STATUS_NORMAL_ALERT: case AGENT_MODULE_STATUS_NORMAL: $filter[] = "( tae.estado = ".AGENT_MODULE_STATUS_NORMAL_ALERT." OR tae.estado = ".AGENT_MODULE_STATUS_NORMAL." )"; break; default: $filter[] = "1=1"; break; } if (!$this->filter['show_not_init_modules'] && $state === false) { if (!empty($filter)) $filter[] = "( tae.estado <> ".AGENT_MODULE_STATUS_NO_DATA." AND tae.estado <> ".AGENT_MODULE_STATUS_NOT_INIT." )"; } $filter = implode(" AND ", $filter); return ($without_ands) ? $filter : " AND $filter "; } public function getGroupAclCondition() { if (users_can_manage_group_all("AR")) return ""; $groups_str= implode(",", $this->userGroupsArray); return " AND ( ta.id_grupo IN ($groups_str) OR tasg.id_group IN ($groups_str) )"; } protected function getGroupSearchInner() { if (empty($this->filter['searchGroup'])) return ""; return "INNER JOIN tgrupo tg ON ta.id_grupo = tg.id_grupo OR tasg.id_group = tg.id_grupo" ; } protected function getGroupSearchFilter() { if (empty($this->filter['searchGroup'])) return ""; return " AND tg.nombre LIKE '%" . $this->filter['searchGroup'] . "%'"; } static function cmpSortNames($a, $b) { return strcmp($a["name"], $b["name"]); } protected function getProcessedItem ($item, $server = false) { if (isset($processed_item['is_processed']) && $processed_item['is_processed']) return $item; $processed_item = array(); $processed_item['id'] = $item['id']; $processed_item['name'] = $item['name']; $processed_item['rootID'] = $item['id']; $processed_item['rootType'] = $this->rootType; $processed_item['searchChildren'] = 1; if (isset($item['type'])) $processed_item['type'] = $item['type']; else $processed_item['type'] = $this->type; if (isset($item['rootType'])) $processed_item['rootType'] = $item['rootType']; else $processed_item['rootType'] = $this->rootType; if ($processed_item['type'] == 'group') { $processed_item['parent'] = $item['parent']; $processed_item['icon'] = empty($item['icon']) ? "without_group.png" : $item['icon'].".png"; } if (isset($item['iconHTML'])) { $processed_item['icon'] = $item['iconHTML']; } if (is_metaconsole() && !empty($server)) { $processed_item['serverID'] = $server['id']; } $counters = array(); if (isset($item['total_unknown_count'])) $counters['unknown'] = $item['total_unknown_count']; if (isset($item['total_critical_count'])) $counters['critical'] = $item['total_critical_count']; if (isset($item['total_warning_count'])) $counters['warning'] = $item['total_warning_count']; if (isset($item['total_not_init_count'])) $counters['not_init'] = $item['total_not_init_count']; if (isset($item['total_normal_count'])) $counters['ok'] = $item['total_normal_count']; if (isset($item['total_count'])) $counters['total'] = $item['total_count']; if (isset($item['total_fired_count'])) $counters['alerts'] = $item['total_fired_count']; if (!empty($counters)) $processed_item['counters'] = $counters; if (!empty($processed_item)) $processed_item['is_processed'] = true; return $processed_item; } // This function should be used only when retrieving the data of the metaconsole's nodes protected function getMergedItems ($items) { // This variable holds the result $mergedItems = array(); foreach ($items as $key => $item) { // Avoid the deleted items if (!isset($items[$key]) || empty($item)) continue; // Store the item in a temporary element $resultItem = $item; // The 'id' parameter will be stored as 'server_id' => 'id' $resultItem['id'] = array(); $resultItem['id'][$item['serverID']] = $item['id']; $resultItem['rootID'] = array(); $resultItem['rootID'][$item['serverID']] = $item['rootID']; $resultItem['serverID'] = array(); $resultItem['serverID'][$item['serverID']] = $item['rootID']; // Initialize counters if any of it don't exist if (!isset($resultItem['counters'])) $resultItem['counters'] = array(); if (!isset($resultItem['counters']['unknown'])) $resultItem['counters']['unknown'] = 0; if (!isset($resultItem['counters']['critical'])) $resultItem['counters']['critical'] = 0; if (!isset($resultItem['counters']['warning'])) $resultItem['counters']['warning'] = 0; if (!isset($resultItem['counters']['not_init'])) $resultItem['counters']['not_init'] = 0; if (!isset($resultItem['counters']['ok'])) $resultItem['counters']['ok'] = 0; if (!isset($resultItem['counters']['total'])) $resultItem['counters']['total'] = 0; if (!isset($resultItem['counters']['alerts'])) $resultItem['counters']['alerts'] = 0; if ($item['type'] == 'group') { // Add the children if (!isset($resultItem['children'])) $resultItem['children'] = array(); } // Iterate over the list to search items that match the actual item foreach ($items as $key2 => $item2) { // Skip the actual or empty items if ($key == $key2 || !isset($items[$key2])) continue; // Match with the name and type if ($item['name'] == $item2['name'] && $item['type'] == $item2['type']) { // Add the matched ids $resultItem['id'][$item2['serverID']] = $item2['id']; $resultItem['rootID'][$item2['serverID']] = $item2['rootID']; $resultItem['serverID'][$item2['serverID']] = $item2['rootID']; // Add the matched counters if (isset($item2['counters']) && !empty($item2['counters'])) { foreach ($item2['counters'] as $type => $value) { if (isset($resultItem['counters'][$type])) $resultItem['counters'][$type] += $value; } } if ($item['type'] == 'group') { // Add the matched children if (isset($item2['children'])) $resultItem['children'] = array_merge($resultItem['children'], $item2['children']); } // Remove the item unset($items[$key2]); } } if ($item['type'] == 'group') { // Get the merged children (recursion) if (!empty($resultItem['children'])) $resultItem['children'] = $this->getMergedItems($resultItem['children']); } // Add the resulting item if (!empty($resultItem) && !empty($resultItem['counters']['total'])) $mergedItems[] = $resultItem; // Remove the item unset($items[$key]); } usort($mergedItems, array("Tree", "cmpSortNames")); return $mergedItems; } protected function processModule (&$module, $server = false, $all_groups) { global $config; if (isset($module['children'])) { foreach ($module['children'] as $i => $children) { $this->processModule($module['children'][$i], $server, $all_groups); } } $module['type'] = 'module'; $module['id'] = (int) $module['id']; $module['name'] = io_safe_output($module['name']); $module['id_module_type'] = (int) $module['id_tipo_modulo']; $module['server_type'] = (int) $module['id_modulo']; $module['status'] = $module['estado']; $module['value'] = $module['datos']; if (is_metaconsole() && !empty($server)) { $module['serverID'] = $server['id']; $module['serverName'] = $server['server_name']; } else { $module['serverName'] = false; $module['serverID'] = false; } if (!isset($module['value'])) $module['value'] = modules_get_last_value($module['id']); // Status switch ($module['status']) { case AGENT_MODULE_STATUS_CRITICAL_ALERT: $module['alert'] = 1; case AGENT_MODULE_STATUS_CRITICAL_BAD: $statusType = STATUS_MODULE_CRITICAL_BALL; $statusTitle = __('CRITICAL'); $module['statusText'] = "critical"; break; case AGENT_MODULE_STATUS_WARNING_ALERT: $module['alert'] = 1; case AGENT_MODULE_STATUS_WARNING: $statusType = STATUS_MODULE_WARNING_BALL; $statusTitle = __('WARNING'); $module['statusText'] = "warning"; break; case AGENT_MODULE_STATUS_UNKNOWN: $statusType = STATUS_MODULE_UNKNOWN_BALL; $statusTitle = __('UNKNOWN'); $module['statusText'] = "unknown"; break; case AGENT_MODULE_STATUS_NO_DATA: case AGENT_MODULE_STATUS_NOT_INIT: $statusType = STATUS_MODULE_NO_DATA_BALL; $statusTitle = __('NO DATA'); $module['statusText'] = "not_init"; break; case AGENT_MODULE_STATUS_NORMAL_ALERT: $module['alert'] = 1; case AGENT_MODULE_STATUS_NORMAL: default: $statusType = STATUS_MODULE_OK_BALL; $statusTitle = __('NORMAL'); $module['statusText'] = "ok"; break; } if ($statusType !== STATUS_MODULE_UNKNOWN_BALL && $statusType !== STATUS_MODULE_NO_DATA_BALL) { if (is_numeric($module["value"])) { $statusTitle .= " : " . format_for_graph($module["value"]); } else { $statusTitle .= " : " . substr(io_safe_output($module["value"]),0,42); } } $module['statusImageHTML'] = ui_print_status_image($statusType, $statusTitle, true); // HTML of the server type image $module['serverTypeHTML'] = servers_show_type($module['server_type']); // Link to the Module graph // ACL $acl_graphs = false; $module["showGraphs"] = 0; // Avoid the check on the metaconsole. Too slow to show/hide an icon depending on the permissions if (!empty($group_id) && !is_metaconsole()) { $acl_graphs = check_acl_one_of_groups($config['id_user'], $all_groups, "RR"); } else if (!empty($all_groups)) { $acl_graphs = true; } if ($acl_graphs) { $module["showGraphs"] = 1; } if ($module["showGraphs"]) { $graphType = return_graphtype($module['id_module_type']); $url = ui_get_full_url("operation/agentes/stat_win.php", false, false, false); $winHandle = dechex(crc32($module['id'].$module['name'])); $graph_params = array( "type" => $graphType, "period" => SECONDS_1DAY, "id" => $module['id'], "label" => base64_encode($module['name']), "refresh" => SECONDS_10MINUTES ); if (is_metaconsole() && !empty($server)) { // Set the server id $graph_params["server"] = $module['serverID']; } $graph_params_str = http_build_query($graph_params); $moduleGraphURL = "$url?$graph_params_str"; $module['moduleGraph'] = array( 'url' => $moduleGraphURL, 'handle' => $winHandle ); // Info to be able to open the snapshot image new page $module['snapshot'] = ui_get_snapshot_link(array( 'id_module' => $module['id'], 'interval' => $module['current_interval'], 'module_name' => $module['name'], 'id_node' => $module['serverID'] ? $module['serverID'] : 0, ), true); } // Alerts fired image if ((bool)$module['alerts']) { $module['alertsImageHTML'] = html_print_image("images/bell.png", true, array("title" => __('Module alerts'))); } } protected function processModules (&$modules, $server = false) { if (!empty($modules)) { $all_groups = modules_get_agent_groups($modules[0]['id']); } foreach ($modules as $iterator => $module) { $this->processModule($modules[$iterator], $server, $all_groups); } } protected function processAgent (&$agent, $server = false) { global $config; $agent['type'] = 'agent'; $agent['id'] = (int) $agent['id']; $agent['name'] = $agent['name']; $agent['rootID'] = $this->rootID; $agent['rootType'] = $this->rootType; if (is_metaconsole()) { if (isset($agent['server_id'])) $agent['serverID'] = $agent['server_id']; else if (!empty($server)) $agent['serverID'] = $server['id']; } // Counters if (empty($agent['counters'])) { $agent['counters'] = array(); $agent['counters']['unknown'] = isset($agent['unknown_count']) ? $agent['unknown_count'] : 0; $agent['counters']['critical'] = isset($agent['critical_count']) ? $agent['critical_count'] : 0; $agent['counters']['warning'] = isset($agent['warning_count']) ? $agent['warning_count'] : 0; $agent['counters']['not_init'] = isset($agent['notinit_count']) ? $agent['notinit_count'] : 0; $agent['counters']['ok'] = isset($agent['normal_count']) ? $agent['normal_count'] : 0; $agent['counters']['total'] = isset($agent['total_count']) ? $agent['total_count'] : 0; $agent['counters']['alerts'] = isset($agent['fired_count']) ? $agent['fired_count'] : 0; } // Status image $agent['statusImageHTML'] = agents_tree_view_status_img_ball( $agent['counters']['critical'], $agent['counters']['warning'], $agent['counters']['unknown'], $agent['counters']['total'], $agent['counters']['not_init']); // Alerts fired image $agent["alertImageHTML"] = agents_tree_view_alert_img_ball($agent['counters']['alerts']); // search module recalculate counters if(array_key_exists('state_normal', $agent)){ $agent['counters']['unknown'] = $agent['state_unknown']; $agent['counters']['critical'] = $agent['state_critical']; $agent['counters']['warning'] = $agent['state_warning']; $agent['counters']['not_init'] = $agent['state_notinit']; $agent['counters']['ok'] = $agent['state_normal']; $agent['counters']['total'] = $agent['state_total']; $agent['critical_count'] = $agent['counters']['critical']; $agent['warning_count'] = $agent['counters']['warning']; $agent['unknown_count'] = $agent['counters']['unknown']; $agent['notinit_count'] = $agent['counters']['not_init']; $agent['normal_count'] = $agent['counters']['ok']; $agent['total_count'] = $agent['counters']['total']; } if (!$this->getEmptyModuleFilterStatus()) { $agent['counters']['unknown'] = 0; $agent['counters']['critical'] = 0; $agent['counters']['warning'] = 0; $agent['counters']['not_init'] = 0; $agent['counters']['ok'] = 0; $agent['counters']['total'] = 0; switch($this->filter['statusModule']) { case AGENT_MODULE_STATUS_CRITICAL_ALERT: case AGENT_MODULE_STATUS_CRITICAL_BAD: $agent['counters']['critical'] = $agent['critical_count']; $agent['counters']['total'] = $agent['critical_count']; break; case AGENT_MODULE_STATUS_WARNING_ALERT: case AGENT_MODULE_STATUS_WARNING: $agent['counters']['warning'] = $agent['warning_count']; $agent['counters']['total'] = $agent['warning_count']; break; case AGENT_MODULE_STATUS_UNKNOWN: $agent['counters']['unknown'] = $agent['unknown_count']; $agent['counters']['total'] = $agent['unknown_count']; break; case AGENT_MODULE_STATUS_NO_DATA: case AGENT_MODULE_STATUS_NOT_INIT: $agent['counters']['not_init'] = $agent['notinit_count']; $agent['counters']['total'] = $agent['notinit_count']; break; case AGENT_MODULE_STATUS_NORMAL_ALERT: case AGENT_MODULE_STATUS_NORMAL: $agent['counters']['ok'] = $agent['normal_count']; $agent['counters']['total'] = $agent['normal_count']; break; } } if (!$this->filter['show_not_init_modules']) { $agent['counters']['total'] -= $agent['counters']['not_init']; $agent['counters']['not_init'] = 0; } // Quiet image if (isset($agent['quiet']) && $agent['quiet']) $agent['quietImageHTML'] = html_print_image("/images/dot_blue.png", true, array("title" => __('Quiet'))); // Children if (empty($agent['children'])) { $agent['children'] = array(); if ($agent['counters']['total'] > 0) { switch ($this->childrenMethod) { case 'on_demand': $agent['searchChildren'] = 1; break; case 'live': $agent['searchChildren'] = 0; break; } } else { switch ($this->childrenMethod) { case 'on_demand': $agent['searchChildren'] = 0; break; case 'live': $agent['searchChildren'] = 0; break; } } } } protected function processAgents (&$agents, $server = false) { if (!empty($agents)) { foreach ($agents as $iterator => $agent) { $this->processAgent($agents[$iterator], $server); } } } protected function getData() { } protected function getFirstLevel() { $sql = $this->getFirstLevelSql(); $items = db_get_all_rows_sql($sql); if ($items === false) $items = array(); $this->tree = $this->getProcessedItemsFirstLevel($items); } protected function getProcessedItemsFirstLevel($items){ $processed_items = array(); foreach ($items as $key => $item) { $processed_item = $this->getProcessedItem($item); $processed_items[] = $processed_item; } return $processed_items; } protected function getFirstLevelSql() { $fields = $this->getFirstLevelFields(); $field_name_sql = $this->L1fieldNameSql; $inside_fields = $this->getFirstLevelFieldsInside(); $inner = $this->L1inner; $inner_inside = $this->L1innerInside; $order_by_final = $this->L1orderByFinal; $group_inner = $this->getGroupSearchInner(); $group_acl = $this->getGroupAclCondition(); $group_search_filter = $this->getGroupSearchFilter(); $agent_search_filter = $this->getAgentSearchFilter(); $agent_status_filter = $this->getAgentStatusFilter(); $module_search_filter = $this->getModuleSearchFilter(); $module_status_inner = ""; $module_status_filter = $this->getModuleStatusFilterFromTestado(); if (!empty($module_status_filter)) { $module_status_inner = " INNER JOIN tagente_estado tae ON tae.id_agente_modulo = tam.id_agente_modulo"; } $sql_model = "SELECT %s FROM ( SELECT COUNT(DISTINCT(ta.id_agente)) AS total, $field_name_sql AS g FROM tagente ta LEFT JOIN tagent_secondary_group tasg ON ta.id_agente = tasg.id_agent INNER JOIN tagente_modulo tam ON ta.id_agente = tam.id_agente $inner_inside $module_status_inner $group_inner WHERE ta.disabled = 0 AND tam.disabled = 0 %s $agent_search_filter $agent_status_filter $module_search_filter $module_status_filter $group_search_filter $group_acl GROUP BY $field_name_sql ) x GROUP BY g"; $sql_array = array(); foreach ($inside_fields as $inside_field) { $sql_array[] = sprintf( $sql_model, $inside_field['header'], $inside_field['condition'] ); } $sql = "SELECT $fields FROM (" . implode(" UNION ALL ", $sql_array) . ") x2 $inner GROUP BY g ORDER BY $order_by_final"; return $sql; } protected function getSecondLevel() { $sql = $this->getSecondLevelSql(); $data = db_process_sql($sql); if (empty($data)) { $this->tree = array(); return; } $this->processAgents($data); $this->tree = $data; } protected function getSecondLevelSql() { $columns = sprintf("ta.id_agente AS id, ta.nombre AS name, ta.alias, ta.fired_count, ta.normal_count, ta.warning_count, ta.critical_count, ta.unknown_count, ta.notinit_count, ta.total_count, ta.quiet, SUM(if(%s, 1, 0)) as state_critical, SUM(if(%s, 1, 0)) as state_warning, SUM(if(%s, 1, 0)) as state_unknown, SUM(if(%s, 1, 0)) as state_notinit, SUM(if(%s, 1, 0)) as state_normal, SUM(if(%s AND tae.estado IS NOT NULL, 1, 0)) as state_total ", $this->getModuleStatusFilterFromTestado(AGENT_MODULE_STATUS_CRITICAL_ALERT, true), $this->getModuleStatusFilterFromTestado(AGENT_MODULE_STATUS_WARNING_ALERT, true), $this->getModuleStatusFilterFromTestado(AGENT_MODULE_STATUS_UNKNOWN, true), $this->getModuleStatusFilterFromTestado(AGENT_MODULE_STATUS_NO_DATA, true), $this->getModuleStatusFilterFromTestado(AGENT_MODULE_STATUS_NORMAL, true), $this->getModuleStatusFilterFromTestado(self::TV_DEFAULT_AGENT_STATUS, true) ); $inner_or_left = $this->getInnerOrLeftJoin(); $group_inner = $this->getGroupSearchInner(); $group_acl = $this->getGroupAclCondition(); $group_search_filter = $this->getGroupSearchFilter(); $agent_search_filter = $this->getAgentSearchFilter(); $agent_status_filter = $this->getAgentStatusFilter(); $module_search_filter = $this->getModuleSearchFilter(); $module_status_filter = $this->getModuleStatusFilter(); $condition = $this->L2condition; $condition_inside = $this->L2conditionInside; $inner = $this->L2inner; $sql = "SELECT $columns FROM tagente ta $inner_or_left JOIN tagente_modulo tam ON ta.id_agente = tam.id_agente AND tam.disabled = 0 $inner_or_left JOIN tagente_estado tae ON tae.id_agente_modulo = tam.id_agente_modulo $inner WHERE ta.id_agente IN ( SELECT ta.id_agente FROM tagente ta LEFT JOIN tagent_secondary_group tasg ON tasg.id_agent = ta.id_agente $group_inner WHERE ta.disabled = 0 $group_acl $group_search_filter $condition_inside ) AND ta.disabled = 0 $condition $agent_search_filter $agent_status_filter $module_search_filter $module_status_filter GROUP BY ta.id_agente ORDER BY ta.alias ASC, ta.id_agente ASC "; return $sql; } protected function getThirdLevel() { $sql = $this->getThirdLevelSql(); $data = db_process_sql($sql); if (empty($data)) { $this->tree = array(); return; } $data = $this->getProcessedModules($data); $this->processModules($data); $this->tree = $data; } protected function getThirdLevelSql() { // Get the server id $serverID = $this->serverID; $group_acl = $this->getGroupAclCondition(); $agent_search_filter = $this->getAgentSearchFilter(); $agent_status_filter = $this->getAgentStatusFilter(); $module_search_filter = $this->getModuleSearchFilter(); $module_status_filter = $this->getModuleStatusFilterFromTestado(); $agent_filter = "AND ta.id_agente = " . $this->id; $tag_join = $this->getTagJoin(); $condition = $this->L2condition; $inner = $this->L2inner; $columns = 'DISTINCT(tam.id_agente_modulo) AS id, tam.nombre AS name, tam.id_tipo_modulo, tam.id_modulo, tae.estado, tae.datos, tam.parent_module_id AS parent, tatm.id AS alerts'; // has any of this tags. $tag_join = ''; $sql = "SELECT $columns FROM tagente_modulo tam $tag_join INNER JOIN tagente_estado tae ON tam.id_agente_modulo = tae.id_agente_modulo INNER JOIN tagente ta ON tam.id_agente = ta.id_agente LEFT JOIN tagent_secondary_group tasg ON ta.id_agente = tasg.id_agent LEFT JOIN talert_template_modules tatm ON tatm.id_agent_module = tam.id_agente_modulo $inner WHERE tam.disabled = 0 AND ta.disabled = 0 $condition $agent_filter $group_acl $agent_search_filter $agent_status_filter $module_status_filter $module_search_filter ORDER BY tam.nombre ASC, tam.id_agente_modulo ASC"; return $sql; } public function getJSON() { $this->getData(); return json_encode($this->tree); } public function getArray() { $this->getData(); return $this->tree; } static function name2symbol($name) { return str_replace( array(' ','#','/','.','(',')','¿','?','¡','!'), array( '_articapandora_'.ord(' ').'_pandoraartica_', '_articapandora_'.ord('#').'_pandoraartica_', '_articapandora_'.ord('/').'_pandoraartica_', '_articapandora_'.ord('.').'_pandoraartica_', '_articapandora_'.ord('(').'_pandoraartica_', '_articapandora_'.ord(')').'_pandoraartica_', '_articapandora_'.ord('¿').'_pandoraartica_', '_articapandora_'.ord('?').'_pandoraartica_', '_articapandora_'.ord('¡').'_pandoraartica_', '_articapandora_'.ord('!').'_pandoraartica_' ), io_safe_output($name) ); } static function symbol2name($name) { $symbols = ' !"#$%&\'()*+,./:;<=>?@[\\]^{|}~'; for ($i = 0; $i < strlen($symbols); $i++) { $name = str_replace('_articapandora_' . ord(substr($symbols, $i, 1)) .'_pandoraartica_', substr($symbols, $i, 1), $name); } return io_safe_input($name); } protected function getProcessedModules($modules_tree) { return $modules_tree; } } ?>