summaryrefslogtreecommitdiffstats
path: root/frontends/php/include/events.inc.php
diff options
context:
space:
mode:
Diffstat (limited to 'frontends/php/include/events.inc.php')
-rw-r--r--frontends/php/include/events.inc.php235
1 files changed, 173 insertions, 62 deletions
diff --git a/frontends/php/include/events.inc.php b/frontends/php/include/events.inc.php
index bbfc2bc1..211c44d8 100644
--- a/frontends/php/include/events.inc.php
+++ b/frontends/php/include/events.inc.php
@@ -27,68 +27,6 @@
}
}
- function get_history_of_discovery_events($start,$num){
- $db_events = DBselect('select distinct e.source,e.object,e.objectid,e.clock,e.value from events e'.
- ' where e.source='.EVENT_SOURCE_DISCOVERY.' order by e.clock desc',
- 10*($start+$num)
- );
-
- $table = new CTableInfo(S_NO_EVENTS_FOUND);
- $table->SetHeader(array(S_TIME, S_IP, S_DESCRIPTION, S_STATUS));
- $col=0;
-
- $skip = $start;
- while(($event_data = DBfetch($db_events))&&($col<$num))
- {
- if($skip > 0)
- {
- $skip--;
- continue;
- }
-
- if($event_data["value"] == 0)
- {
- $value=new CCol(S_UP,"off");
- }
- elseif($event_data["value"] == 1)
- {
- $value=new CCol(S_DOWN,"on");
- }
- else
- {
- $value=new CCol(S_UNKNOWN_BIG,"unknown");
- }
-
-
- switch($event_data['object'])
- {
- case EVENT_OBJECT_DHOST:
- $object_data = DBfetch(DBselect('select ip from dhosts where dhostid='.$event_data['objectid']));
- $description = SPACE;
- break;
- case EVENT_OBJECT_DSERVICE:
- $object_data = DBfetch(DBselect('select h.ip,s.type,s.port from dhosts h,dservices s '.
- ' where h.dhostid=s.dhostid and s.dserviceid='.$event_data['objectid']));
- $description = S_SERVICE.': '.discovery_check_type2str($object_data['type']).'; '.
- S_PORT.': '.$object_data['port'];
- break;
- default:
- continue;
- }
-
- if(!$object_data) continue;
-
-
- $table->AddRow(array(
- date("Y.M.d H:i:s",$event_data["clock"]),
- $object_data['ip'],
- $description,
- $value));
-
- $col++;
- }
- return $table;
- }
/* function:
* event_initial_time
@@ -176,6 +114,14 @@ function first_initial_eventid($row,$show_unknown=0){
return false;
}
+/* function:
+ * get_latest_events
+ *
+ * description:
+ * return latest events by VALUE
+ *
+ * author: Aly
+ */
function get_latest_events($row,$show_unknown=0){
$eventz = array();
@@ -226,6 +172,14 @@ function get_latest_events($row,$show_unknown=0){
return $events;
}
+/* function:
+ * get_next_event
+ *
+ * description:
+ * return next event by value
+ *
+ * author: Aly
+ */
function get_next_event($row,$show_unknown=0){
$sql_cond=($show_unknown == 0)?' AND e.value<>'.TRIGGER_VALUE_UNKNOWN:'';
@@ -251,4 +205,161 @@ function get_next_event($row,$show_unknown=0){
$rez = DBfetch(DBselect($sql,1));
return $rez;
}
+
+
+function get_history_of_discovery_events($start,$num){
+ $db_events = DBselect('select distinct e.source,e.object,e.objectid,e.clock,e.value from events e'.
+ ' where e.source='.EVENT_SOURCE_DISCOVERY.' order by e.clock desc',
+ 10*($start+$num)
+ );
+
+ $table = new CTableInfo(S_NO_EVENTS_FOUND);
+ $table->SetHeader(array(S_TIME, S_IP, S_DESCRIPTION, S_STATUS));
+ $col=0;
+
+ $skip = $start;
+ while(($event_data = DBfetch($db_events))&&($col<$num)){
+ if($skip > 0){
+ $skip--;
+ continue;
+ }
+
+ if($event_data["value"] == 0){
+ $value=new CCol(S_UP,"off");
+ }
+ elseif($event_data["value"] == 1){
+ $value=new CCol(S_DOWN,"on");
+ }
+ else{
+ $value=new CCol(S_UNKNOWN_BIG,"unknown");
+ }
+
+
+ switch($event_data['object']){
+ case EVENT_OBJECT_DHOST:
+ $object_data = DBfetch(DBselect('select ip from dhosts where dhostid='.$event_data['objectid']));
+ $description = SPACE;
+ break;
+ case EVENT_OBJECT_DSERVICE:
+ $object_data = DBfetch(DBselect('select h.ip,s.type,s.port from dhosts h,dservices s '.
+ ' where h.dhostid=s.dhostid and s.dserviceid='.$event_data['objectid']));
+ $description = S_SERVICE.': '.discovery_check_type2str($object_data['type']).'; '.
+ S_PORT.': '.$object_data['port'];
+ break;
+ default:
+ continue;
+ }
+
+ if(!$object_data) continue;
+
+
+ $table->AddRow(array(
+ date("Y.M.d H:i:s",$event_data["clock"]),
+ $object_data['ip'],
+ $description,
+ $value));
+
+ $col++;
+ }
+return $table;
+}
+
+function make_event_details($triggerid,&$trigger_data){
+ $table = new CTableInfo();
+
+ if(is_show_subnodes()){
+ $table->AddRow(array(S_NODE, get_node_name_by_elid($triggerid)));
+ }
+
+ $table->AddRow(array(S_HOST, $trigger_data['host']));
+ $table->AddRow(array(S_TRIGGER, $trigger_data['exp_desc']));
+ $table->AddRow(array(S_SEVERITY, new CSpan(get_severity_description($trigger_data["priority"]), get_severity_style($trigger_data["priority"]))));
+ $table->AddRow(array(S_EXPRESSION, $trigger_data['exp_expr']));
+
+return $table;
+}
+
+function make_small_eventlist($triggerid,&$trigger_data,$show_unknown=0){
+ $sql_cond = '';
+ if(0 == $show_unknown){
+ $sql_cond = ' AND value<>2 ';
+ }
+
+ $table = new CTableInfo();
+ $table->SetHeader(array(S_TIME,S_STATUS,S_ACK,S_DURATION));
+
+ $sql = 'SELECT * '.
+ ' FROM events '.
+ ' WHERE objectid='.$triggerid.
+ ' AND object='.EVENT_OBJECT_TRIGGER.
+ $sql_cond.
+ ' ORDER BY clock DESC';
+
+ $result = DBselect($sql,10*($_REQUEST['start']+PAGE_SIZE));
+
+ $rows = array();
+ $count = 0;
+
+ $col=0;
+ $skip = $_REQUEST['start'];
+ while(($col<PAGE_SIZE) && ($row=DBfetch($result))){
+ if($skip > 0){
+ if((0 == $show_unknown) && ($row['value'] == TRIGGER_VALUE_UNKNOWN)) continue;
+ $skip--;
+ continue;
+ }
+
+ if(!empty($rows) && ($rows[$count]['value'] != $row['value'])){
+ $count++;
+ }
+ else if(!empty($rows) &&
+ ($rows[$count]['value'] == $row['value']) &&
+ ($trigger_data['type'] == TRIGGER_MULT_EVENT_ENABLED) &&
+ ($row['value'] == TRIGGER_VALUE_TRUE)
+ ){
+ $count++;
+ }
+ $rows[$count] = $row;
+ $col++;
+ }
+
+ $clock=time();
+
+ foreach($rows as $id => $row){
+ $lclock=$clock;
+ $clock=$row["clock"];
+
+ $duration = zbx_date2age($lclock,$clock);
+
+ if($row["value"] == TRIGGER_VALUE_FALSE){
+ $value=new CCol(S_FALSE_BIG,"off");
+ }
+ elseif($row["value"] == TRIGGER_VALUE_TRUE){
+ $value=new CCol(S_TRUE_BIG,"on");
+ }
+ else{
+ $value=new CCol(S_UNKNOWN_BIG,"unknown");
+ }
+
+ $ack = "-";
+ if($row["value"] == 1 && $row["acknowledged"] == 1){
+ $db_acks = get_acknowledges_by_eventid($row["eventid"]);
+ $rows=0;
+ while($a=DBfetch($db_acks)) $rows++;
+
+ $ack=array(
+ new CLink(new CSpan(S_YES,'off'),'acknow.php?eventid='.$row['eventid'],'action'),
+ SPACE.'('.$rows.')'
+ );
+ }
+
+ $table->AddRow(array(
+ date('Y.M.d H:i:s',$row['clock']),
+ $value,
+ $ack,
+ $duration
+ ));
+ }
+return $table;
+}
?>
generated by cgit (git 2.34.1) at 2026-01-08 02:21:59 +0000