fix: batch_reassess行业回退stock_sectors_em(300668等6只active此前无行业)
This commit is contained in:
@@ -136,9 +136,14 @@ def collect_data(code):
|
|||||||
try:
|
try:
|
||||||
_sdb = sqlite3.connect(DB, timeout=30)
|
_sdb = sqlite3.connect(DB, timeout=30)
|
||||||
_sr = _sdb.execute("SELECT sector_name FROM stock_sectors WHERE code=? LIMIT 1", (code,)).fetchone()
|
_sr = _sdb.execute("SELECT sector_name FROM stock_sectors WHERE code=? LIMIT 1", (code,)).fetchone()
|
||||||
_sdb.close()
|
|
||||||
if _sr and _sr[0]:
|
if _sr and _sr[0]:
|
||||||
_resolved = f"行业{_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:
|
except Exception:
|
||||||
pass
|
pass
|
||||||
_sector_ctx = _resolved if _resolved else "行业未映射(仅大盘环境参考)"
|
_sector_ctx = _resolved if _resolved else "行业未映射(仅大盘环境参考)"
|
||||||
|
|||||||
Reference in New Issue
Block a user