211 lines
5.7 KiB
PHP
211 lines
5.7 KiB
PHP
<?php
|
||
include_once "../Hv4.Function.php";
|
||
|
||
|
||
/**
|
||
* 高频日志写入解决方案（线程安全+按天分割+自动清理）
|
||
* @param string $content 日志内容
|
||
* @param string $type 日志类型（INFO/WARNING/ERROR等）
|
||
*/
|
||
function 日志写入($content, $type = 'INFO') {
|
||
// 配置参数（可根据需求调整）
|
||
$config = [
|
||
'log_dir' => './Log/ExpiredProductsCleaner', // 日志目录
|
||
'retain_days' => 60, // 日志保留天数（改为60天清理）
|
||
'file_prefix' => 'ExpiredProductsCleaner' // 日志文件前缀
|
||
];
|
||
|
||
// 生成时间相关变量
|
||
$now = new DateTime();
|
||
$currentDate = $now->format('Y-m-d');
|
||
$logFile = sprintf("%s/%s_%s.log", $config['log_dir'], $config['file_prefix'], $currentDate);
|
||
|
||
// 自动创建日志目录
|
||
if (!is_dir($config['log_dir']) && !mkdir($config['log_dir'], 0777, true)) {
|
||
error_log("无法创建日志目录: {$config['log_dir']}");
|
||
return;
|
||
}
|
||
|
||
// 构建日志内容（含毫秒时间戳）
|
||
$timestamp = $now->format('[Y-m-d H:i:s]') . sprintf('.%03d', (float)$now->format('u')/1000);
|
||
$logLine = sprintf("%s <%s> - %s\n", $timestamp, strtoupper($type), $content);
|
||
|
||
// 高性能写入（使用资源句柄+flock避免并发冲突）
|
||
try {
|
||
$handle = fopen($logFile, 'a'); // 追加模式打开
|
||
if (flock($handle, LOCK_EX)) { // 获取独占锁
|
||
fwrite($handle, $logLine);
|
||
flock($handle, LOCK_UN); // 释放锁
|
||
}
|
||
fclose($handle);
|
||
} catch (Exception $e) {
|
||
error_log("日志写入失败: " . $e->getMessage());
|
||
}
|
||
|
||
// 控制台输出（可选调试）
|
||
echo $logLine;
|
||
|
||
// 智能清理（每天只执行一次清理检查）
|
||
$cleanFlagFile = $config['log_dir'] . '/.last_clean';
|
||
if (!file_exists($cleanFlagFile) || (time() - filemtime($cleanFlagFile)) > 86400) {
|
||
$expireDate = $now->modify("-{$config['retain_days']} days")->getTimestamp();
|
||
foreach (glob($config['log_dir'] . "/{$config['file_prefix']}_*.log") as $file) {
|
||
if (filemtime($file) < $expireDate) {
|
||
@unlink($file);
|
||
}
|
||
}
|
||
touch($cleanFlagFile); // 更新清理标记时间
|
||
}
|
||
}
|
||
|
||
|
||
|
||
$语句 = "SELECT *
|
||
FROM purchases
|
||
WHERE
|
||
expiry_time < NOW() -- 过期时间早于当前时间
|
||
AND status = 'expiring'
|
||
ORDER BY expiry_time;
|
||
";
|
||
|
||
日志写入(">>>==================================>>>","执行中");
|
||
|
||
日志写入("ExpiryReminder 任务开始","提示");
|
||
|
||
日志写入("查询中","提示");
|
||
|
||
$结果 = @数据库运行($语句);
|
||
|
||
if (!$结果) {
|
||
日志写入("无结果","提示");
|
||
die();
|
||
}
|
||
|
||
日志写入("查询结果","提示");
|
||
|
||
日志写入(">>>==================================>>>","结果");
|
||
|
||
日志写入(@转JSON($结果),"数据");
|
||
|
||
日志写入(">>>==================================>>>","结果");
|
||
|
||
日志写入("开始循环","提示");
|
||
|
||
foreach ($结果 as $业务元数据) {
|
||
|
||
日志写入(">>>==================================>>>","任务");
|
||
$用户ID = $业务元数据["user_id"];
|
||
$业务ID = $业务元数据["purchase_id"];
|
||
$业务状态 = $业务元数据["status"];
|
||
$业务名称 = $业务元数据["name"];
|
||
$到期时间 = $业务元数据["expiry_time"];
|
||
$产品标识 = $业务元数据["product_id"];
|
||
日志写入("提取业务ID ".$业务ID,"提示");
|
||
日志写入("提取用户ID ".$用户ID,"提示");
|
||
日志写入("提取业务状态 ".$业务状态,"提示");
|
||
|
||
|
||
|
||
|
||
|
||
$dateString = $到期时间;
|
||
|
||
// 创建目标日期对象并设置时间为0点
|
||
$targetDate = DateTime::createFromFormat('Y-m-d H:i:s', $dateString);
|
||
$targetDate->setTime(0, 0, 0);
|
||
|
||
// 创建当前日期对象并设置时间为0点
|
||
$today = new DateTime();
|
||
$today->setTime(0, 0, 0);
|
||
|
||
// 计算日期差异
|
||
$interval = $today->diff($targetDate);
|
||
|
||
// 获取天数差
|
||
$剩余天数 = $interval->days;
|
||
|
||
// 处理过去或未来的情况
|
||
if ($interval->invert) {
|
||
$剩余天数 = -$剩余天数;
|
||
}
|
||
|
||
|
||
|
||
$语句 = "SELECT * FROM users WHERE id = $用户ID;";
|
||
|
||
$用户数据 = @数据库运行($语句);
|
||
|
||
$用户数据 = @reset($用户数据);
|
||
|
||
$QQ = $用户数据["qq"];
|
||
|
||
日志写入("获取邮件模板","提示");
|
||
|
||
$邮件模板 = @file_get_contents("./Res/ExpiredProductsCleaner.html");
|
||
|
||
|
||
$search = ["[到期时间]", "[业务名称]", "[业务ID]"];
|
||
$replace = [$到期时间, $业务名称, $业务ID];
|
||
|
||
$邮件模板 = str_replace($search, $replace, $邮件模板);
|
||
|
||
$结果 = 发送邮件接口(
|
||
$QQ.'@qq.com',
|
||
'关于业务的重要通知',
|
||
$邮件模板
|
||
);
|
||
|
||
日志写入("正在发送邮件","提示");
|
||
|
||
if ($结果 === 200) {
|
||
|
||
日志写入("已发送","成功");
|
||
} else {
|
||
|
||
日志写入("发送失败 " . $结果,"错误");
|
||
}
|
||
|
||
$语句 = "SELECT * FROM products WHERE product_id = '$产品标识';";
|
||
|
||
日志写入("获取产品元数据中","提示");
|
||
|
||
$产品元数据 = @reset(@数据库运行($语句));
|
||
|
||
|
||
日志写入("获取结果","提示");
|
||
|
||
日志写入(">>>==================================>>>","结果");
|
||
|
||
日志写入(@转JSON($产品元数据),"数据");
|
||
|
||
日志写入(">>>==================================>>>","结果");
|
||
|
||
$产品模块 = $产品元数据["module"];
|
||
$产品周期 = $产品元数据["subscription_period"];
|
||
$模块路径 = "../ProductsModule/".$产品模块."/Main.php";
|
||
|
||
日志写入("载入模块 ".$产品模块,"提示");
|
||
require_once $模块路径;
|
||
|
||
|
||
日志写入("删除业务中","提示");
|
||
$结果 = @转JSON(@删除业务($业务元数据,$产品元数据));
|
||
|
||
日志写入("结果 ".$结果,"结果");
|
||
|
||
$语句 = "UPDATE purchases
|
||
SET status = 'expired'
|
||
WHERE purchase_id = '$业务ID';
|
||
";
|
||
@数据库运行($语句);
|
||
|
||
日志写入("已更新业务状态","提示");
|
||
|
||
|
||
}
|
||
|
||
|
||
日志写入("任务结束","提示");
|
||
日志写入(">>>==================================>>>","结束");
|
||
|
||
?>
|