本文目录导读：
我来为你提供PHP用户协议更新通知的完整实现方案,包含数据库设计、核心代码和发送逻辑。
数据库设计
-- 用户协议表
CREATE TABLE `user_agreements` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`version` varchar(20) NOT NULL COMMENT '协议版本号', varchar(200) NOT NULL COMMENT '协议标题',
`content` text NOT NULL COMMENT '协议内容',
`effective_date` datetime NOT NULL COMMENT '生效日期',
`created_at` datetime DEFAULT CURRENT_TIMESTAMP,
`updated_at` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
UNIQUE KEY `uk_version` (`version`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
-- 用户协议接受记录表
CREATE TABLE `user_agreement_acceptances` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`user_id` int(11) NOT NULL COMMENT '用户ID',
`agreement_id` int(11) NOT NULL COMMENT '协议ID',
`accept_ip` varchar(45) DEFAULT NULL COMMENT '接受IP',
`accept_count` int(4) DEFAULT '1' COMMENT '查看次数',
`last_accept_at` datetime DEFAULT NULL COMMENT '最后接受时间',
`created_at` datetime DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
UNIQUE KEY `uk_user_agreement` (`user_id`,`agreement_id`),
KEY `idx_user_id` (`user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
-- 用户协议通知记录表
CREATE TABLE `agreement_notifications` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`user_id` int(11) NOT NULL COMMENT '用户ID',
`agreement_id` int(11) NOT NULL COMMENT '协议ID',
`notify_type` enum('email','sms','push') NOT NULL DEFAULT 'email' COMMENT '通知方式',
`status` tinyint(1) DEFAULT '0' COMMENT '0待发送 1成功 2失败',
`retry_count` int(4) DEFAULT '0' COMMENT '重试次数',
`error_msg` varchar(255) DEFAULT NULL COMMENT '错误信息',
`created_at` datetime DEFAULT CURRENT_TIMESTAMP,
`sent_at` datetime DEFAULT NULL COMMENT '发送时间',
PRIMARY KEY (`id`),
KEY `idx_user_status` (`user_id`,`status`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
核心PHP类实现
1 协议管理类 AgreementManager.php
<?php
class AgreementManager {
private $db;
public function __construct($db) {
$this->db = $db;
}
/**
* 发布新版本协议
*/
public function publishNewAgreement($title, $content, $effectiveDate = null) {
$effectiveDate = $effectiveDate ?: date('Y-m-d H:i:s');
$version = 'v' . date('YmdHis');
try {
$stmt = $this->db->prepare(
"INSERT INTO user_agreements (version, title, content, effective_date)
VALUES (?, ?, ?, ?)"
);
$stmt->execute([$version, $title, $content, $effectiveDate]);
return $this->db->lastInsertId();
} catch (PDOException $e) {
error_log("发布协议失败: " . $e->getMessage());
return false;
}
}
/**
* 获取当前有效协议
*/
public function getLatestAgreement() {
$stmt = $this->db->prepare(
"SELECT * FROM user_agreements
WHERE effective_date <= NOW()
ORDER BY effective_date DESC
LIMIT 1"
);
$stmt->execute();
return $stmt->fetch(PDO::FETCH_ASSOC);
}
/**
* 获取用户未接受的协议
*/
public function getUnacceptedAgreements($userId) {
$sql = "
SELECT a.* FROM user_agreements a
WHERE a.effective_date <= NOW()
AND a.id NOT IN (
SELECT agreement_id FROM user_agreement_acceptances
WHERE user_id = ?
)
ORDER BY a.effective_date DESC
";
$stmt = $this->db->prepare($sql);
$stmt->execute([$userId]);
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
/**
* 记录用户接受协议
*/
public function acceptAgreement($userId, $agreementId, $ip = null) {
try {
// 检查是否已存在记录
$stmt = $this->db->prepare(
"SELECT * FROM user_agreement_acceptances
WHERE user_id = ? AND agreement_id = ?"
);
$stmt->execute([$userId, $agreementId]);
if ($stmt->rowCount() > 0) {
// 更新现有记录
$updateStmt = $this->db->prepare(
"UPDATE user_agreement_acceptances
SET accept_count = accept_count + 1,
last_accept_at = NOW(),
accept_ip = ?
WHERE user_id = ? AND agreement_id = ?"
);
$updateStmt->execute([$ip, $userId, $agreementId]);
} else {
// 插入新记录
$insertStmt = $this->db->prepare(
"INSERT INTO user_agreement_acceptances
(user_id, agreement_id, accept_ip)
VALUES (?, ?, ?)"
);
$insertStmt->execute([$userId, $agreementId, $ip]);
}
// 删除通知记录
$deleteStmt = $this->db->prepare(
"DELETE FROM agreement_notifications
WHERE user_id = ? AND agreement_id = ?"
);
$deleteStmt->execute([$userId, $agreementId]);
return true;
} catch (PDOException $e) {
error_log("接受协议失败: " . $e->getMessage());
return false;
}
}
/**
* 检查用户是否已接受最新协议
*/
public function hasAcceptedLatestAgreement($userId) {
$latest = $this->getLatestAgreement();
if (!$latest) return true;
$stmt = $this->db->prepare(
"SELECT COUNT(*) FROM user_agreement_acceptances
WHERE user_id = ? AND agreement_id = ?"
);
$stmt->execute([$userId, $latest['id']]);
return $stmt->fetchColumn() > 0;
}
}
2 通知发送类 AgreementNotifier.php
<?php
class AgreementNotifier {
private $db;
private $mailer;
private $smsClient;
public function __construct($db, $mailer = null, $smsClient = null) {
$this->db = $db;
$this->mailer = $mailer;
$this->smsClient = $smsClient;
}
/**
* 发送协议更新通知给所有用户
*/
public function notifyAllUsers($agreementId, $userList = null) {
// 获取所有用户
if (!$userList) {
$userList = $this->getAllUsers();
}
foreach ($userList as $user) {
$this->createNotification($user['id'], $agreementId, 'email');
}
return $this->processPendingNotifications();
}
/**
* 创建通知记录
*/
public function createNotification($userId, $agreementId, $type = 'email') {
$stmt = $this->db->prepare(
"INSERT INTO agreement_notifications
(user_id, agreement_id, notify_type)
VALUES (?, ?, ?)"
);
$stmt->execute([$userId, $agreementId, $type]);
return $this->db->lastInsertId();
}
/**
* 处理待发送的通知队列
*/
public function processPendingNotifications($limit = 100) {
$stmt = $this->db->prepare(
"SELECT n.*, u.email, u.username
FROM agreement_notifications n
JOIN users u ON n.user_id = u.id
WHERE n.status = 0
LIMIT ?"
);
$stmt->execute([$limit]);
$notifications = $stmt->fetchAll(PDO::FETCH_ASSOC);
$successCount = 0;
foreach ($notifications as $noti) {
$result = $this->sendNotification($noti);
if ($result) {
$successCount++;
}
}
return $successCount;
}
/**
* 发送具体通知
*/
private function sendNotification($notification) {
try {
switch ($notification['notify_type']) {
case 'email':
$sent = $this->sendEmail($notification);
break;
case 'sms':
$sent = $this->sendSMS($notification);
break;
default:
$sent = false;
}
// 更新通知状态
$status = $sent ? 1 : 2;
$errorMsg = $sent ? null : '发送失败';
$updateStmt = $this->db->prepare(
"UPDATE agreement_notifications
SET status = ?, sent_at = NOW(), error_msg = ?,
retry_count = retry_count + 1
WHERE id = ?"
);
$updateStmt->execute([$status, $errorMsg, $notification['id']]);
return $sent;
} catch (Exception $e) {
$this->updateErrorStatus($notification['id'], $e->getMessage());
return false;
}
}
/**
* 发送邮件通知
*/
private function sendEmail($notification) {
// 获取协议信息
$stmt = $this->db->prepare(
"SELECT * FROM user_agreements WHERE id = ?"
);
$stmt->execute([$notification['agreement_id']]);
$agreement = $stmt->fetch(PDO::FETCH_ASSOC);
if (!$agreement) return false;
$subject = '【重要通知】用户协议更新 - ' . $agreement['version'];
$emailContent = "
<html>
<body>
<h2>尊敬的用户，您好！</h2>
<p>我们的服务协议已更新至<strong>{$agreement['version']}</strong>版本。</p>
<p>更新内容摘要：</p>
<p>{$agreement['title']}</p>
<p>生效日期：{$agreement['effective_date']}</p>
<p>请点击以下链接查看完整的协议内容：</p>
<p><a href='https://yourdomain.com/agreement/{$agreement['id']}'>查看协议详情</a></p>
<p>如您未在7天内确认接受新协议，您的账户可能会受到限制。</p>
<p>如有疑问，请联系客服。</p>
</body>
</html>
";
// 使用你的邮件库发送，这里以PHPMailer为例
if ($this->mailer) {
$this->mailer->addAddress($notification['email']);
$this->mailer->Subject = $subject;
$this->mailer->isHTML(true);
$this->mailer->Body = $emailContent;
return $this->mailer->send();
}
return false;
}
/**
* 发送短信通知（可选）
*/
private function sendSMS($notification) {
// 如果需要短信通知，在这里实现
// 使用阿里云、腾讯云等短信服务
return true;
}
/**
* 更新错误状态
*/
private function updateErrorStatus($notiId, $errorMsg) {
$stmt = $this->db->prepare(
"UPDATE agreement_notifications
SET status = 2, error_msg = ?,
retry_count = retry_count + 1
WHERE id = ?"
);
$stmt->execute([$errorMsg, $notiId]);
}
/**
* 获取所有用户
*/
private function getAllUsers() {
$stmt = $this->db->query("SELECT id, email, username FROM users");
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
}
3 用户协议管理控制器 AgreementController.php
<?php
class AgreementController {
private $agreementManager;
private $notifier;
public function __construct($db, $mailer = null) {
$this->agreementManager = new AgreementManager($db);
$this->notifier = new AgreementNotifier($db, $mailer);
}
/**
* 处理用户接受协议的请求
*/
public function handleAcceptance($userId, $agreementId) {
if ($_SERVER['REQUEST_METHOD'] !== 'POST') {
return json_encode(['error' => 'Invalid request method']);
}
$ip = $_SERVER['REMOTE_ADDR'];
$result = $this->agreementManager->acceptAgreement($userId, $agreementId, $ip);
return json_encode([
'success' => $result,
'message' => $result ? '已接受协议' : '接受协议失败'
]);
}
/**
* 获取用户需要接受的协议列表
*/
public function getPendingAgreements($userId) {
$agreements = $this->agreementManager->getUnacceptedAgreements($userId);
return json_encode($agreements);
}
/**
* 发布新协议并通知用户
*/
public function publishAndNotify($title, $content, $effectiveDate = null) {
$agreementId = $this->agreementManager->publishNewAgreement(
$title, $content, $effectiveDate
);
if ($agreementId) {
// 后台任务异步处理（可以使用redis队列等）
$this->notifier->notifyAllUsers($agreementId);
return "协议发布成功，通知已发送";
}
return "协议发布失败";
}
}
前端页面示例 agreement.php
<?php
// 检查用户登录
session_start();
require_once 'config/database.php';
require_once 'classes/AgreementManager.php';
$db = getDB();
$agreementManager = new AgreementManager($db);
$userId = $_SESSION['user_id'] ?? null;
if (!$userId) {
header('Location: login.php');
exit;
}
$pendingAgreements = $agreementManager->getUnacceptedAgreements($userId);
// 如果用户已接受所有协议，重定向到主页
if (empty($pendingAgreements)) {
header('Location: dashboard.php');
exit;
}
$currentAgreement = $pendingAgreements[0]; // 取最新的一个
?>
<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">用户协议更新</title>
<meta name="csrf-token" content="<?php echo $_SESSION['csrf_token']; ?>">
<style>
body { font-family: 'Microsoft YaHei', sans-serif; margin: 0; padding: 20px; background: #f5f5f5; }
.container { max-width: 800px; margin: 0 auto; background: #fff; padding: 30px; border-radius: 8px; box-shadow: 0 2px 10px rgba(0,0,0,0.1); }
.header { text-align: center; margin-bottom: 30px; }
.header h1 { color: #333; }
.agreement-content {
background: #f9f9f9;
padding: 20px;
border-radius: 5px;
max-height: 400px;
overflow-y: auto;
margin-bottom: 20px;
line-height: 1.6;
}
.actions { display: flex; justify-content: center; gap: 20px; }
.btn {
padding: 10px 30px;
border: none;
border-radius: 5px;
cursor: pointer;
font-size: 16px;
}
.btn-accept { background: #4CAF50; color: #fff; }
.btn-decline { background: #f44336; color: #fff; }
.checkbox-container { margin: 20px 0; }
.checkbox-container label { font-size: 14px; }
.error-msg { color: #f44336; text-align: center; margin-top: 10px; }
</style>
</head>
<body>
<div class="container">
<div class="header">
<h1>用户协议更新通知</h1>
<p>版本：<?php echo htmlspecialchars($currentAgreement['version']); ?> |
生效日期：<?php echo htmlspecialchars($currentAgreement['effective_date']); ?>
</p>
</div>
<div class="agreement-content">
<?php echo nl2br(htmlspecialchars($currentAgreement['content'])); ?>
</div>
<div class="checkbox-container">
<label>
<input type="checkbox" id="acceptCheckbox_<?php echo $currentAgreement['id']; ?>">
我已认真阅读并同意以上协议内容
</label>
</div>
<div class="actions">
<button class="btn btn-accept" onclick="acceptAgreement(<?php echo $currentAgreement['id']; ?>)">
接受协议
</button>
<button class="btn btn-decline" onclick="declineAgreement()">
不同意
</button>
</div>
<div id="errorMsg" class="error-msg"></div>
</div>
<script>
function acceptAgreement(agreementId) {
const checkbox = document.getElementById('acceptCheckbox_' + agreementId);
if (!checkbox.checked) {
alert('请先勾选同意选项');
return;
}
const csrfToken = document.querySelector('meta[name="csrf-token"]').content;
fetch('accept_agreement.php', {
method: 'POST',
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
'X-CSRF-Token': csrfToken
},
body: 'agreement_id=' + agreementId
})
.then(response => response.json())
.then(data => {
if (data.success) {
alert('感谢您的确认！');
// 重新加载以检查是否有其他待接受的协议
window.location.reload();
} else {
document.getElementById('errorMsg').textContent = data.message;
}
})
.catch(error => {
console.error('Error:', error);
document.getElementById('errorMsg').textContent = '网络错误，请稍后重试';
});
}
function declineAgreement() {
if (confirm('您确定不同意此协议吗？不同意将无法使用我们的服务。')) {
// 处理拒绝逻辑
fetch('decline_agreement.php', {
method: 'POST',
headers: {
'Content-Type': 'application/json'
},
body: JSON.stringify({ action: 'decline' })
})
.then(response => response.json())
.then(data => {
window.location.href = 'logout.php';
});
}
}
</script>
</body>
</html>
后台任务脚本 cron/process_notifications.php
<?php
/**
* 定时处理待发送通知（可配置crontab）
* 建议每5分钟运行一次
*/
require_once '../config/database.php';
require_once '../classes/AgreementNotifier.php';
$db = getDB();
$notifier = new AgreementNotifier($db, $mailer);
// 处理待发送的通知
$processed = $notifier->processPendingNotifications();
// 记录日志
$logFile = '../logs/notifications_' . date('Y-m-d') . '.log';
file_put_contents($logFile,
date('Y-m-d H:i:s') . " - 处理了 {$processed} 条通知\n",
FILE_APPEND
);
echo "处理完成：{$processed} 条通知";
使用示例
// 发布新协议并通知所有用户
$controller = new AgreementController($db, $mailer);
$result = $controller->publishAndNotify(
'服务协议更新',
file_get_contents('agreement_content_2024.html'),
new DateTime('2024-01-01') // 可选
);
// 用户接受协议
$userId = 123;
$agreementId = 456;
$acceptance = $controller->handleAcceptance($userId, $agreementId);
推荐增强功能
- 邮件模板：配置美观的邮件HTML模板
- 多语言支持：根据用户语言设置发送不同语言的协议通知
- 重试机制：对未成功发送的通知进行多次重试
- 用户分组：针对不同用户群体发送不同的协议版本
- Webhook：通知第三方系统协议更新事件
- 审计日志：记录所有协议相关操作的完整日志
- 强制过期：可设置协议接受的超时时间，未接受则限制账户
这个方案提供了完整的协议更新通知流程,包含通知的生成、发送和跟踪，以及用户接受协议的前后端交互，你可以根据实际需求进行调整和扩展。
版权声明：NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
NBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
CBA直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
足球直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
英超直播
