Stock Analysis

def _run_tool(script: str, args: str):
    cmd = f"{sys.executable} {TOOLS_DIR}/{script} {args}"
    try:
        r = subprocess.run(cmd, shell=True, capture_output=True, text=True, timeout=30)
        if r.returncode == 0 and r.stdout.strip():
            return json.loads(r.stdout)
    except Exception:

def _run_tool(script: str, args: str) -> dict | list:
    cmd = f"python3 {TOOLS_DIR}/{script} {args}"
    try:
        r = subprocess.run(cmd, shell=True, capture_output=True, text=True, timeout=30)
        if r.returncode == 0 and r.stdout.strip():
            return json.loads(r.stdout)
    except Exception:

def _run_tool(script: str, args: str) -> dict:
    cmd = f"python3 {TOOLS_DIR}/{script} {args}"
    try:
        r = subprocess.run(cmd, shell=True, capture_output=True, text=True, timeout=30)
        if r.returncode == 0 and r.stdout.strip():
            return json.loads(r.stdout)
    except Exception:

tools_dir = Path(__file__).parent
    try:
        result = subprocess.run(
            [sys.executable, str(tools_dir / "search_intel.py"), "search", f"{symbol} 最新消息"],
            capture_output=True,
            text=True,

for source in ["reddit", "twitter", "polymarket"]:
            try:
                resp = requests.get(f"{api_url}/trending/{source}", headers=headers, timeout=10)
                if resp.ok:
                    result["trending"][source] = resp.json()
            except Exception:

for source in ["reddit", "twitter", "polymarket"]:
                try:
                    resp = requests.get(f"{api_url}/sentiment/{source}/{symbol}", headers=headers, timeout=10)
                    if resp.ok:
                        result["sources"][source] = resp.json()
                except Exception:

ts_code = f"{symbol}.SH" if symbol.startswith(("6", "9", "5")) else f"{symbol}.SZ"

    resp = requests.post(
        "http://api.tushare.pro",
        json={
            "api_name": api_name_map.get(period, "daily"),

ts_code = f"{symbol}.SH" if symbol.startswith(("6", "9", "5")) else f"{symbol}.SZ"

    resp = requests.post(
        "http://api.tushare.pro",
        json={
            "api_name": "realtime_quote",