Update.

Author: xOS

service/rpc/server.go

@@ -975,9 +975,11 @@ func checkAndResetCycleTraffic(clientID uint64) {
 	// 读取上次重置参考时间（仍在读锁下，随后立即释放）
 	lastResetTime := time.Time{}
 	hasNextUpdate := false
+	var nextUpdateValue time.Time
 	if stats, exists := singleton.AlertsCycleTransferStatsStore[matchingAlert.ID]; exists && stats != nil {
 		if nu, has := stats.NextUpdate[clientID]; has {
 			hasNextUpdate = true
+			nextUpdateValue = nu
 			// 如果NextUpdate在当前周期开始之前，说明是上个周期的记录，可以作为重置参考
 			if nu.Before(currentCycleStart) {
 				lastResetTime = nu
@@ -990,9 +992,41 @@ func checkAndResetCycleTraffic(clientID uint64) {
 	needReset := false
 	now := time.Now()
 
-	// 重置条件：有NextUpdate记录且lastResetTime在当前周期之前
-	if hasNextUpdate && now.After(currentCycleStart) && !lastResetTime.IsZero() && lastResetTime.Before(currentCycleStart) {
+	// 重置判断逻辑：
+	// 1. 如果没有NextUpdate记录，说明是首次运行，不需要重置
+	// 2. 如果有NextUpdate记录：
+	//    - 若NextUpdate在当前周期之前：说明上个周期结束时设置的，需要重置
+	//    - 若NextUpdate在当前周期之后：正常情况，不需要重置
+	//    - 若NextUpdate在当前周期内：需要检查服务器的累计流量是否为0
+	//      如果累计流量不为0，说明还没重置过，需要重置
+	
+	if !hasNextUpdate {
+		// 没有记录，首次运行或数据丢失，不重置
+		return
+	}
+
+	if !lastResetTime.IsZero() && lastResetTime.Before(currentCycleStart) {
+		// NextUpdate在当前周期之前，需要重置
 		needReset = true
+		log.Printf("[周期流量重置] 服务器ID=%d 触发重置: NextUpdate=%s 在当前周期 %s 之前",
+			clientID, nextUpdateValue.Format("2006-01-02 15:04:05"), currentCycleStart.Format("2006-01-02 15:04:05"))
+	} else if nextUpdateValue.After(currentCycleStart) && nextUpdateValue.Before(currentCycleEnd) {
+		// NextUpdate在当前周期内，检查服务器累计流量
+		singleton.ServerLock.RLock()
+		server, exists := singleton.ServerList[clientID]
+		singleton.ServerLock.RUnlock()
+		
+		if exists && server != nil {
+			// 如果累计流量不为0，说明还没重置，需要重置
+			if server.CumulativeNetInTransfer > 0 || server.CumulativeNetOutTransfer > 0 {
+				needReset = true
+				log.Printf("[周期流量重置] 服务器ID=%d 触发重置: NextUpdate=%s 在当前周期内，但累计流量不为0 (in=%d, out=%d)",
+					clientID, nextUpdateValue.Format("2006-01-02 15:04:05"),
+					server.CumulativeNetInTransfer, server.CumulativeNetOutTransfer)
+			} else {
+				log.Printf("[周期流量检查] 服务器ID=%d NextUpdate在当前周期内且累计流量为0，无需重置", clientID)
+			}
+		}
 	}
 
 	if !needReset {