|
|
|
@ -4,223 +4,57 @@ require_once __DIR__ . '/../src/storage/Database.php';
|
|
|
|
require_once __DIR__ . '/../src/storage/ServiceRepository.php';
|
|
|
|
require_once __DIR__ . '/../src/storage/ServiceRepository.php';
|
|
|
|
require_once __DIR__ . '/../src/storage/SystemSettingsRepository.php';
|
|
|
|
require_once __DIR__ . '/../src/storage/SystemSettingsRepository.php';
|
|
|
|
|
|
|
|
|
|
|
|
//错误提示
|
|
|
|
|
|
|
|
error_reporting(E_ALL);
|
|
|
|
|
|
|
|
ini_set('display_errors', 1);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
session_start();
|
|
|
|
session_start();
|
|
|
|
|
|
|
|
|
|
|
|
// 登录验证
|
|
|
|
// 身份验证
|
|
|
|
if (!isset($_SESSION['user_id'])) {
|
|
|
|
if (!isset($_SESSION['user_id'])) {
|
|
|
|
header('Location: index.php');
|
|
|
|
header('Location: index.php');
|
|
|
|
exit;
|
|
|
|
exit;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 检查管理员权限
|
|
|
|
|
|
|
|
if (!$_SESSION['is_admin']) {
|
|
|
|
|
|
|
|
die('权限不足：只有管理员可以访问此页面');
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
$serviceRepo = new ServiceRepository();
|
|
|
|
$serviceRepo = new ServiceRepository();
|
|
|
|
$settingsRepo = new SystemSettingsRepository();
|
|
|
|
$settingsRepo = new SystemSettingsRepository();
|
|
|
|
$message = '';
|
|
|
|
$message = '';
|
|
|
|
$error = '';
|
|
|
|
$error = '';
|
|
|
|
|
|
|
|
|
|
|
|
// 获取端口设置（放在函数定义之前）
|
|
|
|
|
|
|
|
$smtpPort = $settingsRepo->get('smtp_port', 25);
|
|
|
|
|
|
|
|
$pop3Port = $settingsRepo->get('pop3_port', 110);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function startService($serviceName, $port) {
|
|
|
|
|
|
|
|
$scriptPath = __DIR__ . "/../scripts/start_{$serviceName}.php";
|
|
|
|
|
|
|
|
$logFile = __DIR__ . "/../logs/{$serviceName}.log";
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
error_log("尝试启动服务: $serviceName , 端口: $port");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!file_exists($scriptPath)) {
|
|
|
|
|
|
|
|
return ['success' => false, 'message' => '启动脚本不存在'];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (isServiceRunning($serviceName, $port)) {
|
|
|
|
|
|
|
|
return ['success' => false, 'message' => '服务已在运行'];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@file_put_contents($logFile, '');
|
|
|
|
|
|
|
|
//===== 修复：更稳健的命令执行 =====
|
|
|
|
|
|
|
|
$raw = shell_exec(sprintf(
|
|
|
|
|
|
|
|
'cd %s && (%s > %s 2>/dev/null </dev/null & echo $!)',
|
|
|
|
|
|
|
|
escapeshellarg(dirname($scriptPath, 2)),
|
|
|
|
|
|
|
|
'nohup php ' . escapeshellarg($scriptPath),
|
|
|
|
|
|
|
|
escapeshellarg($logFile)
|
|
|
|
|
|
|
|
));
|
|
|
|
|
|
|
|
/*$raw = shell_exec(sprintf(
|
|
|
|
|
|
|
|
'cd %s && (%s > /dev/null 2>&1 </dev/null & echo $!)',
|
|
|
|
|
|
|
|
escapeshellarg(dirname($scriptPath, 2)),
|
|
|
|
|
|
|
|
'nohup php ' . escapeshellarg($scriptPath),
|
|
|
|
|
|
|
|
escapeshellarg($logFile) // 这一行现在仅用于占位，实际不再写
|
|
|
|
|
|
|
|
));*/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 修复trim(null)问题
|
|
|
|
|
|
|
|
$raw = (string)$raw; // 强制转换为字符串
|
|
|
|
|
|
|
|
$pid = trim($raw); // 现在可以安全trim
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
error_log("Shell命令执行结果: " . var_export($raw, true));
|
|
|
|
|
|
|
|
error_log("获取的PID: " . $pid); // 修复：这里$pid已定义
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!is_numeric($pid) || $pid < 1) {
|
|
|
|
|
|
|
|
error_log("PID无效: $pid");
|
|
|
|
|
|
|
|
return ['success' => false, 'message' => '未能获取有效进程号'];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* ===== 修复：添加进程状态检查 ===== */
|
|
|
|
|
|
|
|
sleep(1); // 先等待1秒
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 检查进程是否还在运行
|
|
|
|
|
|
|
|
$processExists = file_exists("/proc/$pid");
|
|
|
|
|
|
|
|
error_log("进程是否存在: " . ($processExists ? "是" : "否"));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!$processExists) {
|
|
|
|
|
|
|
|
// 查看脚本为什么退出了
|
|
|
|
|
|
|
|
if (file_exists($logFile)) {
|
|
|
|
|
|
|
|
$logContent = file_get_contents($logFile);
|
|
|
|
|
|
|
|
error_log("脚本输出日志:\n" . $logContent);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return ['success' => false, 'message' => '进程已退出'];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* ===== 修复：更长的等待时间 ===== */
|
|
|
|
|
|
|
|
$maxChecks = 6;
|
|
|
|
|
|
|
|
for ($i = 0; $i < $maxChecks; $i++) {
|
|
|
|
|
|
|
|
sleep(1); // 每次检查等待1秒
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (isServiceRunning($serviceName, $port)) {
|
|
|
|
|
|
|
|
// 再次确认PID仍然有效
|
|
|
|
|
|
|
|
if (file_exists("/proc/$pid")) {
|
|
|
|
|
|
|
|
return ['success' => true, 'pid' => $pid];
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
// 进程已退出
|
|
|
|
|
|
|
|
return ['success' => false, 'message' => '进程已退出'];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
error_log("第 " . ($i+1) . " 次检查：端口未监听");
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 启动失败 → 清理孤儿
|
|
|
|
|
|
|
|
if (file_exists("/proc/$pid")) {
|
|
|
|
|
|
|
|
@exec("kill -9 {$pid} 2>/dev/null");
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 输出失败原因
|
|
|
|
|
|
|
|
if (file_exists($logFile)) {
|
|
|
|
|
|
|
|
// 只读取最后10行，避免读取大文件
|
|
|
|
|
|
|
|
$logContent = shell_exec("tail -10 " . escapeshellarg($logFile));
|
|
|
|
|
|
|
|
error_log("最终日志内容(最后100行):\n" . $logContent);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return ['success' => false, 'message' => '服务端口未监听，启动失败'];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function stopService($serviceName, $pid, $port) {
|
|
|
|
|
|
|
|
// ===== 改：优先用 DB 里的 PID，没有再现场嗅探 =====
|
|
|
|
|
|
|
|
if (empty($pid) || !is_numeric($pid)) {
|
|
|
|
|
|
|
|
$pid = getServicePid($serviceName, $port);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
if ($pid) {
|
|
|
|
|
|
|
|
@exec("kill {$pid} 2>/dev/null");
|
|
|
|
|
|
|
|
sleep(1);
|
|
|
|
|
|
|
|
if (isServiceRunning($serviceName, $port)) {
|
|
|
|
|
|
|
|
@exec("kill -9 {$pid} 2>/dev/null");
|
|
|
|
|
|
|
|
sleep(1);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
return !isServiceRunning($serviceName, $port);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function isServiceRunning($serviceName, $port) {
|
|
|
|
|
|
|
|
// 方法1: 使用单引号确保变量正确展开
|
|
|
|
|
|
|
|
$cmd1 = "netstat -tlnp 2>/dev/null | grep ':" . $port . "' | grep LISTEN";
|
|
|
|
|
|
|
|
$result1 = shell_exec($cmd1);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 方法2: 使用ss命令（更可靠）
|
|
|
|
|
|
|
|
$cmd2 = "ss -tlnp 2>/dev/null | grep ':" . $port . "'";
|
|
|
|
|
|
|
|
$result2 = shell_exec($cmd2);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 方法3: 使用lsof（你已验证有效）
|
|
|
|
|
|
|
|
$cmd3 = "lsof -i :" . $port . " 2>/dev/null";
|
|
|
|
|
|
|
|
$result3 = shell_exec($cmd3);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 方法4: 直接socket连接测试（最可靠）
|
|
|
|
|
|
|
|
$fp = @fsockopen('127.0.0.1', $port, $errno, $errstr, 1);
|
|
|
|
|
|
|
|
if ($fp) {
|
|
|
|
|
|
|
|
fclose($fp);
|
|
|
|
|
|
|
|
return true;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 任意一个方法有结果都算服务在运行
|
|
|
|
|
|
|
|
return !empty(trim($result1 ?? '')) ||
|
|
|
|
|
|
|
|
!empty(trim($result2 ?? '')) ||
|
|
|
|
|
|
|
|
!empty(trim($result3 ?? ''));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function getServicePid($serviceName, $port) {
|
|
|
|
|
|
|
|
return trim(shell_exec("lsof -ti: {$port} 2>/dev/null | head -1"));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
// ===================== 修改部分结束 =====================
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 处理服务起停
|
|
|
|
// 处理服务起停
|
|
|
|
if (isset($_GET['action'])) {
|
|
|
|
if (isset($_GET['action'])) {
|
|
|
|
$serviceName = $_GET['service'] ?? '';
|
|
|
|
$serviceName = $_GET['service'] ?? '';
|
|
|
|
$action = $_GET['action'] ?? '';
|
|
|
|
$action = $_GET['action'] ?? '';
|
|
|
|
|
|
|
|
|
|
|
|
if ($serviceName === 'smtp' || $serviceName === 'pop3') {
|
|
|
|
if ($serviceName === 'smtp' || $serviceName === 'pop3') {
|
|
|
|
$port = $serviceName === 'smtp' ? $smtpPort : $pop3Port;
|
|
|
|
|
|
|
|
if ($action === 'start') {
|
|
|
|
if ($action === 'start') {
|
|
|
|
$result = startService($serviceName, $port);
|
|
|
|
// 启动服务（实际应该通过系统服务管理，这里只是更新状态）
|
|
|
|
if ($result['success']) {
|
|
|
|
$pid = null; // 实际应该获取进程ID
|
|
|
|
$pid = $result['pid'];
|
|
|
|
$serviceRepo->updateStatus($serviceName, true, $pid);
|
|
|
|
$serviceRepo->updateStatus($serviceName, true, $pid);
|
|
|
|
$message = strtoupper($serviceName) . "服务已启动";
|
|
|
|
$message = strtoupper($serviceName) . "服务已启动 (PID: {$pid})";
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
$error = strtoupper($serviceName) . "服务启动失败: " . $result['message'];
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
} elseif ($action === 'stop') {
|
|
|
|
} elseif ($action === 'stop') {
|
|
|
|
|
|
|
|
// 停止服务
|
|
|
|
$status = $serviceRepo->getStatus($serviceName);
|
|
|
|
$status = $serviceRepo->getStatus($serviceName);
|
|
|
|
$pid = $status['pid'] ?? getServicePid($serviceName, $port);
|
|
|
|
if ($status && $status['pid']) {
|
|
|
|
|
|
|
|
// 尝试终止进程
|
|
|
|
if (stopService($serviceName, $pid, $port)) {
|
|
|
|
@exec("kill {$status['pid']} 2>/dev/null");
|
|
|
|
$serviceRepo->updateStatus($serviceName, false, null);
|
|
|
|
|
|
|
|
$message = strtoupper($serviceName) . "服务已停止";
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
$error = strtoupper($serviceName) . "服务停止失败";
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// ===================== 修改部分结束 =====================
|
|
|
|
$serviceRepo->updateStatus($serviceName, false, null);
|
|
|
|
|
|
|
|
$message = strtoupper($serviceName) . "服务已停止";
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 获取服务状态（修改判断逻辑）
|
|
|
|
// 获取服务状态
|
|
|
|
// ===================== 修改部分开始 =====================
|
|
|
|
|
|
|
|
$smtpStatus = $serviceRepo->getStatus('smtp');
|
|
|
|
$smtpStatus = $serviceRepo->getStatus('smtp');
|
|
|
|
$pop3Status = $serviceRepo->getStatus('pop3');
|
|
|
|
$pop3Status = $serviceRepo->getStatus('pop3');
|
|
|
|
|
|
|
|
$smtpRunning = $serviceRepo->isRunning('smtp');
|
|
|
|
|
|
|
|
$pop3Running = $serviceRepo->isRunning('pop3');
|
|
|
|
|
|
|
|
|
|
|
|
// 实际检查服务是否运行（使用配置的端口）
|
|
|
|
// 获取端口设置
|
|
|
|
$smtpRunning = isServiceRunning('smtp', $smtpPort);
|
|
|
|
$smtpPort = $settingsRepo->get('smtp_port', 25);
|
|
|
|
$pop3Running = isServiceRunning('pop3', $pop3Port);
|
|
|
|
$pop3Port = $settingsRepo->get('pop3_port', 110);
|
|
|
|
|
|
|
|
|
|
|
|
// 如果数据库状态与实际状态不一致，更新数据库
|
|
|
|
|
|
|
|
if ($smtpStatus['is_running'] != $smtpRunning) {
|
|
|
|
|
|
|
|
$pid = $smtpRunning ? getServicePid('smtp', $smtpPort) : null;
|
|
|
|
|
|
|
|
$serviceRepo->updateStatus('smtp', $smtpRunning, $pid);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if ($pop3Status['is_running'] != $pop3Running) {
|
|
|
|
|
|
|
|
$pid = $pop3Running ? getServicePid('pop3', $pop3Port) : null;
|
|
|
|
|
|
|
|
$serviceRepo->updateStatus('pop3', $pop3Running, $pid);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 重新获取更新后的状态
|
|
|
|
|
|
|
|
$smtpStatus = $serviceRepo->getStatus('smtp');
|
|
|
|
|
|
|
|
$pop3Status = $serviceRepo->getStatus('pop3');
|
|
|
|
|
|
|
|
$smtpRunning = $smtpStatus['is_running'];
|
|
|
|
|
|
|
|
$pop3Running = $pop3Status['is_running'];
|
|
|
|
|
|
|
|
// ===================== 修改部分结束 =====================
|
|
|
|
|
|
|
|
?>
|
|
|
|
?>
|
|
|
|
<!DOCTYPE html>
|
|
|
|
<!DOCTYPE html>
|
|
|
|
<html>
|
|
|
|
<html>
|
|
|
|
@ -258,12 +92,12 @@ $pop3Running = $pop3Status['is_running'];
|
|
|
|
<div class="menu">
|
|
|
|
<div class="menu">
|
|
|
|
<a href="index.php">仪表盘</a>
|
|
|
|
<a href="index.php">仪表盘</a>
|
|
|
|
<a href="users.php">用户管理</a>
|
|
|
|
<a href="users.php">用户管理</a>
|
|
|
|
|
|
|
|
<a href="emails.php">邮件管理</a>
|
|
|
|
<a href="broadcast.php">群发邮件</a>
|
|
|
|
<a href="broadcast.php">群发邮件</a>
|
|
|
|
<a href="filters.php">过滤规则</a>
|
|
|
|
<a href="filters.php">过滤规则</a>
|
|
|
|
<a href="logs.php">系统日志</a>
|
|
|
|
<a href="logs.php">系统日志</a>
|
|
|
|
<a href="services.php">服务管理</a>
|
|
|
|
<a href="services.php">服务管理</a>
|
|
|
|
<a href="settings.php">系统设置</a>
|
|
|
|
<a href="settings.php">系统设置</a>
|
|
|
|
<a href="help.php">帮助</a>
|
|
|
|
|
|
|
|
</div>
|
|
|
|
</div>
|
|
|
|
|
|
|
|
|
|
|
|
<div class="container">
|
|
|
|
<div class="container">
|
|
|
|
@ -320,42 +154,13 @@ $pop3Running = $pop3Status['is_running'];
|
|
|
|
</div>
|
|
|
|
</div>
|
|
|
|
|
|
|
|
|
|
|
|
<div class="note">
|
|
|
|
<div class="note">
|
|
|
|
<strong>注意：</strong>
|
|
|
|
<strong>注意：</strong>此页面仅用于管理服务状态。实际启动服务需要使用命令行：
|
|
|
|
<ul>
|
|
|
|
<ul>
|
|
|
|
<li>如果服务启动失败，请检查是否没有该端口访问权限或端口被占用</li>
|
|
|
|
<li>SMTP服务：<code>sudo php scripts/start_smtp.php</code></li>
|
|
|
|
<li>当前配置：SMTP端口 <?php echo $smtpPort; ?>, POP3端口 <?php echo $pop3Port; ?></li>
|
|
|
|
<li>POP3服务：<code>sudo php scripts/start_pop3.php</code></li>
|
|
|
|
</ul>
|
|
|
|
</ul>
|
|
|
|
</div>
|
|
|
|
</div>
|
|
|
|
</div>
|
|
|
|
</div>
|
|
|
|
|
|
|
|
|
|
|
|
<!-- ===================== 新增部分：自动刷新状态 =====================
|
|
|
|
|
|
|
|
<script>
|
|
|
|
|
|
|
|
// 每5秒自动检查服务状态
|
|
|
|
|
|
|
|
setInterval(function() {
|
|
|
|
|
|
|
|
fetch(window.location.href)
|
|
|
|
|
|
|
|
.then(response => response.text())
|
|
|
|
|
|
|
|
.then(html => {
|
|
|
|
|
|
|
|
// 从返回的HTML中提取运行状态
|
|
|
|
|
|
|
|
const tempDiv = document.createElement('div');
|
|
|
|
|
|
|
|
tempDiv.innerHTML = html;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 检查SMTP状态是否变化
|
|
|
|
|
|
|
|
const smtpStatusText = tempDiv.querySelector('.service-box:nth-child(1) .status')?.textContent;
|
|
|
|
|
|
|
|
const currentSmtpStatus = document.querySelector('.service-box:nth-child(1) .status')?.textContent;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 检查POP3状态是否变化
|
|
|
|
|
|
|
|
const pop3StatusText = tempDiv.querySelector('.service-box:nth-child(2) .status')?.textContent;
|
|
|
|
|
|
|
|
const currentPop3Status = document.querySelector('.service-box:nth-child(2) .status')?.textContent;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 如果有变化，刷新页面
|
|
|
|
|
|
|
|
if (smtpStatusText !== currentSmtpStatus || pop3StatusText !== currentPop3Status) {
|
|
|
|
|
|
|
|
console.log('服务状态变化，刷新页面...');
|
|
|
|
|
|
|
|
location.reload();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
})
|
|
|
|
|
|
|
|
.catch(error => console.error('状态检查失败:', error));
|
|
|
|
|
|
|
|
}, 30000);
|
|
|
|
|
|
|
|
</script>**-->
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
</body>
|
|
|
|
</body>
|
|
|
|
</html>
|
|
|
|
</html>
|
|
|
|
|
|
|
|
|
|
|
|
|
hnu202326010419