diff --git a/deploy/profile-scripts/batch_reassess.py b/deploy/profile-scripts/batch_reassess.py index b94ed8a2..71d9b6a5 100644 --- a/deploy/profile-scripts/batch_reassess.py +++ b/deploy/profile-scripts/batch_reassess.py @@ -136,9 +136,14 @@ def collect_data(code): try: _sdb = sqlite3.connect(DB, timeout=30) _sr = _sdb.execute("SELECT sector_name FROM stock_sectors WHERE code=? LIMIT 1", (code,)).fetchone() - _sdb.close() if _sr and _sr[0]: _resolved = f"行业{_sr[0]}" + else: + # 2026-08-17 修复:stock_sectors 仅898只覆盖不全,回退 stock_sectors_em(5061只) + _sr2 = _sdb.execute("SELECT sector FROM stock_sectors_em WHERE code=? LIMIT 1", (code,)).fetchone() + if _sr2 and _sr2[0]: + _resolved = f"行业{_sr2[0]}" + _sdb.close() except Exception: pass _sector_ctx = _resolved if _resolved else "行业未映射(仅大盘环境参考)"