diff --git a/scripts/technical_analysis.py b/scripts/technical_analysis.py index 27426959..1f3037d9 100644 --- a/scripts/technical_analysis.py +++ b/scripts/technical_analysis.py @@ -55,14 +55,7 @@ def _market_prefix(code): def get_quote(code): - """获取行情数据。DB 优先(price_monitor 维护),腾讯 API fallback""" - # DB 优先 - try: - from mofin_db import get_price_from_db - p, chg = get_price_from_db(code) - if p: return {"code": code, "price": p, "change_pct": chg or 0} - except: pass - # Fallback: 腾讯 API + """获取行情数据。先拿DB的价格和涨跌幅,再调腾讯API拿HLC全量数据""" import time _cache = get_quote.__dict__.get("_cache", {}) now = time.time() @@ -70,6 +63,18 @@ def get_quote(code): if cached and (now - cached["ts"]) < 60: return cached["data"] + # 先从DB拿基础价格(快速,不阻塞) + db_price = None + db_chg = None + try: + from mofin_db import get_price_from_db + p, chg = get_price_from_db(code) + if p: + db_price, db_chg = p, chg + except: + pass + + # 腾讯API获取全量HLC数据 raw = str(code).split("_")[0] prefix = _market_prefix(code) url = f"http://qt.gtimg.cn/q={prefix}{raw}" @@ -77,6 +82,8 @@ def get_quote(code): r = urllib.request.urlopen(url, timeout=5) fields = r.read().decode("gbk").split('"')[1].split("~") except Exception as e: + if db_price: + return {"code": code, "price": db_price, "change_pct": db_chg or 0} return {"code": code, "error": str(e)} def get(i):