Update.

Author: xOS

cmd/dashboard/controller/member_api.go

@@ -1622,7 +1622,7 @@ func (ma *memberAPI) addOrEditAlertRule(c *gin.Context) {
 		// 情况1: ["[]"] -> []
 		// 情况2: "[]" (被双引号包裹) -> []
 		// 情况3: "" (空字符串) -> []
-		
+
 		// 处理 FailTriggerTasksRaw
 		if arf.FailTriggerTasksRaw == `["[]"]` || arf.FailTriggerTasksRaw == `[""]` {
 			arf.FailTriggerTasksRaw = "[]"
@@ -1635,7 +1635,7 @@ func (ma *memberAPI) addOrEditAlertRule(c *gin.Context) {
 				log.Printf("  修复双重序列化的 FailTriggerTasksRaw: %q", arf.FailTriggerTasksRaw)
 			}
 		}
-		
+
 		// 处理 RecoverTriggerTasksRaw
 		if arf.RecoverTriggerTasksRaw == `["[]"]` || arf.RecoverTriggerTasksRaw == `[""]` {
 			arf.RecoverTriggerTasksRaw = "[]"

service/rpc/server.go

@@ -974,10 +974,15 @@ func checkAndResetCycleTraffic(clientID uint64) {
 
 	// 读取上次重置参考时间（仍在读锁下，随后立即释放）
 	lastResetTime := time.Time{}
+	var nextUpdate time.Time
+	hasNextUpdate := false
 	if stats, exists := singleton.AlertsCycleTransferStatsStore[matchingAlert.ID]; exists && stats != nil {
-		if nextUpdate, has := stats.NextUpdate[clientID]; has {
-			if nextUpdate.Before(currentCycleStart) {
-				lastResetTime = nextUpdate
+		if nu, has := stats.NextUpdate[clientID]; has {
+			hasNextUpdate = true
+			nextUpdate = nu
+			// 如果NextUpdate在当前周期开始之前，说明是上个周期的记录，可以作为重置参考
+			if nu.Before(currentCycleStart) {
+				lastResetTime = nu
 			}
 		}
 	}
@@ -986,9 +991,47 @@ func checkAndResetCycleTraffic(clientID uint64) {
 	// 2) 判断是否需要重置（锁外计算）
 	needReset := false
 	now := time.Now()
-	if !lastResetTime.IsZero() && now.After(currentCycleStart) && lastResetTime.Before(currentCycleStart) {
-		needReset = true
+	
+	// 添加调试日志
+	if clientID == 30 || clientID == 17 { // 只记录特定服务器的日志避免日志过多
+		log.Printf("[流量重置调试] 服务器ID=%d, 当前时间=%s, 周期开始=%s, 周期结束=%s", 
+			clientID, now.Format("2006-01-02 15:04:05"), 
+			currentCycleStart.Format("2006-01-02 15:04:05"),
+			currentCycleEnd.Format("2006-01-02 15:04:05"))
+		log.Printf("[流量重置调试] 服务器ID=%d, hasNextUpdate=%v, NextUpdate=%s, lastResetTime=%s, lastResetTime.IsZero=%v", 
+			clientID, hasNextUpdate, nextUpdate.Format("2006-01-02 15:04:05"),
+			lastResetTime.Format("2006-01-02 15:04:05"), lastResetTime.IsZero())
 	}
+	
+	// 重置条件：
+	// 1. 有NextUpdate记录
+	// 2. 当前时间已进入新周期
+	// 3. lastResetTime在当前周期之前（如果有的话）或NextUpdate本身在当前周期之前
+	if hasNextUpdate && now.After(currentCycleStart) {
+		// 情况1: lastResetTime不为空且在周期开始之前（正常情况）
+		if !lastResetTime.IsZero() && lastResetTime.Before(currentCycleStart) {
+			needReset = true
+		} else if lastResetTime.IsZero() {
+			// 情况2: lastResetTime为空，说明NextUpdate >= currentCycleStart
+			// 这种情况发生在：上个周期末更新了NextUpdate为新周期的时间
+			// 需要检查服务器的累计流量来判断是否需要重置
+			singleton.ServerLock.RLock()
+			server := singleton.ServerList[clientID]
+			if server != nil && (server.CumulativeNetInTransfer > 0 || server.CumulativeNetOutTransfer > 0) {
+				needReset = true
+				if clientID == 30 || clientID == 17 {
+					log.Printf("[流量重置调试] 服务器ID=%d, NextUpdate在新周期内但服务器有累计流量，触发重置。入站=%d, 出站=%d",
+						clientID, server.CumulativeNetInTransfer, server.CumulativeNetOutTransfer)
+				}
+			}
+			singleton.ServerLock.RUnlock()
+		}
+	}
+	
+	if clientID == 30 || clientID == 17 {
+		log.Printf("[流量重置调试] 服务器ID=%d, needReset=%v", clientID, needReset)
+	}
+	
 	if !needReset {
 		return
 	}