-
+
+
+
+
Ops
@@ -578,7 +629,7 @@ export function OpsDashboard() {
@@ -589,6 +640,24 @@ export function OpsDashboard() {
{loading ? "加载中" : "刷新"}
+
{error ? (
@@ -662,7 +731,7 @@ export function OpsDashboard() {
-
+
转化漏斗
@@ -738,7 +807,7 @@ export function OpsDashboard() {
-
+
EMOS 上线门禁
@@ -812,13 +881,22 @@ export function OpsDashboard() {
-
+
历史真值主表
永久监督真值，不再受 14 天运行态缓存裁剪影响。
+
+
Wunderground 回填观察
@@ -1038,7 +1116,7 @@ export function OpsDashboard() {
-
+
城市覆盖矩阵
把 truth / feature / EMOS / LGBM 放到一张表里，快速判断哪些城市还只能靠 DEB。
@@ -1113,7 +1191,7 @@ export function OpsDashboard() {
-
+
);
diff --git a/frontend/components/ops/TruthHistoryDashboard.tsx b/frontend/components/ops/TruthHistoryDashboard.tsx
new file mode 100644
index 00000000..340a2c5b
--- /dev/null
+++ b/frontend/components/ops/TruthHistoryDashboard.tsx
@@ -0,0 +1,262 @@
+"use client";
+
+import { useCallback, useEffect, useMemo, useState } from "react";
+import { RefreshCcw } from "lucide-react";
+import { Badge } from "@/components/ui/badge";
+import { Button } from "@/components/ui/button";
+import { Card, CardContent, CardDescription, CardHeader, CardTitle } from "@/components/ui/card";
+
+type TruthHistoryItem = {
+ city: string;
+ display_name?: string;
+ target_date: string;
+ actual_high?: number | null;
+ settlement_source?: string | null;
+ settlement_station_code?: string | null;
+ settlement_station_label?: string | null;
+ truth_version?: string | null;
+ updated_by?: string | null;
+ truth_updated_at?: number | null;
+ is_final?: boolean | null;
+};
+
+type TruthHistoryPayload = {
+ items?: TruthHistoryItem[];
+ available_cities?: Array<{ city: string; name?: string }>;
+ filters?: {
+ city?: string | null;
+ date_from?: string | null;
+ date_to?: string | null;
+ limit?: number;
+ };
+ filtered_count?: number;
+};
+
+function formatUnixDateTime(value?: number | null) {
+ if (!value) return "-";
+ const date = new Date(value * 1000);
+ if (Number.isNaN(date.getTime())) return "-";
+ return date.toLocaleString("zh-CN", { hour12: false });
+}
+
+async function readJson(url: string): Promise {
+ const response = await fetch(url, { cache: "no-store" });
+ if (!response.ok) {
+ const raw = await response.text();
+ throw new Error(`${url} -> HTTP ${response.status} ${raw.slice(0, 180)}`);
+ }
+ return response.json() as Promise;
+}
+
+export function TruthHistoryDashboard() {
+ const [city, setCity] = useState("");
+ const [dateFrom, setDateFrom] = useState("");
+ const [dateTo, setDateTo] = useState("");
+ const [limit, setLimit] = useState("200");
+ const [payload, setPayload] = useState(null);
+ const [loading, setLoading] = useState(true);
+ const [error, setError] = useState(null);
+
+ const load = useCallback(async () => {
+ setLoading(true);
+ setError(null);
+ try {
+ const url = new URL("/api/ops/truth-history", window.location.origin);
+ if (city.trim()) url.searchParams.set("city", city.trim());
+ if (dateFrom.trim()) url.searchParams.set("date_from", dateFrom.trim());
+ if (dateTo.trim()) url.searchParams.set("date_to", dateTo.trim());
+ if (limit.trim()) url.searchParams.set("limit", limit.trim());
+ const data = await readJson(url.toString());
+ setPayload(data);
+ } catch (loadError) {
+ setError(String(loadError));
+ } finally {
+ setLoading(false);
+ }
+ }, [city, dateFrom, dateTo, limit]);
+
+ useEffect(() => {
+ void load();
+ }, [load]);
+
+ const items = payload?.items || [];
+ const availableCities = payload?.available_cities || [];
+ const stats = useMemo(() => {
+ const uniqueCities = new Set(items.map((item) => item.city)).size;
+ const finalCount = items.filter((item) => item.is_final).length;
+ return {
+ rows: items.length,
+ filtered: payload?.filtered_count ?? items.length,
+ uniqueCities,
+ finalCount,
+ };
+ }, [items, payload?.filtered_count]);
+
+ return (
+
+
+ );
+}
diff --git a/tests/test_web_observability.py b/tests/test_web_observability.py
index 2e305949..806da2d9 100644
--- a/tests/test_web_observability.py
+++ b/tests/test_web_observability.py
@@ -3,6 +3,7 @@ from fastapi.testclient import TestClient
from web.app import app
import web.routes as routes
+from src.database.runtime_state import TruthRecordRepository
client = TestClient(app)
@@ -146,3 +147,31 @@ def test_ops_memberships_prefers_supabase_auth_email(monkeypatch):
assert response.status_code == 200
payload = response.json()
assert payload["memberships"][0]["email"] == "fresh@example.com"
+
+
+def test_ops_truth_history_returns_filtered_rows(monkeypatch):
+ monkeypatch.setattr(routes, "_assert_entitlement", lambda request: None)
+ monkeypatch.setattr(routes, "_require_ops_admin", lambda request: None)
+
+ repo = TruthRecordRepository()
+ repo.upsert_truth(
+ city="taipei",
+ target_date="2026-04-02",
+ actual_high=26.0,
+ settlement_source="wunderground",
+ settlement_station_code="RCSS",
+ settlement_station_label="Taipei Songshan Airport Station",
+ truth_version="v1",
+ updated_by="test",
+ source_payload={"sample": True},
+ is_final=True,
+ )
+
+ response = client.get("/api/ops/truth-history?city=taipei&date_from=2026-04-01&date_to=2026-04-03&limit=10")
+
+ assert response.status_code == 200
+ payload = response.json()
+ assert "items" in payload
+ assert payload["filters"]["city"] == "taipei"
+ assert payload["items"][0]["city"] == "taipei"
+ assert payload["items"][0]["settlement_station_code"] == "RCSS"
diff --git a/web/routes.py b/web/routes.py
index fddd236d..f754b4ae 100644
--- a/web/routes.py
+++ b/web/routes.py
@@ -14,6 +14,7 @@ from src.analysis.deb_algorithm import (
)
from src.analysis.probability_snapshot_archive import load_snapshot_rows_for_day
from src.data_collection.city_registry import ALIASES
+from src.database.runtime_state import TruthRecordRepository
from src.utils.metrics import export_prometheus_metrics
from web.analysis_service import (
_analyze,
@@ -555,6 +556,75 @@ async def ops_analytics_funnel(request: Request, days: int = 30):
return db.get_app_analytics_funnel_summary(days=days)
+@router.get("/api/ops/truth-history")
+async def ops_truth_history(
+ request: Request,
+ city: str = "",
+ date_from: str = "",
+ date_to: str = "",
+ limit: int = 200,
+):
+ _assert_entitlement(request)
+ _require_ops_admin(request)
+
+ truth_history = TruthRecordRepository().load_all()
+ normalized_city = str(city or "").strip().lower()
+ normalized_from = str(date_from or "").strip()
+ normalized_to = str(date_to or "").strip()
+ max_limit = max(1, min(int(limit or 200), 1000))
+
+ rows = []
+ for row_city, by_date in truth_history.items():
+ if normalized_city and row_city != normalized_city:
+ continue
+ if not isinstance(by_date, dict):
+ continue
+ for target_date, payload in by_date.items():
+ if normalized_from and str(target_date) < normalized_from:
+ continue
+ if normalized_to and str(target_date) > normalized_to:
+ continue
+ if not isinstance(payload, dict):
+ continue
+ rows.append(
+ {
+ "city": row_city,
+ "display_name": str((CITY_REGISTRY.get(row_city) or {}).get("name") or row_city),
+ "target_date": str(target_date),
+ "actual_high": payload.get("actual_high"),
+ "settlement_source": payload.get("settlement_source"),
+ "settlement_station_code": payload.get("settlement_station_code"),
+ "settlement_station_label": payload.get("settlement_station_label"),
+ "truth_version": payload.get("truth_version"),
+ "updated_by": payload.get("updated_by"),
+ "truth_updated_at": payload.get("truth_updated_at"),
+ "is_final": payload.get("is_final"),
+ }
+ )
+
+ rows.sort(key=lambda item: (str(item["target_date"]), str(item["city"])), reverse=True)
+ filtered_count = len(rows)
+ rows = rows[:max_limit]
+ available_cities = [
+ {
+ "city": city_id,
+ "name": str(info.get("name") or city_id),
+ }
+ for city_id, info in sorted(CITY_REGISTRY.items(), key=lambda item: str(item[1].get("name") or item[0]))
+ ]
+ return {
+ "items": rows,
+ "available_cities": available_cities,
+ "filters": {
+ "city": normalized_city or None,
+ "date_from": normalized_from or None,
+ "date_to": normalized_to or None,
+ "limit": max_limit,
+ },
+ "filtered_count": filtered_count,
+ }
+
+
@router.get("/api/payments/config")
async def payment_config(request: Request):
_assert_entitlement(request)
PolyWeather Ops
- 直接挂在现有域名下的轻量运营页。先做只读运维视图，把系统状态、支付运行态和当前登录态聚合起来。 + 用后台管理系统的方式组织运营视图，把系统状态、训练数据、模型覆盖、支付与会员放到一页里。
+
+
+ Health
+ {health?.status || "unknown"}
+
+
+ Truth Rows
+ {truthRecords?.row_count ?? 0}
+
+
+ EMOS Samples
+ {trainingArtifacts?.emos_training_samples ?? 0}
+
+
+ LGBM Samples
+ {trainingArtifacts?.lgbm_sample_count ?? 0}
+
+
+
+
+ Truth Viewer
+ 按城市和日期直接查看历史真值、来源站点与更新记录。
+
@@ -1287,7 +1365,7 @@ export function OpsDashboard() {
-
+
用户查询
@@ -1381,6 +1459,7 @@ export function OpsDashboard() {
+
+
+
+
+
+
+
+ 当前结果
+ 本次筛选实际返回的记录条数。
+
+ {stats.rows}
+
+
+
+ 匹配总数
+ 过滤后总命中条数，返回结果受 limit 限制。
+
+ {stats.filtered}
+
+
+
+ 覆盖城市
+ 本次结果涉及的城市数量。
+
+ {stats.uniqueCities}
+
+
+
+ Final Rows
+ 当前返回里标记为最终真值的条数。
+
+ {stats.finalCount}
+
+
+
+
+
+ 筛选器
+ 按 city / date range 查历史真值。
+
+
+
+ setDateFrom(event.target.value)}
+ className="rounded-2xl border border-slate-700 bg-slate-950 px-3 py-2 text-sm text-slate-200"
+ />
+ setDateTo(event.target.value)}
+ className="rounded-2xl border border-slate-700 bg-slate-950 px-3 py-2 text-sm text-slate-200"
+ />
+ setLimit(event.target.value)}
+ className="rounded-2xl border border-slate-700 bg-slate-950 px-3 py-2 text-sm text-slate-200"
+ />
+
+
+
+
+ {error ? (
+
+
+ 加载失败
+ {error}
+
+
+ ) : null}
+
+
+
+ 历史真值表
+
+ 字段包括 `actual_high`、`settlement_source`、`station_code`、`truth_version`、`updated_by`、`updated_at`。
+
+
+
+
+
+
+
+
+
+
+
+
+ Ops
+ Truth History
+
+
+
+ 真值历史浏览
++ 面向后台运营/研究的历史真值表格页，支持按城市和日期范围过滤，直接查看最终 `actual_high` 与来源口径。 +
+
+
+
+
+
+ | Date | +City | +Actual | +Source | +Station | +Version | +Updated By | +Updated At | +
|---|---|---|---|---|---|---|---|
| {item.target_date} | +
+ {item.display_name || item.city}
+ {item.city}
+ |
+
+ {item.actual_high ?? "-"}
+ {item.is_final ? "final" : "non-final"}
+ |
+ {item.settlement_source || "-"} | +
+ {item.settlement_station_code || "-"}
+ {item.settlement_station_label || "-"}
+ |
+ {item.truth_version || "-"} | +{item.updated_by || "-"} | +{formatUnixDateTime(item.truth_updated_at)} | +
| + 当前筛选条件下没有历史真值记录 + | +