Update.

Author: xOS

db/badger_init.go

@@ -316,9 +316,9 @@ func startBadgerDBMaintenanceTasks() {
 		for {
 			select {
 			case <-ticker.C:
-				// 清理30天前的监控历史记录
+				// 清理7天前的监控历史记录，减少数据库大小
 				monitorHistoryOps := NewMonitorHistoryOps(DB)
-				count, err := monitorHistoryOps.CleanupOldMonitorHistories(30 * 24 * time.Hour)
+				count, err := monitorHistoryOps.CleanupOldMonitorHistories(7 * 24 * time.Hour)
 				if err != nil {
 					log.Printf("清理过期监控历史记录失败: %v", err)
 				} else if count > 0 {

service/singleton/crontask.go

@@ -23,14 +23,14 @@ func InitCronTask() {
 	Crons = make(map[uint64]*model.Cron)
 
 	// 添加基础的系统定时任务 - 修复重复任务注册问题
-	// 每天凌晨3点清理30天前的数据
+	// 每天凌晨3点清理累计流量数据（已废弃，保留为空函数）
 	if _, err := Cron.AddFunc("0 0 3 * * *", func() {
-		CleanCumulativeTransferData(30)
+		CleanCumulativeTransferData(7) // 改为7天，保持与监控历史一致
 	}); err != nil {
 		panic(err)
 	}
 
-	// 每天的3:30 对 监控记录 和 流量记录 进行清理
+	// 每天的3:30 对 监控记录 和 流量记录 进行清理（7天前数据）
 	if _, err := Cron.AddFunc("0 30 3 * * *", func() {
 		count, err := CleanMonitorHistory() // 处理返回值
 		if err != nil {

service/singleton/singleton.go

@@ -702,7 +702,7 @@ func CleanMonitorHistory() (int64, error) {
 		if db.DB != nil {
 			// 使用BadgerDB的MonitorHistoryOps清理过期数据
 			monitorOps := db.NewMonitorHistoryOps(db.DB)
-			maxAge := 60 * 24 * time.Hour // 60天
+			maxAge := 7 * 24 * time.Hour // 修改为7天，减少数据库大小
 			count, err := monitorOps.CleanupOldMonitorHistories(maxAge)
 			if err != nil {
 				log.Printf("BadgerDB监控历史清理失败: %v", err)
@@ -743,11 +743,11 @@ func CleanMonitorHistory() (int64, error) {
 	err := executeWithoutLock(func() error {
 		batchSize := 25                                // 增加批次大小到25（从20增加）
 		maxRetries := 3                                // 减少重试次数，更快失败
-		cutoffDate := time.Now().AddDate(0, 0, -60)    // 延长到60天，避免误删除有效历史数据
+		cutoffDate := time.Now().AddDate(0, 0, -7)     // 修改为7天，减少数据库大小和内存占用
 		safetyBuffer := time.Now().Add(-6 * time.Hour) // 添加6小时安全缓冲区，避免误删新数据
 
 		// 使用非事务方式分批清理，避免长时间事务锁定
-		// 清理60天前的监控记录，并确保不删除最近6小时的数据
+		// 清理7天前的监控记录，并确保不删除最近6小时的数据
 		for {
 			var count int64
 			var err error
@@ -884,6 +884,38 @@ func CleanMonitorHistory() (int64, error) {
 			break
 		}
 
+		// 清理7天前的流量记录
+		for retry := 0; retry < maxRetries; retry++ {
+			// 等待确保没有其他操作在进行
+			time.Sleep(time.Duration(retry*100) * time.Millisecond)
+
+			if DB == nil {
+				return fmt.Errorf("数据库未初始化")
+			}
+			result := DB.Exec("DELETE FROM transfers WHERE created_at < ?", cutoffDate)
+
+			if result.Error != nil {
+				err := result.Error
+
+				if strings.Contains(err.Error(), "database is locked") ||
+					strings.Contains(err.Error(), "SQL statements in progress") ||
+					strings.Contains(err.Error(), "cannot commit") {
+					if retry < maxRetries-1 {
+						backoffDelay := time.Duration((retry+1)*1000) * time.Millisecond
+						log.Printf("数据库忙碌，%v 后重试历史流量记录清理 (%d/%d)", backoffDelay, retry+1, maxRetries)
+						time.Sleep(backoffDelay)
+						continue
+					}
+				}
+
+				log.Printf("清理历史流量记录失败: %v", err)
+				return err
+			}
+
+			totalCleaned += result.RowsAffected
+			break
+		}
+
 		if totalCleaned > 0 {
 			log.Printf("历史数据清理完成，共清理 %d 条记录", totalCleaned)
 		}