fix: require two-sided ths fund flow

Author: AdvancingTitans

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.11] - 2026-06-02
+
+### Fixed
+- Tonghuashun concept fund-flow is used only when both net-inflow and net-outflow rankings are available; otherwise `young flow` falls back to the existing Eastmoney/Sina/Tencent/local-cache chain.
+- Fund-flow headings now match the actual source scope, including concept boards, sector boards, market-activity references, and Eastmoney main-capital flow.
+
+### Changed
+- Normal command output no longer prints engineering-style data-quality/completeness/source-diagnostic sections; detailed diagnostics remain available with `YOUNG_STOCK_DEBUG=1`.
+
 ## [0.1.10] - 2026-06-02
 
 ### Added

README.md

@@ -77,7 +77,7 @@ It is also a foundation for analysis pipelines: every subcommand maps to a Pytho
 - **Smart caching** — `~/.young_stock/cache/`, 7-day TTL, auto-pruned. Pass `--refresh` to skip.
 - **Trade-day awareness** — nearest-trade-day resolution including weekends and (best-effort) holidays.
 - **Rich terminal tables** — readable on dark and light terminals.
-- **Verified A-share fund flow** — `young flow` first tries Tonghuashun concept-board fund flow for fresh board-direction money signals, then Eastmoney main-capital flow/page indicators, Sina Finance sector fund-flow, Sina/Tencent market-activity references, and finally the most recent locally cached good record. Non-equivalent fallbacks are clearly labeled instead of being presented as whole-market main-capital net inflow.
+- **Verified A-share fund flow** — `young flow` uses Tonghuashun concept-board fund flow only when both net-inflow and net-outflow rankings are available, then falls back to Eastmoney main-capital flow/page indicators, Sina Finance sector fund-flow, Sina/Tencent market-activity references, and finally the most recent locally cached good record. Non-equivalent fallbacks are clearly labeled instead of being presented as whole-market main-capital net inflow.
 - **News heat ranking** — HK/US focus stocks can be ranked by filtered news heat from multiple no-login sources: Futu, Sina Finance, and Eastmoney fast news. Xueqiu/THS are intentionally not hardwired unless a stable no-login interface is available.
 - **Same-day news discipline** — news sections only show items published on the requested trading date, up to five items, with a clear empty-state message when nothing valid is available.
 - **Readable news links** — linked news items are checked for obvious empty/404/no-content pages and replaced by other same-day news when possible.
@@ -139,6 +139,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` 清理。命令会标注当前阶段：上午盘、午间、下午盘或盘后；若展示的是非请求日的最新可用数据，会标注为该交易日盘后数据。
+数据来源：同花顺概念资金流页面（仅在同时拿到净流入/净流出榜时采用）、腾讯财经、新浪财经、东方财富公开行情与快讯接口（`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` 查看详细切换记录。
 
 适用人群：每天盘后想用一条命令看完五张图的开发者 / 量化研究者 / 自动化爱好者。欢迎 issue / PR。

pyproject.toml

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

src/young_stock/__init__.py

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

src/young_stock/_core.py

@@ -608,7 +608,14 @@ def fetch_ths_concept_money_flow_snapshot(date_str: str) -> dict[str, str]:
     """同花顺概念资金流。页面可直接返回表格，作为 young flow 的优先在线源。"""
     cached = cache_load("fund_flow", date_str, "ths", ttl=CACHE_TTL_SECONDS)
     if cached:
-        return cached
+        try:
+            cached_in = json.loads(cached.get("_concept_in", "[]"))
+            cached_out = json.loads(cached.get("_concept_out", "[]"))
+        except json.JSONDecodeError:
+            cached_in, cached_out = [], []
+        if cached_in and cached_out:
+            return cached
+        diag("Ignored THS concept flow cache without two-sided net flow")
     headers = {
         "User-Agent": (
             "Mozilla/5.0 (Windows NT 10.0; Win64; x64) "
@@ -635,6 +642,9 @@ def fetch_ths_concept_money_flow_snapshot(date_str: str) -> dict[str, str]:
         return {}
     top_in_rows = sorted([row for row in rows if float(row.get("net") or 0) > 0], key=lambda item: float(item.get("net") or 0), reverse=True)[:5]
     top_out_rows = sorted([row for row in rows if float(row.get("net") or 0) < 0], key=lambda item: float(item.get("net") or 0))[:5]
+    if not top_in_rows or not top_out_rows:
+        diag("THS concept money-flow snapshot: missing two-sided net flow")
+        return {}
     trade_date = _display_date(nearest_trade_date())
     result = {
         "date": trade_date,
@@ -2370,6 +2380,8 @@ def print_fund_flow(flow_data: dict[str, str]) -> None:
         scope_title = "A股资金流向（概念板块口径）"
     elif flow_data.get("_fallback_indicator") == "sector_money_flow":
         scope_title = "A股资金流向（行业板块口径）"
+    elif flow_data.get("_fallback_indicator") == "market_activity":
+        scope_title = "A股资金流向（指数活跃度参考）"
     print(f"## {scope_title}\n")
     if not flow_data or "_error" in flow_data:
         print("  暂不展示：当前没有拿到可核验交易日的免登录资金流数据。")
@@ -2501,8 +2513,8 @@ def print_sentiment_summary(zt_data: dict, dt_data: dict, zb_data: dict, flow_da
 def print_global_indices(indices: list[QuoteData], market_name: str) -> None:
     print(f"## {market_name} 大盘指数\n")
     activity_label = "成交额" if any(q.turnover is not None for q in indices) else "成交量"
-    print(f"{'指数':<15} {'点位':>12} {'涨跌幅':>10} {activity_label:>14} {'来源':>8} {'完整度':>8}")
-    print("-" * 82)
+    print(f"{'指数':<15} {'点位':>12} {'涨跌幅':>10} {activity_label:>14} {'来源':>8}")
+    print("-" * 72)
     for qd in indices:
         name = qd.name or qd.symbol
         price_str = fmt_price(qd.price)
@@ -2516,8 +2528,7 @@ def print_global_indices(indices: list[QuoteData], market_name: str) -> None:
             "eastmoney_stock_get": "东财",
             "eastmoney_clist": "东财",
         }.get(qd.source, qd.source or "-")
-        quality_str = f"{qd.completeness:.0f}%"
-        print(f"{name:<15} {price_str:>12} {pct_str:>10} {vol_str:>14} {source_str:>8} {quality_str:>8}")
+        print(f"{name:<15} {price_str:>12} {pct_str:>10} {vol_str:>14} {source_str:>8}")
     print()
 
 
@@ -2742,7 +2753,6 @@ 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)}")
-    print(f"  完整度: {qd.completeness:.0f}%")
     if qd.notes:
         print(f"  提醒:   {'；'.join(qd.notes)}")
     print()
@@ -3001,6 +3011,8 @@ def print_global_sentiment(indices: list[QuoteData]) -> None:
 
 
 def print_data_quality_report(results: list[QuoteData]) -> None:
+    if os.environ.get("YOUNG_STOCK_DEBUG") != "1":
+        return
     warnings = []
     source_notes = []
     recommendations = []

tests/test_core.py

@@ -334,8 +334,8 @@ def test_fund_flow_prefers_ths_concept_flow(monkeypatch):
             "date": "2026-06-01",
             "_source": "同花顺概念资金流",
             "_fallback_indicator": "concept_money_flow",
-            "_concept_in": "[]",
-            "_concept_out": "[]",
+            "_concept_in": '[{"name":"ERP概念","net":14.28}]',
+            "_concept_out": '[{"name":"有色金属","net":-8.0}]',
         },
     )
     monkeypatch.setattr(_core, "fetch_fund_flow_json", lambda url: (_ for _ in ()).throw(AssertionError("should not call Eastmoney first")))
@@ -566,10 +566,74 @@ def test_print_fund_flow_market_activity_indicator(capsys):
 
     output = capsys.readouterr().out
     assert "不等同于主力资金净流入" in output
+    assert "指数活跃度参考" in output
     assert "合计成交额" in output
     assert "主力净流入:" not in output
 
 
+def test_print_global_indices_hides_completeness(capsys):
+    _core.print_global_indices(
+        [
+            _core.QuoteData(
+                symbol="^HSI",
+                name="恒生指数",
+                market="hk_market",
+                price=25182.39,
+                change_pct=0.70,
+                turnover=462070141280.0,
+                source="tencent",
+                completeness=100,
+            )
+        ],
+        "港股",
+    )
+
+    output = capsys.readouterr().out
+    assert "完整度" not in output
+    assert "100%" not in output
+
+
+def test_print_data_quality_report_is_quiet_by_default(capsys):
+    _core.DIAGNOSTICS[:] = ["Tencent HK index口径提示"]
+
+    _core.print_data_quality_report(
+        [
+            _core.QuoteData(
+                symbol="^HSI",
+                name="恒生指数",
+                completeness=100,
+                notes=["港股指数采用腾讯收盘口径"],
+            )
+        ]
+    )
+
+    assert capsys.readouterr().out == ""
+    _core.DIAGNOSTICS[:] = []
+
+
+def test_print_single_stock_report_hides_completeness(capsys):
+    _core.print_single_stock_report(
+        _core.QuoteData(
+            symbol="600519",
+            name="贵州茅台",
+            market="cn_market",
+            date="2026-06-01",
+            price=1500.0,
+            prev_close=1490.0,
+            change=10.0,
+            change_pct=0.67,
+            volume=123456,
+            source="sina",
+            completeness=100,
+        ),
+        requested_date="20260601",
+    )
+
+    output = capsys.readouterr().out
+    assert "完整度" not in output
+    assert "100%" not in output
+
+
 def test_diagnostic_summary_is_quiet_by_default(capsys):
     _core.DIAGNOSTICS[:] = ["Sina missing AAPL"]