Update.

Author: xOS

cmd/dashboard/controller/common_page.go

@@ -662,12 +662,14 @@ func (cp *commonPage) createFM(c *gin.Context) {
 
 // 新增：/api/traffic handler，返回和首页相同结构的流量数据
 func (cp *commonPage) apiTraffic(c *gin.Context) {
-	// 使用与 /server 相同的授权机制
-	_, authorized := c.Get(model.CtxKeyAuthorizedUser)
-	if !authorized {
+	// 支持用户登录或view password验证
+	_, isMember := c.Get(model.CtxKeyAuthorizedUser)
+	_, isViewPasswordVerified := c.Get(model.CtxKeyViewPasswordVerified)
+
+	if !isMember && !isViewPasswordVerified {
 		c.JSON(http.StatusForbidden, gin.H{
 			"code":    403,
-			"message": "请先登录",
+			"message": "请先登录或输入访问密码",
 		})
 		return
 	}
@@ -720,12 +722,14 @@ func (cp *commonPage) apiTraffic(c *gin.Context) {
 
 // 新增：/api/server/:id/traffic handler，返回单个服务器的流量数据
 func (cp *commonPage) apiServerTraffic(c *gin.Context) {
-	// 使用与 /server 相同的授权机制
-	_, authorized := c.Get(model.CtxKeyAuthorizedUser)
-	if !authorized {
+	// 支持用户登录或view password验证
+	_, isMember := c.Get(model.CtxKeyAuthorizedUser)
+	_, isViewPasswordVerified := c.Get(model.CtxKeyViewPasswordVerified)
+
+	if !isMember && !isViewPasswordVerified {
 		c.JSON(http.StatusForbidden, gin.H{
 			"code":    403,
-			"message": "请先登录",
+			"message": "请先登录或输入访问密码",
 		})
 		return
 	}

cmd/dashboard/controller/member_api.go

@@ -45,6 +45,7 @@ func (ma *memberAPI) serve() {
 	mr.POST("/cron", ma.addOrEditCron)
 	mr.GET("/cron/:id/manual", ma.manualTrigger)
 	mr.POST("/force-update", ma.forceUpdate)
+	mr.POST("/traffic/refresh", ma.refreshTrafficCache)
 	mr.POST("/batch-update-server-group", ma.batchUpdateServerGroup)
 	mr.POST("/batch-delete-server", ma.batchDeleteServer)
 	mr.POST("/notification", ma.addOrEditNotification)
@@ -1164,3 +1165,60 @@ func onServerDelete(id uint64) {
 
 	singleton.DB.Unscoped().Delete(&model.Transfer{}, "server_id = ?", id)
 }
+
+// refreshTrafficCache 强制刷新流量检测缓存
+func (ma *memberAPI) refreshTrafficCache(c *gin.Context) {
+	user := c.MustGet(model.CtxKeyAuthorizedUser).(*model.User)
+
+	// 清空所有流量检测缓存
+	singleton.AlertsLock.Lock()
+	defer singleton.AlertsLock.Unlock()
+
+	clearedCount := 0
+
+	// 重置所有流量监控规则的下次更新时间
+	for i := 0; i < len(singleton.Alerts); i++ {
+		// 检查是否包含流量规则
+		hasTrafficRule := false
+		for j := 0; j < len(singleton.Alerts[i].Rules); j++ {
+			if singleton.Alerts[i].Rules[j].IsTransferDurationRule() {
+				hasTrafficRule = true
+				// 重置下次更新时间缓存，强制立即更新
+				if singleton.Alerts[i].Rules[j].NextTransferAt != nil {
+					for serverID := range singleton.Alerts[i].Rules[j].NextTransferAt {
+						singleton.Alerts[i].Rules[j].NextTransferAt[serverID] = time.Now()
+						clearedCount++
+					}
+				}
+				// 清空上次状态缓存
+				if singleton.Alerts[i].Rules[j].LastCycleStatus != nil {
+					for serverID := range singleton.Alerts[i].Rules[j].LastCycleStatus {
+						singleton.Alerts[i].Rules[j].LastCycleStatus[serverID] = nil
+					}
+				}
+			}
+		}
+
+		// 如果包含流量规则，也清理AlertsCycleTransferStatsStore
+		if hasTrafficRule && singleton.AlertsCycleTransferStatsStore[singleton.Alerts[i].ID] != nil {
+			for serverID := range singleton.AlertsCycleTransferStatsStore[singleton.Alerts[i].ID].NextUpdate {
+				singleton.AlertsCycleTransferStatsStore[singleton.Alerts[i].ID].NextUpdate[serverID] = time.Now()
+			}
+		}
+	}
+
+	// 同时清理流量管理器缓存
+	tm := singleton.GetTrafficManager()
+	if err := tm.SaveToDatabase(); err != nil {
+		c.JSON(http.StatusInternalServerError, model.Response{
+			Code:    http.StatusInternalServerError,
+			Message: fmt.Sprintf("保存流量数据到数据库失败: %v", err),
+		})
+		return
+	}
+
+	c.JSON(http.StatusOK, model.Response{
+		Code:    http.StatusOK,
+		Message: fmt.Sprintf("流量缓存刷新成功，用户: %s，清理了 %d 个服务器的流量缓存", user.Login, clearedCount),
+	})
+}

model/rule.go

@@ -139,9 +139,33 @@ func (u *Rule) Snapshot(cycleTransferStats *CycleTransferStats, server *Server,
 
 	// 循环区间流量检测 · 更新下次需要检测时间
 	if u.IsTransferDurationRule() {
-		seconds := 1800 * ((u.Max - src) / u.Max)
-		if seconds < 180 {
-			seconds = 180
+		// 分层检测算法：根据使用率采用不同的检测频率
+		var seconds float64
+		if u.Max > 0 {
+			usagePercent := (src / u.Max) * 100
+			switch {
+			case usagePercent >= 90:
+				// 90%+ 使用率 → 1分钟检测（紧急）
+				seconds = 60
+			case usagePercent >= 60:
+				// 60-89% 使用率 → 5分钟检测
+				seconds = 300
+			case usagePercent >= 25:
+				// 25-59% 使用率 → 15分钟检测
+				seconds = 900
+			case usagePercent >= 5:
+				// 5-24% 使用率 → 15分钟检测
+				seconds = 900
+			default:
+				// 0-4% 使用率 → 30分钟检测，渐减到最短10分钟
+				seconds = 1800 - (usagePercent/5.0)*600
+				if seconds < 600 {
+					seconds = 600
+				}
+			}
+		} else {
+			// 如果没有设置最大值，使用默认30分钟
+			seconds = 1800
 		}
 		if u.NextTransferAt == nil {
 			u.NextTransferAt = make(map[uint64]time.Time)