sysparam 配置 > 默认 30 天 $days = (int) ($this->option('days') ?: Sysparam::getValue('message_retention_days', '30')); $imageDays = max(0, (int) $this->option('image-days')); $cutoff = Carbon::now()->subDays($days); $isDryRun = $this->option('dry-run'); $this->cleanupExpiredImages($imageDays, $isDryRun); // 统计待清理数量 $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; } /** * 清理超过图片保留天数的聊天图片文件,并把消息改成过期占位。 */ private function cleanupExpiredImages(int $imageDays, bool $isDryRun): void { $imageCutoff = Carbon::now()->subDays($imageDays); $query = Message::query() ->where('message_type', 'image') ->where('sent_at', '<', $imageCutoff) ->where(function ($builder) { $builder->whereNotNull('image_path')->orWhereNotNull('image_thumb_path'); }); $totalCount = (clone $query)->count(); if ($totalCount === 0) { $this->line("🖼️ 没有超过 {$imageDays} 天的聊天图片需要清理。"); return; } if ($isDryRun) { $this->warn("🔍 [预览模式] 将清理 {$totalCount} 条超过 {$imageDays} 天的聊天图片(截止 {$imageCutoff->toDateTimeString()})"); return; } $processed = 0; $query->orderBy('id')->chunkById(200, function ($messages) use (&$processed) { foreach ($messages as $message) { $paths = array_values(array_filter([ $message->image_path, $message->image_thumb_path, ])); // 先删物理文件,再把数据库消息降级成“图片已过期”占位,避免出现坏图。 if ($paths !== []) { Storage::disk('public')->delete($paths); } $placeholder = trim((string) $message->content); $placeholder = $placeholder !== '' ? $placeholder.' [图片已过期]' : '[图片已过期]'; $message->forceFill([ 'content' => $placeholder, 'message_type' => 'expired_image', 'image_path' => null, 'image_thumb_path' => null, 'image_original_name' => null, ])->save(); $processed++; } }); $this->info("🖼️ 已清理 {$processed} 条超过 {$imageDays} 天的聊天图片。"); } }