Method handleResetTraffic

internal/serverapi/users.go:854–893

handleResetTraffic 重置用户流量。

(w http.ResponseWriter, r *http.Request, userID string)

// handleResetTraffic 重置用户流量。
func (a *userAPI) handleResetTraffic(w http.ResponseWriter, r *http.Request, userID string) {
	if r.Method != http.MethodPost {
		writeJSON(w, http.StatusMethodNotAllowed, map[string]any{"error": "method not allowed"})
		return
	}
	user, err := a.users.GetUser(userID)
	if err != nil {
		writeJSON(w, http.StatusNotFound, map[string]any{"error": "user not found"})
		return
	}
	now := time.Now().UTC()
	user.UploadBytes = 0
	user.DownloadBytes = 0
	user.UsedBytes = 0
	user.RawUploadBytes = 0
	user.RawDownloadBytes = 0
	user.LastTrafficResetAt = &now
	if _, err := a.users.UpsertUser(user); err != nil {
		internalError(w, r, fmt.Errorf("failed to reset traffic: %w", err))
		return
	}
	if err := a.users.ClearUserNodeDailyUsage(userID); err != nil {
		internalError(w, r, fmt.Errorf("failed to clear node daily usage: %w", err))
		return
	}
	accesses, err := a.users.ListUserInboundsByUser(userID)
	if err != nil {
		log.Printf("handleResetTraffic: list user inbounds %s: %v", userID, err)
	}
	affectedNodeIDs := make(map[string]struct{})
	for _, acc := range accesses {
		affectedNodeIDs[acc.NodeID] = struct{}{}
	}
	nodeIDs := make([]string, 0, len(affectedNodeIDs))
	for id := range affectedNodeIDs {
		nodeIDs = append(nodeIDs, id)
	}
	a.applyNodes(nodeIDs)
	writeJSON(w, http.StatusOK, map[string]any{"ok": true})
}

// handleSubLogs 返回用户的订阅访问日志。
func (a *userAPI) handleSubLogs(w http.ResponseWriter, r *http.Request, userID string) {