Compare commits
9 Commits
| Author | SHA1 | Date |
|---|---|---|
 clumxc
|
7b353acd4b | 4 weeks ago |
|
clumxc
|
9d562f3f73 | 4 weeks ago |
|
clumxc
|
72a25da663 | 4 weeks ago |
|
clumxc
|
9697aa33d0 | 4 weeks ago |
|
clumxc
|
f8f3aad04c | 4 weeks ago |
|
clumxc
|
9c8f5756eb | 4 weeks ago |
|
clumxc
|
cfc574741e | 4 weeks ago |
|
clumxc
|
fdd79fbba8 | 4 weeks ago |
|
clumxc
|
07ade37d01 | 4 weeks ago |
@ -0,0 +1,3 @@
|
|||||||
|
{
|
||||||
|
"remote.autoForwardPortsFallback": 0
|
||||||
|
}
|
||||||
@ -1,21 +1,21 @@
|
|||||||
<?php
|
<?php
|
||||||
/**
|
/**
|
||||||
* 数据库配置文件
|
* 数据库配置文件
|
||||||
* 使用环境变量或默认配置
|
* 使用环境变量或默认配置
|
||||||
*/
|
*/
|
||||||
|
|
||||||
return [
|
return [
|
||||||
'host' => getenv('DB_HOST') ?: '127.0.0.1', // 使用127.0.0.1连接映射端口
|
'host' => getenv('DB_HOST') ?: '127.0.0.1', // 使用127.0.0.1连接映射端口
|
||||||
'port' => getenv('DB_PORT') ?: '3308', // Docker映射端口
|
'port' => getenv('DB_PORT') ?: '3308', // Docker映射端口
|
||||||
'database' => getenv('DB_DATABASE') ?: 'mail_server',
|
'database' => getenv('DB_DATABASE') ?: 'mail_server',
|
||||||
'username' => getenv('DB_USERNAME') ?: 'mail_user',
|
'username' => getenv('DB_USERNAME') ?: 'mail_user',
|
||||||
'password' => getenv('DB_PASSWORD') ?: 'user123',
|
'password' => getenv('DB_PASSWORD') ?: 'user123',
|
||||||
'charset' => 'utf8mb4',
|
'charset' => 'utf8mb4',
|
||||||
'collation' => 'utf8mb4_unicode_ci',
|
'collation' => 'utf8mb4_unicode_ci',
|
||||||
'options' => [
|
'options' => [
|
||||||
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
|
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
|
||||||
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
|
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
|
||||||
PDO::ATTR_EMULATE_PREPARES => false,
|
PDO::ATTR_EMULATE_PREPARES => false,
|
||||||
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8mb4 COLLATE utf8mb4_unicode_ci"
|
PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8mb4 COLLATE utf8mb4_unicode_ci"
|
||||||
]
|
]
|
||||||
];
|
];
|
||||||
|
|||||||
@ -1,44 +1,44 @@
|
|||||||
|
|
||||||
services:
|
services:
|
||||||
mysql:
|
mysql:
|
||||||
image: mysql:8.0
|
image: mysql:8.0
|
||||||
container_name: mail-mysql
|
container_name: mail-mysql
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
environment:
|
environment:
|
||||||
MYSQL_ROOT_PASSWORD: root123
|
MYSQL_ROOT_PASSWORD: root123
|
||||||
MYSQL_DATABASE: mail_server
|
MYSQL_DATABASE: mail_server
|
||||||
MYSQL_USER: mail_user
|
MYSQL_USER: mail_user
|
||||||
MYSQL_PASSWORD: user123
|
MYSQL_PASSWORD: user123
|
||||||
ports:
|
ports:
|
||||||
- "3308:3306"
|
- "3308:3306"
|
||||||
volumes:
|
volumes:
|
||||||
- mysql-data:/var/lib/mysql
|
- mysql-data:/var/lib/mysql
|
||||||
- ./scripts/create_all_tables.sql:/docker-entrypoint-initdb.d/init.sql
|
- ./scripts/create_all_tables.sql:/docker-entrypoint-initdb.d/init.sql
|
||||||
command:
|
command:
|
||||||
--character-set-server=utf8mb4
|
--character-set-server=utf8mb4
|
||||||
--collation-server=utf8mb4_unicode_ci
|
--collation-server=utf8mb4_unicode_ci
|
||||||
--default-authentication-plugin=mysql_native_password
|
--default-authentication-plugin=mysql_native_password
|
||||||
healthcheck:
|
healthcheck:
|
||||||
test: ["CMD", "mysqladmin", "ping", "-h", "localhost", "-u", "root", "-proot123"]
|
test: ["CMD", "mysqladmin", "ping", "-h", "localhost", "-u", "root", "-proot123"]
|
||||||
interval: 5s
|
interval: 5s
|
||||||
timeout: 3s
|
timeout: 3s
|
||||||
retries: 10
|
retries: 10
|
||||||
|
|
||||||
phpmyadmin:
|
phpmyadmin:
|
||||||
image: phpmyadmin/phpmyadmin
|
image: phpmyadmin/phpmyadmin
|
||||||
container_name: mail-phpmyadmin
|
container_name: mail-phpmyadmin
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
environment:
|
environment:
|
||||||
PMA_HOST: mysql
|
PMA_HOST: mysql
|
||||||
PMA_PORT: 3306
|
PMA_PORT: 3306
|
||||||
PMA_USER: root
|
PMA_USER: root
|
||||||
PMA_PASSWORD: root123
|
PMA_PASSWORD: root123
|
||||||
UPLOAD_LIMIT: 64M
|
UPLOAD_LIMIT: 64M
|
||||||
ports:
|
ports:
|
||||||
- "8088:80"
|
- "8088:80"
|
||||||
depends_on:
|
depends_on:
|
||||||
mysql:
|
mysql:
|
||||||
condition: service_healthy
|
condition: service_healthy
|
||||||
|
|
||||||
volumes:
|
volumes:
|
||||||
mysql-data:
|
mysql-data:
|
||||||
@ -0,0 +1,20 @@
|
|||||||
|
启动最简POP3邮件服务器
|
||||||
|
==============================
|
||||||
|
|
||||||
|
POP3服务器启动在 0.0.0.0:1100
|
||||||
|
按 Ctrl+C 停止
|
||||||
|
|
||||||
|
数据库连接成功
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
|
服务器: +OK POP3 Simple Server Ready
|
||||||
@ -0,0 +1,7 @@
|
|||||||
|
启动最简SMTP邮件服务器
|
||||||
|
==============================
|
||||||
|
|
||||||
|
SMTP服务器启动在 0.0.0.0:25
|
||||||
|
按 Ctrl+C 停止
|
||||||
|
|
||||||
|
数据库连接成功
|
||||||
@ -1,193 +1,194 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/../config/database.php';
|
require_once __DIR__ . '/../config/database.php';
|
||||||
require_once __DIR__ . '/../src/storage/Database.php';
|
require_once __DIR__ . '/../src/storage/Database.php';
|
||||||
require_once __DIR__ . '/../src/storage/UserRepository.php';
|
require_once __DIR__ . '/../src/storage/UserRepository.php';
|
||||||
require_once __DIR__ . '/../src/storage/EmailRepository.php';
|
require_once __DIR__ . '/../src/storage/EmailRepository.php';
|
||||||
require_once __DIR__ . '/../src/admin/BroadcastService.php';
|
require_once __DIR__ . '/../src/admin/BroadcastService.php';
|
||||||
require_once __DIR__ . '/../src/utils/Security.php';
|
require_once __DIR__ . '/../src/utils/Security.php';
|
||||||
|
|
||||||
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']) {
|
if (!$_SESSION['is_admin']) {
|
||||||
die('权限不足：只有管理员可以访问此页面');
|
die('权限不足：只有管理员可以访问此页面');
|
||||||
}
|
}
|
||||||
|
|
||||||
$broadcastService = new BroadcastService();
|
$broadcastService = new BroadcastService();
|
||||||
$userRepo = new UserRepository();
|
$userRepo = new UserRepository();
|
||||||
$message = '';
|
$message = '';
|
||||||
$error = '';
|
$error = '';
|
||||||
|
|
||||||
// 处理群发邮件
|
// 处理群发邮件
|
||||||
if (isset($_POST['send_broadcast'])) {
|
if (isset($_POST['send_broadcast'])) {
|
||||||
$subject = trim($_POST['subject'] ?? '');
|
$subject = trim($_POST['subject'] ?? '');
|
||||||
$body = trim($_POST['body'] ?? '');
|
$body = trim($_POST['body'] ?? '');
|
||||||
$broadcastType = $_POST['broadcast_type'] ?? 'all';
|
$broadcastType = $_POST['broadcast_type'] ?? 'all';
|
||||||
$recipients = trim($_POST['recipients'] ?? '');
|
$recipients = trim($_POST['recipients'] ?? '');
|
||||||
|
|
||||||
if (empty($subject)) {
|
if (empty($subject)) {
|
||||||
$error = "主题不能为空";
|
$error = "主题不能为空";
|
||||||
} elseif (empty($body)) {
|
} elseif (empty($body)) {
|
||||||
$error = "邮件内容不能为空";
|
$error = "邮件内容不能为空";
|
||||||
} else {
|
} else {
|
||||||
$senderEmail = $_SESSION['username'];
|
$senderEmail = $_SESSION['username'];
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if ($broadcastType === 'all') {
|
if ($broadcastType === 'all') {
|
||||||
// 群发给所有用户
|
// 群发给所有用户
|
||||||
$result = $broadcastService->broadcastToAll($senderEmail, $subject, $body);
|
$result = $broadcastService->broadcastToAll($senderEmail, $subject, $body);
|
||||||
} else {
|
} else {
|
||||||
// 群发给指定用户
|
// 群发给指定用户
|
||||||
$recipientList = array_filter(array_map('trim', explode(',', $recipients)));
|
$recipientList = array_filter(array_map('trim', explode(',', $recipients)));
|
||||||
if (empty($recipientList)) {
|
if (empty($recipientList)) {
|
||||||
$error = "请指定收件人";
|
$error = "请指定收件人";
|
||||||
} else {
|
} else {
|
||||||
$result = $broadcastService->broadcastToUsers($senderEmail, $recipientList, $subject, $body);
|
$result = $broadcastService->broadcastToUsers($senderEmail, $recipientList, $subject, $body);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isset($result)) {
|
if (isset($result)) {
|
||||||
if ($result['success'] > 0) {
|
if ($result['success'] > 0) {
|
||||||
$message = "群发成功！成功发送 {$result['success']} 封邮件";
|
$message = "群发成功！成功发送 {$result['success']} 封邮件";
|
||||||
if ($result['failed'] > 0) {
|
if ($result['failed'] > 0) {
|
||||||
$message .= "，失败 {$result['failed']} 封";
|
$message .= "，失败 {$result['failed']} 封";
|
||||||
}
|
}
|
||||||
if (!empty($result['errors'])) {
|
if (!empty($result['errors'])) {
|
||||||
$error = "部分失败：" . implode('<br>', array_slice($result['errors'], 0, 5));
|
$error = "部分失败：" . implode('<br>', array_slice($result['errors'], 0, 5));
|
||||||
if (count($result['errors']) > 5) {
|
if (count($result['errors']) > 5) {
|
||||||
$error .= "<br>... 还有 " . (count($result['errors']) - 5) . " 个错误";
|
$error .= "<br>... 还有 " . (count($result['errors']) - 5) . " 个错误";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
$error = "群发失败：" . implode('<br>', $result['errors']);
|
$error = "群发失败：" . implode('<br>', $result['errors']);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
$error = "群发失败: " . $e->getMessage();
|
$error = "群发失败: " . $e->getMessage();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 获取所有用户列表（用于选择收件人）
|
// 获取所有用户列表（用于选择收件人）
|
||||||
$allUsers = $userRepo->getAll();
|
$allUsers = $userRepo->getAll();
|
||||||
?>
|
?>
|
||||||
<!DOCTYPE html>
|
<!DOCTYPE html>
|
||||||
<html>
|
<html>
|
||||||
<head>
|
<head>
|
||||||
<title>群发邮件 - 邮件服务器</title>
|
<title>群发邮件 - 邮件服务器</title>
|
||||||
<meta charset="UTF-8">
|
<meta charset="UTF-8">
|
||||||
<style>
|
<style>
|
||||||
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
||||||
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
||||||
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
||||||
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
||||||
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); max-width: 800px; }
|
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); max-width: 800px; }
|
||||||
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
.form-group { margin-bottom: 20px; }
|
.form-group { margin-bottom: 20px; }
|
||||||
.form-group label { display: block; margin-bottom: 8px; font-weight: 500; }
|
.form-group label { display: block; margin-bottom: 8px; font-weight: 500; }
|
||||||
.form-group input, .form-group textarea, .form-group select { width: 100%; padding: 10px; border: 1px solid #ddd; border-radius: 4px; font-size: 14px; }
|
.form-group input, .form-group textarea, .form-group select { width: 100%; padding: 10px; border: 1px solid #ddd; border-radius: 4px; font-size: 14px; }
|
||||||
.form-group textarea { min-height: 200px; font-family: monospace; }
|
.form-group textarea { min-height: 200px; font-family: monospace; }
|
||||||
.form-group small { color: #666; font-size: 12px; }
|
.form-group small { color: #666; font-size: 12px; }
|
||||||
.btn { padding: 10px 20px; border: none; border-radius: 4px; cursor: pointer; font-size: 14px; }
|
.btn { padding: 10px 20px; border: none; border-radius: 4px; cursor: pointer; font-size: 14px; }
|
||||||
.btn-primary { background: #007bff; color: white; }
|
.btn-primary { background: #007bff; color: white; }
|
||||||
.btn-primary:hover { background: #0056b3; }
|
.btn-primary:hover { background: #0056b3; }
|
||||||
.radio-group { display: flex; gap: 20px; margin-bottom: 15px; }
|
.radio-group { display: flex; gap: 20px; margin-bottom: 15px; }
|
||||||
.radio-group label { display: flex; align-items: center; cursor: pointer; }
|
.radio-group label { display: flex; align-items: center; cursor: pointer; }
|
||||||
.radio-group input[type="radio"] { width: auto; margin-right: 5px; }
|
.radio-group input[type="radio"] { width: auto; margin-right: 5px; }
|
||||||
.user-list { max-height: 200px; overflow-y: auto; border: 1px solid #ddd; padding: 10px; border-radius: 4px; background: #f8f9fa; }
|
.user-list { max-height: 200px; overflow-y: auto; border: 1px solid #ddd; padding: 10px; border-radius: 4px; background: #f8f9fa; }
|
||||||
.user-list-item { padding: 5px; }
|
.user-list-item { padding: 5px; }
|
||||||
</style>
|
</style>
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<div class="header">
|
<div class="header">
|
||||||
<h1>邮件服务器管理后台</h1>
|
<h1>邮件服务器管理后台</h1>
|
||||||
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
||||||
(<a href="logout.php" style="color: white;">退出</a>)
|
(<a href="logout.php" style="color: white;">退出</a>)
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<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="settings.php">系统设置</a>
|
<a href="settings.php">系统设置</a>
|
||||||
</div>
|
<a href="help.php">帮助</a>
|
||||||
|
</div>
|
||||||
<div class="container">
|
|
||||||
<h2>群发邮件</h2>
|
<div class="container">
|
||||||
|
<h2>群发邮件</h2>
|
||||||
<?php if ($message): ?>
|
|
||||||
<div class="message"><?php echo $message; ?></div>
|
<?php if ($message): ?>
|
||||||
<?php endif; ?>
|
<div class="message"><?php echo $message; ?></div>
|
||||||
|
<?php endif; ?>
|
||||||
<?php if ($error): ?>
|
|
||||||
<div class="error"><?php echo $error; ?></div>
|
<?php if ($error): ?>
|
||||||
<?php endif; ?>
|
<div class="error"><?php echo $error; ?></div>
|
||||||
|
<?php endif; ?>
|
||||||
<form method="POST">
|
|
||||||
<div class="form-group">
|
<form method="POST">
|
||||||
<label>发送方式</label>
|
<div class="form-group">
|
||||||
<div class="radio-group">
|
<label>发送方式</label>
|
||||||
<label>
|
<div class="radio-group">
|
||||||
<input type="radio" name="broadcast_type" value="all" checked onchange="toggleRecipients()">
|
<label>
|
||||||
发送给所有用户
|
<input type="radio" name="broadcast_type" value="all" checked onchange="toggleRecipients()">
|
||||||
</label>
|
发送给所有用户
|
||||||
<label>
|
</label>
|
||||||
<input type="radio" name="broadcast_type" value="selected" onchange="toggleRecipients()">
|
<label>
|
||||||
发送给指定用户
|
<input type="radio" name="broadcast_type" value="selected" onchange="toggleRecipients()">
|
||||||
</label>
|
发送给指定用户
|
||||||
</div>
|
</label>
|
||||||
</div>
|
</div>
|
||||||
|
</div>
|
||||||
<div class="form-group" id="recipients-group" style="display: none;">
|
|
||||||
<label>收件人（多个邮箱用逗号分隔）</label>
|
<div class="form-group" id="recipients-group" style="display: none;">
|
||||||
<input type="text" name="recipients" placeholder="user1@test.com, user2@test.com">
|
<label>收件人（多个邮箱用逗号分隔）</label>
|
||||||
<small>请输入邮箱地址，多个邮箱用逗号分隔</small>
|
<input type="text" name="recipients" placeholder="user1@test.com, user2@test.com">
|
||||||
<div class="user-list">
|
<small>请输入邮箱地址，多个邮箱用逗号分隔</small>
|
||||||
<strong>可用用户列表：</strong>
|
<div class="user-list">
|
||||||
<?php foreach ($allUsers as $user): ?>
|
<strong>可用用户列表：</strong>
|
||||||
<?php if ($user['is_active'] && $user['username'] !== $_SESSION['username']): ?>
|
<?php foreach ($allUsers as $user): ?>
|
||||||
<div class="user-list-item"><?php echo htmlspecialchars($user['username']); ?></div>
|
<?php if ($user['is_active'] && $user['username'] !== $_SESSION['username']): ?>
|
||||||
<?php endif; ?>
|
<div class="user-list-item"><?php echo htmlspecialchars($user['username']); ?></div>
|
||||||
<?php endforeach; ?>
|
<?php endif; ?>
|
||||||
</div>
|
<?php endforeach; ?>
|
||||||
</div>
|
</div>
|
||||||
|
</div>
|
||||||
<div class="form-group">
|
|
||||||
<label>邮件主题 *</label>
|
<div class="form-group">
|
||||||
<input type="text" name="subject" required placeholder="请输入邮件主题" value="<?php echo htmlspecialchars($_POST['subject'] ?? ''); ?>">
|
<label>邮件主题 *</label>
|
||||||
</div>
|
<input type="text" name="subject" required placeholder="请输入邮件主题" value="<?php echo htmlspecialchars($_POST['subject'] ?? ''); ?>">
|
||||||
|
</div>
|
||||||
<div class="form-group">
|
|
||||||
<label>邮件内容 *</label>
|
<div class="form-group">
|
||||||
<textarea name="body" required placeholder="请输入邮件内容"><?php echo htmlspecialchars($_POST['body'] ?? ''); ?></textarea>
|
<label>邮件内容 *</label>
|
||||||
</div>
|
<textarea name="body" required placeholder="请输入邮件内容"><?php echo htmlspecialchars($_POST['body'] ?? ''); ?></textarea>
|
||||||
|
</div>
|
||||||
<button type="submit" name="send_broadcast" class="btn btn-primary">发送群发邮件</button>
|
|
||||||
</form>
|
<button type="submit" name="send_broadcast" class="btn btn-primary">发送群发邮件</button>
|
||||||
</div>
|
</form>
|
||||||
|
</div>
|
||||||
<script>
|
|
||||||
function toggleRecipients() {
|
<script>
|
||||||
const broadcastType = document.querySelector('input[name="broadcast_type"]:checked').value;
|
function toggleRecipients() {
|
||||||
const recipientsGroup = document.getElementById('recipients-group');
|
const broadcastType = document.querySelector('input[name="broadcast_type"]:checked').value;
|
||||||
if (broadcastType === 'selected') {
|
const recipientsGroup = document.getElementById('recipients-group');
|
||||||
recipientsGroup.style.display = 'block';
|
if (broadcastType === 'selected') {
|
||||||
} else {
|
recipientsGroup.style.display = 'block';
|
||||||
recipientsGroup.style.display = 'none';
|
} else {
|
||||||
}
|
recipientsGroup.style.display = 'none';
|
||||||
}
|
}
|
||||||
</script>
|
}
|
||||||
</body>
|
</script>
|
||||||
</html>
|
</body>
|
||||||
|
</html>
|
||||||
|
|
||||||
|
|||||||
@ -1,240 +1,238 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/../config/database.php';
|
require_once __DIR__ . '/../config/database.php';
|
||||||
require_once __DIR__ . '/../src/storage/Database.php';
|
require_once __DIR__ . '/../src/storage/Database.php';
|
||||||
require_once __DIR__ . '/../src/storage/EmailRepository.php';
|
require_once __DIR__ . '/../src/storage/EmailRepository.php';
|
||||||
require_once __DIR__ . '/../src/utils/Security.php';
|
require_once __DIR__ . '/../src/utils/Security.php';
|
||||||
|
|
||||||
session_start();
|
session_start();
|
||||||
|
|
||||||
// 身份验证
|
// 身份验证
|
||||||
if (!isset($_SESSION['user_id'])) {
|
if (!isset($_SESSION['user_id'])) {
|
||||||
header('Location: index.php');
|
header('Location: index.php');
|
||||||
exit;
|
exit;
|
||||||
}
|
}
|
||||||
|
|
||||||
$emailRepo = new EmailRepository();
|
$emailRepo = new EmailRepository();
|
||||||
$message = '';
|
$message = '';
|
||||||
$error = '';
|
$error = '';
|
||||||
|
|
||||||
// 处理删除邮件
|
// 处理删除邮件
|
||||||
if (isset($_GET['delete'])) {
|
if (isset($_GET['delete'])) {
|
||||||
$emailId = (int)$_GET['delete'];
|
$emailId = (int)$_GET['delete'];
|
||||||
if ($emailRepo->delete($emailId)) {
|
if ($emailRepo->delete($emailId)) {
|
||||||
$message = "邮件删除成功";
|
$message = "邮件删除成功";
|
||||||
} else {
|
} else {
|
||||||
$error = "删除失败";
|
$error = "删除失败";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 处理标记已读
|
// 处理标记已读
|
||||||
if (isset($_GET['mark_read'])) {
|
if (isset($_GET['mark_read'])) {
|
||||||
$emailId = (int)$_GET['mark_read'];
|
$emailId = (int)$_GET['mark_read'];
|
||||||
if ($emailRepo->markAsRead($emailId)) {
|
if ($emailRepo->markAsRead($emailId)) {
|
||||||
$message = "邮件已标记为已读";
|
$message = "邮件已标记为已读";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 获取邮件列表
|
// 获取邮件列表
|
||||||
$isAdmin = $_SESSION['is_admin'] ?? false;
|
$isAdmin = $_SESSION['is_admin'] ?? false;
|
||||||
$userId = $_SESSION['user_id'];
|
$userId = $_SESSION['user_id'];
|
||||||
|
|
||||||
// 分页参数
|
// 分页参数
|
||||||
$page = isset($_GET['page']) ? max(1, (int)$_GET['page']) : 1;
|
$page = isset($_GET['page']) ? max(1, (int)$_GET['page']) : 1;
|
||||||
$perPage = 20;
|
$perPage = 20;
|
||||||
$offset = ($page - 1) * $perPage;
|
$offset = ($page - 1) * $perPage;
|
||||||
|
|
||||||
// 获取邮件
|
// 获取邮件
|
||||||
if ($isAdmin) {
|
if ($isAdmin) {
|
||||||
$emails = $emailRepo->getAll($perPage, $offset);
|
$emails = $emailRepo->getAll($perPage, $offset);
|
||||||
$totalEmails = $emailRepo->getCount();
|
$totalEmails = $emailRepo->getCount();
|
||||||
} else {
|
} else {
|
||||||
$emails = $emailRepo->getInbox($userId, $perPage, $offset);
|
$emails = $emailRepo->getInbox($userId, $perPage, $offset);
|
||||||
$totalEmails = $emailRepo->getCount($userId);
|
$totalEmails = $emailRepo->getCount($userId);
|
||||||
}
|
}
|
||||||
|
|
||||||
$totalPages = ceil($totalEmails / $perPage);
|
$totalPages = ceil($totalEmails / $perPage);
|
||||||
?>
|
?>
|
||||||
<!DOCTYPE html>
|
<!DOCTYPE html>
|
||||||
<html>
|
<html>
|
||||||
<head>
|
<head>
|
||||||
<title>邮件管理 - 邮件服务器</title>
|
<title>邮件管理 - 邮件服务器</title>
|
||||||
<meta charset="UTF-8">
|
<meta charset="UTF-8">
|
||||||
<style>
|
<style>
|
||||||
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
||||||
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
||||||
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
||||||
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
||||||
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
||||||
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
table { width: 100%; border-collapse: collapse; margin-top: 20px; }
|
table { width: 100%; border-collapse: collapse; margin-top: 20px; }
|
||||||
th, td { border: 1px solid #ddd; padding: 12px; text-align: left; }
|
th, td { border: 1px solid #ddd; padding: 12px; text-align: left; }
|
||||||
th { background: #f8f9fa; font-weight: 600; }
|
th { background: #f8f9fa; font-weight: 600; }
|
||||||
tr:hover { background: #f8f9fa; }
|
tr:hover { background: #f8f9fa; }
|
||||||
.btn { padding: 6px 12px; border: none; border-radius: 4px; cursor: pointer; text-decoration: none; display: inline-block; }
|
.btn { padding: 6px 12px; border: none; border-radius: 4px; cursor: pointer; text-decoration: none; display: inline-block; }
|
||||||
.btn-primary { background: #007bff; color: white; }
|
.btn-primary { background: #007bff; color: white; }
|
||||||
.btn-danger { background: #dc3545; color: white; }
|
.btn-danger { background: #dc3545; color: white; }
|
||||||
.btn-success { background: #28a745; color: white; }
|
.btn-success { background: #28a745; color: white; }
|
||||||
.btn-small { padding: 4px 8px; font-size: 12px; }
|
.btn-small { padding: 4px 8px; font-size: 12px; }
|
||||||
.badge { padding: 4px 8px; border-radius: 3px; font-size: 12px; font-weight: 500; }
|
.badge { padding: 4px 8px; border-radius: 3px; font-size: 12px; font-weight: 500; }
|
||||||
.badge-read { background: #6c757d; color: white; }
|
.badge-read { background: #6c757d; color: white; }
|
||||||
.badge-unread { background: #007bff; color: white; }
|
.badge-unread { background: #007bff; color: white; }
|
||||||
.email-unread { font-weight: bold; }
|
.email-unread { font-weight: bold; }
|
||||||
.pagination { margin-top: 20px; text-align: center; }
|
.pagination { margin-top: 20px; text-align: center; }
|
||||||
.pagination a { display: inline-block; padding: 8px 12px; margin: 0 4px; text-decoration: none; border: 1px solid #ddd; border-radius: 4px; }
|
.pagination a { display: inline-block; padding: 8px 12px; margin: 0 4px; text-decoration: none; border: 1px solid #ddd; border-radius: 4px; }
|
||||||
.pagination a:hover { background: #f8f9fa; }
|
.pagination a:hover { background: #f8f9fa; }
|
||||||
.pagination .current { background: #007bff; color: white; border-color: #007bff; }
|
.pagination .current { background: #007bff; color: white; border-color: #007bff; }
|
||||||
.email-preview { max-width: 300px; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; }
|
.email-preview { max-width: 300px; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; }
|
||||||
.modal { display: none; position: fixed; z-index: 1000; left: 0; top: 0; width: 100%; height: 100%; background: rgba(0,0,0,0.5); overflow: auto; }
|
.modal { display: none; position: fixed; z-index: 1000; left: 0; top: 0; width: 100%; height: 100%; background: rgba(0,0,0,0.5); overflow: auto; }
|
||||||
.modal-content { background: white; margin: 50px auto; padding: 20px; width: 80%; max-width: 800px; border-radius: 5px; }
|
.modal-content { background: white; margin: 50px auto; padding: 20px; width: 80%; max-width: 800px; border-radius: 5px; }
|
||||||
.close { float: right; font-size: 28px; font-weight: bold; cursor: pointer; }
|
.close { float: right; font-size: 28px; font-weight: bold; cursor: pointer; }
|
||||||
.email-body { white-space: pre-wrap; background: #f8f9fa; padding: 15px; border-radius: 5px; margin-top: 10px; }
|
.email-body { white-space: pre-wrap; background: #f8f9fa; padding: 15px; border-radius: 5px; margin-top: 10px; }
|
||||||
</style>
|
</style>
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<div class="header">
|
<div class="header">
|
||||||
<h1>邮件服务器管理后台</h1>
|
<h1>邮件服务器管理后台</h1>
|
||||||
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
||||||
(<a href="logout.php" style="color: white;">退出</a>)
|
(<a href="logout.php" style="color: white;">退出</a>)
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="menu">
|
<div class="menu">
|
||||||
<a href="index.php">仪表盘</a>
|
<a href="index.php">仪表盘</a>
|
||||||
<?php if ($isAdmin): ?>
|
<a href="users.php">用户管理</a>
|
||||||
<a href="users.php">用户管理</a>
|
<a href="broadcast.php">群发邮件</a>
|
||||||
<?php endif; ?>
|
<a href="filters.php">过滤规则</a>
|
||||||
<a href="emails.php">邮件管理</a>
|
<a href="logs.php">系统日志</a>
|
||||||
<a href="filters.php">过滤规则</a>
|
<a href="services.php">服务管理</a>
|
||||||
<a href="logs.php">系统日志</a>
|
<a href="settings.php">系统设置</a>
|
||||||
<?php if ($isAdmin): ?>
|
<a href="help.php">帮助</a>
|
||||||
<a href="settings.php">系统设置</a>
|
</div>
|
||||||
<?php endif; ?>
|
|
||||||
</div>
|
<div class="container">
|
||||||
|
<h2>邮箱管理 <?php if ($isAdmin): ?>(全部邮件)<?php else: ?>(我的收件箱)<?php endif; ?></h2>
|
||||||
<div class="container">
|
|
||||||
<h2>邮件管理 <?php if ($isAdmin): ?>(全部邮件)<?php else: ?>(我的收件箱)<?php endif; ?></h2>
|
<?php if ($message): ?>
|
||||||
|
<div class="message"><?php echo $message; ?></div>
|
||||||
<?php if ($message): ?>
|
<?php endif; ?>
|
||||||
<div class="message"><?php echo $message; ?></div>
|
|
||||||
<?php endif; ?>
|
<?php if ($error): ?>
|
||||||
|
<div class="error"><?php echo $error; ?></div>
|
||||||
<?php if ($error): ?>
|
<?php endif; ?>
|
||||||
<div class="error"><?php echo $error; ?></div>
|
|
||||||
<?php endif; ?>
|
<p>共 <?php echo $totalEmails; ?> 封邮件</p>
|
||||||
|
|
||||||
<p>共 <?php echo $totalEmails; ?> 封邮件</p>
|
<table>
|
||||||
|
<thead>
|
||||||
<table>
|
<tr>
|
||||||
<thead>
|
<th>ID</th>
|
||||||
<tr>
|
<th>发件人</th>
|
||||||
<th>ID</th>
|
<th>收件人</th>
|
||||||
<th>发件人</th>
|
<th>主题</th>
|
||||||
<th>收件人</th>
|
<th>状态</th>
|
||||||
<th>主题</th>
|
<th>时间</th>
|
||||||
<th>状态</th>
|
<th>操作</th>
|
||||||
<th>时间</th>
|
</tr>
|
||||||
<th>操作</th>
|
</thead>
|
||||||
</tr>
|
<tbody>
|
||||||
</thead>
|
<?php if (empty($emails)): ?>
|
||||||
<tbody>
|
<tr>
|
||||||
<?php if (empty($emails)): ?>
|
<td colspan="7" style="text-align: center; padding: 40px;">
|
||||||
<tr>
|
暂无邮件
|
||||||
<td colspan="7" style="text-align: center; padding: 40px;">
|
</td>
|
||||||
暂无邮件
|
</tr>
|
||||||
</td>
|
<?php else: ?>
|
||||||
</tr>
|
<?php foreach ($emails as $email): ?>
|
||||||
<?php else: ?>
|
<tr class="<?php echo $email['is_read'] ? '' : 'email-unread'; ?>">
|
||||||
<?php foreach ($emails as $email): ?>
|
<td><?php echo $email['id']; ?></td>
|
||||||
<tr class="<?php echo $email['is_read'] ? '' : 'email-unread'; ?>">
|
<td><?php echo htmlspecialchars($email['sender_name'] ?? $email['sender'] ?? '未知'); ?></td>
|
||||||
<td><?php echo $email['id']; ?></td>
|
<td><?php echo htmlspecialchars($email['recipient_name'] ?? $email['recipient'] ?? '未知'); ?></td>
|
||||||
<td><?php echo htmlspecialchars($email['sender_name'] ?? $email['sender'] ?? '未知'); ?></td>
|
<td class="email-preview">
|
||||||
<td><?php echo htmlspecialchars($email['recipient_name'] ?? $email['recipient'] ?? '未知'); ?></td>
|
<a href="#" onclick="viewEmail(<?php echo htmlspecialchars(json_encode($email)); ?>); return false;">
|
||||||
<td class="email-preview">
|
<?php echo htmlspecialchars($email['subject'] ?? '(无主题)'); ?>
|
||||||
<a href="#" onclick="viewEmail(<?php echo htmlspecialchars(json_encode($email)); ?>); return false;">
|
</a>
|
||||||
<?php echo htmlspecialchars($email['subject'] ?? '(无主题)'); ?>
|
</td>
|
||||||
</a>
|
<td>
|
||||||
</td>
|
<?php if ($email['is_read']): ?>
|
||||||
<td>
|
<span class="badge badge-read">已读</span>
|
||||||
<?php if ($email['is_read']): ?>
|
<?php else: ?>
|
||||||
<span class="badge badge-read">已读</span>
|
<span class="badge badge-unread">未读</span>
|
||||||
<?php else: ?>
|
<?php endif; ?>
|
||||||
<span class="badge badge-unread">未读</span>
|
</td>
|
||||||
<?php endif; ?>
|
<td><?php echo $email['created_at']; ?></td>
|
||||||
</td>
|
<td>
|
||||||
<td><?php echo $email['created_at']; ?></td>
|
<a href="#" onclick="viewEmail(<?php echo htmlspecialchars(json_encode($email)); ?>); return false;" class="btn btn-primary btn-small">查看</a>
|
||||||
<td>
|
<?php if (!$email['is_read']): ?>
|
||||||
<a href="#" onclick="viewEmail(<?php echo htmlspecialchars(json_encode($email)); ?>); return false;" class="btn btn-primary btn-small">查看</a>
|
<a href="?mark_read=<?php echo $email['id']; ?>" class="btn btn-success btn-small">标记已读</a>
|
||||||
<?php if (!$email['is_read']): ?>
|
<?php endif; ?>
|
||||||
<a href="?mark_read=<?php echo $email['id']; ?>" class="btn btn-success btn-small">标记已读</a>
|
<a href="?delete=<?php echo $email['id']; ?>" class="btn btn-danger btn-small" onclick="return confirm('确定要删除此邮件吗？');">删除</a>
|
||||||
<?php endif; ?>
|
</td>
|
||||||
<a href="?delete=<?php echo $email['id']; ?>" class="btn btn-danger btn-small" onclick="return confirm('确定要删除此邮件吗？');">删除</a>
|
</tr>
|
||||||
</td>
|
<?php endforeach; ?>
|
||||||
</tr>
|
<?php endif; ?>
|
||||||
<?php endforeach; ?>
|
</tbody>
|
||||||
<?php endif; ?>
|
</table>
|
||||||
</tbody>
|
|
||||||
</table>
|
<!-- 分页 -->
|
||||||
|
<?php if ($totalPages > 1): ?>
|
||||||
<!-- 分页 -->
|
<div class="pagination">
|
||||||
<?php if ($totalPages > 1): ?>
|
<?php if ($page > 1): ?>
|
||||||
<div class="pagination">
|
<a href="?page=<?php echo $page - 1; ?>">上一页</a>
|
||||||
<?php if ($page > 1): ?>
|
<?php endif; ?>
|
||||||
<a href="?page=<?php echo $page - 1; ?>">上一页</a>
|
|
||||||
<?php endif; ?>
|
<?php for ($i = 1; $i <= $totalPages; $i++): ?>
|
||||||
|
<?php if ($i == $page): ?>
|
||||||
<?php for ($i = 1; $i <= $totalPages; $i++): ?>
|
<span class="current"><?php echo $i; ?></span>
|
||||||
<?php if ($i == $page): ?>
|
<?php else: ?>
|
||||||
<span class="current"><?php echo $i; ?></span>
|
<a href="?page=<?php echo $i; ?>"><?php echo $i; ?></a>
|
||||||
<?php else: ?>
|
<?php endif; ?>
|
||||||
<a href="?page=<?php echo $i; ?>"><?php echo $i; ?></a>
|
<?php endfor; ?>
|
||||||
<?php endif; ?>
|
|
||||||
<?php endfor; ?>
|
<?php if ($page < $totalPages): ?>
|
||||||
|
<a href="?page=<?php echo $page + 1; ?>">下一页</a>
|
||||||
<?php if ($page < $totalPages): ?>
|
<?php endif; ?>
|
||||||
<a href="?page=<?php echo $page + 1; ?>">下一页</a>
|
</div>
|
||||||
<?php endif; ?>
|
<?php endif; ?>
|
||||||
</div>
|
</div>
|
||||||
<?php endif; ?>
|
|
||||||
</div>
|
<!-- 查看邮件模态框 -->
|
||||||
|
<div id="emailModal" class="modal">
|
||||||
<!-- 查看邮件模态框 -->
|
<div class="modal-content">
|
||||||
<div id="emailModal" class="modal">
|
<span class="close" onclick="closeEmailModal()">×</span>
|
||||||
<div class="modal-content">
|
<h3 id="email-subject">邮件详情</h3>
|
||||||
<span class="close" onclick="closeEmailModal()">×</span>
|
<div>
|
||||||
<h3 id="email-subject">邮件详情</h3>
|
<strong>发件人：</strong><span id="email-sender"></span><br>
|
||||||
<div>
|
<strong>收件人：</strong><span id="email-recipient"></span><br>
|
||||||
<strong>发件人：</strong><span id="email-sender"></span><br>
|
<strong>时间：</strong><span id="email-time"></span><br>
|
||||||
<strong>收件人：</strong><span id="email-recipient"></span><br>
|
<strong>主题：</strong><span id="email-subject-text"></span>
|
||||||
<strong>时间：</strong><span id="email-time"></span><br>
|
</div>
|
||||||
<strong>主题：</strong><span id="email-subject-text"></span>
|
<div class="email-body" id="email-body"></div>
|
||||||
</div>
|
</div>
|
||||||
<div class="email-body" id="email-body"></div>
|
</div>
|
||||||
</div>
|
|
||||||
</div>
|
<script>
|
||||||
|
function viewEmail(email) {
|
||||||
<script>
|
document.getElementById('email-subject').textContent = email.subject || '(无主题)';
|
||||||
function viewEmail(email) {
|
document.getElementById('email-subject-text').textContent = email.subject || '(无主题)';
|
||||||
document.getElementById('email-subject').textContent = email.subject || '(无主题)';
|
document.getElementById('email-sender').textContent = email.sender_name || email.sender || '未知';
|
||||||
document.getElementById('email-subject-text').textContent = email.subject || '(无主题)';
|
document.getElementById('email-recipient').textContent = email.recipient_name || email.recipient || '未知';
|
||||||
document.getElementById('email-sender').textContent = email.sender_name || email.sender || '未知';
|
document.getElementById('email-time').textContent = email.created_at;
|
||||||
document.getElementById('email-recipient').textContent = email.recipient_name || email.recipient || '未知';
|
document.getElementById('email-body').textContent = email.body || '(无内容)';
|
||||||
document.getElementById('email-time').textContent = email.created_at;
|
document.getElementById('emailModal').style.display = 'block';
|
||||||
document.getElementById('email-body').textContent = email.body || '(无内容)';
|
}
|
||||||
document.getElementById('emailModal').style.display = 'block';
|
|
||||||
}
|
function closeEmailModal() {
|
||||||
|
document.getElementById('emailModal').style.display = 'none';
|
||||||
function closeEmailModal() {
|
}
|
||||||
document.getElementById('emailModal').style.display = 'none';
|
|
||||||
}
|
window.onclick = function(event) {
|
||||||
|
var modal = document.getElementById('emailModal');
|
||||||
window.onclick = function(event) {
|
if (event.target == modal) {
|
||||||
var modal = document.getElementById('emailModal');
|
closeEmailModal();
|
||||||
if (event.target == modal) {
|
}
|
||||||
closeEmailModal();
|
}
|
||||||
}
|
</script>
|
||||||
}
|
</body>
|
||||||
</script>
|
</html>
|
||||||
</body>
|
|
||||||
</html>
|
|
||||||
|
|
||||||
|
|||||||
@ -1,243 +1,257 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/../config/database.php';
|
require_once __DIR__ . '/../config/database.php';
|
||||||
require_once __DIR__ . '/../src/storage/Database.php';
|
require_once __DIR__ . '/../src/storage/Database.php';
|
||||||
require_once __DIR__ . '/../src/storage/FilterRepository.php';
|
require_once __DIR__ . '/../src/storage/FilterRepository.php';
|
||||||
require_once __DIR__ . '/../src/utils/Validator.php';
|
require_once __DIR__ . '/../src/utils/Validator.php';
|
||||||
require_once __DIR__ . '/../src/utils/Security.php';
|
require_once __DIR__ . '/../src/utils/Security.php';
|
||||||
|
|
||||||
session_start();
|
//开启所有错误日志报告
|
||||||
|
error_reporting(E_ALL);
|
||||||
// 身份验证
|
ini_set('display_errors', 1);
|
||||||
if (!isset($_SESSION['user_id'])) {
|
|
||||||
header('Location: index.php');
|
session_start();
|
||||||
exit;
|
|
||||||
}
|
// 身份验证
|
||||||
|
if (!isset($_SESSION['user_id'])) {
|
||||||
$filterRepo = new FilterRepository();
|
header('Location: index.php');
|
||||||
$message = '';
|
exit;
|
||||||
$error = '';
|
}
|
||||||
|
|
||||||
// 处理创建过滤规则
|
$filterRepo = new FilterRepository();
|
||||||
if (isset($_POST['create_filter'])) {
|
$message = '';
|
||||||
$ruleType = $_POST['rule_type'] ?? '';
|
$error = '';
|
||||||
$ruleValue = trim($_POST['rule_value'] ?? '');
|
|
||||||
$action = $_POST['action'] ?? 'block';
|
if (isset($_POST['toggle_id'])) {
|
||||||
$description = trim($_POST['description'] ?? '');
|
$id = (int)$_POST['toggle_id'];
|
||||||
|
$row = $filterRepo->getById($id);
|
||||||
if (empty($ruleValue)) {
|
if ($row) {
|
||||||
$error = "规则值不能为空";
|
$filterRepo->updateStatus($id, !(bool)$row['is_active']);
|
||||||
} else {
|
}
|
||||||
if ($ruleType === 'email') {
|
header('Location: filters.php'); // 302 跳回干净地址
|
||||||
if (!Validator::validateEmail($ruleValue)) {
|
exit;
|
||||||
$error = "邮箱格式无效";
|
}
|
||||||
}
|
|
||||||
} elseif ($ruleType === 'ip') {
|
|
||||||
if (!Validator::validateIP($ruleValue)) {
|
|
||||||
$error = "IP地址格式无效";
|
// 处理创建过滤规则
|
||||||
}
|
if (isset($_POST['create_filter'])) {
|
||||||
} else {
|
$ruleType = $_POST['rule_type'] ?? '';
|
||||||
$error = "规则类型无效";
|
$ruleValue = trim($_POST['rule_value'] ?? '');
|
||||||
}
|
$action = $_POST['action'] ?? 'block';
|
||||||
|
$description = trim($_POST['description'] ?? '');
|
||||||
if (empty($error)) {
|
|
||||||
try {
|
if (empty($ruleValue)) {
|
||||||
if ($filterRepo->create($ruleType, $ruleValue, $action, $description)) {
|
$error = "规则值不能为空";
|
||||||
$message = "过滤规则创建成功";
|
} else {
|
||||||
} else {
|
if ($ruleType === 'email') {
|
||||||
$error = "创建失败，可能已存在相同规则";
|
if (!Validator::validateEmail($ruleValue)) {
|
||||||
}
|
$error = "邮箱格式无效";
|
||||||
} catch (Exception $e) {
|
}
|
||||||
$error = "创建失败: " . $e->getMessage();
|
} elseif ($ruleType === 'ip') {
|
||||||
}
|
if (!Validator::validateIP($ruleValue)) {
|
||||||
}
|
$error = "IP地址格式无效";
|
||||||
}
|
}
|
||||||
}
|
} else {
|
||||||
|
$error = "规则类型无效";
|
||||||
// 处理删除规则
|
}
|
||||||
if (isset($_GET['delete'])) {
|
|
||||||
$id = (int)$_GET['delete'];
|
if (empty($error)) {
|
||||||
if ($filterRepo->delete($id)) {
|
try {
|
||||||
$message = "规则删除成功";
|
if ($filterRepo->create($ruleType, $ruleValue, $action, $description)) {
|
||||||
} else {
|
$message = "过滤规则创建成功";
|
||||||
$error = "删除失败";
|
} else {
|
||||||
}
|
$error = "创建失败，可能已存在相同规则";
|
||||||
}
|
}
|
||||||
|
} catch (Exception $e) {
|
||||||
// 处理切换规则状态
|
$error = "创建失败: " . $e->getMessage();
|
||||||
if (isset($_GET['toggle'])) {
|
}
|
||||||
$id = (int)$_GET['toggle'];
|
}
|
||||||
$rule = $filterRepo->getAll();
|
}
|
||||||
$currentRule = null;
|
}
|
||||||
foreach ($rule as $r) {
|
|
||||||
if ($r['id'] == $id) {
|
// 处理删除规则
|
||||||
$currentRule = $r;
|
if (isset($_GET['delete'])) {
|
||||||
break;
|
$id = (int)$_GET['delete'];
|
||||||
}
|
if ($filterRepo->delete($id)) {
|
||||||
}
|
$message = "规则删除成功";
|
||||||
if ($currentRule) {
|
} else {
|
||||||
$newStatus = !$currentRule['is_active'];
|
$error = "删除失败";
|
||||||
if ($filterRepo->updateStatus($id, $newStatus)) {
|
}
|
||||||
$message = "规则状态已更新";
|
}
|
||||||
} else {
|
|
||||||
$error = "更新失败";
|
/*------------------------------------
|
||||||
}
|
// 处理切换规则状态
|
||||||
}
|
if (isset($_GET['toggle'])) {
|
||||||
}
|
$id = (int)$_GET['toggle'];
|
||||||
|
$row = $filterRepo->getById($id); // 改用 public 方法
|
||||||
// 获取所有规则
|
if ($row) {
|
||||||
$rules = $filterRepo->getAll();
|
$newStatus = !(bool)$row['is_active'];
|
||||||
?>
|
if ($filterRepo->updateStatus($id, $newStatus)) {
|
||||||
<!DOCTYPE html>
|
$message = "规则状态已更新";
|
||||||
<html>
|
} else {
|
||||||
<head>
|
$error = "更新失败";
|
||||||
<title>过滤规则 - 邮件服务器</title>
|
}
|
||||||
<meta charset="UTF-8">
|
} else {
|
||||||
<style>
|
$error = "规则不存在";
|
||||||
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
}
|
||||||
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
}
|
||||||
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
------------------------------------ */
|
||||||
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
// 获取所有规则
|
||||||
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
$rules = $filterRepo->getAll();
|
||||||
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
|
||||||
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
?>
|
||||||
.form-group { margin-bottom: 15px; }
|
<!DOCTYPE html>
|
||||||
.form-group label { display: block; margin-bottom: 5px; font-weight: 500; }
|
<html>
|
||||||
.form-group input, .form-group select, .form-group textarea { width: 100%; max-width: 500px; padding: 8px; border: 1px solid #ddd; border-radius: 4px; }
|
<head>
|
||||||
.form-inline { display: flex; gap: 10px; align-items: flex-end; }
|
<title>过滤规则 - 邮件服务器</title>
|
||||||
.form-inline .form-group { flex: 1; margin-bottom: 0; }
|
<meta charset="UTF-8">
|
||||||
.btn { padding: 6px 12px; border: none; border-radius: 4px; cursor: pointer; text-decoration: none; display: inline-block; }
|
<style>
|
||||||
.btn-primary { background: #007bff; color: white; }
|
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
||||||
.btn-danger { background: #dc3545; color: white; }
|
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
||||||
.btn-success { background: #28a745; color: white; }
|
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
||||||
.btn-warning { background: #ffc107; color: #000; }
|
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
||||||
table { width: 100%; border-collapse: collapse; margin-top: 20px; }
|
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
||||||
th, td { border: 1px solid #ddd; padding: 12px; text-align: left; }
|
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
th { background: #f8f9fa; }
|
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
.badge { padding: 4px 8px; border-radius: 3px; font-size: 12px; font-weight: 500; }
|
.form-group { margin-bottom: 15px; }
|
||||||
.badge-email { background: #17a2b8; color: white; }
|
.form-group label { display: block; margin-bottom: 5px; font-weight: 500; }
|
||||||
.badge-ip { background: #6c757d; color: white; }
|
.form-group input, .form-group select, .form-group textarea { width: 100%; max-width: 500px; padding: 8px; border: 1px solid #ddd; border-radius: 4px; }
|
||||||
.badge-block { background: #dc3545; color: white; }
|
.form-inline { display: flex; gap: 10px; align-items: flex-end; }
|
||||||
.badge-allow { background: #28a745; color: white; }
|
.form-inline .form-group { flex: 1; margin-bottom: 0; }
|
||||||
.badge-active { background: #28a745; color: white; }
|
.btn { padding: 6px 12px; border: none; border-radius: 4px; cursor: pointer; text-decoration: none; display: inline-block; }
|
||||||
.badge-inactive { background: #6c757d; color: white; }
|
.btn-primary { background: #007bff; color: white; }
|
||||||
</style>
|
.btn-danger { background: #dc3545; color: white; }
|
||||||
</head>
|
.btn-success { background: #28a745; color: white; }
|
||||||
<body>
|
.btn-warning { background: #ffc107; color: #000; }
|
||||||
<div class="header">
|
table { width: 100%; border-collapse: collapse; margin-top: 20px; }
|
||||||
<h1>邮件服务器管理后台</h1>
|
th, td { border: 1px solid #ddd; padding: 12px; text-align: left; }
|
||||||
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
th { background: #f8f9fa; }
|
||||||
(<a href="logout.php" style="color: white;">退出</a>)
|
.badge { padding: 4px 8px; border-radius: 3px; font-size: 12px; font-weight: 500; }
|
||||||
</div>
|
.badge-email { background: #17a2b8; color: white; }
|
||||||
</div>
|
.badge-ip { background: #6c757d; color: white; }
|
||||||
|
.badge-block { background: #dc3545; color: white; }
|
||||||
<div class="menu">
|
.badge-allow { background: #28a745; color: white; }
|
||||||
<a href="index.php">仪表盘</a>
|
.badge-active { background: #28a745; color: white; }
|
||||||
<?php if ($_SESSION['is_admin'] ?? false): ?>
|
.badge-inactive { background: #6c757d; color: white; }
|
||||||
<a href="users.php">用户管理</a>
|
</style>
|
||||||
<?php endif; ?>
|
</head>
|
||||||
<a href="emails.php">邮件管理</a>
|
<body>
|
||||||
<a href="filters.php">过滤规则</a>
|
<div class="header">
|
||||||
<a href="logs.php">系统日志</a>
|
<h1>邮件服务器管理后台</h1>
|
||||||
<?php if ($_SESSION['is_admin'] ?? false): ?>
|
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
||||||
<a href="settings.php">系统设置</a>
|
(<a href="logout.php" style="color: white;">退出</a>)
|
||||||
<?php endif; ?>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<div class="container">
|
<div class="menu">
|
||||||
<h2>过滤规则管理</h2>
|
<a href="index.php">仪表盘</a>
|
||||||
|
<a href="users.php">用户管理</a>
|
||||||
<?php if ($message): ?>
|
<a href="broadcast.php">群发邮件</a>
|
||||||
<div class="message"><?php echo $message; ?></div>
|
<a href="filters.php">过滤规则</a>
|
||||||
<?php endif; ?>
|
<a href="logs.php">系统日志</a>
|
||||||
|
<a href="services.php">服务管理</a>
|
||||||
<?php if ($error): ?>
|
<a href="settings.php">系统设置</a>
|
||||||
<div class="error"><?php echo $error; ?></div>
|
<a href="help.php">帮助</a>
|
||||||
<?php endif; ?>
|
</div>
|
||||||
|
|
||||||
<!-- 创建过滤规则 -->
|
<div class="container">
|
||||||
<h3>创建过滤规则</h3>
|
<h2>过滤规则管理</h2>
|
||||||
<form method="POST" class="form-inline">
|
|
||||||
<div class="form-group">
|
<?php if ($message): ?>
|
||||||
<label>规则类型</label>
|
<div class="message"><?php echo $message; ?></div>
|
||||||
<select name="rule_type" required>
|
<?php endif; ?>
|
||||||
<option value="email">邮箱过滤</option>
|
|
||||||
<option value="ip">IP地址过滤</option>
|
<?php if ($error): ?>
|
||||||
</select>
|
<div class="error"><?php echo $error; ?></div>
|
||||||
</div>
|
<?php endif; ?>
|
||||||
<div class="form-group">
|
|
||||||
<label>规则值</label>
|
<!-- 创建过滤规则 -->
|
||||||
<input type="text" name="rule_value" placeholder="邮箱或IP地址" required>
|
<h3>创建过滤规则</h3>
|
||||||
</div>
|
<form method="POST" class="form-inline">
|
||||||
<div class="form-group">
|
<div class="form-group">
|
||||||
<label>动作</label>
|
<label>规则类型</label>
|
||||||
<select name="action" required>
|
<select name="rule_type" required>
|
||||||
<option value="block">阻止</option>
|
<option value="email">邮箱过滤</option>
|
||||||
<option value="allow">允许</option>
|
<option value="ip">IP地址过滤</option>
|
||||||
</select>
|
</select>
|
||||||
</div>
|
</div>
|
||||||
<div class="form-group">
|
<div class="form-group">
|
||||||
<label>描述</label>
|
<label>规则值</label>
|
||||||
<input type="text" name="description" placeholder="规则描述（可选）">
|
<input type="text" name="rule_value" placeholder="邮箱或IP地址" required>
|
||||||
</div>
|
</div>
|
||||||
<div class="form-group">
|
<div class="form-group">
|
||||||
<button type="submit" name="create_filter" class="btn btn-primary">创建规则</button>
|
<label>动作</label>
|
||||||
</div>
|
<select name="action" required>
|
||||||
</form>
|
<option value="block">阻止</option>
|
||||||
|
<option value="allow">允许</option>
|
||||||
<!-- 规则列表 -->
|
</select>
|
||||||
<h3>过滤规则列表 (<?php echo count($rules); ?>)</h3>
|
</div>
|
||||||
<table>
|
<div class="form-group">
|
||||||
<thead>
|
<label>描述</label>
|
||||||
<tr>
|
<input type="text" name="description" placeholder="规则描述（可选）">
|
||||||
<th>ID</th>
|
</div>
|
||||||
<th>类型</th>
|
<div class="form-group">
|
||||||
<th>规则值</th>
|
<button type="submit" name="create_filter" class="btn btn-primary">创建规则</button>
|
||||||
<th>动作</th>
|
</div>
|
||||||
<th>描述</th>
|
</form>
|
||||||
<th>状态</th>
|
|
||||||
<th>创建时间</th>
|
<!-- 规则列表 -->
|
||||||
<th>操作</th>
|
<h3>过滤规则列表 (<?php echo count($rules); ?>)</h3>
|
||||||
</tr>
|
<table>
|
||||||
</thead>
|
<thead>
|
||||||
<tbody>
|
<tr>
|
||||||
<?php if (empty($rules)): ?>
|
<th>ID</th>
|
||||||
<tr>
|
<th>类型</th>
|
||||||
<td colspan="8" style="text-align: center; padding: 40px;">暂无过滤规则</td>
|
<th>规则值</th>
|
||||||
</tr>
|
<th>动作</th>
|
||||||
<?php else: ?>
|
<th>描述</th>
|
||||||
<?php foreach ($rules as $rule): ?>
|
<th>状态</th>
|
||||||
<tr>
|
<th>创建时间</th>
|
||||||
<td><?php echo $rule['id']; ?></td>
|
<th>操作</th>
|
||||||
<td>
|
</tr>
|
||||||
<span class="badge badge-<?php echo $rule['rule_type']; ?>">
|
</thead>
|
||||||
<?php echo $rule['rule_type'] === 'email' ? '邮箱' : 'IP'; ?>
|
<tbody>
|
||||||
</span>
|
<?php if (empty($rules)): ?>
|
||||||
</td>
|
<tr>
|
||||||
<td><?php echo htmlspecialchars($rule['rule_value']); ?></td>
|
<td colspan="8" style="text-align: center; padding: 40px;">暂无过滤规则</td>
|
||||||
<td>
|
</tr>
|
||||||
<span class="badge badge-<?php echo $rule['action']; ?>">
|
<?php else: ?>
|
||||||
<?php echo $rule['action'] === 'block' ? '阻止' : '允许'; ?>
|
<?php foreach ($rules as $rule): ?>
|
||||||
</span>
|
<tr>
|
||||||
</td>
|
<td><?php echo $rule['id']; ?></td>
|
||||||
<td><?php echo htmlspecialchars($rule['description'] ?? '-'); ?></td>
|
<td>
|
||||||
<td>
|
<span class="badge badge-<?php echo $rule['rule_type']; ?>">
|
||||||
<span class="badge badge-<?php echo $rule['is_active'] ? 'active' : 'inactive'; ?>">
|
<?php echo $rule['rule_type'] === 'email' ? '邮箱' : 'IP'; ?>
|
||||||
<?php echo $rule['is_active'] ? '激活' : '禁用'; ?>
|
</span>
|
||||||
</span>
|
</td>
|
||||||
</td>
|
<td><?php echo htmlspecialchars($rule['rule_value']); ?></td>
|
||||||
<td><?php echo $rule['created_at']; ?></td>
|
<td>
|
||||||
<td>
|
<span class="badge badge-<?php echo $rule['action']; ?>">
|
||||||
<a href="?toggle=<?php echo $rule['id']; ?>" class="btn btn-warning">
|
<?php echo $rule['action'] === 'block' ? '阻止' : '允许'; ?>
|
||||||
<?php echo $rule['is_active'] ? '禁用' : '启用'; ?>
|
</span>
|
||||||
</a>
|
</td>
|
||||||
<a href="?delete=<?php echo $rule['id']; ?>" class="btn btn-danger" onclick="return confirm('确定要删除此规则吗？');">删除</a>
|
<td><?php echo htmlspecialchars($rule['description'] ?? '-'); ?></td>
|
||||||
</td>
|
<td>
|
||||||
</tr>
|
<span class="badge badge-<?php echo $rule['is_active'] ? 'active' : 'inactive'; ?>">
|
||||||
<?php endforeach; ?>
|
<?php echo $rule['is_active'] ? '激活' : '禁用'; ?>
|
||||||
<?php endif; ?>
|
</span>
|
||||||
</tbody>
|
</td>
|
||||||
</table>
|
<td><?php echo $rule['created_at']; ?></td>
|
||||||
</div>
|
<td>
|
||||||
</body>
|
<form method="post" style="display:inline;">
|
||||||
</html>
|
<input type="hidden" name="toggle_id" value="<?php echo $rule['id']; ?>">
|
||||||
|
<button type="submit" class="btn btn-warning">
|
||||||
|
<?php echo $rule['is_active'] ? '禁用' : '启用'; ?>
|
||||||
|
</button>
|
||||||
|
</form>
|
||||||
|
<a href="?delete=<?php echo $rule['id']; ?>" class="btn btn-danger" onclick="return confirm('确定要删除此规则吗？');">删除</a>
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
<?php endforeach; ?>
|
||||||
|
<?php endif; ?>
|
||||||
|
</tbody>
|
||||||
|
</table>
|
||||||
|
</div>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
|
|
||||||
|
|||||||
@ -1,18 +1,18 @@
|
|||||||
<?php
|
<?php
|
||||||
session_start();
|
session_start();
|
||||||
|
|
||||||
// 清除所有会话数据
|
// 清除所有会话数据
|
||||||
$_SESSION = array();
|
$_SESSION = array();
|
||||||
|
|
||||||
// 销毁会话cookie
|
// 销毁会话cookie
|
||||||
if (isset($_COOKIE[session_name()])) {
|
if (isset($_COOKIE[session_name()])) {
|
||||||
setcookie(session_name(), '', time()-3600, '/');
|
setcookie(session_name(), '', time()-3600, '/');
|
||||||
}
|
}
|
||||||
|
|
||||||
// 销毁会话
|
// 销毁会话
|
||||||
session_destroy();
|
session_destroy();
|
||||||
|
|
||||||
// 重定向到登录页面
|
// 重定向到登录页面
|
||||||
header('Location: index.php');
|
header('Location: index.php');
|
||||||
exit;
|
exit;
|
||||||
|
|
||||||
|
|||||||
@ -1,292 +1,299 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/../config/database.php';
|
require_once __DIR__ . '/../config/database.php';
|
||||||
require_once __DIR__ . '/../src/storage/Database.php';
|
require_once __DIR__ . '/../src/storage/Database.php';
|
||||||
require_once __DIR__ . '/../src/storage/UserRepository.php';
|
require_once __DIR__ . '/../src/storage/UserRepository.php';
|
||||||
require_once __DIR__ . '/../src/utils/Validator.php';
|
require_once __DIR__ . '/../src/utils/Validator.php';
|
||||||
require_once __DIR__ . '/../src/utils/Security.php';
|
require_once __DIR__ . '/../src/utils/Security.php';
|
||||||
|
require_once __DIR__ . '/../src/storage/SystemSettingsRepository.php';
|
||||||
session_start();
|
|
||||||
|
session_start();
|
||||||
// 身份验证
|
|
||||||
if (!isset($_SESSION['user_id'])) {
|
// 身份验证
|
||||||
header('Location: index.php');
|
if (!isset($_SESSION['user_id'])) {
|
||||||
exit;
|
header('Location: index.php');
|
||||||
}
|
exit;
|
||||||
|
}
|
||||||
// 检查管理员权限
|
|
||||||
if (!$_SESSION['is_admin']) {
|
$settingsRepo = new SystemSettingsRepository();
|
||||||
die('权限不足：只有管理员可以访问此页面');
|
// 获取域名设置（放在函数定义之前）
|
||||||
}
|
$domain = $settingsRepo->get('domain', 'test.com');
|
||||||
|
|
||||||
$userRepo = new UserRepository();
|
$userRepo = new UserRepository();
|
||||||
$message = '';
|
$message = '';
|
||||||
$error = '';
|
$error = '';
|
||||||
|
|
||||||
// 处理创建用户
|
// 处理创建用户
|
||||||
if (isset($_POST['create_user'])) {
|
if (isset($_POST['create_user'])) {
|
||||||
$username = trim($_POST['username'] ?? '');
|
$username = trim($_POST['username'] ?? '');
|
||||||
$password = $_POST['password'] ?? '';
|
$password = $_POST['password'] ?? '';
|
||||||
$isAdmin = isset($_POST['is_admin']) ? 1 : 0;
|
$isAdmin = isset($_POST['is_admin']) ? 1 : 0;
|
||||||
$isActive = isset($_POST['is_active']) ? 1 : 0;
|
$isActive = isset($_POST['is_active']) ? 1 : 0;
|
||||||
|
|
||||||
$usernameValidation = Validator::validateUsername($username);
|
$usernameValidation = Validator::validateUsername($username);
|
||||||
if (!$usernameValidation['valid']) {
|
if (!$usernameValidation['valid']) {
|
||||||
$error = implode('<br>', $usernameValidation['errors']);
|
$error = implode('<br>', $usernameValidation['errors']);
|
||||||
} else {
|
} else {
|
||||||
if (!Validator::validateEmailDomain($username, 'test.com')) {
|
if (!Validator::validateEmailDomain($username, $domain)) {
|
||||||
$error = "邮箱域名必须是 @test.com";
|
$error = "邮箱域名必须是 @".$domain;
|
||||||
} else {
|
} else {
|
||||||
$passwordValidation = Validator::validatePassword($password, 6);
|
$passwordValidation = Validator::validatePassword($password, 6);
|
||||||
if (!$passwordValidation['valid']) {
|
if (!$passwordValidation['valid']) {
|
||||||
$error = implode('<br>', $passwordValidation['errors']);
|
$error = implode('<br>', $passwordValidation['errors']);
|
||||||
} else {
|
} else {
|
||||||
try {
|
try {
|
||||||
if ($userRepo->usernameExists($username)) {
|
if ($userRepo->usernameExists($username)) {
|
||||||
$error = "用户名已存在";
|
$error = "用户名已存在";
|
||||||
} else {
|
} else {
|
||||||
$userRepo->create($username, $password, $isAdmin, $isActive);
|
$userRepo->create($username, $password, $isAdmin, $isActive);
|
||||||
$message = "用户创建成功";
|
$message = "用户创建成功";
|
||||||
}
|
}
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
$error = "创建失败: " . $e->getMessage();
|
$error = "创建失败: " . $e->getMessage();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 处理更新用户
|
// 处理更新用户
|
||||||
if (isset($_POST['update_user'])) {
|
if (isset($_POST['update_user'])) {
|
||||||
$userId = (int)$_POST['user_id'];
|
$userId = (int)$_POST['user_id'];
|
||||||
$data = [];
|
$data = [];
|
||||||
|
|
||||||
if (!empty($_POST['new_password'])) {
|
if (!empty($_POST['new_password'])) {
|
||||||
$passwordValidation = Validator::validatePassword($_POST['new_password'], 6);
|
$passwordValidation = Validator::validatePassword($_POST['new_password'], 6);
|
||||||
if (!$passwordValidation['valid']) {
|
if (!$passwordValidation['valid']) {
|
||||||
$error = implode('<br>', $passwordValidation['errors']);
|
$error = implode('<br>', $passwordValidation['errors']);
|
||||||
} else {
|
} else {
|
||||||
$data['password'] = $_POST['new_password'];
|
$data['password'] = $_POST['new_password'];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isset($_POST['is_admin'])) {
|
/**if (isset($_POST['is_admin'])) {
|
||||||
$data['is_admin'] = (int)$_POST['is_admin'];
|
$data['is_admin'] = (int)$_POST['is_admin'];
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isset($_POST['is_active'])) {
|
if (isset($_POST['is_active'])) {
|
||||||
$data['is_active'] = (int)$_POST['is_active'];
|
$data['is_active'] = (int)$_POST['is_active'];
|
||||||
}
|
}**/
|
||||||
|
// 管理员权限总是更新
|
||||||
if (empty($error) && !empty($data)) {
|
$data['is_admin'] = isset($_POST['is_admin']) ? 1 : 0;
|
||||||
if ($userRepo->update($userId, $data)) {
|
|
||||||
$message = "用户更新成功";
|
// 激活状态也是
|
||||||
} else {
|
$data['is_active'] = isset($_POST['is_active']) ? 1 : 0;
|
||||||
$error = "更新失败";
|
|
||||||
}
|
if (empty($error) && !empty($data)) {
|
||||||
}
|
if ($userRepo->update($userId, $data)) {
|
||||||
}
|
$message = "用户更新成功";
|
||||||
|
} else {
|
||||||
// 处理删除用户
|
$error = "更新失败";
|
||||||
if (isset($_GET['delete'])) {
|
}
|
||||||
$userId = (int)$_GET['delete'];
|
}
|
||||||
if ($userId != $_SESSION['user_id']) { // 不能删除自己
|
}
|
||||||
if ($userRepo->delete($userId)) {
|
|
||||||
$message = "用户删除成功";
|
// 处理删除用户
|
||||||
} else {
|
if (isset($_GET['delete'])) {
|
||||||
$error = "删除失败";
|
$userId = (int)$_GET['delete'];
|
||||||
}
|
if ($userId != $_SESSION['user_id']) { // 不能删除自己
|
||||||
} else {
|
if ($userRepo->delete($userId)) {
|
||||||
$error = "不能删除自己的账号";
|
$message = "用户删除成功";
|
||||||
}
|
} else {
|
||||||
}
|
$error = "删除失败";
|
||||||
|
}
|
||||||
// 获取所有用户
|
} else {
|
||||||
$users = $userRepo->getAll();
|
$error = "不能删除自己的账号";
|
||||||
?>
|
}
|
||||||
<!DOCTYPE html>
|
}
|
||||||
<html>
|
|
||||||
<head>
|
// 获取所有用户
|
||||||
<title>用户管理 - 邮件服务器</title>
|
$users = $userRepo->getAll();
|
||||||
<meta charset="UTF-8">
|
?>
|
||||||
<style>
|
<!DOCTYPE html>
|
||||||
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
<html>
|
||||||
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
<head>
|
||||||
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
<title>用户管理 - 邮件服务器</title>
|
||||||
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
<meta charset="UTF-8">
|
||||||
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
<style>
|
||||||
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
body { font-family: Arial, sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
|
||||||
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
.header { background: #007bff; color: white; padding: 15px; margin: -20px -20px 20px -20px; }
|
||||||
table { width: 100%; border-collapse: collapse; margin-top: 20px; }
|
.menu { background: white; padding: 10px; margin-bottom: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
||||||
th, td { border: 1px solid #ddd; padding: 12px; text-align: left; }
|
.menu a { margin-right: 15px; text-decoration: none; color: #007bff; }
|
||||||
th { background: #f8f9fa; font-weight: 600; }
|
.container { background: white; padding: 20px; border-radius: 5px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); }
|
||||||
tr:hover { background: #f8f9fa; }
|
.message { background: #d4edda; color: #155724; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
.btn { padding: 6px 12px; border: none; border-radius: 4px; cursor: pointer; text-decoration: none; display: inline-block; }
|
.error { background: #f8d7da; color: #721c24; padding: 12px; border-radius: 5px; margin-bottom: 20px; }
|
||||||
.btn-primary { background: #007bff; color: white; }
|
table { width: 100%; border-collapse: collapse; margin-top: 20px; }
|
||||||
.btn-danger { background: #dc3545; color: white; }
|
th, td { border: 1px solid #ddd; padding: 12px; text-align: left; }
|
||||||
.btn-success { background: #28a745; color: white; }
|
th { background: #f8f9fa; font-weight: 600; }
|
||||||
.btn-small { padding: 4px 8px; font-size: 12px; }
|
tr:hover { background: #f8f9fa; }
|
||||||
.form-group { margin-bottom: 15px; }
|
.btn { padding: 6px 12px; border: none; border-radius: 4px; cursor: pointer; text-decoration: none; display: inline-block; }
|
||||||
.form-group label { display: block; margin-bottom: 5px; font-weight: 500; }
|
.btn-primary { background: #007bff; color: white; }
|
||||||
.form-group input, .form-group select { width: 100%; padding: 8px; border: 1px solid #ddd; border-radius: 4px; }
|
.btn-danger { background: #dc3545; color: white; }
|
||||||
.form-inline { display: flex; gap: 10px; align-items: flex-end; }
|
.btn-success { background: #28a745; color: white; }
|
||||||
.form-inline .form-group { flex: 1; margin-bottom: 0; }
|
.btn-small { padding: 4px 8px; font-size: 12px; }
|
||||||
.badge { padding: 4px 8px; border-radius: 3px; font-size: 12px; font-weight: 500; }
|
.form-group { margin-bottom: 15px; }
|
||||||
.badge-admin { background: #ffc107; color: #000; }
|
.form-group label { display: block; margin-bottom: 5px; font-weight: 500; }
|
||||||
.badge-active { background: #28a745; color: white; }
|
.form-group input, .form-group select { width: 100%; padding: 8px; border: 1px solid #ddd; border-radius: 4px; }
|
||||||
.badge-inactive { background: #6c757d; color: white; }
|
.form-inline { display: flex; gap: 10px; align-items: flex-end; }
|
||||||
.modal { display: none; position: fixed; z-index: 1000; left: 0; top: 0; width: 100%; height: 100%; background: rgba(0,0,0,0.5); }
|
.form-inline .form-group { flex: 1; margin-bottom: 0; }
|
||||||
.modal-content { background: white; margin: 50px auto; padding: 20px; width: 500px; border-radius: 5px; }
|
.badge { padding: 4px 8px; border-radius: 3px; font-size: 12px; font-weight: 500; }
|
||||||
.close { float: right; font-size: 28px; font-weight: bold; cursor: pointer; }
|
.badge-admin { background: #ffc107; color: #000; }
|
||||||
</style>
|
.badge-active { background: #28a745; color: white; }
|
||||||
</head>
|
.badge-inactive { background: #6c757d; color: white; }
|
||||||
<body>
|
.modal { display: none; position: fixed; z-index: 1000; left: 0; top: 0; width: 100%; height: 100%; background: rgba(0,0,0,0.5); }
|
||||||
<div class="header">
|
.modal-content { background: white; margin: 50px auto; padding: 20px; width: 500px; border-radius: 5px; }
|
||||||
<h1>邮件服务器管理后台</h1>
|
.close { float: right; font-size: 28px; font-weight: bold; cursor: pointer; }
|
||||||
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
</style>
|
||||||
(<a href="logout.php" style="color: white;">退出</a>)
|
</head>
|
||||||
</div>
|
<body>
|
||||||
</div>
|
<div class="header">
|
||||||
|
<h1>邮件服务器管理后台</h1>
|
||||||
<div class="menu">
|
<div>欢迎, <?php echo htmlspecialchars($_SESSION['username']); ?>
|
||||||
<a href="index.php">仪表盘</a>
|
(<a href="logout.php" style="color: white;">退出</a>)
|
||||||
<a href="users.php">用户管理</a>
|
</div>
|
||||||
<a href="emails.php">邮件管理</a>
|
</div>
|
||||||
<a href="filters.php">过滤规则</a>
|
|
||||||
<a href="logs.php">系统日志</a>
|
<div class="menu">
|
||||||
<a href="settings.php">系统设置</a>
|
<a href="index.php">仪表盘</a>
|
||||||
</div>
|
<a href="users.php">用户管理</a>
|
||||||
|
<a href="broadcast.php">群发邮件</a>
|
||||||
<div class="container">
|
<a href="filters.php">过滤规则</a>
|
||||||
<h2>用户管理</h2>
|
<a href="logs.php">系统日志</a>
|
||||||
|
<a href="services.php">服务管理</a>
|
||||||
<?php if ($message): ?>
|
<a href="settings.php">系统设置</a>
|
||||||
<div class="message"><?php echo $message; ?></div>
|
<a href="help.php">帮助</a>
|
||||||
<?php endif; ?>
|
</div>
|
||||||
|
|
||||||
<?php if ($error): ?>
|
<div class="container">
|
||||||
<div class="error"><?php echo $error; ?></div>
|
<h2>用户管理</h2>
|
||||||
<?php endif; ?>
|
|
||||||
|
<?php if ($message): ?>
|
||||||
<!-- 创建用户表单 -->
|
<div class="message"><?php echo $message; ?></div>
|
||||||
<h3>创建新用户</h3>
|
<?php endif; ?>
|
||||||
<form method="POST" class="form-inline">
|
|
||||||
<div class="form-group">
|
<?php if ($error): ?>
|
||||||
<label>邮箱地址</label>
|
<div class="error"><?php echo $error; ?></div>
|
||||||
<input type="email" name="username" placeholder="user@test.com" required>
|
<?php endif; ?>
|
||||||
</div>
|
|
||||||
<div class="form-group">
|
<!-- 创建用户表单 -->
|
||||||
<label>密码</label>
|
<h3>创建新用户</h3>
|
||||||
<input type="password" name="password" placeholder="至少6个字符" required minlength="6">
|
<form method="POST" class="form-inline">
|
||||||
</div>
|
<div class="form-group">
|
||||||
<div class="form-group">
|
<label>邮箱地址</label>
|
||||||
<label>管理员</label>
|
<input type="email" name="username" placeholder="user@<?= htmlspecialchars($domain) ?>" required>
|
||||||
<input type="checkbox" name="is_admin" value="1">
|
</div>
|
||||||
</div>
|
<div class="form-group">
|
||||||
<div class="form-group">
|
<label>密码</label>
|
||||||
<label>激活</label>
|
<input type="password" name="password" placeholder="至少6个字符" required minlength="6">
|
||||||
<input type="checkbox" name="is_active" value="1" checked>
|
</div>
|
||||||
</div>
|
<div class="form-group">
|
||||||
<div class="form-group">
|
<label>管理员</label>
|
||||||
<button type="submit" name="create_user" class="btn btn-primary">创建用户</button>
|
<input type="checkbox" name="is_admin" value="1">
|
||||||
</div>
|
</div>
|
||||||
</form>
|
<div class="form-group">
|
||||||
|
<label>激活</label>
|
||||||
<!-- 用户列表 -->
|
<input type="checkbox" name="is_active" value="1" checked>
|
||||||
<h3>用户列表 (<?php echo count($users); ?>)</h3>
|
</div>
|
||||||
<table>
|
<div class="form-group">
|
||||||
<thead>
|
<button type="submit" name="create_user" class="btn btn-primary">创建用户</button>
|
||||||
<tr>
|
</div>
|
||||||
<th>ID</th>
|
</form>
|
||||||
<th>用户名</th>
|
|
||||||
<th>角色</th>
|
<!-- 用户列表 -->
|
||||||
<th>状态</th>
|
<h3>用户列表 (<?php echo count($users); ?>)</h3>
|
||||||
<th>创建时间</th>
|
<table>
|
||||||
<th>操作</th>
|
<thead>
|
||||||
</tr>
|
<tr>
|
||||||
</thead>
|
<th>ID</th>
|
||||||
<tbody>
|
<th>用户名</th>
|
||||||
<?php foreach ($users as $user): ?>
|
<th>角色</th>
|
||||||
<tr>
|
<th>状态</th>
|
||||||
<td><?php echo $user['id']; ?></td>
|
<th>创建时间</th>
|
||||||
<td><?php echo htmlspecialchars($user['username']); ?></td>
|
<th>操作</th>
|
||||||
<td>
|
</tr>
|
||||||
<?php if ($user['is_admin']): ?>
|
</thead>
|
||||||
<span class="badge badge-admin">管理员</span>
|
<tbody>
|
||||||
<?php else: ?>
|
<?php foreach ($users as $user): ?>
|
||||||
<span>普通用户</span>
|
<tr>
|
||||||
<?php endif; ?>
|
<td><?php echo $user['id']; ?></td>
|
||||||
</td>
|
<td><?php echo htmlspecialchars($user['username']); ?></td>
|
||||||
<td>
|
<td>
|
||||||
<?php if ($user['is_active']): ?>
|
<?php if ($user['is_admin']): ?>
|
||||||
<span class="badge badge-active">激活</span>
|
<span class="badge badge-admin">管理员</span>
|
||||||
<?php else: ?>
|
<?php else: ?>
|
||||||
<span class="badge badge-inactive">禁用</span>
|
<span>普通用户</span>
|
||||||
<?php endif; ?>
|
<?php endif; ?>
|
||||||
</td>
|
</td>
|
||||||
<td><?php echo $user['created_at']; ?></td>
|
<td>
|
||||||
<td>
|
<?php if ($user['is_active']): ?>
|
||||||
<a href="#" onclick="editUser(<?php echo htmlspecialchars(json_encode($user)); ?>); return false;" class="btn btn-primary btn-small">编辑</a>
|
<span class="badge badge-active">激活</span>
|
||||||
<?php if ($user['id'] != $_SESSION['user_id']): ?>
|
<?php else: ?>
|
||||||
<a href="?delete=<?php echo $user['id']; ?>" class="btn btn-danger btn-small" onclick="return confirm('确定要删除此用户吗？');">删除</a>
|
<span class="badge badge-inactive">禁用</span>
|
||||||
<?php endif; ?>
|
<?php endif; ?>
|
||||||
</td>
|
</td>
|
||||||
</tr>
|
<td><?php echo $user['created_at']; ?></td>
|
||||||
<?php endforeach; ?>
|
<td>
|
||||||
</tbody>
|
<a href="#" onclick="editUser(<?php echo htmlspecialchars(json_encode($user)); ?>); return false;" class="btn btn-primary btn-small">编辑</a>
|
||||||
</table>
|
<?php if ($user['id'] != $_SESSION['user_id']): ?>
|
||||||
</div>
|
<a href="?delete=<?php echo $user['id']; ?>" class="btn btn-danger btn-small" onclick="return confirm('确定要删除此用户吗？');">删除</a>
|
||||||
|
<?php endif; ?>
|
||||||
<!-- 编辑用户模态框 -->
|
</td>
|
||||||
<div id="editModal" class="modal">
|
</tr>
|
||||||
<div class="modal-content">
|
<?php endforeach; ?>
|
||||||
<span class="close" onclick="closeModal()">×</span>
|
</tbody>
|
||||||
<h3>编辑用户</h3>
|
</table>
|
||||||
<form method="POST">
|
</div>
|
||||||
<input type="hidden" name="user_id" id="edit_user_id">
|
|
||||||
<div class="form-group">
|
<!-- 编辑用户模态框 -->
|
||||||
<label>用户名</label>
|
<div id="editModal" class="modal">
|
||||||
<input type="text" id="edit_username" readonly style="background: #f5f5f5;">
|
<div class="modal-content">
|
||||||
</div>
|
<span class="close" onclick="closeModal()">×</span>
|
||||||
<div class="form-group">
|
<h3>编辑用户</h3>
|
||||||
<label>新密码（留空则不修改）</label>
|
<form method="POST">
|
||||||
<input type="password" name="new_password" placeholder="留空则不修改">
|
<input type="hidden" name="user_id" id="edit_user_id">
|
||||||
</div>
|
<div class="form-group">
|
||||||
<div class="form-group">
|
<label>用户名</label>
|
||||||
<label>
|
<input type="text" id="edit_username" readonly style="background: #f5f5f5;">
|
||||||
<input type="checkbox" name="is_admin" id="edit_is_admin" value="1"> 管理员
|
</div>
|
||||||
</label>
|
<div class="form-group">
|
||||||
</div>
|
<label>新密码（留空则不修改）</label>
|
||||||
<div class="form-group">
|
<input type="password" name="new_password" placeholder="留空则不修改">
|
||||||
<label>
|
</div>
|
||||||
<input type="checkbox" name="is_active" id="edit_is_active" value="1"> 激活
|
<div class="form-group">
|
||||||
</label>
|
<label>
|
||||||
</div>
|
<input type="checkbox" name="is_admin" id="edit_is_admin" value="1"> 管理员
|
||||||
<button type="submit" name="update_user" class="btn btn-success">保存</button>
|
</label>
|
||||||
<button type="button" onclick="closeModal()" class="btn">取消</button>
|
</div>
|
||||||
</form>
|
<div class="form-group">
|
||||||
</div>
|
<label>
|
||||||
</div>
|
<input type="checkbox" name="is_active" id="edit_is_active" value="1"> 激活
|
||||||
|
</label>
|
||||||
<script>
|
</div>
|
||||||
function editUser(user) {
|
<button type="submit" name="update_user" class="btn btn-success">保存</button>
|
||||||
document.getElementById('edit_user_id').value = user.id;
|
<button type="button" onclick="closeModal()" class="btn">取消</button>
|
||||||
document.getElementById('edit_username').value = user.username;
|
</form>
|
||||||
document.getElementById('edit_is_admin').checked = user.is_admin == 1;
|
</div>
|
||||||
document.getElementById('edit_is_active').checked = user.is_active == 1;
|
</div>
|
||||||
document.getElementById('editModal').style.display = 'block';
|
|
||||||
}
|
<script>
|
||||||
|
function editUser(user) {
|
||||||
function closeModal() {
|
document.getElementById('edit_user_id').value = user.id;
|
||||||
document.getElementById('editModal').style.display = 'none';
|
document.getElementById('edit_username').value = user.username;
|
||||||
}
|
document.getElementById('edit_is_admin').checked = user.is_admin == 1;
|
||||||
|
document.getElementById('edit_is_active').checked = user.is_active == 1;
|
||||||
window.onclick = function(event) {
|
document.getElementById('editModal').style.display = 'block';
|
||||||
var modal = document.getElementById('editModal');
|
}
|
||||||
if (event.target == modal) {
|
|
||||||
closeModal();
|
function closeModal() {
|
||||||
}
|
document.getElementById('editModal').style.display = 'none';
|
||||||
}
|
}
|
||||||
</script>
|
|
||||||
</body>
|
window.onclick = function(event) {
|
||||||
</html>
|
var modal = document.getElementById('editModal');
|
||||||
|
if (event.target == modal) {
|
||||||
|
closeModal();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
</script>
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
|
|
||||||
|
|||||||
@ -1,106 +1,106 @@
|
|||||||
<?php
|
<?php
|
||||||
/**
|
/**
|
||||||
* 测试用户注册功能
|
* 测试用户注册功能
|
||||||
* 用法: php scripts/test_register.php
|
* 用法: php scripts/test_register.php
|
||||||
*/
|
*/
|
||||||
|
|
||||||
require_once __DIR__ . '/../config/database.php';
|
require_once __DIR__ . '/../config/database.php';
|
||||||
require_once __DIR__ . '/../src/storage/Database.php';
|
require_once __DIR__ . '/../src/storage/Database.php';
|
||||||
require_once __DIR__ . '/../src/storage/UserRepository.php';
|
require_once __DIR__ . '/../src/storage/UserRepository.php';
|
||||||
require_once __DIR__ . '/../src/utils/Validator.php';
|
require_once __DIR__ . '/../src/utils/Validator.php';
|
||||||
require_once __DIR__ . '/../src/utils/Security.php';
|
require_once __DIR__ . '/../src/utils/Security.php';
|
||||||
|
|
||||||
echo "=== 用户注册功能测试 ===\n\n";
|
echo "=== 用户注册功能测试 ===\n\n";
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$userRepo = new UserRepository();
|
$userRepo = new UserRepository();
|
||||||
|
|
||||||
// 测试1: 验证邮箱格式
|
// 测试1: 验证邮箱格式
|
||||||
echo "测试1: 验证邮箱格式\n";
|
echo "测试1: 验证邮箱格式\n";
|
||||||
$testEmails = [
|
$testEmails = [
|
||||||
'valid@test.com' => true,
|
'valid@test.com' => true,
|
||||||
'invalid-email' => false,
|
'invalid-email' => false,
|
||||||
'test@test.com' => true,
|
'test@test.com' => true,
|
||||||
'user@wrong.com' => false,
|
'user@wrong.com' => false,
|
||||||
];
|
];
|
||||||
|
|
||||||
foreach ($testEmails as $email => $expected) {
|
foreach ($testEmails as $email => $expected) {
|
||||||
$isValid = Validator::validateEmail($email);
|
$isValid = Validator::validateEmail($email);
|
||||||
$domainValid = Validator::validateEmailDomain($email, 'test.com');
|
$domainValid = Validator::validateEmailDomain($email, 'test.com');
|
||||||
$result = $isValid && ($expected ? $domainValid : !$domainValid);
|
$result = $isValid && ($expected ? $domainValid : !$domainValid);
|
||||||
echo " {$email}: " . ($result ? "✓" : "✗") . "\n";
|
echo " {$email}: " . ($result ? "✓" : "✗") . "\n";
|
||||||
}
|
}
|
||||||
|
|
||||||
// 测试2: 验证密码强度
|
// 测试2: 验证密码强度
|
||||||
echo "\n测试2: 验证密码强度\n";
|
echo "\n测试2: 验证密码强度\n";
|
||||||
$testPasswords = [
|
$testPasswords = [
|
||||||
'12345' => false, // 太短
|
'12345' => false, // 太短
|
||||||
'123456' => true, // 符合最小长度
|
'123456' => true, // 符合最小长度
|
||||||
'password123' => true,
|
'password123' => true,
|
||||||
];
|
];
|
||||||
|
|
||||||
foreach ($testPasswords as $password => $expected) {
|
foreach ($testPasswords as $password => $expected) {
|
||||||
$validation = Validator::validatePassword($password, 6);
|
$validation = Validator::validatePassword($password, 6);
|
||||||
$result = $validation['valid'] === $expected;
|
$result = $validation['valid'] === $expected;
|
||||||
echo " '{$password}': " . ($result ? "✓" : "✗") . "\n";
|
echo " '{$password}': " . ($result ? "✓" : "✗") . "\n";
|
||||||
if (!$validation['valid']) {
|
if (!$validation['valid']) {
|
||||||
echo " 错误: " . implode(', ', $validation['errors']) . "\n";
|
echo " 错误: " . implode(', ', $validation['errors']) . "\n";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 测试3: 检查用户名是否存在
|
// 测试3: 检查用户名是否存在
|
||||||
echo "\n测试3: 检查用户名是否存在\n";
|
echo "\n测试3: 检查用户名是否存在\n";
|
||||||
$existingUser = $userRepo->findByUsername('admin@test.com');
|
$existingUser = $userRepo->findByUsername('admin@test.com');
|
||||||
if ($existingUser) {
|
if ($existingUser) {
|
||||||
echo " admin@test.com 存在: ✓\n";
|
echo " admin@test.com 存在: ✓\n";
|
||||||
} else {
|
} else {
|
||||||
echo " admin@test.com 不存在: ✗\n";
|
echo " admin@test.com 不存在: ✗\n";
|
||||||
}
|
}
|
||||||
|
|
||||||
// 测试4: 创建测试用户（如果不存在）
|
// 测试4: 创建测试用户（如果不存在）
|
||||||
echo "\n测试4: 创建测试用户\n";
|
echo "\n测试4: 创建测试用户\n";
|
||||||
$testUsername = 'testuser@test.com';
|
$testUsername = 'testuser@test.com';
|
||||||
|
|
||||||
if ($userRepo->usernameExists($testUsername)) {
|
if ($userRepo->usernameExists($testUsername)) {
|
||||||
echo " 测试用户已存在，跳过创建\n";
|
echo " 测试用户已存在，跳过创建\n";
|
||||||
} else {
|
} else {
|
||||||
try {
|
try {
|
||||||
$newUser = $userRepo->create($testUsername, 'test123456', false, true);
|
$newUser = $userRepo->create($testUsername, 'test123456', false, true);
|
||||||
echo " 创建用户成功: ✓\n";
|
echo " 创建用户成功: ✓\n";
|
||||||
echo " 用户ID: {$newUser['id']}\n";
|
echo " 用户ID: {$newUser['id']}\n";
|
||||||
echo " 用户名: {$newUser['username']}\n";
|
echo " 用户名: {$newUser['username']}\n";
|
||||||
echo " 是否管理员: " . ($newUser['is_admin'] ? '是' : '否') . "\n";
|
echo " 是否管理员: " . ($newUser['is_admin'] ? '是' : '否') . "\n";
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
echo " 创建用户失败: ✗ - " . $e->getMessage() . "\n";
|
echo " 创建用户失败: ✗ - " . $e->getMessage() . "\n";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 测试5: 验证密码
|
// 测试5: 验证密码
|
||||||
echo "\n测试5: 验证密码\n";
|
echo "\n测试5: 验证密码\n";
|
||||||
$testUser = $userRepo->findByUsername($testUsername);
|
$testUser = $userRepo->findByUsername($testUsername);
|
||||||
if ($testUser) {
|
if ($testUser) {
|
||||||
$verified = $userRepo->verifyPassword($testUsername, 'test123456');
|
$verified = $userRepo->verifyPassword($testUsername, 'test123456');
|
||||||
if ($verified) {
|
if ($verified) {
|
||||||
echo " 密码验证成功: ✓\n";
|
echo " 密码验证成功: ✓\n";
|
||||||
} else {
|
} else {
|
||||||
echo " 密码验证失败: ✗\n";
|
echo " 密码验证失败: ✗\n";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 测试6: 获取所有用户
|
// 测试6: 获取所有用户
|
||||||
echo "\n测试6: 获取用户列表\n";
|
echo "\n测试6: 获取用户列表\n";
|
||||||
$users = $userRepo->getAll(10);
|
$users = $userRepo->getAll(10);
|
||||||
echo " 用户总数: " . count($users) . "\n";
|
echo " 用户总数: " . count($users) . "\n";
|
||||||
foreach ($users as $user) {
|
foreach ($users as $user) {
|
||||||
echo " - {$user['username']} (ID: {$user['id']}, " .
|
echo " - {$user['username']} (ID: {$user['id']}, " .
|
||||||
($user['is_admin'] ? '管理员' : '普通用户') . ", " .
|
($user['is_admin'] ? '管理员' : '普通用户') . ", " .
|
||||||
($user['is_active'] ? '激活' : '禁用') . ")\n";
|
($user['is_active'] ? '激活' : '禁用') . ")\n";
|
||||||
}
|
}
|
||||||
|
|
||||||
echo "\n=== 测试完成 ===\n";
|
echo "\n=== 测试完成 ===\n";
|
||||||
|
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
echo "错误: " . $e->getMessage() . "\n";
|
echo "错误: " . $e->getMessage() . "\n";
|
||||||
echo "堆栈跟踪:\n" . $e->getTraceAsString() . "\n";
|
echo "堆栈跟踪:\n" . $e->getTraceAsString() . "\n";
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -1 +0,0 @@
|
|||||||
//处理管理请求
|
|
||||||
@ -1,150 +1,150 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/../storage/Database.php';
|
require_once __DIR__ . '/../storage/Database.php';
|
||||||
require_once __DIR__ . '/../storage/UserRepository.php';
|
require_once __DIR__ . '/../storage/UserRepository.php';
|
||||||
require_once __DIR__ . '/../storage/EmailRepository.php';
|
require_once __DIR__ . '/../storage/EmailRepository.php';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 群发邮件服务
|
* 群发邮件服务
|
||||||
*/
|
*/
|
||||||
class BroadcastService {
|
class BroadcastService {
|
||||||
private $db;
|
private $db;
|
||||||
private $userRepo;
|
private $userRepo;
|
||||||
private $emailRepo;
|
private $emailRepo;
|
||||||
|
|
||||||
public function __construct() {
|
public function __construct() {
|
||||||
$this->db = Database::getInstance();
|
$this->db = Database::getInstance();
|
||||||
$this->userRepo = new UserRepository();
|
$this->userRepo = new UserRepository();
|
||||||
$this->emailRepo = new EmailRepository();
|
$this->emailRepo = new EmailRepository();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 群发邮件给所有用户
|
* 群发邮件给所有用户
|
||||||
* @param string $senderEmail 发件人邮箱
|
* @param string $senderEmail 发件人邮箱
|
||||||
* @param string $subject 主题
|
* @param string $subject 主题
|
||||||
* @param string $body 内容
|
* @param string $body 内容
|
||||||
* @return array ['success' => int, 'failed' => int, 'errors' => array]
|
* @return array ['success' => int, 'failed' => int, 'errors' => array]
|
||||||
*/
|
*/
|
||||||
public function broadcastToAll($senderEmail, $subject, $body) {
|
public function broadcastToAll($senderEmail, $subject, $body) {
|
||||||
$users = $this->userRepo->getAll();
|
$users = $this->userRepo->getAll();
|
||||||
$sender = $this->userRepo->findByUsername($senderEmail);
|
$sender = $this->userRepo->findByUsername($senderEmail);
|
||||||
|
|
||||||
if (!$sender) {
|
if (!$sender) {
|
||||||
return ['success' => 0, 'failed' => 0, 'errors' => ['发件人不存在']];
|
return ['success' => 0, 'failed' => 0, 'errors' => ['发件人不存在']];
|
||||||
}
|
}
|
||||||
|
|
||||||
$success = 0;
|
$success = 0;
|
||||||
$failed = 0;
|
$failed = 0;
|
||||||
$errors = [];
|
$errors = [];
|
||||||
|
|
||||||
foreach ($users as $user) {
|
foreach ($users as $user) {
|
||||||
// 跳过发件人自己
|
// 跳过发件人自己
|
||||||
if ($user['username'] === $senderEmail) {
|
if ($user['username'] === $senderEmail) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 跳过禁用的用户
|
// 跳过禁用的用户
|
||||||
if (!$user['is_active']) {
|
if (!$user['is_active']) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$this->sendEmail($sender['id'], $user['id'], $subject, $body);
|
$this->sendEmail($sender['id'], $user['id'], $subject, $body);
|
||||||
$success++;
|
$success++;
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
$failed++;
|
$failed++;
|
||||||
$errors[] = "发送给 {$user['username']} 失败: " . $e->getMessage();
|
$errors[] = "发送给 {$user['username']} 失败: " . $e->getMessage();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return [
|
return [
|
||||||
'success' => $success,
|
'success' => $success,
|
||||||
'failed' => $failed,
|
'failed' => $failed,
|
||||||
'errors' => $errors
|
'errors' => $errors
|
||||||
];
|
];
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 群发邮件给指定用户列表
|
* 群发邮件给指定用户列表
|
||||||
* @param string $senderEmail 发件人邮箱
|
* @param string $senderEmail 发件人邮箱
|
||||||
* @param array $recipientEmails 收件人邮箱列表
|
* @param array $recipientEmails 收件人邮箱列表
|
||||||
* @param string $subject 主题
|
* @param string $subject 主题
|
||||||
* @param string $body 内容
|
* @param string $body 内容
|
||||||
* @return array ['success' => int, 'failed' => int, 'errors' => array]
|
* @return array ['success' => int, 'failed' => int, 'errors' => array]
|
||||||
*/
|
*/
|
||||||
public function broadcastToUsers($senderEmail, $recipientEmails, $subject, $body) {
|
public function broadcastToUsers($senderEmail, $recipientEmails, $subject, $body) {
|
||||||
$sender = $this->userRepo->findByUsername($senderEmail);
|
$sender = $this->userRepo->findByUsername($senderEmail);
|
||||||
|
|
||||||
if (!$sender) {
|
if (!$sender) {
|
||||||
return ['success' => 0, 'failed' => 0, 'errors' => ['发件人不存在']];
|
return ['success' => 0, 'failed' => 0, 'errors' => ['发件人不存在']];
|
||||||
}
|
}
|
||||||
|
|
||||||
$success = 0;
|
$success = 0;
|
||||||
$failed = 0;
|
$failed = 0;
|
||||||
$errors = [];
|
$errors = [];
|
||||||
|
|
||||||
foreach ($recipientEmails as $email) {
|
foreach ($recipientEmails as $email) {
|
||||||
$recipient = $this->userRepo->findByUsername(trim($email));
|
$recipient = $this->userRepo->findByUsername(trim($email));
|
||||||
|
|
||||||
if (!$recipient) {
|
if (!$recipient) {
|
||||||
$failed++;
|
$failed++;
|
||||||
$errors[] = "用户 {$email} 不存在";
|
$errors[] = "用户 {$email} 不存在";
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!$recipient['is_active']) {
|
if (!$recipient['is_active']) {
|
||||||
$failed++;
|
$failed++;
|
||||||
$errors[] = "用户 {$email} 已被禁用";
|
$errors[] = "用户 {$email} 已被禁用";
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$this->sendEmail($sender['id'], $recipient['id'], $subject, $body);
|
$this->sendEmail($sender['id'], $recipient['id'], $subject, $body);
|
||||||
$success++;
|
$success++;
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
$failed++;
|
$failed++;
|
||||||
$errors[] = "发送给 {$email} 失败: " . $e->getMessage();
|
$errors[] = "发送给 {$email} 失败: " . $e->getMessage();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return [
|
return [
|
||||||
'success' => $success,
|
'success' => $success,
|
||||||
'failed' => $failed,
|
'failed' => $failed,
|
||||||
'errors' => $errors
|
'errors' => $errors
|
||||||
];
|
];
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 发送邮件
|
* 发送邮件
|
||||||
* @param int $senderId 发件人ID
|
* @param int $senderId 发件人ID
|
||||||
* @param int $recipientId 收件人ID
|
* @param int $recipientId 收件人ID
|
||||||
* @param string $subject 主题
|
* @param string $subject 主题
|
||||||
* @param string $body 内容
|
* @param string $body 内容
|
||||||
* @return bool 是否成功
|
* @return bool 是否成功
|
||||||
*/
|
*/
|
||||||
private function sendEmail($senderId, $recipientId, $subject, $body) {
|
private function sendEmail($senderId, $recipientId, $subject, $body) {
|
||||||
$sender = $this->userRepo->findById($senderId);
|
$sender = $this->userRepo->findById($senderId);
|
||||||
$recipient = $this->userRepo->findById($recipientId);
|
$recipient = $this->userRepo->findById($recipientId);
|
||||||
|
|
||||||
if (!$sender || !$recipient) {
|
if (!$sender || !$recipient) {
|
||||||
throw new Exception("发件人或收件人不存在");
|
throw new Exception("发件人或收件人不存在");
|
||||||
}
|
}
|
||||||
|
|
||||||
$sizeBytes = strlen($subject) + strlen($body);
|
$sizeBytes = strlen($subject) + strlen($body);
|
||||||
|
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
INSERT INTO emails (sender_id, recipient_id, sender, recipient, subject, body, size_bytes, created_at)
|
INSERT INTO emails (sender_id, recipient_id, sender, recipient, subject, body, size_bytes, created_at)
|
||||||
VALUES (?, ?, ?, ?, ?, ?, ?, NOW())
|
VALUES (?, ?, ?, ?, ?, ?, ?, NOW())
|
||||||
");
|
");
|
||||||
|
|
||||||
return $stmt->execute([
|
return $stmt->execute([
|
||||||
$senderId,
|
$senderId,
|
||||||
$recipientId,
|
$recipientId,
|
||||||
$sender['username'],
|
$sender['username'],
|
||||||
$recipient['username'],
|
$recipient['username'],
|
||||||
$subject,
|
$subject,
|
||||||
$body,
|
$body,
|
||||||
$sizeBytes
|
$sizeBytes
|
||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -0,0 +1,32 @@
|
|||||||
|
<?php
|
||||||
|
require_once __DIR__ . '/../storage/Database.php';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 一次性把 users.username 中 @oldDomain 批量替换成 @newDomain
|
||||||
|
*/
|
||||||
|
class SyncDomainService
|
||||||
|
{
|
||||||
|
private $db;
|
||||||
|
public function __construct()
|
||||||
|
{
|
||||||
|
$this->db = Database::getInstance();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @return int 实际被更新的用户数
|
||||||
|
*/
|
||||||
|
public function run(string $oldDomain, string $newDomain): int
|
||||||
|
{
|
||||||
|
// 防止注入，直接用 REPLACE 函数最省事
|
||||||
|
$sql = "UPDATE users
|
||||||
|
SET username = REPLACE(username, :old, :new)
|
||||||
|
WHERE username LIKE :like";
|
||||||
|
$stmt = $this->db->prepare($sql);
|
||||||
|
$stmt->execute([
|
||||||
|
':old' => '@' . $oldDomain,
|
||||||
|
':new' => '@' . $newDomain,
|
||||||
|
':like' => '%@' . $oldDomain
|
||||||
|
]);
|
||||||
|
return $stmt->rowCount();
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -1 +0,0 @@
|
|||||||
// 管理后台网页" - 网页界面
|
|
||||||
@ -1,114 +1,121 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/Database.php';
|
require_once __DIR__ . '/Database.php';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 过滤规则数据访问层
|
* 过滤规则数据访问层
|
||||||
*/
|
*/
|
||||||
class FilterRepository {
|
class FilterRepository {
|
||||||
private $db;
|
private $db;
|
||||||
|
|
||||||
public function __construct() {
|
public function __construct() {
|
||||||
$this->db = Database::getInstance();
|
$this->db = Database::getInstance();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 创建过滤规则
|
* 创建过滤规则
|
||||||
* @param string $type 规则类型 ('email' 或 'ip')
|
* @param string $type 规则类型 ('email' 或 'ip')
|
||||||
* @param string $value 规则值
|
* @param string $value 规则值
|
||||||
* @param string $action 动作 ('block' 或 'allow')
|
* @param string $action 动作 ('block' 或 'allow')
|
||||||
* @param string $description 描述
|
* @param string $description 描述
|
||||||
* @return bool 是否成功
|
* @return bool 是否成功
|
||||||
*/
|
*/
|
||||||
public function create($type, $value, $action = 'block', $description = '') {
|
public function create($type, $value, $action = 'block', $description = '') {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
INSERT INTO filter_rules (rule_type, rule_value, action, description, is_active)
|
INSERT INTO filter_rules (rule_type, rule_value, action, description, is_active)
|
||||||
VALUES (?, ?, ?, ?, 1)
|
VALUES (?, ?, ?, ?, 1)
|
||||||
");
|
");
|
||||||
return $stmt->execute([$type, $value, $action, $description]);
|
return $stmt->execute([$type, $value, $action, $description]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取所有过滤规则
|
* 获取所有过滤规则
|
||||||
* @return array 规则列表
|
* @return array 规则列表
|
||||||
*/
|
*/
|
||||||
public function getAll() {
|
public function getAll() {
|
||||||
$stmt = $this->db->query("
|
$stmt = $this->db->query("
|
||||||
SELECT * FROM filter_rules
|
SELECT * FROM filter_rules
|
||||||
ORDER BY rule_type, created_at DESC
|
ORDER BY rule_type, created_at DESC
|
||||||
");
|
");
|
||||||
return $stmt->fetchAll();
|
return $stmt->fetchAll();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取激活的过滤规则
|
* 获取激活的过滤规则
|
||||||
* @return array 规则列表
|
* @return array 规则列表
|
||||||
*/
|
*/
|
||||||
public function getActive() {
|
public function getActive() {
|
||||||
$stmt = $this->db->query("
|
$stmt = $this->db->query("
|
||||||
SELECT * FROM filter_rules
|
SELECT * FROM filter_rules
|
||||||
WHERE is_active = 1
|
WHERE is_active = 1
|
||||||
ORDER BY rule_type, created_at DESC
|
ORDER BY rule_type, created_at DESC
|
||||||
");
|
");
|
||||||
return $stmt->fetchAll();
|
return $stmt->fetchAll();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 检查邮箱是否被过滤
|
* 检查邮箱是否被过滤
|
||||||
* @param string $email 邮箱地址
|
* @param string $email 邮箱地址
|
||||||
* @return bool 是否被阻止
|
* @return bool 是否被阻止
|
||||||
*/
|
*/
|
||||||
public function isEmailBlocked($email) {
|
public function isEmailBlocked($email) {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
SELECT action FROM filter_rules
|
SELECT action FROM filter_rules
|
||||||
WHERE rule_type = 'email'
|
WHERE rule_type = 'email'
|
||||||
AND is_active = 1
|
AND is_active = 1
|
||||||
AND (rule_value = ? OR rule_value LIKE ?)
|
AND (rule_value = ? OR rule_value LIKE ?)
|
||||||
ORDER BY action DESC
|
ORDER BY action DESC
|
||||||
LIMIT 1
|
LIMIT 1
|
||||||
");
|
");
|
||||||
$stmt->execute([$email, $email]);
|
$stmt->execute([$email, $email]);
|
||||||
$result = $stmt->fetch();
|
$result = $stmt->fetch();
|
||||||
return $result && $result['action'] === 'block';
|
return $result && $result['action'] === 'block';
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 检查IP是否被过滤
|
* 检查IP是否被过滤
|
||||||
* @param string $ip IP地址
|
* @param string $ip IP地址
|
||||||
* @return bool 是否被阻止
|
* @return bool 是否被阻止
|
||||||
*/
|
*/
|
||||||
public function isIPBlocked($ip) {
|
public function isIPBlocked($ip) {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
SELECT action FROM filter_rules
|
SELECT action FROM filter_rules
|
||||||
WHERE rule_type = 'ip'
|
WHERE rule_type = 'ip'
|
||||||
AND is_active = 1
|
AND is_active = 1
|
||||||
AND rule_value = ?
|
AND rule_value = ?
|
||||||
ORDER BY action DESC
|
ORDER BY action DESC
|
||||||
LIMIT 1
|
LIMIT 1
|
||||||
");
|
");
|
||||||
$stmt->execute([$ip]);
|
$stmt->execute([$ip]);
|
||||||
$result = $stmt->fetch();
|
$result = $stmt->fetch();
|
||||||
return $result && $result['action'] === 'block';
|
return $result && $result['action'] === 'block';
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 删除规则
|
* 删除规则
|
||||||
* @param int $id 规则ID
|
* @param int $id 规则ID
|
||||||
* @return bool 是否成功
|
* @return bool 是否成功
|
||||||
*/
|
*/
|
||||||
public function delete($id) {
|
public function delete($id) {
|
||||||
$stmt = $this->db->prepare("DELETE FROM filter_rules WHERE id = ?");
|
$stmt = $this->db->prepare("DELETE FROM filter_rules WHERE id = ?");
|
||||||
return $stmt->execute([$id]);
|
return $stmt->execute([$id]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 更新规则状态
|
* 更新规则状态
|
||||||
* @param int $id 规则ID
|
* @param int $id 规则ID
|
||||||
* @param bool $isActive 是否激活
|
* @param bool $isActive 是否激活
|
||||||
* @return bool 是否成功
|
* @return bool 是否成功
|
||||||
*/
|
*/
|
||||||
public function updateStatus($id, $isActive) {
|
public function updateStatus($id, $isActive) {
|
||||||
$stmt = $this->db->prepare("UPDATE filter_rules SET is_active = ? WHERE id = ?");
|
$stmt = $this->db->prepare("UPDATE filter_rules SET is_active = ? WHERE id = ?");
|
||||||
return $stmt->execute([$isActive ? 1 : 0, $id]);
|
return $stmt->execute([$isActive ? 1 : 0, $id]);
|
||||||
}
|
$this->db->commit();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function getById(int $id): ?array
|
||||||
|
{
|
||||||
|
$stmt = $this->db->prepare("SELECT * FROM filter_rules WHERE id = ? LIMIT 1");
|
||||||
|
$stmt->execute([$id]);
|
||||||
|
return $stmt->fetch() ?: null;
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -1,84 +1,84 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/Database.php';
|
require_once __DIR__ . '/Database.php';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 邮箱管理数据访问层
|
* 邮箱管理数据访问层
|
||||||
*
|
*
|
||||||
* @package storage
|
* @package storage
|
||||||
*/
|
*/
|
||||||
class MailboxRepository {
|
class MailboxRepository {
|
||||||
private $db;
|
private $db;
|
||||||
|
|
||||||
public function __construct() {
|
public function __construct() {
|
||||||
$this->db = Database::getInstance();
|
$this->db = Database::getInstance();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取用户邮箱大小限制
|
* 获取用户邮箱大小限制
|
||||||
* @param int $userId 用户ID
|
* @param int $userId 用户ID
|
||||||
* @return int 大小限制（字节）
|
* @return int 大小限制（字节）
|
||||||
*/
|
*/
|
||||||
public function getSizeLimit($userId) {
|
public function getSizeLimit($userId) {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
SELECT size_limit_bytes FROM user_mailbox_limits WHERE user_id = ?
|
SELECT size_limit_bytes FROM user_mailbox_limits WHERE user_id = ?
|
||||||
");
|
");
|
||||||
$stmt->execute([$userId]);
|
$stmt->execute([$userId]);
|
||||||
$result = $stmt->fetch();
|
$result = $stmt->fetch();
|
||||||
|
|
||||||
if ($result) {
|
if ($result) {
|
||||||
return (int)$result['size_limit_bytes'];
|
return (int)$result['size_limit_bytes'];
|
||||||
}
|
}
|
||||||
|
|
||||||
// 返回默认值
|
// 返回默认值
|
||||||
return 104857600; // 100MB
|
return 104857600; // 100MB
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 设置用户邮箱大小限制
|
* 设置用户邮箱大小限制
|
||||||
* @param int $userId 用户ID
|
* @param int $userId 用户ID
|
||||||
* @param int $sizeBytes 大小限制（字节）
|
* @param int $sizeBytes 大小限制（字节）
|
||||||
* @return bool 是否成功
|
* @return bool 是否成功
|
||||||
*/
|
*/
|
||||||
public function setSizeLimit($userId, $sizeBytes) {
|
public function setSizeLimit($userId, $sizeBytes) {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
INSERT INTO user_mailbox_limits (user_id, size_limit_bytes)
|
INSERT INTO user_mailbox_limits (user_id, size_limit_bytes)
|
||||||
VALUES (?, ?)
|
VALUES (?, ?)
|
||||||
ON DUPLICATE KEY UPDATE size_limit_bytes = VALUES(size_limit_bytes)
|
ON DUPLICATE KEY UPDATE size_limit_bytes = VALUES(size_limit_bytes)
|
||||||
");
|
");
|
||||||
return $stmt->execute([$userId, $sizeBytes]);
|
return $stmt->execute([$userId, $sizeBytes]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取用户当前邮箱使用大小
|
* 获取用户当前邮箱使用大小
|
||||||
* @param int $userId 用户ID
|
* @param int $userId 用户ID
|
||||||
* @return int 已使用大小（字节）
|
* @return int 已使用大小（字节）
|
||||||
*/
|
*/
|
||||||
public function getUsedSize($userId) {
|
public function getUsedSize($userId) {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
SELECT COALESCE(SUM(size_bytes), 0) as total_size
|
SELECT COALESCE(SUM(size_bytes), 0) as total_size
|
||||||
FROM emails
|
FROM emails
|
||||||
WHERE recipient_id = ? AND is_deleted = 0
|
WHERE recipient_id = ? AND is_deleted = 0
|
||||||
");
|
");
|
||||||
$stmt->execute([$userId]);
|
$stmt->execute([$userId]);
|
||||||
$result = $stmt->fetch();
|
$result = $stmt->fetch();
|
||||||
return (int)($result['total_size'] ?? 0);
|
return (int)($result['total_size'] ?? 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取用户邮箱使用情况
|
* 获取用户邮箱使用情况
|
||||||
* @param int $userId 用户ID
|
* @param int $userId 用户ID
|
||||||
* @return array ['limit' => int, 'used' => int, 'percentage' => float]
|
* @return array ['limit' => int, 'used' => int, 'percentage' => float]
|
||||||
*/
|
*/
|
||||||
public function getUsage($userId) {
|
public function getUsage($userId) {
|
||||||
$limit = $this->getSizeLimit($userId);
|
$limit = $this->getSizeLimit($userId);
|
||||||
$used = $this->getUsedSize($userId);
|
$used = $this->getUsedSize($userId);
|
||||||
$percentage = $limit > 0 ? ($used / $limit) * 100 : 0;
|
$percentage = $limit > 0 ? ($used / $limit) * 100 : 0;
|
||||||
|
|
||||||
return [
|
return [
|
||||||
'limit' => $limit,
|
'limit' => $limit,
|
||||||
'used' => $used,
|
'used' => $used,
|
||||||
'percentage' => round($percentage, 2)
|
'percentage' => round($percentage, 2)
|
||||||
];
|
];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -1,79 +1,79 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/Database.php';
|
require_once __DIR__ . '/Database.php';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 服务状态数据访问层
|
* 服务状态数据访问层
|
||||||
*/
|
*/
|
||||||
class ServiceRepository {
|
class ServiceRepository {
|
||||||
private $db;
|
private $db;
|
||||||
|
|
||||||
public function __construct() {
|
public function __construct() {
|
||||||
$this->db = Database::getInstance();
|
$this->db = Database::getInstance();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取服务状态
|
* 获取服务状态
|
||||||
* @param string $serviceName 服务名称 ('smtp' 或 'pop3')
|
* @param string $serviceName 服务名称 ('smtp' 或 'pop3')
|
||||||
* @return array|null 服务状态或null
|
* @return array|null 服务状态或null
|
||||||
*/
|
*/
|
||||||
public function getStatus($serviceName) {
|
public function getStatus($serviceName) {
|
||||||
$stmt = $this->db->prepare("SELECT * FROM service_status WHERE service_name = ?");
|
$stmt = $this->db->prepare("SELECT * FROM service_status WHERE service_name = ?");
|
||||||
$stmt->execute([$serviceName]);
|
$stmt->execute([$serviceName]);
|
||||||
return $stmt->fetch();
|
return $stmt->fetch();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 更新服务状态
|
* 更新服务状态
|
||||||
* @param string $serviceName 服务名称
|
* @param string $serviceName 服务名称
|
||||||
* @param bool $isRunning 是否运行
|
* @param bool $isRunning 是否运行
|
||||||
* @param int|null $pid 进程ID
|
* @param int|null $pid 进程ID
|
||||||
* @return bool 是否成功
|
* @return bool 是否成功
|
||||||
*/
|
*/
|
||||||
public function updateStatus($serviceName, $isRunning, $pid = null) {
|
public function updateStatus($serviceName, $isRunning, $pid = null) {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
INSERT INTO service_status (service_name, is_running, pid, last_started_at, last_stopped_at)
|
INSERT INTO service_status (service_name, is_running, pid, last_started_at, last_stopped_at)
|
||||||
VALUES (?, ?, ?, NOW(), NULL)
|
VALUES (?, ?, ?, NOW(), NULL)
|
||||||
ON DUPLICATE KEY UPDATE
|
ON DUPLICATE KEY UPDATE
|
||||||
is_running = VALUES(is_running),
|
is_running = VALUES(is_running),
|
||||||
pid = VALUES(pid),
|
pid = VALUES(pid),
|
||||||
last_started_at = IF(VALUES(is_running) = 1, NOW(), last_started_at),
|
last_started_at = IF(VALUES(is_running) = 1, NOW(), last_started_at),
|
||||||
last_stopped_at = IF(VALUES(is_running) = 0, NOW(), last_stopped_at)
|
last_stopped_at = IF(VALUES(is_running) = 0, NOW(), last_stopped_at)
|
||||||
");
|
");
|
||||||
return $stmt->execute([$serviceName, $isRunning ? 1 : 0, $pid]);
|
return $stmt->execute([$serviceName, $isRunning ? 1 : 0, $pid]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取所有服务状态
|
* 获取所有服务状态
|
||||||
* @return array 服务状态列表
|
* @return array 服务状态列表
|
||||||
*/
|
*/
|
||||||
public function getAllStatus() {
|
public function getAllStatus() {
|
||||||
$stmt = $this->db->query("SELECT * FROM service_status ORDER BY service_name");
|
$stmt = $this->db->query("SELECT * FROM service_status ORDER BY service_name");
|
||||||
return $stmt->fetchAll();
|
return $stmt->fetchAll();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 检查服务是否运行
|
* 检查服务是否运行
|
||||||
* @param string $serviceName 服务名称
|
* @param string $serviceName 服务名称
|
||||||
* @return bool 是否运行
|
* @return bool 是否运行
|
||||||
*/
|
*/
|
||||||
public function isRunning($serviceName) {
|
public function isRunning($serviceName) {
|
||||||
$status = $this->getStatus($serviceName);
|
$status = $this->getStatus($serviceName);
|
||||||
if (!$status) {
|
if (!$status) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 检查进程是否真的在运行
|
// 检查进程是否真的在运行
|
||||||
if ($status['pid'] && $status['is_running']) {
|
if ($status['pid'] && $status['is_running']) {
|
||||||
// 检查进程是否存在
|
// 检查进程是否存在
|
||||||
$result = shell_exec("ps -p {$status['pid']} -o pid= 2>/dev/null");
|
$result = shell_exec("ps -p {$status['pid']} -o pid= 2>/dev/null");
|
||||||
if (empty(trim($result))) {
|
if (empty(trim($result))) {
|
||||||
// 进程不存在，更新状态
|
// 进程不存在，更新状态
|
||||||
$this->updateStatus($serviceName, false, null);
|
$this->updateStatus($serviceName, false, null);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return (bool)$status['is_running'];
|
return (bool)$status['is_running'];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -1,56 +1,56 @@
|
|||||||
<?php
|
<?php
|
||||||
require_once __DIR__ . '/Database.php';
|
require_once __DIR__ . '/Database.php';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 系统设置数据访问层
|
* 系统设置数据访问层
|
||||||
*/
|
*/
|
||||||
class SystemSettingsRepository {
|
class SystemSettingsRepository {
|
||||||
private $db;
|
private $db;
|
||||||
|
|
||||||
public function __construct() {
|
public function __construct() {
|
||||||
$this->db = Database::getInstance();
|
$this->db = Database::getInstance();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取设置值
|
* 获取设置值
|
||||||
* @param string $key 设置键
|
* @param string $key 设置键
|
||||||
* @param mixed $default 默认值
|
* @param mixed $default 默认值
|
||||||
* @return mixed 设置值
|
* @return mixed 设置值
|
||||||
*/
|
*/
|
||||||
public function get($key, $default = null) {
|
public function get($key, $default = null) {
|
||||||
$stmt = $this->db->prepare("SELECT setting_value FROM system_settings WHERE setting_key = ?");
|
$stmt = $this->db->prepare("SELECT setting_value FROM system_settings WHERE setting_key = ?");
|
||||||
$stmt->execute([$key]);
|
$stmt->execute([$key]);
|
||||||
$result = $stmt->fetch();
|
$result = $stmt->fetch();
|
||||||
return $result ? $result['setting_value'] : $default;
|
return $result ? $result['setting_value'] : $default;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 设置值
|
* 设置值
|
||||||
* @param string $key 设置键
|
* @param string $key 设置键
|
||||||
* @param mixed $value 设置值
|
* @param mixed $value 设置值
|
||||||
* @return bool 是否成功
|
* @return bool 是否成功
|
||||||
*/
|
*/
|
||||||
public function set($key, $value) {
|
public function set($key, $value) {
|
||||||
$stmt = $this->db->prepare("
|
$stmt = $this->db->prepare("
|
||||||
INSERT INTO system_settings (setting_key, setting_value)
|
INSERT INTO system_settings (setting_key, setting_value)
|
||||||
VALUES (?, ?)
|
VALUES (?, ?)
|
||||||
ON DUPLICATE KEY UPDATE setting_value = VALUES(setting_value)
|
ON DUPLICATE KEY UPDATE setting_value = VALUES(setting_value)
|
||||||
");
|
");
|
||||||
return $stmt->execute([$key, $value]);
|
return $stmt->execute([$key, $value]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 获取所有设置
|
* 获取所有设置
|
||||||
* @return array 所有设置
|
* @return array 所有设置
|
||||||
*/
|
*/
|
||||||
public function getAll() {
|
public function getAll() {
|
||||||
$stmt = $this->db->query("SELECT setting_key, setting_value FROM system_settings");
|
$stmt = $this->db->query("SELECT setting_key, setting_value FROM system_settings");
|
||||||
$results = $stmt->fetchAll();
|
$results = $stmt->fetchAll();
|
||||||
$settings = [];
|
$settings = [];
|
||||||
foreach ($results as $row) {
|
foreach ($results as $row) {
|
||||||
$settings[$row['setting_key']] = $row['setting_value'];
|
$settings[$row['setting_key']] = $row['setting_value'];
|
||||||
}
|
}
|
||||||
return $settings;
|
return $settings;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -1,30 +1,30 @@
|
|||||||
#!/bin/bash
|
#!/bin/bash
|
||||||
echo "测试SMTP服务器..."
|
echo "测试SMTP服务器..."
|
||||||
|
|
||||||
# 启动服务器（后台运行）
|
# 启动服务器（后台运行）
|
||||||
sudo php scripts/start_smtp.php &
|
sudo php scripts/start_smtp.php &
|
||||||
SERVER_PID=$!
|
SERVER_PID=$!
|
||||||
sleep 3 # 等待更长时间确保服务器启动
|
sleep 3 # 等待更长时间确保服务器启动
|
||||||
|
|
||||||
echo "发送测试邮件..."
|
echo "发送测试邮件..."
|
||||||
# 使用timeout防止telnet无限等待
|
# 使用timeout防止telnet无限等待
|
||||||
timeout 5 telnet localhost 25 << 'EOF'
|
timeout 5 telnet localhost 25 << 'EOF'
|
||||||
HELO test
|
HELO test
|
||||||
MAIL FROM: <user1@test.com>
|
MAIL FROM: <user1@test.com>
|
||||||
RCPT TO: <admin@test.com>
|
RCPT TO: <admin@test.com>
|
||||||
DATA
|
DATA
|
||||||
Subject: 自动测试邮件
|
Subject: 自动测试邮件
|
||||||
From: user1@test.com
|
From: user1@test.com
|
||||||
To: admin@test.com
|
To: admin@test.com
|
||||||
|
|
||||||
这是自动发送的测试邮件
|
这是自动发送的测试邮件
|
||||||
.
|
.
|
||||||
QUIT
|
QUIT
|
||||||
EOF
|
EOF
|
||||||
|
|
||||||
# 等待服务器处理完成
|
# 等待服务器处理完成
|
||||||
sleep 2
|
sleep 2
|
||||||
|
|
||||||
|
|
||||||
kill $SERVER_PID 2>/dev/null
|
kill $SERVER_PID 2>/dev/null
|
||||||
echo "测试完成"
|
echo "测试完成"
|
||||||
Loading…
Reference in new issue