pandorafms/pandora_console/include/class/Tree.class.php

<?php
//Pandora FMS- http://pandorafms.com
// ==================================================
// Copyright (c) 2005-2011 Artica Soluciones Tecnologicas
// Please see http://pandorafms.org for full contribution list

// This program is free software; you can redistribute it and/or
// modify it under the terms of the  GNU Lesser General Public License
// as published by the Free Software Foundation; version 2

// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

class Tree {
	protected $type = null;
	protected $rootType = null;
	protected $id = -1;
	protected $rootID = -1;
	protected $serverID = false;
	protected $tree = array();
	protected $filter = array();
	protected $childrenMethod = "on_demand";

	protected $userGroupsACL;
	protected $userGroups;
	protected $userGroupsArray;

	protected $acltags = false;
	protected $access = false;

	protected $L1fieldName = '';
	protected $L1fieldNameSql = '';
	protected $L1extraFields = array();
	protected $L1inner = '';
	protected $L1innerInside = '';
	protected $L1orderByFinal = '';

	protected $L2condition = '';
	protected $L2conditionInside = '';
	protected $L2inner = '';

	const TV_DEFAULT_AGENT_STATUS = -1;

	public function __construct($type, $rootType = '', $id = -1, $rootID = -1, $serverID = false, $childrenMethod = "on_demand", $access = 'AR') {

		$this->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 ";
	}

	protected 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'] . "%'";
	}

	protected function getAgentCounterColumnsSql ($agent_table) {
		// Add the agent counters to the columns

		if ($this->filter['statusAgent'] == -1) {
			// Critical
			$agent_critical_filter = $this->getAgentStatusFilter(AGENT_STATUS_CRITICAL);
			$agents_critical_count = "($agent_table
										$agent_critical_filter) AS total_critical_count";
			// Warning
			$agent_warning_filter = $this->getAgentStatusFilter(AGENT_STATUS_WARNING);
			$agents_warning_count = "($agent_table
										$agent_warning_filter) AS total_warning_count";
			// Unknown
			$agent_unknown_filter = $this->getAgentStatusFilter(AGENT_STATUS_UNKNOWN);
			$agents_unknown_count = "($agent_table
										$agent_unknown_filter) AS total_unknown_count";
			// Normal
			$agent_normal_filter = $this->getAgentStatusFilter(AGENT_STATUS_NORMAL);
			$agents_normal_count = "($agent_table
										$agent_normal_filter) AS total_normal_count";
			// Not init
			if($this->filter['show_not_init_agents']){
				$agent_not_init_filter = $this->getAgentStatusFilter(AGENT_STATUS_NOT_INIT);
				$agents_not_init_count = "($agent_table
											$agent_not_init_filter) AS total_not_init_count";
			}
			else{
				$agent_not_init_filter = 0;
				$agents_not_init_count = 0;
			}

			// Alerts fired
			$agents_fired_count = "($agent_table
										AND ta.fired_count > 0) AS total_fired_count";
			// Total
			$agents_total_count = "($agent_table) AS total_count";

			$columns = "$agents_critical_count, $agents_warning_count, "
				. "$agents_unknown_count, $agents_normal_count, $agents_not_init_count, "
				. "$agents_fired_count, $agents_total_count";
		}
		else {
			// Alerts fired
			$agents_fired_count = "($agent_table
										AND ta.fired_count > 0) AS total_fired_count";
			// Total
			$agents_total_count = "($agent_table) AS total_count";

			switch ($this->filter['statusAgent']) {
				case AGENT_STATUS_NOT_INIT:
					// Not init
					$agent_not_init_filter = $this->getAgentStatusFilter(AGENT_STATUS_NOT_INIT);
					$agents_not_init_count = "($agent_table
												$agent_not_init_filter) AS total_not_init_count";
					$columns = "$agents_not_init_count, $agents_fired_count, $agents_total_count";
					break;
				case AGENT_STATUS_CRITICAL:
					// Critical
					$agent_critical_filter = $this->getAgentStatusFilter(AGENT_STATUS_CRITICAL);
					$agents_critical_count = "($agent_table
												$agent_critical_filter) AS total_critical_count";
					$columns = "$agents_critical_count, $agents_fired_count, $agents_total_count";
					break;
				case AGENT_STATUS_WARNING:
					// Warning
					$agent_warning_filter = $this->getAgentStatusFilter(AGENT_STATUS_WARNING);
					$agents_warning_count = "($agent_table
												$agent_warning_filter) AS total_warning_count";
					$columns = "$agents_warning_count, $agents_fired_count, $agents_total_count";
					break;
				case AGENT_STATUS_UNKNOWN:
					// Unknown
					$agent_unknown_filter = $this->getAgentStatusFilter(AGENT_STATUS_UNKNOWN);
					$agents_unknown_count = "($agent_table
												$agent_unknown_filter) AS total_unknown_count";
					$columns = "$agents_unknown_count, $agents_fired_count, $agents_total_count";
					break;
				case AGENT_STATUS_NORMAL:
					// Normal
					$agent_normal_filter = $this->getAgentStatusFilter(AGENT_STATUS_NORMAL);
					$agents_normal_count = "($agent_table
												$agent_normal_filter) AS total_normal_count";
					$columns = "$agents_normal_count, $agents_fired_count, $agents_total_count";
					break;
			}
		}

		return $columns;
	}

	protected function getAgentCountersSql ($agent_table) {
		global $config;

		$columns = $this->getAgentCounterColumnsSql($agent_table);
		$columns = "SELECT $columns FROM dual LIMIT 1";

		return $columns;
	}

	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, 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
			INNER 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 AND tam.disabled = 0
				$condition
				$agent_search_filter
				$agent_status_filter
				$module_search_filter
				$module_status_filter
			GROUP BY ta.id_agente
			HAVING state_total > 0
			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;
	}

}
?>