Method buildStatPayload

internal/panel/handler.go:193–356

()

}

func (h *Handler) buildStatPayload() (*statPayload, error) {
	allNodes, err := h.nodeStore.List()
	if err != nil {
		return nil, err
	}
	// 监控数据只包含启用的节点
	nodeList := make([]nodes.Node, 0, len(allNodes))
	for _, n := range allNodes {
		if !n.Disabled {
			nodeList = append(nodeList, n)
		}
	}
	checkMap, _ := h.nodeStore.ListAllNodeCheckResults()
	speedMap, _ := h.nodeStore.ListAllNodeSpeedTests()
	uptimeBarsMap, _ := h.nodeStore.ListNodeUptimeBars(3)
	tracerouteMap, _ := h.nodeStore.ListLatestTracerouteSnapshots()

	// 拉取过去 1 小时的延迟采样，按 node_id 分组
	nodeIDs := make([]string, 0, len(nodeList))
	for _, n := range nodeList {
		nodeIDs = append(nodeIDs, n.ID)
	}
	latencyMap := make(map[string][]statLatencySample)
	latencyNow := time.Now().UTC()
	if samples, err := h.nodeStore.QueryLatencySamples(nodeIDs, latencyNow.Add(-1*time.Hour), latencyNow); err == nil {
		for _, s := range samples {
			var rtt *int
			if s.RttMs != nil {
				v := *s.RttMs
				rtt = &v
			}
			latencyMap[s.NodeID] = append(latencyMap[s.NodeID], statLatencySample{
				ISP:       s.ISP,
				RttMs:     rtt,
				SampledAt: s.SampledAt.Format(time.RFC3339),
			})
		}
	}

	toChecks := func(crs []nodes.CheckResult) []statCheck {
		out := make([]statCheck, 0, len(crs))
		for _, cr := range crs {
			jc := statCheck{Service: cr.Service, Unlocked: cr.Unlocked, Region: cr.Region, Note: cr.Note}
			if !cr.CheckedAt.IsZero() {
				jc.CheckedAt = cr.CheckedAt.Format(time.RFC3339)
			}
			out = append(out, jc)
		}
		return out
	}

	// 预构建节点 IP → GeoIP 信息映射（DB 未就绪时静默跳过）
	geoMap := make(map[string]*statNodeGeo, len(nodeList))
	if h.geoDB != nil && h.geoDB.Ready() {
		for _, n := range nodeList {
			host := strings.TrimSpace(n.IPOverride)
			if host == "" {
				// 从 base_url 提取 hostname