hmo/MoFin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: stock_sectors列名sector→sector_name（静默except吞掉的错误）

Browse Source
This commit is contained in:
hmo
2026-07-22 12:50:41 +08:00
parent eb644221f4
commit cdbbcec69e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
deploy/profile-scripts/batch_reassess.py
+2 -2
View File
@@ -129,7 +129,7 @@ def collect_data(code):
if (not _sector_ctx) or _sector_ctx.startswith('大盘上涨比') or len(_sector_ctx) < 4: if (not _sector_ctx) or _sector_ctx.startswith('大盘上涨比') or len(_sector_ctx) < 4:
try: try:
_sdb = sqlite3.connect(DB) _sdb = sqlite3.connect(DB)
_sr = _sdb.execute("SELECT sector 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() _sdb.close()
if _sr and _sr[0]: if _sr and _sr[0]:
_sector_ctx = f"行业{_sr[0]}" _sector_ctx = f"行业{_sr[0]}"
@@ -184,7 +184,7 @@ def build_prompt(data):
_sector_name = "" _sector_name = ""
try: try:
_sr = _db.execute( _sr = _db.execute(
"SELECT sector FROM stock_sectors WHERE code=? LIMIT 1", (data['code'],)).fetchone() "SELECT sector_name FROM stock_sectors WHERE code=? LIMIT 1", (data['code'],)).fetchone()
_sector_name = _sr[0] if _sr else "" _sector_name = _sr[0] if _sr else ""
except Exception: except Exception:
pass pass