tyler.durden
/
pandorafms
mirror of https://github.com/pandorafms/pandorafms.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add links counters cfv 

Former-commit-id: 5a1bdfc376db32f94d06330c2e498c473361e710
This commit is contained in:
Daniel Barbero 2019-04-26 14:25:51 +02:00
parent 6de9b4f23e
commit e54112641d
2 changed files with 284 additions and 107 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

286
pandora_console/include/ajax/custom_fields.php
View File

@ -1,17 +1,33 @@
<?php <?php
/**
* Extension to manage a list of gateways and the node address where they should
* point to.
*
* @category Custom fields View
* @package Pandora FMS
* @subpackage Community
* @version 1.0.0
* @license See below
*
* ______ ___ _______ _______ ________
* | __ \.-----.--.--.--| |.-----.----.-----. | ___| | | __|
* | __/| _ | | _ || _ | _| _ | | ___| |__ |
* |___| |___._|__|__|_____||_____|__| |___._| |___| |__|_|__|_______|
*
* ============================================================================
* Copyright (c) 2005-2019 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 General Public License
* as published by the Free Software Foundation for 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.
* ============================================================================
*/
if (check_login()) { if (check_login()) {
// Pandora FMS- http://pandorafms.com
// ==================================================
// Copyright (c) 2005-2010 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.
global $config; global $config;
include_once $config['homedir'].'/include/functions_agents.php'; include_once $config['homedir'].'/include/functions_agents.php';
@ -21,9 +37,18 @@ if (check_login()) {
enterprise_include_once('include/functions_metaconsole.php'); enterprise_include_once('include/functions_metaconsole.php');
$get_custom_fields_data = (bool) get_parameter('get_custom_fields_data', 0); $get_custom_fields_data = (bool) get_parameter('get_custom_fields_data', 0);
$build_table_custom_fields = (bool) get_parameter('build_table_custom_fields', 0); $build_table_custom_fields = (bool) get_parameter(
$build_table_child_custom_fields = (bool) get_parameter('build_table_child_custom_fields', 0); 'build_table_custom_fields',
$build_table_save_filter = (bool) get_parameter('build_table_save_filter', 0); 0
);
$build_table_child_custom_fields = (bool) get_parameter(
'build_table_child_custom_fields',
0
);
$build_table_save_filter = (bool) get_parameter(
'build_table_save_filter',
0
);
$append_tab_filter = (bool) get_parameter('append_tab_filter', 0); $append_tab_filter = (bool) get_parameter('append_tab_filter', 0);
$create_filter_cf = (bool) get_parameter('create_filter_cf', 0); $create_filter_cf = (bool) get_parameter('create_filter_cf', 0);
$update_filter_cf = (bool) get_parameter('update_filter_cf', 0); $update_filter_cf = (bool) get_parameter('update_filter_cf', 0);
@ -43,9 +68,16 @@ if (check_login()) {
$start = get_parameter('start', 0); $start = get_parameter('start', 0);
$draw = get_parameter('draw', 0); $draw = get_parameter('draw', 0);
$search = get_parameter('search', ''); $search = get_parameter('search', '');
$indexed_descriptions = json_decode(io_safe_output(get_parameter('indexed_descriptions', '')), true); $indexed_descriptions = json_decode(
io_safe_output(
get_parameter('indexed_descriptions', '')
),
true
);
$module_status = get_parameter('module_status');
$id_status = get_parameter('id_status');
// order query // Order query.
$order_column = $order[0]['column']; $order_column = $order[0]['column'];
$type_order = $order[0]['dir']; $type_order = $order[0]['dir'];
switch ($order_column) { switch ($order_column) {
@ -66,27 +98,34 @@ if (check_login()) {
break; break;
} }
// table temporary for save array in table by order and search custom_field data // Table temporary for save array in table
// by order and search custom_field data.
$table_temporary = 'CREATE TEMPORARY TABLE temp_custom_fields ( $table_temporary = 'CREATE TEMPORARY TABLE temp_custom_fields (
id_server int(10), id_server int(10),
id_agent int(10), id_agent int(10),
name_custom_fields varchar(2048), name_custom_fields varchar(2048),
critical_count int,
warning_count int,
unknown_count int,
notinit_count int,
normal_count int,
total_count int,
`status` int(2), `status` int(2),
KEY `data_index_temp_1` (`id_server`, `id_agent`) KEY `data_index_temp_1` (`id_server`, `id_agent`)
)'; )';
db_process_sql($table_temporary); db_process_sql($table_temporary);
// insert values array in table temporary // Insert values array in table temporary.
$values_insert = []; $values_insert = [];
foreach ($indexed_descriptions as $key => $value) { foreach ($indexed_descriptions as $key => $value) {
$values_insert[] = '('.$value['id_server'].', '.$value['id_agente'].", '".$value['description']."', ".$value['status'].')'; $values_insert[] = '('.$value['id_server'].', '.$value['id_agente'].", '".$value['description']."', '".$value['critical_count']."', '".$value['warning_count']."', '".$value['unknown_count']."', '".$value['notinit_count']."', '".$value['normal_count']."', '".$value['total_count']."', ".$value['status'].')';
} }
$values_insert_implode = implode(',', $values_insert); $values_insert_implode = implode(',', $values_insert);
$query_insert = 'INSERT INTO temp_custom_fields VALUES '.$values_insert_implode; $query_insert = 'INSERT INTO temp_custom_fields VALUES '.$values_insert_implode;
db_process_sql($query_insert); db_process_sql($query_insert);
// search table for alias, custom field data, server_name, direction // Search table for alias, custom field data, server_name, direction.
$search_query = ''; $search_query = '';
if ($search['value'] != '') { if ($search['value'] != '') {
$search_query = ' AND (tma.alias LIKE "%'.$search['value'].'%"'; $search_query = ' AND (tma.alias LIKE "%'.$search['value'].'%"';
@ -95,7 +134,61 @@ if (check_login()) {
$search_query .= ' OR temp.name_custom_fields LIKE "%'.$search['value'].'%" ) '; $search_query .= ' OR temp.name_custom_fields LIKE "%'.$search['value'].'%" ) ';
} }
// query all fields result // Search for status module.
$status_agent_search = '';
if (isset($id_status) === true && is_array($id_status) === true) {
if (in_array(-1, $id_status) === false) {
if (in_array(AGENT_MODULE_STATUS_NOT_NORMAL, $id_status) === false) {
$status_agent_search = ' AND temp.status IN ('.implode(',', $id_status).')';
} else {
// Not normal statuses.
$status_agent_search = ' AND temp.status IN (1,2,3,4,5)';
}
}
}
// Search for status module.
$status_module_search = '';
if (isset($module_status) === true && is_array($module_status) === true) {
if (in_array(-1, $module_status) === false) {
if (in_array(AGENT_MODULE_STATUS_NOT_NORMAL, $module_status) === false) {
if (count($module_status) > 0) {
$status_module_search = ' AND ( ';
foreach ($module_status as $key => $value) {
$status_module_search .= ($key != 0) ? ' OR (' : ' (';
switch ($value) {
default:
case AGENT_STATUS_NORMAL:
$status_module_search .= ' temp.critical_count = 0 AND temp.warning_count = 0 AND temp.unknown_count = 0 AND temp.notinit_count <> temp.total_count ) ';
break;
case AGENT_STATUS_CRITICAL:
$status_module_search .= ' temp.critical_count > 0) ';
break;
case AGENT_STATUS_WARNING:
$status_module_search .= ' temp.critical_count = 0 AND temp.warning_count > 0) ';
break;
case AGENT_STATUS_UNKNOWN:
$status_module_search .= ' temp.critical_count = 0 AND temp.warning_count = 0 AND temp.unknown_count > 0) ';
break;
case AGENT_STATUS_NOT_INIT:
$status_module_search .= ' temp.total_count = temp.notinit_count) ';
break;
}
}
$status_module_search .= ' ) ';
}
} else {
// Not normal.
$status_module_search = ' AND NOT ( temp.critical_count = 0 AND temp.warning_count = 0 AND temp.unknown_count = 0 AND temp.notinit_count <> temp.total_count)';
}
}
}
// Query all fields result.
$query = sprintf( $query = sprintf(
'SELECT 'SELECT
tma.id_agente, tma.id_agente,
@ -112,10 +205,14 @@ if (check_login()) {
AND temp.id_server = tma.id_tmetaconsole_setup AND temp.id_server = tma.id_tmetaconsole_setup
WHERE tma.disabled = 0 WHERE tma.disabled = 0
%s %s
%s
%s
%s %s
LIMIT %d OFFSET %d LIMIT %d OFFSET %d
', ',
$search_query, $search_query,
$status_agent_search,
$status_module_search,
$order_by, $order_by,
$length, $length,
$start $start
@ -123,23 +220,27 @@ if (check_login()) {
$result = db_get_all_rows_sql($query); $result = db_get_all_rows_sql($query);
// query count // Query count.
$query_count = sprintf( $query_count = sprintf(
'SELECT 'SELECT
COUNT(tma.id_agente) AS `count` COUNT(tma.id_agente) AS `count`
FROM tmetaconsole_agent tma FROM tmetaconsole_agent tma
INNER JOIN temp_custom_fields temp INNER JOIN temp_custom_fields temp
ON temp.id_agent = tma.id_tagente ON temp.id_agent = tma.id_tagente
AND temp.id_server = tma.id_tmetaconsole_setup AND temp.id_server = tma.id_tmetaconsole_setup
WHERE tma.disabled = 0 WHERE tma.disabled = 0
%s %s
', %s
$search_query %s
',
$search_query,
$status_agent_search,
$status_module_search
); );
$count = db_get_sql($query_count); $count = db_get_sql($query_count);
// for link nodes. // For link nodes.
$array_nodes = metaconsole_get_connections(); $array_nodes = metaconsole_get_connections();
if (isset($array_nodes) && is_array($array_nodes)) { if (isset($array_nodes) && is_array($array_nodes)) {
$hash_array_nodes = []; $hash_array_nodes = [];
@ -158,20 +259,20 @@ if (check_login()) {
$user_rot13 = str_rot13($config['id_user']); $user_rot13 = str_rot13($config['id_user']);
$hashdata = $user.$pwd; $hashdata = $user.$pwd;
$hashdata = md5($hashdata); $hashdata = md5($hashdata);
$url_hash = '&amp;'.'loginhash=auto&amp;'.'loginhash_data='.$hashdata.'&amp;'.'loginhash_user='.$user_rot13; $url_hash = '&amp;loginhash=auto&amp;loginhash_data='.$hashdata.'&amp;loginhash_user='.$user_rot13;
$hash_array_nodes[$server['id']]['hashurl'] = $url_hash; $hash_array_nodes[$server['id']]['hashurl'] = $url_hash;
$hash_array_nodes[$server['id']]['server_url'] = $server['server_url']; $hash_array_nodes[$server['id']]['server_url'] = $server['server_url'];
} }
} }
// prepare rows for table dinamic // Prepare rows for table dinamic.
$data = []; $data = [];
foreach ($result as $values) { foreach ($result as $values) {
$image_status = agents_get_image_status($values['status']); $image_status = agents_get_image_status($values['status']);
// link nodes // Link nodes.
$agent_link = '<a href="'.$hash_array_nodes[$values['id_tmetaconsole_setup']]['server_url'].'/'.'index.php?'.'sec=estado&amp;'.'sec2=operation/agentes/ver_agente&amp;'.'id_agente='.$values['id_tagente'].$hash_array_nodes[$values['id_tmetaconsole_setup']]['hashurl'].'">'; $agent_link = '<a href="'.$hash_array_nodes[$values['id_tmetaconsole_setup']]['server_url'].'/index.php?sec=estado&amp;sec2=operation/agentes/ver_agente&amp;id_agente='.$values['id_tagente'].$hash_array_nodes[$values['id_tmetaconsole_setup']]['hashurl'].'">';
$agent_alias = ui_print_truncate_text( $agent_alias = ui_print_truncate_text(
$values['alias'], $values['alias'],
@ -225,7 +326,7 @@ if (check_login()) {
$name_where = " AND tam.nombre LIKE '%".$module_search."%'"; $name_where = " AND tam.nombre LIKE '%".$module_search."%'";
} }
// filter by status module // Filter by status module.
$and_module_status = ''; $and_module_status = '';
if (is_array($module_status)) { if (is_array($module_status)) {
if (!in_array(-1, $module_status)) { if (!in_array(-1, $module_status)) {
@ -260,7 +361,7 @@ if (check_login()) {
$and_module_status .= ' ) '; $and_module_status .= ' ) ';
} }
} else { } else {
// not normal // Not normal.
$and_module_status = 'AND tae.estado <> 0 AND tae.estado <> 300 '; $and_module_status = 'AND tae.estado <> 0 AND tae.estado <> 300 ';
} }
} }
@ -314,7 +415,12 @@ if (check_login()) {
&& $value['id_tipo_modulo'] != 23 && $value['id_tipo_modulo'] != 23
&& $value['id_tipo_modulo'] != 33 && $value['id_tipo_modulo'] != 33
) { ) {
$table_modules->data[$key][1] = remove_right_zeros(number_format($value['datos'], $config['graph_precision'])); $table_modules->data[$key][1] = remove_right_zeros(
number_format(
$value['datos'],
$config['graph_precision']
)
);
} else { } else {
$table_modules->data[$key][1] = $value['datos']; $table_modules->data[$key][1] = $value['datos'];
} }
@ -329,7 +435,10 @@ if (check_login()) {
); );
$table_modules->data[$key][3] = $value['current_interval']; $table_modules->data[$key][3] = $value['current_interval'];
$table_modules->data[$key][4] = ui_print_timestamp($value['utimestamp'], true); $table_modules->data[$key][4] = ui_print_timestamp(
$value['utimestamp'],
true
);
switch ($value['estado']) { switch ($value['estado']) {
case 0: case 0:
case 300: case 300:
@ -398,7 +507,7 @@ if (check_login()) {
} }
} }
// status agents from tagente // Status agents from tagente.
$sql_info_agents = 'SELECT * fROM tagente WHERE id_agente ='.$id_agent; $sql_info_agents = 'SELECT * fROM tagente WHERE id_agente ='.$id_agent;
$info_agents = db_get_row_sql($sql_info_agents); $info_agents = db_get_row_sql($sql_info_agents);
$status_agent = agents_get_status_from_counts($info_agents); $status_agent = agents_get_status_from_counts($info_agents);
@ -463,7 +572,13 @@ if (check_login()) {
false false
); );
$table->data[0][3] = html_print_submit_button(__('Load filter'), 'load_filter', false, 'class="sub upd"', true); $table->data[0][3] = html_print_submit_button(
__('Load filter'),
'load_filter',
false,
'class="sub upd"',
true
);
echo "<form action='' method='post'>"; echo "<form action='' method='post'>";
html_print_table($table); html_print_table($table);
@ -474,7 +589,12 @@ if (check_login()) {
} }
if ($append_tab_filter) { if ($append_tab_filter) {
$filters = json_decode(io_safe_output(get_parameter('filters', '')), true); $filters = json_decode(
io_safe_output(
get_parameter('filters', '')
),
true
);
$table = new StdClass; $table = new StdClass;
$table->id = 'save_filter_form'; $table->id = 'save_filter_form';
@ -485,7 +605,14 @@ if (check_login()) {
if ($filters['id'] == 'extended_create_filter') { if ($filters['id'] == 'extended_create_filter') {
echo "<div id='msg_error_create'></div>"; echo "<div id='msg_error_create'></div>";
$table->data[0][0] = __('Filter name'); $table->data[0][0] = __('Filter name');
$table->data[0][1] = html_print_input_text('id_name', '', '', 15, 255, true); $table->data[0][1] = html_print_input_text(
'id_name',
'',
'',
15,
255,
true
);
$table->data[1][0] = __('Group'); $table->data[1][0] = __('Group');
$table->data[1][1] = html_print_select_groups( $table->data[1][1] = html_print_select_groups(
@ -510,7 +637,13 @@ if (check_login()) {
); );
$table->rowspan[0][2] = 2; $table->rowspan[0][2] = 2;
$table->data[0][2] = html_print_submit_button(__('Create filter'), 'create_filter', false, 'class="sub upd"', true); $table->data[0][2] = html_print_submit_button(
__('Create filter'),
'create_filter',
false,
'class="sub upd"',
true
);
} else { } else {
echo "<div id='msg_error_update'></div>"; echo "<div id='msg_error_update'></div>";
echo "<div id='msg_error_delete'></div>"; echo "<div id='msg_error_delete'></div>";
@ -552,8 +685,20 @@ if (check_login()) {
false false
); );
$table->data[0][2] = html_print_submit_button(__('Delete filter'), 'delete_filter', false, 'class="sub upd"', true); $table->data[0][2] = html_print_submit_button(
$table->data[1][2] = html_print_submit_button(__('Update filter'), 'update_filter', false, 'class="sub upd"', true); __('Delete filter'),
'delete_filter',
false,
'class="sub upd"',
true
);
$table->data[1][2] = html_print_submit_button(
__('Update filter'),
'update_filter',
false,
'class="sub upd"',
true
);
} }
html_print_table($table); html_print_table($table);
@ -561,17 +706,20 @@ if (check_login()) {
} }
if ($create_filter_cf) { if ($create_filter_cf) {
// initialize result // Initialize result.
$result_array = []; $result_array = [];
$result_array['error'] = 0; $result_array['error'] = 0;
$result_array['msg'] = ''; $result_array['msg'] = '';
// initialize vars // Initialize vars.
$filters = json_decode(io_safe_output(get_parameter('filters', '')), true); $filters = json_decode(
io_safe_output(get_parameter('filters', '')),
true
);
$name_filter = get_parameter('name_filter', ''); $name_filter = get_parameter('name_filter', '');
$group_search = get_parameter('group_search', 0); $group_search = get_parameter('group_search', 0);
// check that the name is not empty // Check that the name is not empty.
if ($name_filter == '') { if ($name_filter == '') {
$result_array['error'] = 1; $result_array['error'] = 1;
$result_array['msg'] = ui_print_error_message( $result_array['msg'] = ui_print_error_message(
@ -596,7 +744,7 @@ if (check_login()) {
return; return;
} }
// check custom field is not empty // Check custom field is not empty.
if ($filters['id_custom_fields'] == '') { if ($filters['id_custom_fields'] == '') {
$result_array['error'] = 1; $result_array['error'] = 1;
$result_array['msg'] = ui_print_error_message( $result_array['msg'] = ui_print_error_message(
@ -608,13 +756,15 @@ if (check_login()) {
return; return;
} }
// insert // Insert.
$values = []; $values = [];
$values['name'] = $name_filter; $values['name'] = $name_filter;
$values['group_search'] = $group_search; $values['group_search'] = $group_search;
$values['id_group'] = $filters['group']; $values['id_group'] = $filters['group'];
$values['id_custom_field'] = $filters['id_custom_fields']; $values['id_custom_field'] = $filters['id_custom_fields'];
$values['id_custom_fields_data'] = json_encode($filters['id_custom_fields_data']); $values['id_custom_fields_data'] = json_encode(
$filters['id_custom_fields_data']
);
$values['id_status'] = json_encode($filters['id_status']); $values['id_status'] = json_encode($filters['id_status']);
$values['module_search'] = $filters['module_search']; $values['module_search'] = $filters['module_search'];
$values['module_status'] = json_encode($filters['module_status']); $values['module_status'] = json_encode($filters['module_status']);
@ -622,7 +772,7 @@ if (check_login()) {
$insert = db_process_sql_insert('tagent_custom_fields_filter', $values); $insert = db_process_sql_insert('tagent_custom_fields_filter', $values);
// check error insert // Check error insert.
if ($insert) { if ($insert) {
$result_array['error'] = 0; $result_array['error'] = 0;
$result_array['msg'] = ui_print_success_message( $result_array['msg'] = ui_print_success_message(
@ -644,17 +794,17 @@ if (check_login()) {
} }
if ($update_filter_cf) { if ($update_filter_cf) {
// initialize result // Initialize result.
$result_array = []; $result_array = [];
$result_array['error'] = 0; $result_array['error'] = 0;
$result_array['msg'] = ''; $result_array['msg'] = '';
// initialize vars // Initialize vars.
$filters = json_decode(io_safe_output(get_parameter('filters', '')), true); $filters = json_decode(io_safe_output(get_parameter('filters', '')), true);
$id_filter = get_parameter('id_filter', ''); $id_filter = get_parameter('id_filter', '');
$group_search = get_parameter('group_search', 0); $group_search = get_parameter('group_search', 0);
// check selected filter // Check selected filter.
if ($id_filter == -1) { if ($id_filter == -1) {
$result_array['error'] = 1; $result_array['error'] = 1;
$result_array['msg'] = ui_print_error_message( $result_array['msg'] = ui_print_error_message(
@ -666,11 +816,11 @@ if (check_login()) {
return; return;
} }
// array condition update // Array condition update.
$condition = []; $condition = [];
$condition['id'] = $id_filter; $condition['id'] = $id_filter;
// check selected custom fields // Check selected custom fields.
if ($filters['id_custom_fields'] == '') { if ($filters['id_custom_fields'] == '') {
$result_array['error'] = 1; $result_array['error'] = 1;
$result_array['msg'] = ui_print_error_message( $result_array['msg'] = ui_print_error_message(
@ -682,7 +832,7 @@ if (check_login()) {
return; return;
} }
// array values update // Array values update.
$values = []; $values = [];
$values['id_group'] = $filters['group']; $values['id_group'] = $filters['group'];
$values['group_search'] = $group_search; $values['group_search'] = $group_search;
@ -693,10 +843,10 @@ if (check_login()) {
$values['module_status'] = json_encode($filters['module_status']); $values['module_status'] = json_encode($filters['module_status']);
$values['recursion'] = $filters['recursion']; $values['recursion'] = $filters['recursion'];
// update // Update.
$update = db_process_sql_update('tagent_custom_fields_filter', $values, $condition); $update = db_process_sql_update('tagent_custom_fields_filter', $values, $condition);
// check error insert // Check error insert.
if ($update) { if ($update) {
$result_array['error'] = 0; $result_array['error'] = 0;
$result_array['msg'] = ui_print_success_message( $result_array['msg'] = ui_print_success_message(
@ -718,16 +868,16 @@ if (check_login()) {
} }
if ($delete_filter_cf) { if ($delete_filter_cf) {
// Initialize result // Initialize result.
$result_array = []; $result_array = [];
$result_array['error'] = 0; $result_array['error'] = 0;
$result_array['msg'] = ''; $result_array['msg'] = '';
// Initialize vars // Initialize vars.
$filters = json_decode(io_safe_output(get_parameter('filters', '')), true); $filters = json_decode(io_safe_output(get_parameter('filters', '')), true);
$id_filter = get_parameter('id_filter', ''); $id_filter = get_parameter('id_filter', '');
// Check selected filter // Check selected filter.
if ($id_filter == -1) { if ($id_filter == -1) {
$result_array['error'] = 1; $result_array['error'] = 1;
$result_array['msg'] = ui_print_error_message( $result_array['msg'] = ui_print_error_message(
@ -739,14 +889,14 @@ if (check_login()) {
return; return;
} }
// Array condition update // Array condition update.
$condition = []; $condition = [];
$condition['id'] = $id_filter; $condition['id'] = $id_filter;
// Delete // Delete.
$delete = db_process_sql_delete('tagent_custom_fields_filter', $condition); $delete = db_process_sql_delete('tagent_custom_fields_filter', $condition);
// Check error insert // Check error insert.
if ($delete) { if ($delete) {
$result_array['error'] = 0; $result_array['error'] = 0;
$result_array['msg'] = ui_print_success_message( $result_array['msg'] = ui_print_success_message(

105
pandora_console/include/functions_custom_fields.php
View File

@ -1,16 +1,31 @@
<?php <?php
/**
// Pandora FMS - http://pandorafms.com * Extension to manage a list of gateways and the node address where they should
// ================================================== * point to.
// Copyright (c) 2005-2010 Artica Soluciones Tecnologicas *
// Please see http://pandorafms.org for full contribution list * @category Custom fields View
// This program is free software; you can redistribute it and/or * @package Pandora FMS
// modify it under the terms of the GNU Lesser General Public License * @subpackage Community
// as published by the Free Software Foundation; version 2 * @version 1.0.0
// This program is distributed in the hope that it will be useful, * @license See below
// 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. * | __ \.-----.--.--.--| |.-----.----.-----. | ___| | | __|
* | __/| _ | | _ || _ | _| _ | | ___| |__ |
* |___| |___._|__|__|_____||_____|__| |___._| |___| |__|_|__|_______|
*
* ============================================================================
* Copyright (c) 2005-2019 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 General Public License
* as published by the Free Software Foundation for 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.
* ============================================================================
*/
/** /**
@ -56,14 +71,14 @@ function get_custom_fields($custom_field_id=false, $select=true, $display_on_fro
} }
} else { } else {
$metaconsole_connections = metaconsole_get_connection_names(); $metaconsole_connections = metaconsole_get_connection_names();
// For all nodes // For all nodes.
if (isset($metaconsole_connections) && is_array($metaconsole_connections)) { if (isset($metaconsole_connections) && is_array($metaconsole_connections)) {
$result_meta = []; $result_meta = [];
foreach ($metaconsole_connections as $metaconsole) { foreach ($metaconsole_connections as $metaconsole) {
// Get server connection data // Get server connection data.
$server_data = metaconsole_get_connection($metaconsole); $server_data = metaconsole_get_connection($metaconsole);
// Establishes connection // Establishes connection.
if (metaconsole_load_external_db($server_data) !== NOERR) { if (metaconsole_load_external_db($server_data) !== NOERR) {
continue; continue;
} }
@ -82,7 +97,7 @@ function get_custom_fields($custom_field_id=false, $select=true, $display_on_fro
$result[] = db_get_all_rows_sql($sql); $result[] = db_get_all_rows_sql($sql);
// Restore connection to root node // Restore connection to root node.
metaconsole_restore_db(); metaconsole_restore_db();
if (isset($result) && is_array($result)) { if (isset($result) && is_array($result)) {
@ -109,7 +124,7 @@ function get_custom_fields($custom_field_id=false, $select=true, $display_on_fro
/** /**
* Returns custom field data. * Returns custom field data.
* *
* @param integer custom_field_id id. * @param integer $custom_field_name Custom_field_id id.
* *
* @return array custom fields data. * @return array custom fields data.
*/ */
@ -141,14 +156,14 @@ function get_custom_fields_data($custom_field_name)
} }
} else { } else {
$metaconsole_connections = metaconsole_get_connection_names(); $metaconsole_connections = metaconsole_get_connection_names();
// For all nodes // For all nodes.
if (isset($metaconsole_connections) && is_array($metaconsole_connections)) { if (isset($metaconsole_connections) && is_array($metaconsole_connections)) {
$result_meta = []; $result_meta = [];
foreach ($metaconsole_connections as $metaconsole) { foreach ($metaconsole_connections as $metaconsole) {
// Get server connection data // Get server connection data.
$server_data = metaconsole_get_connection($metaconsole); $server_data = metaconsole_get_connection($metaconsole);
// Establishes connection // Establishes connection.
if (metaconsole_load_external_db($server_data) !== NOERR) { if (metaconsole_load_external_db($server_data) !== NOERR) {
continue; continue;
} }
@ -168,7 +183,7 @@ function get_custom_fields_data($custom_field_name)
$result_meta[] = db_get_all_rows_sql($sql); $result_meta[] = db_get_all_rows_sql($sql);
// Restore connection to root node // Restore connection to root node.
metaconsole_restore_db(); metaconsole_restore_db();
} }
@ -189,9 +204,15 @@ function get_custom_fields_data($custom_field_name)
} }
/**
* Function for custom field view return all conter for agents
*
* @param array $filters Params for search.
* @return void False or array.
*/
function agent_counters_custom_fields($filters) function agent_counters_custom_fields($filters)
{ {
// filter by status agent // Filter by status agent.
$and_status = ''; $and_status = '';
$agent_state_normal = 0; $agent_state_normal = 0;
@ -262,7 +283,7 @@ function agent_counters_custom_fields($filters)
} }
} }
// filter by status module // Filter by status module.
$empty_agents_count = "UNION ALL $empty_agents_count = "UNION ALL
SELECT ta.id_agente, SELECT ta.id_agente,
0 AS c_m_total, 0 AS c_m_total,
@ -314,20 +335,20 @@ function agent_counters_custom_fields($filters)
$and_module_status .= ' ) '; $and_module_status .= ' ) ';
} }
} else { } else {
// not normal // Not normal.
$and_module_status = 'AND tae.estado <> 0 AND tae.estado <> 300 '; $and_module_status = 'AND tae.estado <> 0 AND tae.estado <> 300 ';
$empty_agents_count = ''; $empty_agents_count = '';
} }
} }
} }
// filters module // Filters module.
if ($filters['module_search']) { if ($filters['module_search']) {
$and_module_search = 'AND tam.nombre LIKE "%'.$filters['module_search'].'%"'; $and_module_search = 'AND tam.nombre LIKE "%'.$filters['module_search'].'%"';
$empty_agents_count = ''; $empty_agents_count = '';
} }
// filter group and check ACL groups // Filter group and check ACL groups.
$groups_and = ''; $groups_and = '';
if (!users_can_manage_group_all('AR')) { if (!users_can_manage_group_all('AR')) {
if ($filters['group']) { if ($filters['group']) {
@ -338,7 +359,7 @@ function agent_counters_custom_fields($filters)
} }
if ($filters['group']) { if ($filters['group']) {
// recursion check acl // Recursion check acl.
if ($filters['recursion']) { if ($filters['recursion']) {
$recursion_groups = groups_get_id_recursive($filters['group'], true); $recursion_groups = groups_get_id_recursive($filters['group'], true);
if (!users_can_manage_group_all('AR')) { if (!users_can_manage_group_all('AR')) {
@ -362,26 +383,26 @@ function agent_counters_custom_fields($filters)
} }
} }
// filter custom data // Filter custom data.
$custom_data_and = ''; $custom_data_and = '';
if (!in_array(-1, $filters['id_custom_fields_data'])) { if (!in_array(-1, $filters['id_custom_fields_data'])) {
$custom_data_array = implode("', '", $filters['id_custom_fields_data']); $custom_data_array = implode("', '", $filters['id_custom_fields_data']);
$custom_data_and = "AND tcd.description IN ('".$custom_data_array."')"; $custom_data_and = "AND tcd.description IN ('".$custom_data_array."')";
} }
// filter custom name // Filter custom name.
$custom_field_name = $filters['id_custom_fields']; $custom_field_name = $filters['id_custom_fields'];
if (is_metaconsole()) { if (is_metaconsole()) {
$metaconsole_connections = metaconsole_get_connection_names(); $metaconsole_connections = metaconsole_get_connection_names();
// For all nodes // For all nodes.
if (isset($metaconsole_connections) && is_array($metaconsole_connections)) { if (isset($metaconsole_connections) && is_array($metaconsole_connections)) {
$result_meta = []; $result_meta = [];
$data = []; $data = [];
foreach ($metaconsole_connections as $metaconsole) { foreach ($metaconsole_connections as $metaconsole) {
// Get server connection data // Get server connection data.
$server_data = metaconsole_get_connection($metaconsole); $server_data = metaconsole_get_connection($metaconsole);
// Establishes connection // Establishes connection.
if (metaconsole_load_external_db($server_data) !== NOERR) { if (metaconsole_load_external_db($server_data) !== NOERR) {
continue; continue;
} }
@ -470,7 +491,13 @@ function agent_counters_custom_fields($filters)
WHEN ta.total_count = ta.notinit_count WHEN ta.total_count = ta.notinit_count
THEN 5 THEN 5
ELSE 0 ELSE 0
END) AS `status` END) AS `status`,
ta.critical_count,
ta.warning_count,
ta.unknown_count,
ta.notinit_count,
ta.normal_count,
ta.total_count
FROM tagente ta FROM tagente ta
LEFT JOIN tagent_secondary_group tasg LEFT JOIN tagent_secondary_group tasg
ON ta.id_agente = tasg.id_agent ON ta.id_agente = tasg.id_agent
@ -510,7 +537,7 @@ function agent_counters_custom_fields($filters)
} }
$data = array_merge($data, $node_result); $data = array_merge($data, $node_result);
// Restore connection to root node // Restore connection to root node.
metaconsole_restore_db(); metaconsole_restore_db();
} }
} }
@ -519,7 +546,7 @@ function agent_counters_custom_fields($filters)
$array_data = []; $array_data = [];
if (isset($result_meta) && is_array($result_meta)) { if (isset($result_meta) && is_array($result_meta)) {
// initialize counters // Initialize counters.
$final_result['counters_total'] = [ $final_result['counters_total'] = [
't_m_normal' => 0, 't_m_normal' => 0,
't_m_critical' => 0, 't_m_critical' => 0,
@ -538,7 +565,7 @@ function agent_counters_custom_fields($filters)
foreach ($result_meta as $k => $nodo) { foreach ($result_meta as $k => $nodo) {
if (isset($nodo) && is_array($nodo)) { if (isset($nodo) && is_array($nodo)) {
foreach ($nodo as $key => $value) { foreach ($nodo as $key => $value) {
// Sum counters total // Sum counters total.
$final_result['counters_total']['t_m_normal'] += $value['m_normal']; $final_result['counters_total']['t_m_normal'] += $value['m_normal'];
$final_result['counters_total']['t_m_critical'] += $value['m_critical']; $final_result['counters_total']['t_m_critical'] += $value['m_critical'];
$final_result['counters_total']['t_m_warning'] += $value['m_warning']; $final_result['counters_total']['t_m_warning'] += $value['m_warning'];
@ -553,7 +580,7 @@ function agent_counters_custom_fields($filters)
$final_result['counters_total']['t_a_not_init'] += $value['a_not_init']; $final_result['counters_total']['t_a_not_init'] += $value['a_not_init'];
$final_result['counters_total']['t_a_agents'] += $value['a_agents']; $final_result['counters_total']['t_a_agents'] += $value['a_agents'];
// Sum counters for data // Sum counters for data.
$array_data[$value['name_data']]['m_normal'] += $value['m_normal']; $array_data[$value['name_data']]['m_normal'] += $value['m_normal'];
$array_data[$value['name_data']]['m_critical'] += $value['m_critical']; $array_data[$value['name_data']]['m_critical'] += $value['m_critical'];
$array_data[$value['name_data']]['m_warning'] += $value['m_warning']; $array_data[$value['name_data']]['m_warning'] += $value['m_warning'];
@ -576,7 +603,7 @@ function agent_counters_custom_fields($filters)
$final_result['indexed_descriptions'] = $data; $final_result['indexed_descriptions'] = $data;
} else { } else {
// TODO // TODO.
$final_result = false; $final_result = false;
} }
@ -586,7 +613,7 @@ function agent_counters_custom_fields($filters)
function get_filters_custom_fields_view($id=0, $for_select=false, $name='') function get_filters_custom_fields_view($id=0, $for_select=false, $name='')
{ {
// filter group and check ACL groups // Filter group and check ACL groups.
$groups_and = ''; $groups_and = '';
if (!users_can_manage_group_all()) { if (!users_can_manage_group_all()) {
$user_groups = array_keys(users_get_groups(false, 'AR', false)); $user_groups = array_keys(users_get_groups(false, 'AR', false));