1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
<?php
/* Copyright (C) 2017 Icinga Development Team <info@icinga.com> */
namespace Icinga\Module\Toplevelview\Monitoring;
use Icinga\Module\Monitoring\Backend\Ido\Query\ServicestatusQuery as IcingaServicestatusQuery;
/**
* Patched version of ServicestatusQuery
*/
class ServicestatusQuery extends IcingaServicestatusQuery
{
use IgnoredNotificationPeriods;
use Options;
public function __construct($ds, $columns = null, $options = null)
{
$this->setOptions($options);
parent::__construct($ds, $columns);
}
public function init()
{
if (($periods = $this->getOption('ignored_notification_periods')) !== null) {
$this->ignoreNotificationPeriods($periods);
}
$patchedColumnMap = array(
'servicestatus' => array(
'service_handled_wo_host' => 'CASE WHEN ss.problem_has_been_acknowledged > 0 THEN 1 ELSE 0 END',
),
'servicenotificationperiod' => array(
'service_notification_period' => 'ntpo.name1',
'service_in_notification_period' => '
CASE WHEN ntpo.name1 IS NULL
THEN 1
ELSE CASE WHEN ntpr.timeperiod_id IS NOT NULL
THEN 1
ELSE 0
END
END',
),
);
foreach ($patchedColumnMap as $table => $columns) {
foreach ($columns as $k => $v) {
$this->columnMap[$table][$k] = $v;
}
}
parent::init();
}
protected function joinServicenotificationperiod()
{
$extraJoinCond = '';
if ($this->hasIgnoredNotifications()) {
$extraJoinCond .= $this->db->quoteInto(
' AND ntpo.name1 NOT IN (?)',
$this->getIgnoredNotificationPeriods()
);
}
$this->select->joinLeft(
["ntp" => $this->prefix . 'timeperiods'],
'ntp.timeperiod_object_id = s.notification_timeperiod_object_id'
. ' AND ntp.config_type = 1 AND ntp.instance_id = s.instance_id',
[]
);
$this->select->joinLeft(
['ntpo' => $this->prefix . 'objects'],
'ntpo.object_id = s.notification_timeperiod_object_id'
. $extraJoinCond,
[]
);
$this->select->joinLeft(
['ntpr' => $this->prefix . 'timeperiod_timeranges'],
'ntpr.timeperiod_id = ntp.timeperiod_id
AND ntpr.day = DAYOFWEEK(CURRENT_DATE()) - 1
AND ntpr.start_sec < UNIX_TIMESTAMP() - UNIX_TIMESTAMP(CURRENT_DATE())
AND ntpr.end_sec > UNIX_TIMESTAMP() - UNIX_TIMESTAMP(CURRENT_DATE())
',
[]
);
}
}
|
