feat: add personalized daily report

Author: AdvancingTitans

CHANGELOG.md

@@ -5,6 +5,16 @@ 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.12] - 2026-06-03
+
+### Added
+- Added `young profile add-stock`, `young profile add-fund`, and `young profile show` to maintain local investment memory in `~/.young_stock/profile.json`.
+- Added `young daily`, a personalized daily market report that combines saved stock/fund watchlists, global indices, A-share sentiment, fund flow, and risk-oriented suggestions.
+- Exposed `run_daily_report()` in `young_stock._core` so agent skills can depend on the PyPI package instead of copying the core script.
+
+### Changed
+- The daily report uses the existing nearest-trade-date logic, so pre-close weekday runs still review the latest settled trading day.
+
 ## [0.1.11] - 2026-06-02
 
 ### Fixed

README.md

@@ -33,6 +33,9 @@ young us                # US indices snapshot
 young global            # A + HK + US in one view
 young stock 600519      # one stock snapshot (A-share / HK / US)
 young fund 161725       # fund estimate + top holdings quote/news
+young profile add-stock 600519
+young profile add-fund 161725
+young daily             # personalized daily report from saved investment memory
 young news 3690.HK      # multi-source news only
 young stock AAPL --no-news
 young fund 161725 --no-news
@@ -73,6 +76,7 @@ It is also a foundation for analysis pipelines: every subcommand maps to a Pytho
 - **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.
 - **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, global indices, A-share sentiment, and risk-oriented suggestions. First use: add symbols with `young profile add-stock 600519` and `young profile add-fund 161725`.
 - **Single-stock news** — `young news 3690.HK` prints only the news/momentum view, with each item showing source and link status.
 - **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.

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "young-stock-cli"
-version = "0.1.11"
+version = "0.1.12"
 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.11"
+__version__ = "0.1.12"

src/young_stock/_core.py

@@ -310,14 +310,17 @@ def cache_clear_old(days: int = 7) -> None:
     cutoff = datetime.now() - timedelta(days=days)
     if not CACHE_DIR.exists():
         return
-    for d in CACHE_DIR.iterdir():
+    try:
+        dirs = list(CACHE_DIR.iterdir())
+    except OSError:
+        return
+    for d in dirs:
         if d.is_dir():
             try:
                 dt = datetime.strptime(d.name, "%Y%m%d")
                 if dt < cutoff:
-                    import shutil
                     shutil.rmtree(d)
-            except ValueError:
+            except (ValueError, OSError):
                 pass
 
 
@@ -2950,6 +2953,103 @@ def run_stock_news(symbol: str, date_str: str, size: int = 8) -> None:
     print_report_footer()
 
 
+def _daily_watchlist_items(watchlist: dict[str, list[str]] | None, key: str) -> list[str]:
+    if not watchlist:
+        return []
+    values = watchlist.get(key) or []
+    return [str(v).strip() for v in values if str(v).strip()]
+
+
+def _quote_trend_label(qd: QuoteData) -> str:
+    pct = qd.change_pct
+    if pct is None:
+        return "趋势待确认"
+    if pct >= 2:
+        return "强势上行"
+    if pct >= 0.3:
+        return "偏强"
+    if pct <= -2:
+        return "明显走弱"
+    if pct <= -0.3:
+        return "偏弱"
+    return "震荡"
+
+
+def print_daily_watchlist(watchlist: dict[str, list[str]] | None, date_str: str, include_news: bool = True) -> None:
+    stocks = _daily_watchlist_items(watchlist, "stocks")
+    funds = _daily_watchlist_items(watchlist, "funds")
+    print("## 一、关注标的\n")
+    if not stocks and not funds:
+        print("  尚未设置关注股票或基金。")
+        print()
+        return
+
+    if stocks:
+        print("### 个股/ETF行情与趋势\n")
+        for symbol in stocks:
+            try:
+                qd = get_single_stock_quote(symbol, date_str)
+            except ValueError as e:
+                print(f"- {symbol}: 暂未拿到可核验行情（{e}）")
+                continue
+            if not qd:
+                print(f"- {symbol}: 暂未拿到可核验行情")
+                continue
+            name = qd.name or qd.symbol
+            print(
+                f"- {name} ({qd.symbol}): 最新 {fmt_price(qd.price)} {qd.currency}, "
+                f"涨跌幅 {fmt_pct(qd.change_pct)}, {_quote_trend_label(qd)}；"
+                f"来源 {_source_label(qd.source)}，数据日 {qd.date or '-'}。"
+            )
+            if include_news:
+                keyword = qd.name if qd.market in ("cn_market", "hk_market") and qd.name else qd.symbol
+                lang = "zh-CN" if qd.market in ("cn_market", "hk_market") else "en"
+                news = combined_news_search(keyword, size=3, lang=lang, aliases=_news_aliases(qd.symbol, qd.name), date_str=date_str)
+                items = news.get("data", []) if "_error" not in news else []
+                if items:
+                    title = _clean_news_title(str(items[0].get("title") or ""))
+                    print(f"  相关新闻: {title}")
+        print()
+
+    if funds:
+        print("### 基金估值与持仓\n")
+        for code in funds:
+            run_fund_report(code, date_str, include_news=include_news)
+
+
+def run_daily_report(
+    date_str: str,
+    watchlist: dict[str, list[str]] | None = None,
+    include_news: bool = True,
+) -> None:
+    DIAGNOSTICS.clear()
+    display_date = _display_date(date_str)
+    print(f"# 每日行情日报（{display_date}）\n")
+    print_stage_line(date_str)
+    print("数据来源: young-stock-cli 核心模块，多源免登录行情与新闻聚合。")
+    print("说明: 以下内容仅供复盘参考，不构成投资建议。\n")
+    print("=" * 60 + "\n")
+
+    print_daily_watchlist(watchlist, date_str, include_news=include_news)
+
+    print("## 二、全球指数与大盘概览\n")
+    run_global_market(date_str)
+
+    print("## 三、A股大盘与市场情绪\n")
+    run_a_share(date_str, include_news=include_news)
+
+    print("## 四、投资建议\n")
+    print("- 先看交易日与数据源日期是否一致；若出现最新可用数据提示，不把旧行情当成当日信号。")
+    print("- 个股/基金优先结合持仓成本、仓位上限和新闻催化验证，不因单日涨跌直接追涨杀跌。")
+    print("- 市场情绪偏弱或资金流口径降级时，降低加仓冲动；情绪修复时再观察量能和领涨方向持续性。")
+    print("- 基金估值是盘中/收盘估算，正式净值以基金公司晚间披露为准。")
+    print()
+
+    if DIAGNOSTICS:
+        print_diagnostic_summary()
+    print_report_footer()
+
+
 def print_futu_news(news_data: dict, keyword: str, limit: int = 5) -> None:
     if "_error" in news_data:
         return

src/young_stock/cli.py

@@ -1,8 +1,11 @@
 """young-stock-cli command line interface."""
 from __future__ import annotations
 
+import json
+import os
 import subprocess
 import sys
+from pathlib import Path
 
 import click
 
@@ -40,6 +43,54 @@ def _run(market: str, date: str | None, refresh: bool, include_news: bool = True
 _refresh_opt = click.option("--refresh", is_flag=True, help="Skip cache and force re-fetch.")
 
 
+def _profile_path() -> Path:
+    override = os.environ.get("YOUNG_STOCK_PROFILE")
+    if override:
+        return Path(override).expanduser()
+    return Path.home() / ".young_stock" / "profile.json"
+
+
+def _load_profile() -> dict[str, list[str]]:
+    path = _profile_path()
+    if not path.exists():
+        return {"stocks": [], "funds": []}
+    try:
+        data = json.loads(path.read_text(encoding="utf-8"))
+    except (OSError, json.JSONDecodeError):
+        return {"stocks": [], "funds": []}
+    return {
+        "stocks": [str(v) for v in data.get("stocks", []) if str(v).strip()],
+        "funds": [str(v) for v in data.get("funds", []) if str(v).strip()],
+    }
+
+
+def _save_profile(profile: dict[str, list[str]]) -> None:
+    path = _profile_path()
+    path.parent.mkdir(parents=True, exist_ok=True)
+    path.write_text(json.dumps(profile, ensure_ascii=False, indent=2) + "\n", encoding="utf-8")
+
+
+def _add_profile_item(kind: str, value: str) -> dict[str, list[str]]:
+    profile = _load_profile()
+    items = profile.setdefault(kind, [])
+    normalized = value.strip()
+    if normalized and normalized not in items:
+        items.append(normalized)
+    _save_profile(profile)
+    return profile
+
+
+def _print_first_use_guide() -> None:
+    click.echo("# 每日行情日报")
+    click.echo()
+    click.echo("尚未设置投资记忆。首次使用请先添加你关注的股票、ETF 或基金：")
+    click.echo("  young profile add-stock 600519")
+    click.echo("  young profile add-stock 0700.HK")
+    click.echo("  young profile add-fund 161725")
+    click.echo()
+    click.echo(f"配置会保存到: {_profile_path()}")
+
+
 @cli.command(help="A-share dashboard: indices, ZT/DT pool, verified A-share fund flow, boards.")
 @_date_opt
 @_refresh_opt
@@ -164,6 +215,50 @@ def news(parts: tuple[str, ...], date: str | None, refresh: bool, limit: int) ->
     _core.run_stock_news(symbol, date_str, size=limit)
 
 
+@cli.command(help="Personal daily report from your saved watchlist.")
+@_date_opt
+@_refresh_opt
+@click.option("--no-news", is_flag=True, help="Only show market data, skip news lookup.")
+def daily(date: str | None, refresh: bool, no_news: bool) -> None:
+    if refresh:
+        _core.NO_CACHE = True
+    _core.cache_clear_old(days=7)
+    date_str = date or _core.nearest_trade_date()
+    profile = _load_profile()
+    if not profile.get("stocks") and not profile.get("funds"):
+        _print_first_use_guide()
+        return
+    _core.run_daily_report(date_str, profile, include_news=not no_news)
+
+
+@cli.group(help="Manage local investment memory for daily reports.")
+def profile() -> None:
+    pass
+
+
+@profile.command("add-stock", help="Add a stock/ETF symbol to your daily watchlist.")
+@click.argument("symbol")
+def profile_add_stock(symbol: str) -> None:
+    data = _add_profile_item("stocks", symbol)
+    click.echo(f"Added stock: {symbol.strip()}")
+    click.echo(f"Stocks: {', '.join(data.get('stocks', [])) or '-'}")
+
+
+@profile.command("add-fund", help="Add a fund code to your daily watchlist.")
+@click.argument("code")
+def profile_add_fund(code: str) -> None:
+    data = _add_profile_item("funds", code)
+    click.echo(f"Added fund: {code.strip()}")
+    click.echo(f"Funds: {', '.join(data.get('funds', [])) or '-'}")
+
+
+@profile.command("show", help="Show saved daily-report investment memory.")
+def profile_show() -> None:
+    data = _load_profile()
+    click.echo(f"Stocks: {', '.join(data.get('stocks', [])) or '-'}")
+    click.echo(f"Funds: {', '.join(data.get('funds', [])) or '-'}")
+
+
 @cli.command(help="Clear cached responses older than N days.")
 @click.option("--days", default=7, show_default=True, help="Delete cache files older than this many days.")
 def cache_clear(days: int) -> None:

tests/test_cli.py

@@ -31,7 +31,7 @@ def test_cli_subcommands_registered():
     from click.testing import CliRunner
     runner = CliRunner()
     result = runner.invoke(cli, ["--help"])
-    for sub in ["a", "hk", "us", "global", "indices", "zt-pool", "flow", "stock", "fund", "news", "cache-clear", "update"]:
+    for sub in ["a", "hk", "us", "global", "indices", "zt-pool", "flow", "stock", "fund", "news", "daily", "profile", "cache-clear", "update"]:
         assert sub in result.output, f"subcommand `{sub}` missing from help"
 
 
@@ -153,3 +153,44 @@ def fake_run(cmd, check):
         [sys.executable, "-m", "pip", "install", "--upgrade", "young-stock-cli", "--pre", "--user"],
         False,
     )]
+
+
+def test_cli_daily_guides_first_use_when_profile_empty(monkeypatch, tmp_path):
+    from click.testing import CliRunner
+
+    monkeypatch.setenv("YOUNG_STOCK_PROFILE", str(tmp_path / "profile.json"))
+    monkeypatch.setattr(cli_module._core, "nearest_trade_date", lambda: "20260529")
+    monkeypatch.setattr(cli_module._core, "cache_clear_old", lambda days: None)
+
+    runner = CliRunner()
+    result = runner.invoke(cli, ["daily", "--no-news"])
+
+    assert result.exit_code == 0
+    assert "尚未设置投资记忆" in result.output
+    assert "young profile add-stock 600519" in result.output
+    assert "young profile add-fund 161725" in result.output
+
+
+def test_cli_profile_add_stock_and_fund_then_daily_uses_memory(monkeypatch, tmp_path):
+    from click.testing import CliRunner
+
+    profile_path = tmp_path / "profile.json"
+    monkeypatch.setenv("YOUNG_STOCK_PROFILE", str(profile_path))
+    monkeypatch.setattr(cli_module._core, "nearest_trade_date", lambda: "20260529")
+    monkeypatch.setattr(cli_module._core, "cache_clear_old", lambda days: None)
+
+    calls = []
+    monkeypatch.setattr(
+        cli_module._core,
+        "run_daily_report",
+        lambda date_str, watchlist=None, include_news=True: calls.append((date_str, watchlist, include_news)),
+    )
+
+    runner = CliRunner()
+    assert runner.invoke(cli, ["profile", "add-stock", "600519"]).exit_code == 0
+    assert runner.invoke(cli, ["profile", "add-fund", "161725"]).exit_code == 0
+
+    result = runner.invoke(cli, ["daily", "--no-news"])
+
+    assert result.exit_code == 0
+    assert calls == [("20260529", {"stocks": ["600519"], "funds": ["161725"]}, False)]

tests/test_core.py

@@ -634,6 +634,37 @@ def test_print_single_stock_report_hides_completeness(capsys):
     assert "100%" not in output
 
 
+def test_run_daily_report_prints_watchlist_and_market_sections(monkeypatch, capsys):
+    calls = []
+
+    monkeypatch.setattr(
+        _core,
+        "get_single_stock_quote",
+        lambda symbol, date: _core.QuoteData(
+            symbol=symbol,
+            name="测试股票",
+            market="cn_market",
+            date="2026-05-29",
+            price=10,
+            change_pct=1.2,
+            source="test",
+        ),
+    )
+    monkeypatch.setattr(_core, "run_fund_report", lambda code, date, include_news=True: calls.append(("fund", code, date, include_news)))
+    monkeypatch.setattr(_core, "run_global_market", lambda date: calls.append(("global", date)))
+    monkeypatch.setattr(_core, "run_a_share", lambda date, include_news=True: calls.append(("a", date, include_news)))
+    monkeypatch.setattr(_core, "print_report_footer", lambda: None)
+
+    _core.run_daily_report("20260529", {"stocks": ["600519"], "funds": ["161725"]}, include_news=False)
+
+    output = capsys.readouterr().out
+    assert "每日行情日报" in output
+    assert "一、关注标的" in output
+    assert "测试股票 (600519)" in output
+    assert "四、投资建议" in output
+    assert calls == [("fund", "161725", "20260529", False), ("global", "20260529"), ("a", "20260529", False)]
+
+
 def test_diagnostic_summary_is_quiet_by_default(capsys):
     _core.DIAGNOSTICS[:] = ["Sina missing AAPL"]