90 lines
3.2 KiB
PHP
90 lines
3.2 KiB
PHP
<?php
|
|
header("Content-Type: application/json; charset=utf-8");
|
|
header("Access-Control-Allow-Origin: *");
|
|
header("Access-Control-Allow-Methods: GET,POST,OPTIONS");
|
|
header("Access-Control-Allow-Headers: Content-Type");
|
|
if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') {
|
|
exit(json_encode(['code' => 0, 'msg' => 'ok']));
|
|
}
|
|
|
|
// 数据库配置
|
|
$dbHost = '127.0.0.1';
|
|
$dbUser = 'root';
|
|
$dbPwd = 'hp93000';
|
|
$dbName = 'monitor';
|
|
|
|
session_start();
|
|
$expire = 1800;
|
|
if (empty($_SESSION['user_id']) || (time() - $_SESSION['login_time'] > $expire)) {
|
|
echo json_encode(['code' => 401, 'msg' => '登录失效，请重新登录']);
|
|
exit;
|
|
}
|
|
$uid = $_SESSION['user_id'];
|
|
|
|
$conn = mysqli_connect($dbHost, $dbUser, $dbPwd, $dbName);
|
|
if (!$conn) {
|
|
echo json_encode(['code' => 500, 'msg' => '数据库连接失败:' . mysqli_connect_error()]);
|
|
exit;
|
|
}
|
|
mysqli_set_charset($conn, 'utf8mb4');
|
|
|
|
$action = isset($_REQUEST['action']) ? $_REQUEST['action'] : '';
|
|
|
|
// 获取当前用户订阅配置
|
|
if ($action === 'get_subscribe') {
|
|
$sql = "SELECT * FROM alert_subscribe WHERE uid = ? LIMIT 1";
|
|
$stmt = mysqli_prepare($conn, $sql);
|
|
mysqli_stmt_bind_param($stmt, 's', $uid);
|
|
mysqli_stmt_execute($stmt);
|
|
$res = mysqli_stmt_get_result($stmt);
|
|
$data = mysqli_fetch_assoc($res);
|
|
if (empty($data)) {
|
|
$data = [
|
|
'severity' => '',
|
|
'instance' => '',
|
|
'alertname' => '',
|
|
'dingtalk_webhook' => '',
|
|
'wecom_webhook' => '',
|
|
'mail_receiver' => '',
|
|
'enable' => 0
|
|
];
|
|
}
|
|
echo json_encode(['code' => 0, 'msg' => 'ok', 'data' => $data], JSON_UNESCAPED_UNICODE);
|
|
exit;
|
|
}
|
|
|
|
// 保存/更新订阅配置
|
|
if ($action === 'save_subscribe') {
|
|
$post = json_decode(file_get_contents('php://input'), true);
|
|
$severity = $post['severity'] ?? '';
|
|
$instance = $post['instance'] ?? '';
|
|
$alertname = $post['alertname'] ?? '';
|
|
$dingtalk = $post['dingtalk_webhook'] ?? '';
|
|
$wecom = $post['wecom_webhook'] ?? '';
|
|
$mail = $post['mail_receiver'] ?? '';
|
|
$enable = intval($post['enable'] ?? 0);
|
|
|
|
$check = mysqli_query($conn, "SELECT id FROM alert_subscribe WHERE uid = '$uid' LIMIT 1");
|
|
if (mysqli_num_rows($check) > 0) {
|
|
$sql = "UPDATE alert_subscribe SET severity=?,instance=?,alertname=?,dingtalk_webhook=?,wecom_webhook=?,mail_receiver=?,enable=? WHERE uid=?";
|
|
$stmt = mysqli_prepare($conn, $sql);
|
|
mysqli_stmt_bind_param($stmt, 'ssssssis', $severity, $instance, $alertname, $dingtalk, $wecom, $mail, $enable, $uid);
|
|
} else {
|
|
$sql = "INSERT INTO alert_subscribe(uid,severity,instance,alertname,dingtalk_webhook,wecom_webhook,mail_receiver,enable) VALUES (?,?,?,?,?,?,?,?)";
|
|
$stmt = mysqli_prepare($conn, $sql);
|
|
mysqli_stmt_bind_param($stmt, 'ssssssss', $uid, $severity, $instance, $alertname, $dingtalk, $wecom, $mail, $enable);
|
|
}
|
|
$ok = mysqli_stmt_execute($stmt);
|
|
if ($ok) {
|
|
echo json_encode(['code' => 0, 'msg' => '订阅配置保存成功'], JSON_UNESCAPED_UNICODE);
|
|
} else {
|
|
echo json_encode(['code' => 500, 'msg' => '保存失败:' . mysqli_error($conn)], JSON_UNESCAPED_UNICODE);
|
|
}
|
|
exit;
|
|
}
|
|
|
|
echo json_encode(['code' => 400, 'msg' => '无效操作']);
|
|
mysqli_close($conn);
|
|
exit;
|
|
?>
|