看股功能更新

backend/app/api.py

@@ -3,6 +3,7 @@
   GET  /api/health               健康检查
   GET  /api/candles/{sym}        取 K 线（支持 1d/1w/1M/1y 周期，日线为基底聚合）
   GET  /api/stocks               全市场股票列表（基本信息 + 最新行情 + 缓存条数）
+  GET  /api/market/overview      主页大盘总览（A 股/港美指数 + 两市市值成交统计）
   POST /api/backtest             跑回测，返回 K线+指标+买卖点+净值+绩效
   POST /api/screener/run         智能选股：自然语言 -> 条件 -> 全市场筛选
   POST /api/screener/sync        启动全市场数据同步（后台任务）
@@ -28,6 +29,7 @@ from .backtest.strategies import build_strategy
 from .config import settings
 from .data import fetcher, repository
 from .data.aggregation import bars_per_year, resample_bars
+from .data.market_overview import MarketOverviewError, fetch_overview
 from .data.symbols import plain_code
 from .db import get_session
 from .domain import Bar
@@ -52,6 +54,7 @@ from .schemas import (
     EventBacktestRequest,
     EventBacktestResponse,
     IndicatorOut,
+    MarketOverviewResponse,
     MetricsOut,
     PreferencesOut,
     PreferencesUpdate,
@@ -319,6 +322,19 @@ async def stock_facets(session: AsyncSession = Depends(get_session)) -> StockFac
     return resp
 
 
+@router.get("/market/overview", response_model=MarketOverviewResponse)
+async def get_market_overview() -> MarketOverviewResponse:
+    """主页大盘总览：A 股 + 港美指数最近收盘（含迷你走势），沪深两市市值/成交统计。
+
+    收盘口径（token 无实时权限），展示时标注交易日；部分来源失败不影响其余。
+    """
+    try:
+        data = await fetch_overview()
+    except MarketOverviewError as e:
+        raise HTTPException(status_code=503, detail=str(e)) from e
+    return MarketOverviewResponse(**data)
+
+
 @router.post("/backtest", response_model=BacktestResponse)
 async def backtest(
     req: BacktestRequest,

backend/app/config.py

@@ -30,6 +30,7 @@ class Settings(BaseSettings):
     redis_url: str = ""
     stocks_cache_ttl: int = 300        # 股票列表缓存秒数（行情列允许最多滞后这么多秒）
     facets_cache_ttl: int = 3600       # 行业/地域筛选项缓存秒数（stock_basic 很少变）
+    market_overview_ttl: int = 300     # 主页大盘总览缓存秒数（收盘口径数据，无需更勤）
 
     # ---- LLM（智能选股的自然语言解析；DeepSeek，OpenAI 兼容协议，可换任意兼容网关）----
     llm_base_url: str = "https://api.deepseek.com"

backend/app/schemas.py

@@ -373,3 +373,32 @@ class TradesImportResponse(BaseModel):
 
 class TradesClearResponse(BaseModel):
     deleted: int
+
+
+# ---------- 大盘总览（主页） ----------
+class IndexQuoteOut(BaseModel):
+    code: str                        # 000001.SH / HKTECH / DJI
+    name: str                        # 上证指数 / 恒生科技 / 道琼斯
+    region: str                      # cn | hk | us（前端分组展示）
+    close: float | None = None
+    change: float | None = None
+    pct_chg: float | None = None
+    trade_date: date | None = None   # 最近交易日（收盘口径）
+    spark: list[float] = []          # 近 N 日收盘（旧 -> 新），迷你走势用
+    spark_dates: list[str] = []      # 与 spark 对齐的交易日（YYYYMMDD），hover 提示用
+
+
+class MarketStatsOut(BaseModel):
+    """沪深两市汇总（daily_info：沪 SH_A + 深 SZ_MARKET，亿元）。"""
+    trade_date: date | None = None
+    total_mv: float | None = None    # 总市值（亿元）
+    float_mv: float | None = None    # 流通市值（亿元）
+    amount: float | None = None      # 两市成交额（亿元）
+    turnover: float | None = None    # 换手率 %（沪市口径）
+
+
+class MarketOverviewResponse(BaseModel):
+    updated_at: datetime
+    indexes: list[IndexQuoteOut] = []
+    stats: MarketStatsOut | None = None
+    errors: list[str] = []           # 部分来源失败的说明（透明但不阻塞展示）