diff --git a/scripts/stale_detector.py b/scripts/stale_detector.py index ef6e54f..0230073 100644 --- a/scripts/stale_detector.py +++ b/scripts/stale_detector.py @@ -115,8 +115,7 @@ def main(): cash = 0 total_assets = 0 try: - with open(PORTFOLIO_PATH) as f: - pf = json.load(f) + pf = read_portfolio() position_pct = pf.get("position_pct", 0) cash = pf.get("cash", 0) total_assets = pf.get("total_assets", 0) diff --git a/scripts/stale_push_wlin.py b/scripts/stale_push_wlin.py index 8ad3324..99c031c 100644 --- a/scripts/stale_push_wlin.py +++ b/scripts/stale_push_wlin.py @@ -225,15 +225,11 @@ def trigger_regen_sync(stock_codes=None): def load_cash(): - """从 portfolio.json 实时读可用现金(可用 ≈ 实时买力),不硬编码""" + """从 mo_data 实时读可用现金""" try: - with open(PORTFOLIO_PATH) as f: - data = json.load(f) - if isinstance(data, dict): - # 先读 cash_available(拆分了可用/冻结),fallback 到 cash - return data.get("cash_available", data.get("cash", 0)) - if isinstance(data, list) and len(data) > 1 and isinstance(data[1], dict): - return data[1].get("cash_available", data[1].get("cash", 0)) + pf = read_portfolio() + if isinstance(pf, dict): + return pf.get("cash_available", pf.get("cash", 0)) return 0 except Exception: return 0