Files
thetool/lib/Zabbix/Zabbix.php
2025-09-01 10:26:01 +00:00

345 lines
11 KiB
PHP

<?php
class Zabbix
{
private $url;
private $apiKey;
public function __construct($url, $apiKey)
{
$this->url = $url;
$this->apiKey = $apiKey;
}
public function zabbixRequest($method, $params, $die = false)
{
$data = array(
'jsonrpc' => '2.0',
'method' => $method,
'params' => $params,
'id' => 1
);
$options = array(
'http' => array(
'header' => "Content-Type: application/json\r\n" .
"Authorization: Bearer " . $this->apiKey . "\r\n",
'method' => 'POST',
'content' => json_encode($data),
'timeout' => 30
)
);
if ($die) {
var_dump($options);
echo json_encode($data);
die();
}
$context = stream_context_create($options);
$result = file_get_contents($this->url, false, $context);
return json_decode($result, true);
}
public function getHostById($hostId)
{
$response = $this->zabbixRequest('host.get', array(
'hostids' => $hostId
));
return $response['result'];
}
public function getItemValues($itemIds, $limit = 15)
{
if (empty($itemIds)) return [];
$response = $this->zabbixRequest('history.get', array(
'itemids' => $itemIds,
'output' => 'extend',
'sortfield' => 'clock',
'sortorder' => 'DESC',
'limit' => $limit
));
return $response['result'];
}
public function getHosts($hostname = null, $ip = null)
{
if ($hostname) {
$response = $this->zabbixRequest('host.get', array(
'search' => array('name' => array($hostname))
));
return $response['result'];
} elseif ($ip) {
$response = $this->zabbixRequest('host.get', array(
'search' => array('host' => array($ip))
));
return $response['result'];
}
return [];
}
public function getHostInterfaceItems($hostId)
{
$response = $this->zabbixRequest('item.get', array(
'hostids' => $hostId,
'output' => ['itemid', 'name', 'key_', 'units'],
'search' => ['name' => ["Bits received", "Bits sent"]],
'searchByAny' => true,
'sortfield' => 'name'
));
return $response['result'];
}
public function getICMPItems($hostId)
{
$response = $this->zabbixRequest('item.get', array(
'hostids' => $hostId,
'search' => array('name' => array("ICMP"))
));
return $response['result'];
}
public function getUptimeItems($hostId)
{
$response = $this->zabbixRequest('item.get', array(
'hostids' => $hostId,
'search' => array('name' => array("Uptime"))
));
return $response['result'];
}
public function getHostInterfaces($hostIds)
{
$response = $this->zabbixRequest('hostinterface.get', array('hostids' => $hostIds, 'output' => 'extend'));
return $response['result'];
}
public function createTask($itemid)
{
$response = $this->zabbixRequest('task.create', array(
'type' => 6,
'request' => array('itemid' => $itemid)
));
return $response['result'];
}
public function getAllHostsWithDetails()
{
$response = $this->zabbixRequest('host.get', [
'output' => ['hostid', 'host', 'name', 'status'],
'selectInventory' => ['location_lat', 'location_lon'],
'selectParentTemplates' => ['templateid', 'name'],
'selectHostGroups' => 'extend'
]);
return $response['result'] ?? [];
}
public function updateHostInventory($hostId, $inventoryData)
{
$hostResponse = $this->zabbixRequest('host.get', [
'hostids' => $hostId,
'selectInventory' => 'extend'
]);
$currentInventory = $hostResponse['result'][0]['inventory'] ?? [];
$newInventory = array_merge($currentInventory, $inventoryData);
$params = [
'hostid' => $hostId,
'inventory_mode' => 0, // Set to manual mode
'inventory' => $newInventory
];
$response = $this->zabbixRequest('host.update', $params);
return $response['result'] ?? ['error' => $response['error'] ?? 'Unknown error'];
}
public function getTemplateIdByName($templateName)
{
$response = $this->zabbixRequest('template.get', [
'output' => ['templateid'],
'filter' => ['host' => [$templateName]]
]);
return $response['result'][0]['templateid'] ?? null;
}
public function getTemplatesByNames(array $templateNames)
{
$response = $this->zabbixRequest('template.get', [
'output' => ['templateid', 'name'],
'filter' => ['host' => $templateNames]
]);
return $response['result'] ?? [];
}
public function createHost($visibleName, $ip, $groupId, $templateIds)
{
$templatesData = array_map(function ($id) {
return ['templateid' => $id];
}, $templateIds);
$params = [
'host' => $ip,
'name' => $visibleName,
'interfaces' => [
[
'type' => 2, // 2 for SNMP
'main' => 1,
'useip' => 1,
'ip' => $ip,
'dns' => '',
'port' => '161',
'details' => [
'version' => 2,
'community' => 'public_xinon'
]
]
],
'groups' => [['groupid' => $groupId]],
'templates' => $templatesData
];
$response = $this->zabbixRequest('host.create', $params);
return $response['result'] ?? ['error' => $response['error'] ?? 'Unknown error'];
}
public function getHostGroupIdByName($groupName)
{
$response = $this->zabbixRequest('hostgroup.get', [
'output' => ['groupid'],
'filter' => ['name' => [$groupName]]
]);
return $response['result'][0]['groupid'] ?? null;
}
public function getHostWithInterfaces($hostId)
{
$response = $this->zabbixRequest('host.get', [
'hostids' => $hostId,
'output' => ['hostid', 'host', 'name'],
'selectInterfaces' => 'extend'
]);
return $response['result'][0] ?? null;
}
public function getResolvedProblems($hostId, $time_from)
{
$response = $this->zabbixRequest('event.get', [
'hostids' => $hostId,
'output' => 'extend',
'select_acknowledges' => ['message'],
'sortfield' => ['clock'],
'sortorder' => 'DESC',
'time_from' => $time_from,
'object' => 0,
'value' => 0
]);
return $response['result'] ?? [];
}
public function updateHostInterface($interfaceId, $details)
{
$params = ['interfaceid' => $interfaceId, 'details' => $details];
$response = $this->zabbixRequest('hostinterface.update', $params);
return $response['result'] ?? ['error' => $response['error'] ?? 'Unknown error'];
}
public function getInterfaceOperationalStatusItems($hostId)
{
$response = $this->zabbixRequest('item.get', [
'hostids' => $hostId,
'output' => ['itemid', 'name', 'key_'],
'search' => ['key_' => 'net.if.status'],
'sortfield' => 'name'
]);
return $response['result'] ?? [];
}
public function getTriggersForHostByDescription($hostId, $description)
{
$response = $this->zabbixRequest('trigger.get', [
'hostids' => $hostId,
'output' => ['triggerid', 'description'],
'search' => ['description' => $description],
'searchByAny' => true
]);
return $response['result'] ?? [];
}
public function createInterfaceLinkDownTrigger($expression, $description, $priority = 4)
{
$params = [
'description' => $description,
'expression' => $expression,
'priority' => $priority,
];
$response = $this->zabbixRequest('trigger.create', $params);
return $response['result'] ?? ['error' => $response['error'] ?? 'Unknown error'];
}
public function deleteTriggers(array $triggerIds)
{
if (empty($triggerIds)) return [];
$response = $this->zabbixRequest('trigger.delete', $triggerIds);
return $response['result'] ?? ['error' => $response['error'] ?? 'Unknown error'];
}
public function getTrends(array $itemIds, $time_from)
{
if (empty($itemIds)) return [];
$response = $this->zabbixRequest('trend.get', [
'itemids' => $itemIds,
'output' => ['itemid', 'num', 'value_min', 'value_avg', 'value_max'],
'time_from' => $time_from
]);
return $response['result'] ?? [];
}
public function getOverviewData($hostId)
{
$items = $this->zabbixRequest('item.get', [
'hostids' => $hostId,
'output' => ['itemid', 'name', 'units', 'key_'],
'search' => ['key_' => ['icmpping', 'system.uptime']],
'searchByAny' => true
])['result'] ?? [];
$itemIds = [];
$itemMap = [];
$data = ['ping' => [], 'uptime' => []];
foreach ($items as $item) {
$itemIds[] = $item['itemid'];
$type = str_contains($item['key_'], 'uptime') ? 'uptime' : 'ping';
$itemMap[$item['itemid']] = ['type' => $type, 'name' => $item['name'], 'units' => $item['units']];
}
if (!empty($itemIds)) {
$history = $this->getItemValues($itemIds, 1);
foreach ($history as $h) {
if (!isset($itemMap[$h['itemid']])) continue;
$info = $itemMap[$h['itemid']];
$data[$info['type']][] = ['name' => $info['name'], 'value' => $h['value'], 'clock' => $h['clock'], 'units' => $info['units']];
}
}
$time30d = time() - 2592000;
$problems = $this->zabbixRequest('problem.get', [
'hostids' => $hostId,
'time_from' => $time30d,
'output' => ['clock']
])['result'] ?? [];
$time7d = time() - 604800;
$time24h = time() - 86400;
$counts = ['24h' => 0, '7d' => 0, '30d' => 0];
foreach ($problems as $p) {
$counts['30d']++;
if ($p['clock'] >= $time7d) $counts['7d']++;
if ($p['clock'] >= $time24h) $counts['24h']++;
}
$data['problemCounts'] = $counts;
return $data;
}
}