guanlan.py 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327
  1. #!/usr/bin/env python3
  2. # -*- coding: utf-8 -*-
  3. """观澜 · 如东样板 v2 启动器 (跨平台, 只用标准库). 用法:
  4. python guanlan.py check 自检: Python/依赖/端口/数据产物/发布件/Ollama
  5. python guanlan.py serve 启动全部服务 (网关 + 工作台 + CMS + 仿真×2 + 三维), 写 run/pids.json, 等 healthz
  6. python guanlan.py status 各服务端口/进程状态
  7. python guanlan.py stop 停止本启动器起的全部服务
  8. python guanlan.py open 打印入口地址 (并尝试用系统浏览器打开)
  9. python guanlan.py qa 离线模型已知答案回放 (需服务已起; 参数见 scripts/llm_known_answer.py)
  10. 端口与路径在 configs/serve.json (没有则用内置默认). 所有服务只绑 127.0.0.1."""
  11. from __future__ import annotations
  12. import json, os, socket, subprocess, sys, time, urllib.request, warnings, webbrowser, signal
  13. from pathlib import Path
  14. ROOT = Path(__file__).resolve().parent; RUN = ROOT / "run"; LOGS = ROOT / "logs"; PIDS = RUN / "pids.json"
  15. sys.path.insert(0, str(ROOT))
  16. from src import paths as P # 配置/路径唯一取用口 (P.SERVE_JSON / P.config()…, 见 docs §11)
  17. WIN = os.name == "nt"
  18. def _hermetic():
  19. """摘掉机器全局的 PYTHONPATH: 本项目依赖都装在 .venv 里, 而 PYTHONPATH 会被插到 sys.path 前面,
  20. 顶掉 venv 里 pin 住的版本 (实测 requests 2.33.0 顶掉 2.34.2), 还会让 pip 少装传递依赖。
  21. 子进程从 env() 继承的是摘干净之后的环境。"""
  22. for d in [x for x in os.environ.pop("PYTHONPATH", "").split(os.pathsep) if x]:
  23. while d in sys.path: sys.path.remove(d)
  24. _hermetic()
  25. DEFAULT = {
  26. "host": "127.0.0.1", "gateway": 28084, "detail": 18033, "cms": 18020, "sim": 18791, "sim_sys": 18792, "viewer": 64292, "ollama": 11434,
  27. "release_dir": "release", "viewer_dir": "release/viewer", "sim_dir": "resources/oem_envision_sc1_rudong2014",
  28. "python": "", # 空 = 当前解释器 (安装脚本建的 .venv)
  29. }
  30. def jload(p: Path):
  31. """读 JSON 配置。必须用 utf-8-sig: 记事本和 PowerShell 5.1 的 `Set-Content -Encoding UTF8`
  32. 写出的都是 **带 BOM** 的 UTF-8, 裸 utf-8 读会 JSONDecodeError (Unexpected UTF-8 BOM)。"""
  33. return json.loads(Path(p).read_text(encoding="utf-8-sig"))
  34. def cfg():
  35. c = dict(DEFAULT); p = P.SERVE_JSON # 端口/路径真源 (配置取用口 = src/paths.py)
  36. if p.exists():
  37. try: c.update(jload(p))
  38. except Exception as ex: # 配置写坏不该让整个产品起不来: 退回内置默认端口, 但要说清楚
  39. print(f" [X] {p} 读不了 ({ex.__class__.__name__}: {str(ex)[:100]}); 本次用内置默认端口。"
  40. f" 重跑 install 脚本可重写该文件")
  41. return c
  42. def py(c):
  43. """解释器: serve.json 的 python (相对路径按**安装根**解析) → 本目录 .venv (按平台探测) → 当前解释器。
  44. 2026-09-11: 原来只认绝对路径 —— 安装目录整个拷到别的电脑/别的盘后, 那个绝对路径就失效了。"""
  45. v = (c.get("python") or "").strip()
  46. if v:
  47. p = Path(v)
  48. p = p if p.is_absolute() else (ROOT / p)
  49. if p.exists(): return str(p)
  50. for rel in (".venv/Scripts/python.exe", ".venv/bin/python", ".venv/bin/python3"):
  51. p = ROOT / rel
  52. if p.exists(): return str(p)
  53. return sys.executable
  54. def up(host, port, t=0.4):
  55. try:
  56. with socket.create_connection((host, port), timeout=t): return True
  57. except OSError: return False
  58. def env(c):
  59. e = dict(os.environ); rel = str(ROOT / c["release_dir"])
  60. raw = Path(c.get("raw_dir", "data/raw")); raw = raw if raw.is_absolute() else (ROOT / raw)
  61. e.update(GUANLAN_RELEASE_DIR=rel, GUANLAN_PORTAL=str(ROOT / c["release_dir"] / "portal.html"), GUANLAN_STATIC=rel, WINDSCADA_ROOT=str(ROOT), WINDCMS_ROOT=str(ROOT),
  62. WINDSCADA_RUDONG_SRC=str(raw), GUANLAN_OLLAMA_PORT=str(c["ollama"]), PYTHONUTF8="1", PYTHONIOENCODING="utf-8"); return e
  63. def services(c):
  64. P = py(c); h = c["host"]
  65. return [
  66. ("detail", c["detail"], [P, "scripts/windscada_serve.py", "--host", h, "--port", str(c["detail"])]),
  67. ("cms", c["cms"], [P, "scripts/windcms.py", "serve", "--farm", "rudong", "--port", str(c["cms"])]),
  68. ("viewer", c["viewer"], [P, "scripts/static_server.py", "--port", str(c["viewer"]), "--host", h,
  69. "--dir", str(ROOT / c["viewer_dir"]), "--comp", "viewer"]),
  70. ("sim_sys", c["sim_sys"], [P, "-u", str(ROOT / c["release_dir"] / "sim_sys_server.py")]),
  71. ("sim", c["sim"], [P, "scripts/static_server.py", "--port", str(c["sim"]), "--host", h,
  72. "--dir", str(ROOT / c["sim_dir"]), "--comp", "sim"]),
  73. ("gateway", c["gateway"], [P, "scripts/guanlan_gateway.py", "--host", h, "--port", str(c["gateway"])]),
  74. ]
  75. def spawn(cmd, log: Path, e):
  76. f = open(log, "ab")
  77. kw = dict(cwd=str(ROOT), env=e, stdout=f, stderr=subprocess.STDOUT, stdin=subprocess.DEVNULL)
  78. if WIN:
  79. # 2026-09-16: 统一到 CREATE_NO_WINDOW (src/proc.py) —— 原先用 DETACHED_PROCESS, 子进程没有控制台,
  80. # 而 .venv 的 python.exe 是**转发器**, 它会再拉一个真解释器; 落地实测那一步会冒出可见黑窗。
  81. # CREATE_NO_WINDOW 给的是"没有窗口的控制台", stdio 照旧重定向到日志, 且与 DETACHED 互斥故只用前者。
  82. from src import proc as _proc
  83. kw["creationflags"] = _proc.flags()
  84. else: kw["start_new_session"] = True
  85. return subprocess.Popen(cmd, **kw).pid
  86. def alive(pid):
  87. if not pid:
  88. return False
  89. if WIN:
  90. # errors="replace" 必须有: tasklist 的输出是**控制台代码页**(中文 Windows = GBK), 而本进程
  91. # 可能是 PYTHONUTF8=1 起的(默认文本编码变 UTF-8) → 解码失败会让 r.stdout 变成 None,
  92. # 下一行 `str(pid) in None` 直接 TypeError。2026-09-12 由运维控制台的动作进程实测逮到。
  93. # ★ 走 src.proc.run_text: 本函数也会被**无控制台**的进程调用 (网关/运维任务), 裸 spawn tasklist
  94. # 会给它新建可见控制台 → 反复闪窗 (2026-09-16)。
  95. from src import proc as _proc
  96. r = _proc.run_text(["tasklist", "/FI", f"PID eq {pid}"])
  97. return r.stdout is not None and str(pid) in r.stdout
  98. try: os.kill(pid, 0); return True
  99. except OSError: return False
  100. def kill(pid):
  101. from src import proc as _proc
  102. if WIN: _proc.run(["taskkill", "/PID", str(pid), "/T", "/F"], capture_output=True)
  103. else:
  104. try: os.killpg(os.getpgid(pid), signal.SIGTERM)
  105. except OSError:
  106. try: os.kill(pid, signal.SIGTERM)
  107. except OSError: pass
  108. def cmd_check(c):
  109. ok = True
  110. def row(name, good, note=""):
  111. nonlocal ok; ok &= bool(good); print(f" [{'OK' if good else 'FAIL'}] {name}{(' — ' + note) if note else ''}")
  112. print(f"观澜·如东样板 v2 自检 @ {ROOT}"); v = sys.version_info; row("Python ≥ 3.11", v >= (3, 11), f"{v.major}.{v.minor}.{v.micro} ({sys.executable})")
  113. # 源码可编译性 —— 重点是**非法转义序列**: 普通字符串里写 `\d` `\*` 这类, Python 3.12 只给
  114. # SyntaxWarning, 未来版本会变成 SyntaxError。这类问题在开发机上永远看不见, 换台机器/换个解释器才炸
  115. # (2026-09-11 逮到 src\windcms\serve.py 里 JS 正则的两处, 已按"补成合法转义"修好)。
  116. srcs = sorted(list((ROOT / "src").rglob("*.py")) + list((ROOT / "scripts").rglob("*.py")))
  117. bad = []
  118. with warnings.catch_warnings(record=True) as w:
  119. warnings.simplefilter("always")
  120. for f in srcs:
  121. try: compile(f.read_text(encoding="utf-8"), str(f), "exec")
  122. except SyntaxError as e: bad.append(f"{f.relative_to(ROOT)}:{e.lineno} {e.msg}")
  123. for it in w:
  124. if issubclass(it.category, SyntaxWarning): bad.append(f"{Path(str(it.filename)).name}:{it.lineno} {it.message}")
  125. row(f"源码可编译 ({len(srcs)} 个文件, 无非法转义/语法错)", not bad, "; ".join(bad[:3]))
  126. # 子进程口径自检 (2026-09-16 加): 这三条是**回归守卫** —— 它们各自都真炸过一次, 而炸法都是"静默":
  127. # ① capture_output=True 与显式 stdout 互斥 → 异常被 except 吞成 alive=False ⇒ 在跑的任务被
  128. # 误判成"被强杀", 页面显示完成、重算按钮可再点(可能并发重算);
  129. # ② CREATE_NO_WINDOW 新建的控制台会把子进程标准句柄吸走 ⇒ 重算日志一个字都没有、任务挂住;
  130. # ③ 不弹窗 (NO_WINDOW 位必须真的设上, 否则"点按钮闪黑窗"回来)。
  131. try:
  132. from src import proc as _proc
  133. _r = _proc.run_text([sys.executable, "-c", "print('proc-ok')"])
  134. row("子进程口径: run_text(capture_output) 可用", _r.returncode == 0 and "proc-ok" in (_r.stdout or ""),
  135. "src/proc.py (capture_output 与显式 stdout 互斥, 冲突会让 job_running 误判任务已死)")
  136. import tempfile as _tf
  137. _lg = Path(_tf.gettempdir()) / "_guanlan_proc_check.log"
  138. _p = _proc.spawn([sys.executable, "-c", "print('spawn-ok')"], log=_lg); _p.wait(timeout=60)
  139. _txt = _lg.read_text(encoding="utf-8", errors="replace") if _lg.exists() else ""
  140. try: _lg.unlink()
  141. except OSError: pass
  142. row("子进程口径: spawn(log=) 输出进日志", "spawn-ok" in _txt,
  143. "CREATE_NO_WINDOW 会吸走句柄, 不显式继承则日志空白 (重算看起来卡住)")
  144. row("子进程口径: 无窗口位已设 (CREATE_NO_WINDOW)", bool(_proc.flags() & 0x08000000) or os.name != "nt",
  145. f"flags={hex(_proc.flags())}")
  146. except Exception as _e:
  147. row("子进程口径自检", False, f"{type(_e).__name__}: {_e}")
  148. # 入口引用闭合 (2026-09-16 现场实炸后加): 目标机 (D:\产品\app) 双击 start.bat 报
  149. # "无法找到脚本文件 start_hidden.vbs" —— 包少带了一个被引用的文件。这条守卫在**装机后**复查一遍:
  150. # start.bat/check.bat/stop.bat/install.* 引用的每个文件都必须在位, 缺一个就 FAIL。
  151. # (那个 .vbs 已按用户令删除, 无窗口启动改用 pythonw.exe + scripts\guanlan_start_hidden.py;
  152. # 守卫与实现语言无关, 照样生效 —— 现在它盯的是 start.bat → scripts\guanlan_start_hidden.py 这类引用。)
  153. try:
  154. from src.entry_refs import encoding_problems, missing_refs, referenced_tree_files
  155. _miss = missing_refs(ROOT)
  156. _nref = sum(len(v) for v in referenced_tree_files(ROOT).values())
  157. row(f"入口脚本引用闭合 ({_nref} 条: start.bat→guanlan_start_hidden.py 等)", not _miss,
  158. "; ".join(f"{e} 缺 {r}" for e, r in _miss[:3]) or "每个入口引用的文件都在位")
  159. _enc = encoding_problems(ROOT)
  160. row("入口脚本编码守则 (.ps1 = UTF-8 BOM + CRLF; .bat = 纯 ASCII/CRLF/无 BOM/无 `<<`; .sh = LF)", not _enc,
  161. "; ".join(_enc[:2]) or "编码与字符都对 (PS 5.1 才不会把中文按 GBK 解错; 批处理里不放中文/重定向符)")
  162. except Exception as _e:
  163. row("入口脚本引用闭合", False, f"{type(_e).__name__}: {_e}")
  164. # 页面归口 (2026-09-17 用户令 1): 门户里哪些页面是"数据派生快照"(属于产物)、它们陈旧没陈旧。
  165. # 用户问过"#findings/#sim/#documents 该不该随输入数据变、算不算产物" —— 答案落在
  166. # configs/portal_pages.yaml 登记表 + scripts/pages_audit.py 的检查里, 这里只报结论。
  167. # 退出码: 0 一致 / 5 缺文件或未登记 / 6 溯源缺失 / 7 **页面陈旧**(数据变了页面没变) / 8 交付件缺版本 / 9 分类错。
  168. try:
  169. import importlib.util as _ilu
  170. _spec = _ilu.spec_from_file_location('_pages_audit', ROOT / "scripts" / "pages_audit.py")
  171. _m = _ilu.module_from_spec(_spec)
  172. _spec.loader.exec_module(_m)
  173. _rc, _res, _gaps = _m.audit()
  174. _bad = [r for r in _res if r[0] not in ("OK", "i")]
  175. _known = [r for r in _res if r[0] == "i"]
  176. _note = (f"检查 {len(_res)} 项: 不一致 {len(_bad)}"
  177. + (f" ({'; '.join(f'{r[1]}: {r[2][:60]}' for r in _bad[:2])})" if _bad else "")
  178. + f" · 已知缺口 {len(_known)} (引用悬空/无溯源, 登记表明写理由)"
  179. + (f" · 未登记页 {len(_gaps)}" if _gaps else ""))
  180. row("页面归口: 页面是否随数据变 / 是否陈旧 (configs/portal_pages.yaml)", _rc == 0, _note)
  181. except Exception as _e:
  182. row("页面归口审计", False, f"{type(_e).__name__}: {_e}")
  183. # 配置与日志的统一口径 (2026-09-17 用户令 2): 配置目录/文件、日志目录/命名/格式。
  184. # 两个检查器都是"看一眼实物 + 代码"的静态检查, 很便宜; 有问题就 FAIL 并指到具体文件。
  185. for _script, _label in (("config_audit.py", "配置统一: 目录约定/命名/内容/引用闭合/不手拼路径"),
  186. ("log_audit.py", "日志统一: logs/ 唯一落点/命名/行格式/保留策略")):
  187. try:
  188. import importlib.util as _ilu2
  189. _sp = _ilu2.spec_from_file_location(f'_{_script[:-3]}', ROOT / "scripts" / _script)
  190. _mod = _ilu2.module_from_spec(_sp)
  191. _sp.loader.exec_module(_mod)
  192. _rc2, _res2, _info2 = _mod.audit()
  193. _lvl = {}
  194. for _l in _res2:
  195. _lvl[_l[0]] = _lvl.get(_l[0], 0) + 1
  196. _bad2 = [r for r in _res2 if r[0] in ("X", "!")]
  197. row(_label, _rc2 == 0,
  198. (f"rc={_rc2}: " + "; ".join(f"{r[1]}: {r[2][:70]}" for r in _bad2[:2])) if _bad2
  199. else f"无不一致 · 已知缺口/白名单 {_lvl.get('i', 0)} · 提示 {_lvl.get('?', 0)}")
  200. except Exception as _e:
  201. row(_label, False, f"{type(_e).__name__}: {_e}")
  202. # 输入数据放置体检 (2026-09-17 用户令 3): data/raw 的结构/命名是否合约定、源类齐不齐。
  203. # 判 FAIL 的只有**结构类**问题 (放错层/名字不对/压缩包没解压) —— 那类问题会让摄入静默读不到;
  204. # "缺某类源件"只作为提示 (新装的机器本来就没数据, 不该因此判失败)。
  205. try:
  206. import importlib.util as _ilu3
  207. _sp3 = _ilu3.spec_from_file_location('_raw_check', ROOT / "scripts" / "raw_data_check.py")
  208. _rc3 = _ilu3.module_from_spec(_sp3)
  209. _sp3.loader.exec_module(_rc3)
  210. _r3, _n3, _s3 = _rc3.check_tree(Path(_rc3.station_dir()), deep=False)
  211. _struct = [x for x in _r3 if x[3] in (_rc3.RC_STRUCT, _rc3.RC_CLASH)]
  212. _gaps = [x for x in _r3 if x[3] == _rc3.RC_GAP]
  213. if not _s3.get('exists'):
  214. row("输入数据放置体检 (data/raw)", True,
  215. "尚未放置输入数据 —— 属预期; 放置规范见 docs/输入数据放置指导_v0.1.md")
  216. else:
  217. row("输入数据放置体检 (data/raw 结构/命名/源类)", not _struct,
  218. (f"{len(_struct)} 项结构问题: " + "; ".join(f"{x[1]}: {x[2][:60]}" for x in _struct[:2])) if _struct
  219. else f"{_s3.get('files', 0):,} 件源件 · 结构合规"
  220. + (f" · 缺 {len(_gaps)} 类/项: " + "; ".join(f"{x[1]}: {x[2][:50]}" for x in _gaps[:2]) if _gaps else "")
  221. + (f" · {len(_n3)} 条提示" if _n3 else ""))
  222. except Exception as _e:
  223. row("输入数据放置体检", False, f"{type(_e).__name__}: {_e}")
  224. for m in ("numpy", "pandas", "pyarrow", "polars", "yaml", "matplotlib", "plotly", "jinja2", "docx"):
  225. try: __import__(m); row(f"依赖 {m}", True)
  226. except Exception as ex: row(f"依赖 {m}", False, f"未安装: {ex.__class__.__name__} (运行 install 脚本)")
  227. # ★2026-09-16 用户令: 打包"不含 输入数据/产物/日志"。产物缺失时, 若包内 dist-manifest.json 就声明了
  228. # no_products/no_data, 这里显示 `--`(待重算) 而**不是 FAIL** —— 否则开箱自检会把"本来就该重算"的
  229. # 状态报成失败, install 脚本收尾的那次 check 也会失败 (把正常状态说成问题)。
  230. _man = {}
  231. try:
  232. _mp = ROOT / "dist-manifest.json"
  233. _man = jload(_mp) if _mp.is_file() else {}
  234. except Exception:
  235. _man = {}
  236. _no_products = bool(_man.get("no_products"))
  237. for rel, n in (("outputs/rudong/windscada", "L0/L1 产物 (parquet)"), ("outputs/rudong/ontology/objects.json", "本体对象库"), ("outputs/rudong/sop/findings.json", "findings"), ("outputs/rudong/guanlan/facts_contract_v0.json", "事实契约"),
  238. (c["release_dir"] + "/portal.html", "门户"), (c["release_dir"] + "/sim_sys_server.py", "仿真合页服务"), (c["release_dir"] + "/如东SWT40_控制律仿真台_20260906.zip", "仿真合页资料包"), (c["viewer_dir"], "三维 viewer 资产"), (c["sim_dir"], "仿真回放资产"), (c["release_dir"] + "/如东", "治理清单交付件 (可选)")):
  239. p = ROOT / rel; exists = p.exists() and (any(p.iterdir()) if p.is_dir() else p.stat().st_size > 0)
  240. if "可选" in n: print(f" [{'OK' if exists else '--'}] {n}: {rel}")
  241. elif _no_products and rel.startswith("outputs/"):
  242. print(f" [--] {n}: {rel} (本包按用户令**未随产物** —— 把现场包放好后跑 "
  243. f"scripts/place_raw_data.py --src <现场包目录> --scope full 再 scripts/rebuild_all.py)")
  244. else: row(n, exists, rel)
  245. raw = Path(c.get("raw_dir", "data/raw")); raw = raw if raw.is_absolute() else (ROOT / raw)
  246. print(f" [{'OK' if raw.exists() else '--'}] 原始件目录 (补数据放这里): {raw}{'' if raw.exists() else ' (不存在; 原始件不随包分发, 只影响摄入命令, 不影响页面)'}")
  247. for name, port, _ in services(c): print(f" [{'运行中' if up(c['host'], port) else '空闲'}] 端口 {port} ({name})")
  248. # 模型闸: 探针 (generate 非 tags) + 档位模型是否都在本机 + 摘要记录; 无模型时问答不可用, 其余页面不受影响
  249. sys.path.insert(0, str(ROOT))
  250. try:
  251. from src.ontology import llm_gate; mcfg = jload(P.MODELS_JSON)
  252. pr = llm_gate.probe(mcfg["tiers"]["default_qa"]["model"], timeout=90); row("本机模型 Ollama 探针 (默认档)", pr["ok"], f"{pr.get('latency_s')} s, digest {pr.get('digest')}" if pr["ok"] else pr.get("err", "") + " (启动 Ollama 并按 configs/models.json 的 pull_commands 拉模型)")
  253. try:
  254. with urllib.request.urlopen(f"http://{c['host']}:{c['ollama']}/api/tags", timeout=10) as r: have = {m["name"] for m in json.load(r).get("models", [])}
  255. for tier, t in mcfg["tiers"].items():
  256. name = t["model"]; ok_ = name in have or (name + ":latest") in have; print(f" [{'OK' if ok_ else '--'}] 模型档 {tier}: {name}{'' if ok_ else ' (未下载: ' + 'ollama pull ' + name + ')'}")
  257. except Exception as ex: print(f" [--] 模型清单不可读: {ex.__class__.__name__}")
  258. st = llm_gate.state(); print(f" [{'FAIL' if st['open'] else 'OK'}] 模型可用性检查: {'已熔断 (连续失败后自动停用, 60 秒后重试)' if st['open'] else '正常'}; 审计日志 {st['audit']}")
  259. except Exception as ex: row("模型可用性检查", False, f"{ex.__class__.__name__}: {str(ex)[:100]}")
  260. print("结论:", "全绿, 可 serve" if ok else "有 FAIL 项, 先按提示处理"); return 0 if ok else 2
  261. def cmd_serve(c):
  262. from src import logfile as _lf; _lf.prefix_stdout('serve') # 统一日志格式 (用户令 2)
  263. RUN.mkdir(exist_ok=True); LOGS.mkdir(exist_ok=True); pids = jload(PIDS) if PIDS.exists() else {}; e = env(c)
  264. for name, port, cmd in services(c):
  265. if up(c["host"], port): print(f" {name} {port} 已在运行 (复用)"); continue
  266. if name == "gateway": time.sleep(1.5)
  267. pid = spawn(cmd, LOGS / f"{name}.log", e); pids[name] = {"pid": pid, "port": port}; print(f" {name} {port} 启动 pid {pid}")
  268. PIDS.write_text(json.dumps(pids, ensure_ascii=False, indent=1), encoding="utf-8")
  269. url = f"http://{c['host']}:{c['gateway']}/healthz"
  270. for _ in range(40):
  271. try:
  272. with urllib.request.urlopen(url, timeout=20) as r: d = json.load(r); break
  273. except Exception: time.sleep(1)
  274. else: print("网关 healthz 60 s 内未就绪, 看 logs/gateway.log"); return 2
  275. bad = [m for m in d["modules"] if not m["ok"]]; print(f"入口 http://{c['host']}:{c['gateway']}/ 状态 {d['status']} {d['mode']} 模块 {len(d['modules']) - len(bad)}/{len(d['modules'])} ok")
  276. for m in bad: print(f" [DOWN] {m['path']} {m['name']} (看 logs/)")
  277. return 0 if not bad else 1
  278. def cmd_status(c):
  279. pids = jload(PIDS) if PIDS.exists() else {}
  280. for name, port, _ in services(c):
  281. p = pids.get(name, {}).get("pid"); print(f" {name:8s} 端口 {port} {'监听中' if up(c['host'], port) else '未监听'} pid {p if p else '-'} {'存活' if p and alive(p) else ''}")
  282. return 0
  283. def cmd_stop(c):
  284. if not PIDS.exists(): print("没有 pids.json (不是本启动器起的, 或已停)"); return 0
  285. pids = jload(PIDS)
  286. for name, v in pids.items(): kill(v["pid"]); print(f" 停 {name} pid {v['pid']}")
  287. time.sleep(1.5); left = [n for n, p, _ in services(c) if up(c["host"], p)]; PIDS.unlink()
  288. print("全部已停" if not left else f"仍在监听 (可能是别的实例): {left}"); return 0
  289. def main():
  290. a = sys.argv[1] if len(sys.argv) > 1 else "check"; c = cfg()
  291. if a == "open": url = f"http://{c['host']}:{c['gateway']}/"; print(url); webbrowser.open(url); return 0
  292. if a == "qa": return subprocess.call([py(c), str(ROOT / "scripts/llm_known_answer.py"), "--port", str(c["detail"])] + sys.argv[2:], cwd=str(ROOT))
  293. return {"check": cmd_check, "serve": cmd_serve, "status": cmd_status, "stop": cmd_stop}.get(a, lambda c: (print(__doc__), 2)[1])(c)
  294. if __name__ == "__main__":
  295. sys.exit(main())