更新UI

server/unified-management/internal/db/audit_store.go

@@ -20,6 +20,7 @@ func (s *Store) DashboardOverview(limit int) (map[string]any, error) {
 	healthCounts, _ := s.groupCounts("source_endpoints", "last_status")
 	recentChecks, _ := s.RecentSourceChecks(limit)
 	recentCalls, _ := s.RecentSourceCalls(limit)
+	averageLatency, _ := s.AverageSourceLatencyBuckets(limit)
 	audit, _ := s.ListAuditLogs(10)
 	return map[string]any{
 		"ok": true,
@@ -34,12 +35,94 @@ func (s *Store) DashboardOverview(limit int) (map[string]any, error) {
 		"feedbackStatus": statusCounts,
 		"sourceHealth":   healthCounts,
 		"heartbeats":     recentChecks,
+		"averageLatency": averageLatency,
 		"clientCalls":    recentCalls,
 		"database":       s.Status(),
 		"audit":          audit,
 	}, nil
 }
 
+func (s *Store) AverageSourceLatencyBuckets(limit int) ([]map[string]any, error) {
+	if limit <= 0 || limit > 200 {
+		limit = 80
+	}
+	rows, err := s.query(`SELECT checked_at, latency_ms, status FROM endpoint_health_checks ORDER BY checked_at DESC, id DESC LIMIT ?`, limit*4)
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	type bucket struct {
+		label  string
+		total  int
+		count  int
+		ok     int
+		latest string
+	}
+	order := []string{}
+	buckets := map[string]*bucket{}
+	for rows.Next() {
+		var checkedAt, status string
+		var latency int
+		if err := rows.Scan(&checkedAt, &latency, &status); err != nil {
+			return nil, err
+		}
+		label := latencyBucketLabel(checkedAt)
+		if label == "" {
+			label = checkedAt
+		}
+		item, ok := buckets[label]
+		if !ok {
+			item = &bucket{label: label, latest: checkedAt}
+			buckets[label] = item
+			order = append(order, label)
+		}
+		item.total += latency
+		item.count++
+		if status == "ok" || status == "redirected" {
+			item.ok++
+		}
+		if checkedAt > item.latest {
+			item.latest = checkedAt
+		}
+	}
+	if err := rows.Err(); err != nil {
+		return nil, err
+	}
+	out := []map[string]any{}
+	for i := len(order) - 1; i >= 0; i-- {
+		item := buckets[order[i]]
+		if item == nil || item.count == 0 {
+			continue
+		}
+		out = append(out, map[string]any{
+			"label":          item.label,
+			"averageLatency": item.total / item.count,
+			"avgLatencyMs":   item.total / item.count,
+			"sampleCount":    item.count,
+			"healthyCount":   item.ok,
+			"checkedAt":      item.latest,
+		})
+	}
+	if len(out) > limit {
+		out = out[len(out)-limit:]
+	}
+	return out, nil
+}
+
+func latencyBucketLabel(value string) string {
+	if value == "" {
+		return ""
+	}
+	parsed, err := time.Parse(time.RFC3339, value)
+	if err != nil {
+		if len(value) >= 16 {
+			return value[:16]
+		}
+		return value
+	}
+	return parsed.UTC().Format("01-02 15:04")
+}
+
 func (s *Store) RecentSourceChecks(limit int) ([]map[string]any, error) {
 	rows, err := s.query(`SELECT h.id, h.source_db_id, COALESCE(e.source_id, ''), COALESCE(e.name, ''), h.status, h.latency_ms, h.error, h.checked_at
 		FROM endpoint_health_checks h LEFT JOIN source_endpoints e ON e.id = h.source_db_id