Add Tencent quote enrichment

Author: yjw

CHANGELOG.md

@@ -5,6 +5,15 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.1.19] - 2026-06-15
+
+### Added
+- Added Tencent Finance stock quotes as a verified enrichment source for A-share, Hong Kong, and US single-stock snapshots, market focus-stock sections, and fund holding quotes.
+- Single-stock output now shows turnover, turnover rate when available, market cap, PE/PB, and 52-week range when a validated no-login source provides those fields.
+
+### Changed
+- Sina Finance remains the primary quote path for HK/US focus stocks, while Tencent now supplements missing valuation/liquidity fields before Eastmoney `stock/get`/`clist` fallback is used.
+
 ## [0.1.18] - 2026-06-14
 
 ### Fixed

README.md

@@ -97,7 +97,7 @@ The internals are being split into focused modules: `young_stock.calendar` handl
 ## What's in the box
 
 - **Multiple public quote sources** — Tencent Finance, Sina Finance, and Eastmoney are tried in sequence so temporary source failures can be filled by another no-login endpoint.
-- **Single-stock lookup** — `young stock 600519`, `young stock 0700.HK`, or `young stock AAPL` prints a compact quote snapshot with source, trade date, price, change, volume, turnover when available, and optional news.
+- **Single-stock lookup** — `young stock 600519`, `young stock 0700.HK`, or `young stock AAPL` prints a compact quote snapshot with source, trade date, price, change, volume, turnover, market cap, PE/PB, 52-week range when available, and optional news.
 - **Fund holding lookup** — `young fund 161725` prints the fund's same-day estimated change, latest NAV date, top holdings, holding-stock quotes, rough contribution estimate, and same-day holding-stock news. Official fund NAVs usually update at night, so intraday/close values are clearly labeled as estimates.
 - **Personal daily report** — `young daily` reads your local investment memory from `~/.young_stock/profile.json`, then prints saved stock/ETF trends, fund estimates, only the markets relevant to your stocks and fund top holdings, and portfolio-style suggestions grounded in your funds, stocks, holding dates, quantities, and available news. First use requires a verified symbol plus `--buy-date` and `--quantity`, for example `young profile add-stock 600519 --buy-date 2026-01-15 --quantity 100` or `young profile add-fund 161725 --buy-date 2026-01-10 --quantity 1000`.
 - **Short report modes** — `young daily --format summary` keeps terminal output compact; `--format key-points` adds a few trend/risk bullets; `--only`, `--order`, and `--quick` trim slower or irrelevant sections.
@@ -172,6 +172,6 @@ young a -d 20260530 --refresh    # 指定日期 + 强制刷新
 young update       # 在当前 Python 环境中更新 CLI
 ```
 
-数据来源：同花顺概念资金流页面（仅在同时拿到净流入/净流出榜时采用）、腾讯财经、新浪财经、东方财富公开行情与快讯接口（`data.10jqka.com.cn` / `qt.gtimg.cn` / `hq.sinajs.cn` / `push2.eastmoney.com` / `push2ex.eastmoney.com` / `np-listapi.eastmoney.com`），多源自动切换。本地缓存 7 天，目录 `~/.young_stock/cache/`，可用 `young cache-clear` 清理。命令会标注当前阶段：上午盘、午间、下午盘或盘后；若展示的是非请求日的最新可用数据，会标注为该交易日盘后数据。普通输出不展示完整度和数据源诊断，排查问题时可设置 `YOUNG_STOCK_DEBUG=1` 查看详细切换记录。
+数据来源：同花顺概念资金流页面（仅在同时拿到净流入/净流出榜时采用）、腾讯财经、新浪财经、东方财富公开行情与快讯接口（`data.10jqka.com.cn` / `qt.gtimg.cn` / `hq.sinajs.cn` / `push2.eastmoney.com` / `push2ex.eastmoney.com` / `np-listapi.eastmoney.com`），多源自动切换。单只股票和基金持仓股会用腾讯财经补充成交额、换手率、市值、PE/PB、52 周高低等字段；价格主口径仍优先使用当前验证更稳的新浪/腾讯/东财链路。本地缓存 7 天，目录 `~/.young_stock/cache/`，可用 `young cache-clear` 清理。命令会标注当前阶段：上午盘、午间、下午盘或盘后；若展示的是非请求日的最新可用数据，会标注为该交易日盘后数据。普通输出不展示完整度和数据源诊断，排查问题时可设置 `YOUNG_STOCK_DEBUG=1` 查看详细切换记录。
 
 适用人群：每天盘后想用一条命令看完五张图的开发者 / 量化研究者 / 自动化爱好者。欢迎 issue / PR。

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "young-stock-cli"
-version = "0.1.18"
+version = "0.1.19"
 description = "A-share (China stock market) after-hours CLI — no login, no scraping tricks, just data."
 readme = "README.md"
 requires-python = ">=3.9"

src/young_stock/__init__.py

@@ -1,3 +1,3 @@
 """young-stock-cli: A-share after-hours CLI."""
 
-__version__ = "0.1.18"
+__version__ = "0.1.19"

src/young_stock/_core.py

@@ -223,6 +223,14 @@ class QuoteData:
     low: float | None = None
     volume: int | None = None
     turnover: float | None = None
+    turnover_rate: float | None = None
+    market_cap: float | None = None
+    float_market_cap: float | None = None
+    pe: float | None = None
+    pb: float | None = None
+    high_52w: float | None = None
+    low_52w: float | None = None
+    amplitude_pct: float | None = None
     currency: str = "USD"
     source: str = ""
     quality_flags: list[str] = field(default_factory=list)
@@ -800,6 +808,19 @@ def _source_date(value: str | None) -> str:
     return m.group(1) if m else value
 
 
+def _tencent_source_date(value: str | None, date_str: str) -> str:
+    value = str(value or "").strip()
+    if not value:
+        return _display_date(date_str)
+    if re.match(r"\d{4}/\d{2}/\d{2}", value):
+        return _source_date(value)
+    if re.match(r"\d{4}-\d{2}-\d{2}", value):
+        return _source_date(value)
+    if re.match(r"\d{14}$", value):
+        return f"{value[:4]}-{value[4:6]}-{value[6:8]}"
+    return _display_date(date_str)
+
+
 def session_stage_label(dt: datetime | None = None, *, data_date: str | None = None, requested_date: str | None = None) -> str:
     """返回股民更容易理解的行情阶段。历史/非请求日数据按盘后展示。"""
     if data_date and requested_date and data_date.replace("-", "") != requested_date:
@@ -1471,6 +1492,109 @@ def fetch_us_indices_tencent(symbols_map: dict[str, str], date_str: str) -> list
     return results
 
 
+def _tencent_cn_code(symbol: str) -> str:
+    raw = symbol.upper().replace(".SH", "").replace(".SZ", "").replace(".BJ", "")
+    if raw.startswith(("5", "6", "9")):
+        return f"sh{raw}"
+    if raw.startswith(("4", "8")):
+        return f"bj{raw}"
+    return f"sz{raw}"
+
+
+def _tencent_hk_code(symbol: str) -> str:
+    raw = symbol.upper().replace(".HK", "").lstrip("0") or "0"
+    return f"r_hk{raw.zfill(5)}"
+
+
+def _tencent_us_code(symbol: str) -> str:
+    return f"us{symbol.upper().lstrip('^')}"
+
+
+def _tencent_stock_to_quote(fields: list[str], symbol: str, market: str, date_str: str) -> QuoteData | None:
+    if len(fields) < 45:
+        return None
+    currency = {"cn_market": "CNY", "hk_market": "HKD", "us_market": "USD"}.get(market, "USD")
+    turnover = _safe_float(fields[37] if len(fields) > 37 else None)
+    if market == "cn_market" and turnover is not None:
+        turnover *= 1e4  # A股腾讯字段为万元
+    qd = QuoteData(
+        symbol=symbol,
+        name=str(fields[1] or symbol),
+        market=market,
+        date=_tencent_source_date(fields[30] if len(fields) > 30 else "", date_str),
+        price=_safe_float(fields[3]),
+        prev_close=_safe_float(fields[4]),
+        change=_safe_float(fields[31] if len(fields) > 31 else None),
+        change_pct=_safe_float(fields[32] if len(fields) > 32 else None),
+        open_price=_safe_float(fields[5]),
+        high=_safe_float(fields[33] if len(fields) > 33 else None),
+        low=_safe_float(fields[34] if len(fields) > 34 else None),
+        volume=_safe_int(fields[6]),
+        turnover=turnover,
+        turnover_rate=_safe_float(fields[38] if len(fields) > 38 else None),
+        market_cap=_safe_float(fields[44] if len(fields) > 44 else None),
+        float_market_cap=_safe_float(fields[45] if len(fields) > 45 else None),
+        pe=_safe_float(fields[39] if len(fields) > 39 else None),
+        high_52w=_safe_float(fields[48] if len(fields) > 48 else None),
+        low_52w=_safe_float(fields[49] if len(fields) > 49 else None),
+        amplitude_pct=_safe_float(fields[43] if len(fields) > 43 else None),
+        currency=currency,
+        source="tencent",
+    )
+    if market == "cn_market":
+        qd.pb = _safe_float(fields[46] if len(fields) > 46 else None)
+        qd.high_52w = _safe_float(fields[47] if len(fields) > 47 else None)
+        qd.low_52w = _safe_float(fields[48] if len(fields) > 48 else None)
+    elif market == "hk_market":
+        # 港股腾讯字段 58 为 PB；56/57 可能随标的含义变化，不作为 PB。
+        qd.pb = _safe_float(fields[58] if len(fields) > 58 else None)
+        if qd.turnover_rate == 0:
+            qd.turnover_rate = None
+    return validate_quote(qd)
+
+
+def fetch_cn_stocks_tencent(symbols: list[str], date_str: str) -> list[QuoteData]:
+    raw_map = _parse_tencent_batch(fetch_tencent_batch([_tencent_cn_code(s) for s in symbols]))
+    results: list[QuoteData] = []
+    for sym in symbols:
+        fields = raw_map.get(_tencent_cn_code(sym))
+        if not fields:
+            diag(f"Tencent missing A-share: {sym}")
+            continue
+        qd = _tencent_stock_to_quote(fields, sym, "cn_market", date_str)
+        if qd:
+            results.append(qd)
+    return results
+
+
+def fetch_hk_stocks_tencent(symbols: list[str], date_str: str) -> list[QuoteData]:
+    raw_map = _parse_tencent_batch(fetch_tencent_batch([_tencent_hk_code(s) for s in symbols]))
+    results: list[QuoteData] = []
+    for sym in symbols:
+        fields = raw_map.get(_tencent_hk_code(sym))
+        if not fields:
+            diag(f"Tencent missing HK: {sym}")
+            continue
+        qd = _tencent_stock_to_quote(fields, sym, "hk_market", date_str)
+        if qd:
+            results.append(qd)
+    return results
+
+
+def fetch_us_stocks_tencent(symbols: list[str], date_str: str) -> list[QuoteData]:
+    raw_map = _parse_tencent_batch(fetch_tencent_batch([_tencent_us_code(s) for s in symbols]))
+    results: list[QuoteData] = []
+    for sym in symbols:
+        fields = raw_map.get(_tencent_us_code(sym))
+        if not fields:
+            diag(f"Tencent missing US: {sym}")
+            continue
+        qd = _tencent_stock_to_quote(fields, sym, "us_market", date_str)
+        if qd:
+            results.append(qd)
+    return results
+
+
 def _fetch_a_indices_tencent() -> list[dict[str, Any]]:
     raw_map = _parse_tencent_batch(fetch_tencent_batch(list(TENCENT_A_INDEX_MAP.keys())))
     result = []
@@ -1498,6 +1622,41 @@ def merge_quotes_by_symbol(primary: list[QuoteData], fallback: list[QuoteData],
     return [lookup[s.upper()] for s in order if s.upper() in lookup]
 
 
+def enrich_quotes_by_symbol(primary: list[QuoteData], supplemental: list[QuoteData], order: list[str]) -> list[QuoteData]:
+    """保留主源价格口径，用补充源填充成交额、估值、市值等扩展字段。"""
+    fallback = {q.symbol.upper(): q for q in supplemental}
+    primary_lookup = {q.symbol.upper(): q for q in primary}
+    enriched: list[QuoteData] = []
+    enrich_fields = (
+        "turnover",
+        "turnover_rate",
+        "market_cap",
+        "float_market_cap",
+        "pe",
+        "pb",
+        "high_52w",
+        "low_52w",
+        "amplitude_pct",
+    )
+    for sym in order:
+        key = sym.upper()
+        qd = primary_lookup.get(key) or fallback.get(key)
+        if not qd:
+            continue
+        extra = fallback.get(key)
+        if extra and qd is not extra:
+            changed = False
+            for field_name in enrich_fields:
+                if getattr(qd, field_name, None) is None and getattr(extra, field_name, None) is not None:
+                    setattr(qd, field_name, getattr(extra, field_name))
+                    changed = True
+            if changed:
+                qd.notes.append("腾讯财经补充成交额/估值字段")
+                validate_quote(qd)
+        enriched.append(qd)
+    return enriched
+
+
 def _has_all_quotes(quotes: list[QuoteData], order: list[str]) -> bool:
     found = {q.symbol.upper() for q in quotes}
     return all(symbol.upper() in found for symbol in order)
@@ -2586,6 +2745,21 @@ def print_global_stock(qd: QuoteData) -> None:
     if any(f in qd.quality_flags for f in ["volume_zero", "volume_anomaly"]):
         vol_str += " *"
     print(f"  成交量: {vol_str}")
+    if qd.turnover is not None:
+        print(f"  成交额: {fmt_amount(qd.turnover)}")
+    if qd.turnover_rate is not None and qd.turnover_rate > 0:
+        print(f"  换手率: {fmt_pct(qd.turnover_rate)}")
+    if qd.market_cap is not None:
+        print(f"  总市值: {fmt_amount(qd.market_cap * 1e8)}")
+    valuation = []
+    if qd.pe is not None and qd.pe > 0:
+        valuation.append(f"PE {qd.pe:.2f}")
+    if qd.pb is not None and qd.pb > 0:
+        valuation.append(f"PB {qd.pb:.2f}")
+    if valuation:
+        print(f"  估值:   {' | '.join(valuation)}")
+    if qd.high_52w is not None or qd.low_52w is not None:
+        print(f"  52周:   {fmt_price(qd.low_52w)} - {fmt_price(qd.high_52w)}")
     print(f"  货币:   {qd.currency}")
     if qd.change is not None and qd.change_pct is not None:
         print(f"  涨跌:   {qd.change:+.2f} ({qd.change_pct:+.2f}%)")
@@ -2819,6 +2993,10 @@ def fetch_fund_holding_quotes(holdings: list[dict[str, Any]], date_str: str) ->
     if not codes:
         return {}
     quotes = fetch_cn_stocks_sina(codes, date_str)
+    tencent_quotes = fetch_cn_stocks_tencent(codes, date_str)
+    if not _has_all_quotes(quotes, codes):
+        quotes = merge_quotes_by_symbol(quotes, tencent_quotes, codes)
+    quotes = enrich_quotes_by_symbol(quotes, tencent_quotes, codes)
     if not _has_all_quotes(quotes, codes):
         quotes = merge_quotes_by_symbol(quotes, fetch_cn_stocks_direct(codes, date_str), codes)
     return {q.symbol: q for q in quotes if _is_usable_quote(q)}
@@ -2833,16 +3011,28 @@ def get_single_stock_quote(symbol: str, date_str: str) -> QuoteData | None:
     quotes: list[QuoteData] = []
     if market == "cn_market":
         quotes = fetch_cn_stocks_sina([normalized], date_str)
+        tencent_quotes = fetch_cn_stocks_tencent([normalized], date_str)
+        if not _has_all_quotes(quotes, [normalized]):
+            quotes = merge_quotes_by_symbol(quotes, tencent_quotes, [normalized])
+        quotes = enrich_quotes_by_symbol(quotes, tencent_quotes, [normalized])
         if not _has_all_quotes(quotes, [normalized]):
             quotes = merge_quotes_by_symbol(quotes, fetch_cn_stocks_direct([normalized], date_str), [normalized])
     elif market == "hk_market":
         quotes = fetch_hk_stocks_sina([normalized], date_str)
+        tencent_quotes = fetch_hk_stocks_tencent([normalized], date_str)
+        if not _has_all_quotes(quotes, [normalized]):
+            quotes = merge_quotes_by_symbol(quotes, tencent_quotes, [normalized])
+        quotes = enrich_quotes_by_symbol(quotes, tencent_quotes, [normalized])
         if not _has_all_quotes(quotes, [normalized]):
             quotes = merge_quotes_by_symbol(quotes, fetch_hk_stocks_direct([normalized], date_str), [normalized])
         if not _has_all_quotes(quotes, [normalized]):
             quotes = merge_quotes_by_symbol(quotes, fetch_em_stocks([normalized], date_str, EM_FS["hk_stock"]), [normalized])
     elif market == "us_market":
         quotes = fetch_us_stocks_sina([normalized], date_str)
+        tencent_quotes = fetch_us_stocks_tencent([normalized], date_str)
+        if not _has_all_quotes(quotes, [normalized]):
+            quotes = merge_quotes_by_symbol(quotes, tencent_quotes, [normalized])
+        quotes = enrich_quotes_by_symbol(quotes, tencent_quotes, [normalized])
         if not _has_all_quotes(quotes, [normalized]):
             quotes = merge_quotes_by_symbol(quotes, fetch_us_stocks_direct([normalized], date_str), [normalized])
         if not _has_all_quotes(quotes, [normalized]):
@@ -2881,6 +3071,19 @@ def print_single_stock_report(qd: QuoteData, requested_date: str) -> None:
     if qd.turnover is not None:
         print(f"  成交额: {fmt_amount(qd.turnover)}")
     print(f"  成交量: {fmt_volume(qd.volume)}")
+    if qd.turnover_rate is not None and qd.turnover_rate > 0:
+        print(f"  换手率: {fmt_pct(qd.turnover_rate)}")
+    if qd.market_cap is not None:
+        print(f"  总市值: {fmt_amount(qd.market_cap * 1e8)}")
+    valuation = []
+    if qd.pe is not None and qd.pe > 0:
+        valuation.append(f"PE {qd.pe:.2f}")
+    if qd.pb is not None and qd.pb > 0:
+        valuation.append(f"PB {qd.pb:.2f}")
+    if valuation:
+        print(f"  估值:   {' | '.join(valuation)}")
+    if qd.high_52w is not None or qd.low_52w is not None:
+        print(f"  52周:   {fmt_price(qd.low_52w)} - {fmt_price(qd.high_52w)}")
     if qd.notes:
         print(f"  提醒:   {'；'.join(qd.notes)}")
     print()
@@ -3372,6 +3575,10 @@ def run_us_market(date_str: str, include_news: bool = True) -> None:
         hot_stocks = list(dict.fromkeys([*ranked_news, *default_hot_stocks]))[:5]
     print("## 重点个股行情\n")
     stocks = fetch_us_stocks_sina(hot_stocks, date_str)
+    tencent_stocks = fetch_us_stocks_tencent(hot_stocks, date_str)
+    if not _has_all_quotes(stocks, hot_stocks):
+        stocks = merge_quotes_by_symbol(stocks, tencent_stocks, hot_stocks)
+    stocks = enrich_quotes_by_symbol(stocks, tencent_stocks, hot_stocks)
     if not _has_all_quotes(stocks, hot_stocks):
         stocks = merge_quotes_by_symbol(stocks, fetch_us_stocks_direct(hot_stocks, date_str), hot_stocks)
     if not _has_all_quotes(stocks, hot_stocks):
@@ -3448,6 +3655,10 @@ def run_hk_market(date_str: str, include_news: bool = True) -> None:
         hot_stocks = list(dict.fromkeys([*ranked_news, *default_hot_stocks]))[:5]
     print("## 重点个股行情\n")
     stocks = fetch_hk_stocks_sina(hot_stocks, date_str)
+    tencent_stocks = fetch_hk_stocks_tencent(hot_stocks, date_str)
+    if not _has_all_quotes(stocks, hot_stocks):
+        stocks = merge_quotes_by_symbol(stocks, tencent_stocks, hot_stocks)
+    stocks = enrich_quotes_by_symbol(stocks, tencent_stocks, hot_stocks)
     if not _has_all_quotes(stocks, hot_stocks):
         stocks = merge_quotes_by_symbol(stocks, fetch_hk_stocks_direct(hot_stocks, date_str), hot_stocks)
     if not _has_all_quotes(stocks, hot_stocks):