2569718930@qq.com
6c08a68413
性能与用户体验全面优化
前端性能:
- 移除 Three.js 依赖（~600KB），天气粒子改为纯 CSS 动画 + Canvas 2D
- Google Fonts 切换为 next/font 自托管，消除跨域字体请求
- 合并 ScanTerminalLightTheme.module.css (37KB) 到主 CSS，亮/暗主题统一用 CSS 变量
- 新增 /api/dashboard/init 聚合端点，首次加载 4 次往返 → 1 次
- 添加 Service Worker 静态资源缓存，修复 PWA manifest 配置
用户体验:
- 新增全局错误边界 error.tsx / global-error.tsx，崩溃不再白屏
- 决策卡和城市详情的更新时间改为相对时间（"15秒前"），每秒自动刷新
- 数据陈旧时状态标签从青色切换为琥珀色提示
DEB 算法增强:
- 市场扫描路径接入 Open-Meteo 多模型数据（ECMWF/GFS/ICON/JMA/HRDPS 等）
- MAE 计算加入时间衰减（decay_factor=0.85），近期模型误差权重更高
Scope-risk: MEDIUM — 全量 170 测试通过，前端 TypeScript/build 通过，ruff 零告警
Tested: python -m pytest -q (170 passed), npx tsc --noEmit (0 errors), npm run build (success), ruff check .
@
91 lines
3.0 KiB
Python
91 lines
3.0 KiB
Python
"""Dashboard init — bundled payload to reduce API waterfall on first paint."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import time
|
|
from typing import Any, Dict, Optional
|
|
|
|
from fastapi import Request
|
|
from fastapi.concurrency import run_in_threadpool
|
|
from loguru import logger
|
|
|
|
import web.routes as legacy_routes
|
|
from web.services.city_api import _build_cities_payload
|
|
|
|
|
|
def _resolve_default_city(request: Request) -> Optional[str]:
|
|
tz = (
|
|
getattr(request.state, "auth_timezone", None)
|
|
or str(request.headers.get("X-User-Timezone") or "").strip()
|
|
or None
|
|
)
|
|
if tz and hasattr(legacy_routes, "TIMEZONE_DEFAULT_CITIES"):
|
|
cities_map = getattr(legacy_routes, "TIMEZONE_DEFAULT_CITIES", {})
|
|
if tz in cities_map:
|
|
return cities_map[tz]
|
|
return next(iter(getattr(legacy_routes, "DEFAULT_PREWARM_CITIES", [])), None)
|
|
|
|
|
|
async def build_dashboard_init_payload(request: Request) -> Dict[str, Any]:
|
|
started = time.perf_counter()
|
|
legacy_routes._bind_optional_supabase_identity(request)
|
|
is_pro = bool(getattr(request.state, "auth_user_id", None))
|
|
|
|
cities_payload = await run_in_threadpool(_build_cities_payload)
|
|
|
|
default_city = _resolve_default_city(request)
|
|
detail_payload: Optional[Dict[str, Any]] = None
|
|
if default_city:
|
|
try:
|
|
cached_entry = await run_in_threadpool(
|
|
legacy_routes._CACHE_DB.get_city_cache, "panel", default_city,
|
|
)
|
|
if cached_entry:
|
|
detail_payload = cached_entry.get("payload") or {}
|
|
else:
|
|
detail_payload = await run_in_threadpool(
|
|
legacy_routes._refresh_city_panel_cache, default_city, False,
|
|
)
|
|
except Exception as exc:
|
|
logger.warning(
|
|
"dashboard_init default_city={} panel failed: {}", default_city, exc
|
|
)
|
|
|
|
scan_payload: Optional[Dict[str, Any]] = None
|
|
if is_pro:
|
|
try:
|
|
scan_payload = await run_in_threadpool(
|
|
legacy_routes.build_scan_terminal_payload,
|
|
{
|
|
"scan_mode": "tradable",
|
|
"min_price": 0.05,
|
|
"max_price": 0.95,
|
|
"min_edge_pct": 2.0,
|
|
"min_liquidity": 500.0,
|
|
"market_type": "maxtemp",
|
|
"time_range": "today",
|
|
"limit": 25,
|
|
},
|
|
False,
|
|
)
|
|
except Exception as exc:
|
|
logger.warning("dashboard_init scan terminal failed: {}", exc)
|
|
|
|
duration_ms = round((time.perf_counter() - started) * 1000.0, 1)
|
|
logger.info(
|
|
"dashboard_init is_pro={} default_city={} duration_ms={}",
|
|
is_pro,
|
|
default_city,
|
|
duration_ms,
|
|
)
|
|
|
|
payload: Dict[str, Any] = {
|
|
"cities": cities_payload.get("cities", []),
|
|
"default_city": default_city or "",
|
|
"default_city_detail": detail_payload,
|
|
"is_pro": is_pro,
|
|
}
|
|
if scan_payload is not None:
|
|
payload["scan_terminal"] = scan_payload
|
|
return payload
|