From 4a3339fcfb5c3fc7a5ac6ed9056243152d50c866 Mon Sep 17 00:00:00 2001
From: maguodong <maguodong@gmail.com>
Date: Sat, 28 Mar 2026 09:33:03 +0800
Subject: [PATCH] =?UTF-8?q?feat(log):=20=E6=B7=BB=E5=8A=A0=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E6=96=87=E4=BB=B6=E8=87=AA=E5=8A=A8=E6=B8=85=E7=90=86?=
 =?UTF-8?q?=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 实现 cleanOldLogs 函数用于删除指定天数之前的日志文件
- 添加日志文件名格式匹配逻辑，只处理 log-YYYY-MM-DD.log 格式的文件
- 在日志文件切换时自动清理 30 天前的过期日志文件
- 在系统启动时执行一次日志清理操作
- 添加日志输出显示已删除的过期日志文件信息
---
 log/log.go | 49 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 49 insertions(+)

diff --git a/log/log.go b/log/log.go
index b2ef276..f3539df 100644
--- a/log/log.go
+++ b/log/log.go
@@ -5,6 +5,7 @@ import (
 	"io"
 	"log"
 	"os"
+	"path/filepath"
 	"regexp"
 	"runtime/debug"
 	"strings"
@@ -62,6 +63,48 @@ func (w *logWriter) Write(p []byte) (n int, err error) {
 	return len(p), nil
 }
 
+// cleanOldLogs 删除指定天数之前的日志文件
+func cleanOldLogs(days int) {
+	if !gfile.Exists(logPath) {
+		return
+	}
+
+	// 获取所有日志文件
+	files, err := gfile.DirNames(logPath)
+	if err != nil {
+		return
+	}
+
+	now := time.Now()
+	for _, file := range files {
+		path := filepath.Join(logPath, file)
+		if gfile.IsDir(path) {
+			continue
+		}
+		// 匹配日志文件名格式：log-YYYY-MM-DD.log
+		if !strings.HasPrefix(file, "log-") || !strings.HasSuffix(file, ".log") {
+			continue
+		}
+
+		// 提取日期部分
+		dateStr := strings.TrimSuffix(strings.TrimPrefix(file, "log-"), ".log")
+		fileTime, err := time.Parse("2006-01-02", dateStr)
+		if err != nil {
+			continue // 日期格式不正确，跳过
+		}
+
+		// 计算文件年龄
+		tage := now.Sub(fileTime)
+		if tage.Hours() > float64(days*24) {
+			// 超过指定天数，删除文件
+			err = os.Remove(path)
+			if err == nil {
+				Info(fmt.Sprintf("已删除过期日志文件：%s", file))
+			}
+		}
+	}
+}
+
 // checkAndRotateLogFile 检查是否需要切换日志文件（跨天时）
 func checkAndRotateLogFile() {
 	date := gtime.Date()
@@ -82,6 +125,9 @@ func checkAndRotateLogFile() {
 			file:    fileLogger,
 		}
 		sysLog = log.New(multiWriter, "", 0)
+
+		// 清理 30 天前的旧日志
+		cleanOldLogs(30)
 	}
 }
 
@@ -106,6 +152,9 @@ func Init() {
 		file:    fileLogger,
 	}
 	sysLog = log.New(multiWriter, "", 0)
+
+	// 启动时清理 30 天前的旧日志
+	cleanOldLogs(30)
 }
 
 func Info(v ...any) {