新增:聊天记录定期清理任务

- 新增 messages:purge Artisan 命令,分批删除旧消息
- 默认保留最近 30 天,可通过 sysparam message_retention_days 配置
- 支持 --days 参数覆盖和 --dry-run 预览模式
- 每天凌晨 3 点自动执行
- 线上需配置 crontab: * * * * * php artisan schedule:run
This commit is contained in:
2026-02-27 00:12:16 +08:00
parent fc09a6b895
commit e3cc1d2c70
2 changed files with 95 additions and 0 deletions

View File

@@ -0,0 +1,91 @@
<?php
/**
* 文件功能:定期清理聊天记录 Artisan 命令
*
* 每天自动清理超过指定天数的聊天记录,保持数据库体积可控。
* 保留天数可通过 sysparam 表的 message_retention_days 配置,默认 30 天。
*
* @author ChatRoom Laravel
*
* @version 1.0.0
*/
namespace App\Console\Commands;
use App\Models\Message;
use App\Models\Sysparam;
use Carbon\Carbon;
use Illuminate\Console\Command;
class PurgeOldMessages extends Command
{
/**
* 命令签名
*
* @var string
*/
protected $signature = 'messages:purge
{--days= : 覆盖默认保留天数}
{--dry-run : 仅预览不实际删除}';
/**
* 命令描述
*
* @var string
*/
protected $description = '清理超过指定天数的聊天记录(保留天数由 sysparam message_retention_days 配置,默认 30 天)';
/**
* 执行命令
*
* 按批次删除旧消息,避免长时间锁表。
*/
public function handle(): int
{
// 保留天数:命令行参数 > sysparam 配置 > 默认 30 天
$days = (int) ($this->option('days')
?: Sysparam::getValue('message_retention_days', '30'));
$cutoff = Carbon::now()->subDays($days);
$isDryRun = $this->option('dry-run');
// 统计待清理数量
$totalCount = Message::where('sent_at', '<', $cutoff)->count();
if ($totalCount === 0) {
$this->info("✅ 没有超过 {$days} 天的聊天记录需要清理。");
return self::SUCCESS;
}
if ($isDryRun) {
$this->warn("🔍 [预览模式] 将删除 {$totalCount} 条超过 {$days} 天的聊天记录(截止 {$cutoff->toDateTimeString()}");
return self::SUCCESS;
}
$this->info("🧹 开始清理超过 {$days} 天的聊天记录(截止 {$cutoff->toDateTimeString()}...");
$this->info(" 待清理数量:{$totalCount}");
// 分批删除,每批 1000 条,避免长时间锁表
$deleted = 0;
$batchSize = 1000;
do {
$batch = Message::where('sent_at', '<', $cutoff)
->limit($batchSize)
->delete();
$deleted += $batch;
if ($batch > 0) {
$this->line(" 已删除 {$deleted}/{$totalCount} 条...");
}
} while ($batch === $batchSize);
$this->info("✅ 清理完成!共删除 {$deleted} 条聊天记录。");
return self::SUCCESS;
}
}

View File

@@ -2,7 +2,11 @@
use Illuminate\Foundation\Inspiring;
use Illuminate\Support\Facades\Artisan;
use Illuminate\Support\Facades\Schedule;
Artisan::command('inspire', function () {
$this->comment(Inspiring::quote());
})->purpose('Display an inspiring quote');
// 每天凌晨 3 点清理超过 30 天的聊天记录
Schedule::command('messages:purge')->dailyAt('03:00');