state_manager.py 52 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273
  1. #!/usr/bin/env python3
  2. # -*- coding: utf-8 -*-
  3. """
  4. State Manager - 状态管理模块 (v5.4)
  5. 管理 state.json 的读写操作:
  6. - 实体状态管理
  7. - 进度追踪
  8. - 关系记录
  9. v5.1 变更(v5.4 沿用):
  10. - 集成 SQLStateManager,同步写入 SQLite (index.db)
  11. - state.json 保留精简数据,大数据自动迁移到 SQLite
  12. """
  13. import json
  14. import sys
  15. from pathlib import Path
  16. from typing import Dict, List, Optional, Any
  17. from dataclasses import dataclass, field, asdict
  18. from datetime import datetime
  19. import filelock
  20. from .config import get_config
  21. try:
  22. # 当 scripts 目录在 sys.path 中(常见:从 scripts/ 运行)
  23. from security_utils import atomic_write_json, read_json_safe
  24. except ImportError: # pragma: no cover
  25. # 当以 `python -m scripts.data_modules...` 从仓库根目录运行
  26. from scripts.security_utils import atomic_write_json, read_json_safe
  27. @dataclass
  28. class EntityState:
  29. """实体状态"""
  30. id: str
  31. name: str
  32. type: str # 角色/地点/物品/势力
  33. tier: str = "装饰" # 核心/重要/次要/装饰
  34. aliases: List[str] = field(default_factory=list)
  35. attributes: Dict[str, Any] = field(default_factory=dict)
  36. first_appearance: int = 0
  37. last_appearance: int = 0
  38. @dataclass
  39. class Relationship:
  40. """实体关系"""
  41. from_entity: str
  42. to_entity: str
  43. type: str
  44. description: str
  45. chapter: int
  46. @dataclass
  47. class StateChange:
  48. """状态变化记录"""
  49. entity_id: str
  50. field: str
  51. old_value: Any
  52. new_value: Any
  53. reason: str
  54. chapter: int
  55. timestamp: str = field(default_factory=lambda: datetime.now().isoformat())
  56. @dataclass
  57. class _EntityPatch:
  58. """待写入的实体增量补丁(用于锁内合并)"""
  59. entity_type: str
  60. entity_id: str
  61. replace: bool = False
  62. base_entity: Optional[Dict[str, Any]] = None # 新建实体时的完整快照(用于填充缺失字段)
  63. top_updates: Dict[str, Any] = field(default_factory=dict)
  64. current_updates: Dict[str, Any] = field(default_factory=dict)
  65. appearance_chapter: Optional[int] = None
  66. class StateManager:
  67. """状态管理器(v5.1 entities_v3 格式 + SQLite 同步,v5.4 沿用)"""
  68. # v5.0 引入的实体类型
  69. ENTITY_TYPES = ["角色", "地点", "物品", "势力", "招式"]
  70. def __init__(self, config=None, enable_sqlite_sync: bool = True):
  71. """
  72. 初始化状态管理器
  73. 参数:
  74. - config: 配置对象
  75. - enable_sqlite_sync: 是否启用 SQLite 同步 (默认 True)
  76. """
  77. self.config = config or get_config()
  78. self._state: Dict[str, Any] = {}
  79. # 与 security_utils.atomic_write_json 保持一致:state.json.lock
  80. self._lock_path = self.config.state_file.with_suffix(self.config.state_file.suffix + ".lock")
  81. # v5.1 引入: SQLite 同步
  82. self._enable_sqlite_sync = enable_sqlite_sync
  83. self._sql_state_manager = None
  84. if enable_sqlite_sync:
  85. try:
  86. from .sql_state_manager import SQLStateManager
  87. self._sql_state_manager = SQLStateManager(self.config)
  88. except ImportError:
  89. pass # SQLStateManager 不可用时静默降级
  90. # 待写入的增量(锁内重读 + 合并 + 写入)
  91. self._pending_entity_patches: Dict[tuple[str, str], _EntityPatch] = {}
  92. self._pending_alias_entries: Dict[str, List[Dict[str, str]]] = {}
  93. self._pending_state_changes: List[Dict[str, Any]] = []
  94. self._pending_structured_relationships: List[Dict[str, Any]] = []
  95. self._pending_disambiguation_warnings: List[Dict[str, Any]] = []
  96. self._pending_disambiguation_pending: List[Dict[str, Any]] = []
  97. self._pending_progress_chapter: Optional[int] = None
  98. self._pending_progress_words_delta: int = 0
  99. self._pending_chapter_meta: Dict[str, Any] = {}
  100. # v5.1 引入: 缓存待同步到 SQLite 的数据
  101. self._pending_sqlite_data: Dict[str, Any] = {
  102. "entities_appeared": [],
  103. "entities_new": [],
  104. "state_changes": [],
  105. "relationships_new": [],
  106. "chapter": None
  107. }
  108. self._load_state()
  109. def _now_progress_timestamp(self) -> str:
  110. return datetime.now().strftime("%Y-%m-%d %H:%M:%S")
  111. def _ensure_state_schema(self, state: Dict[str, Any]) -> Dict[str, Any]:
  112. """确保 state.json 具备运行所需的关键字段(尽量不破坏既有数据)。"""
  113. if not isinstance(state, dict):
  114. state = {}
  115. state.setdefault("project_info", {})
  116. state.setdefault("progress", {})
  117. state.setdefault("protagonist_state", {})
  118. # relationships: 旧版本可能是 list(实体关系),v5.0 运行态用 dict(人物关系/重要关系)
  119. relationships = state.get("relationships")
  120. if isinstance(relationships, list):
  121. state.setdefault("structured_relationships", [])
  122. if isinstance(state.get("structured_relationships"), list):
  123. state["structured_relationships"].extend(relationships)
  124. state["relationships"] = {}
  125. elif not isinstance(relationships, dict):
  126. state["relationships"] = {}
  127. state.setdefault("world_settings", {"power_system": [], "factions": [], "locations": []})
  128. state.setdefault("plot_threads", {"active_threads": [], "foreshadowing": []})
  129. state.setdefault("review_checkpoints", [])
  130. state.setdefault("chapter_meta", {})
  131. state.setdefault(
  132. "strand_tracker",
  133. {
  134. "last_quest_chapter": 0,
  135. "last_fire_chapter": 0,
  136. "last_constellation_chapter": 0,
  137. "current_dominant": "quest",
  138. "chapters_since_switch": 0,
  139. "history": [],
  140. },
  141. )
  142. entities_v3 = state.get("entities_v3")
  143. # v5.1 引入: entities_v3, alias_index, state_changes, structured_relationships 已迁移到 index.db
  144. # 不再在 state.json 中初始化或维护这些字段
  145. if not isinstance(state.get("disambiguation_warnings"), list):
  146. state["disambiguation_warnings"] = []
  147. if not isinstance(state.get("disambiguation_pending"), list):
  148. state["disambiguation_pending"] = []
  149. # progress 基础字段
  150. progress = state["progress"]
  151. if not isinstance(progress, dict):
  152. progress = {}
  153. state["progress"] = progress
  154. progress.setdefault("current_chapter", 0)
  155. progress.setdefault("total_words", 0)
  156. progress.setdefault("last_updated", self._now_progress_timestamp())
  157. return state
  158. def _load_state(self):
  159. """加载状态文件"""
  160. if self.config.state_file.exists():
  161. self._state = read_json_safe(self.config.state_file, default={})
  162. self._state = self._ensure_state_schema(self._state)
  163. else:
  164. self._state = self._ensure_state_schema({})
  165. def save_state(self):
  166. """
  167. 保存状态文件(锁内重读 + 合并 + 原子写入)。
  168. 解决多 Agent 并行下的“读-改-写覆盖”风险:
  169. - 获取锁
  170. - 重新读取磁盘最新 state.json
  171. - 仅合并本实例产生的增量(pending_*)
  172. - 原子化写入
  173. """
  174. # 无增量时不写入,避免无意义覆盖
  175. has_pending = any(
  176. [
  177. self._pending_entity_patches,
  178. self._pending_alias_entries,
  179. self._pending_state_changes,
  180. self._pending_structured_relationships,
  181. self._pending_disambiguation_warnings,
  182. self._pending_disambiguation_pending,
  183. self._pending_chapter_meta,
  184. self._pending_progress_chapter is not None,
  185. self._pending_progress_words_delta != 0,
  186. ]
  187. )
  188. if not has_pending:
  189. return
  190. self.config.ensure_dirs()
  191. lock = filelock.FileLock(str(self._lock_path), timeout=10)
  192. try:
  193. with lock:
  194. disk_state = read_json_safe(self.config.state_file, default={})
  195. disk_state = self._ensure_state_schema(disk_state)
  196. # progress(合并为 max(chapter) + words_delta 累加)
  197. if self._pending_progress_chapter is not None or self._pending_progress_words_delta != 0:
  198. progress = disk_state.get("progress", {})
  199. if not isinstance(progress, dict):
  200. progress = {}
  201. disk_state["progress"] = progress
  202. try:
  203. current_chapter = int(progress.get("current_chapter", 0) or 0)
  204. except (TypeError, ValueError):
  205. current_chapter = 0
  206. if self._pending_progress_chapter is not None:
  207. progress["current_chapter"] = max(current_chapter, int(self._pending_progress_chapter))
  208. if self._pending_progress_words_delta:
  209. try:
  210. total_words = int(progress.get("total_words", 0) or 0)
  211. except (TypeError, ValueError):
  212. total_words = 0
  213. progress["total_words"] = total_words + int(self._pending_progress_words_delta)
  214. progress["last_updated"] = self._now_progress_timestamp()
  215. # v5.1 引入: 强制使用 SQLite 模式,移除大数据字段
  216. # 确保 state.json 中不存在这些膨胀字段
  217. for field in ["entities_v3", "alias_index", "state_changes", "structured_relationships"]:
  218. disk_state.pop(field, None)
  219. # 标记已迁移
  220. disk_state["_migrated_to_sqlite"] = True
  221. # disambiguation_warnings(追加去重 + 截断)
  222. if self._pending_disambiguation_warnings:
  223. warnings_list = disk_state.get("disambiguation_warnings")
  224. if not isinstance(warnings_list, list):
  225. warnings_list = []
  226. disk_state["disambiguation_warnings"] = warnings_list
  227. def _warn_key(w: Dict[str, Any]) -> tuple:
  228. return (
  229. w.get("chapter"),
  230. w.get("mention"),
  231. w.get("chosen_id"),
  232. w.get("confidence"),
  233. )
  234. existing_keys = {_warn_key(w) for w in warnings_list if isinstance(w, dict)}
  235. for w in self._pending_disambiguation_warnings:
  236. if not isinstance(w, dict):
  237. continue
  238. k = _warn_key(w)
  239. if k in existing_keys:
  240. continue
  241. warnings_list.append(w)
  242. existing_keys.add(k)
  243. # 只保留最近 N 条,避免文件无限增长
  244. max_keep = self.config.max_disambiguation_warnings
  245. if len(warnings_list) > max_keep:
  246. disk_state["disambiguation_warnings"] = warnings_list[-max_keep:]
  247. # disambiguation_pending(追加去重 + 截断)
  248. if self._pending_disambiguation_pending:
  249. pending_list = disk_state.get("disambiguation_pending")
  250. if not isinstance(pending_list, list):
  251. pending_list = []
  252. disk_state["disambiguation_pending"] = pending_list
  253. def _pending_key(w: Dict[str, Any]) -> tuple:
  254. return (
  255. w.get("chapter"),
  256. w.get("mention"),
  257. w.get("suggested_id"),
  258. w.get("confidence"),
  259. )
  260. existing_keys = {_pending_key(w) for w in pending_list if isinstance(w, dict)}
  261. for w in self._pending_disambiguation_pending:
  262. if not isinstance(w, dict):
  263. continue
  264. k = _pending_key(w)
  265. if k in existing_keys:
  266. continue
  267. pending_list.append(w)
  268. existing_keys.add(k)
  269. max_keep = self.config.max_disambiguation_pending
  270. if len(pending_list) > max_keep:
  271. disk_state["disambiguation_pending"] = pending_list[-max_keep:]
  272. # chapter_meta(新增:按章节号覆盖写入)
  273. if self._pending_chapter_meta:
  274. chapter_meta = disk_state.get("chapter_meta")
  275. if not isinstance(chapter_meta, dict):
  276. chapter_meta = {}
  277. disk_state["chapter_meta"] = chapter_meta
  278. chapter_meta.update(self._pending_chapter_meta)
  279. # 原子写入(锁已持有,不再二次加锁)
  280. atomic_write_json(self.config.state_file, disk_state, use_lock=False, backup=True)
  281. # v5.1 引入: 同步到 SQLite(必须在清空 pending 之前调用)
  282. self._sync_to_sqlite()
  283. # 同步内存为磁盘最新快照,并清空增量队列
  284. self._state = disk_state
  285. self._pending_entity_patches.clear()
  286. self._pending_alias_entries.clear()
  287. self._pending_state_changes.clear()
  288. self._pending_structured_relationships.clear()
  289. self._pending_disambiguation_warnings.clear()
  290. self._pending_disambiguation_pending.clear()
  291. self._pending_chapter_meta.clear()
  292. self._pending_progress_chapter = None
  293. self._pending_progress_words_delta = 0
  294. except filelock.Timeout:
  295. raise RuntimeError("无法获取 state.json 文件锁,请稍后重试")
  296. def _sync_to_sqlite(self):
  297. """同步待处理数据到 SQLite(v5.1 引入,v5.4 沿用)"""
  298. if not self._sql_state_manager:
  299. return
  300. # 方式1: 通过 process_chapter_result 收集的数据
  301. sqlite_data = self._pending_sqlite_data
  302. chapter = sqlite_data.get("chapter")
  303. # 记录已处理的 (entity_id, chapter) 组合,避免重复写入 appearances
  304. processed_appearances = set()
  305. if chapter is not None:
  306. try:
  307. self._sql_state_manager.process_chapter_entities(
  308. chapter=chapter,
  309. entities_appeared=sqlite_data.get("entities_appeared", []),
  310. entities_new=sqlite_data.get("entities_new", []),
  311. state_changes=sqlite_data.get("state_changes", []),
  312. relationships_new=sqlite_data.get("relationships_new", [])
  313. )
  314. # 标记已处理的出场记录
  315. for entity in sqlite_data.get("entities_appeared", []):
  316. if entity.get("id"):
  317. processed_appearances.add((entity.get("id"), chapter))
  318. for entity in sqlite_data.get("entities_new", []):
  319. eid = entity.get("suggested_id") or entity.get("id")
  320. if eid:
  321. processed_appearances.add((eid, chapter))
  322. except Exception:
  323. pass # SQLite 同步失败时静默降级(避免中断主流程)
  324. # 方式2: 使用 add_entity/update_entity 收集的增量数据。
  325. # 数据缓存在 _pending_entity_patches 等变量中。
  326. self._sync_pending_patches_to_sqlite(processed_appearances)
  327. self._clear_pending_sqlite_data()
  328. def _sync_pending_patches_to_sqlite(self, processed_appearances: set = None):
  329. """同步 _pending_entity_patches 等到 SQLite(v5.1 引入,v5.4 沿用)
  330. Args:
  331. processed_appearances: 已通过 process_chapter_entities 处理的 (entity_id, chapter) 集合,
  332. 用于避免重复写入 appearances 表(防止覆盖 mentions)
  333. """
  334. if not self._sql_state_manager:
  335. return
  336. if processed_appearances is None:
  337. processed_appearances = set()
  338. # 元数据字段(不应写入 current_json)
  339. METADATA_FIELDS = {"canonical_name", "tier", "desc", "is_protagonist", "is_archived"}
  340. try:
  341. from .sql_state_manager import EntityData
  342. from .index_manager import EntityMeta
  343. # 同步实体补丁
  344. for (entity_type, entity_id), patch in self._pending_entity_patches.items():
  345. if patch.base_entity:
  346. # 新实体
  347. entity_data = EntityData(
  348. id=entity_id,
  349. type=entity_type,
  350. name=patch.base_entity.get("canonical_name", entity_id),
  351. tier=patch.base_entity.get("tier", "装饰"),
  352. desc=patch.base_entity.get("desc", ""),
  353. current=patch.base_entity.get("current", {}),
  354. aliases=[],
  355. first_appearance=patch.base_entity.get("first_appearance", 0),
  356. last_appearance=patch.base_entity.get("last_appearance", 0),
  357. is_protagonist=patch.base_entity.get("is_protagonist", False)
  358. )
  359. self._sql_state_manager.upsert_entity(entity_data)
  360. # 记录首次出场(跳过已处理的,避免覆盖 mentions)
  361. if patch.appearance_chapter is not None:
  362. if (entity_id, patch.appearance_chapter) not in processed_appearances:
  363. self._sql_state_manager._index_manager.record_appearance(
  364. entity_id=entity_id,
  365. chapter=patch.appearance_chapter,
  366. mentions=[entity_data.name],
  367. confidence=1.0,
  368. skip_if_exists=True # 关键:不覆盖已有记录
  369. )
  370. else:
  371. # 更新现有实体
  372. has_metadata_updates = bool(patch.top_updates and
  373. any(k in METADATA_FIELDS for k in patch.top_updates))
  374. # 非元数据的 top_updates 应该当作 current 更新
  375. # 例如:realm, layer, location 等状态字段
  376. non_metadata_top_updates = {
  377. k: v for k, v in patch.top_updates.items()
  378. if k not in METADATA_FIELDS
  379. } if patch.top_updates else {}
  380. # 合并 current_updates 和非元数据的 top_updates
  381. effective_current_updates = {**non_metadata_top_updates}
  382. if patch.current_updates:
  383. effective_current_updates.update(patch.current_updates)
  384. if has_metadata_updates:
  385. # 有元数据更新:使用 upsert_entity(update_metadata=True)
  386. existing = self._sql_state_manager.get_entity(entity_id)
  387. if existing:
  388. # 合并 current
  389. current = existing.get("current_json", {})
  390. if isinstance(current, str):
  391. import json
  392. current = json.loads(current) if current else {}
  393. if effective_current_updates:
  394. current.update(effective_current_updates)
  395. new_canonical_name = patch.top_updates.get("canonical_name")
  396. old_canonical_name = existing.get("canonical_name", "")
  397. entity_meta = EntityMeta(
  398. id=entity_id,
  399. type=existing.get("type", entity_type),
  400. canonical_name=new_canonical_name or old_canonical_name,
  401. tier=patch.top_updates.get("tier", existing.get("tier", "装饰")),
  402. desc=patch.top_updates.get("desc", existing.get("desc", "")),
  403. current=current,
  404. first_appearance=existing.get("first_appearance", 0),
  405. last_appearance=patch.appearance_chapter or existing.get("last_appearance", 0),
  406. is_protagonist=patch.top_updates.get("is_protagonist", existing.get("is_protagonist", False)),
  407. is_archived=patch.top_updates.get("is_archived", existing.get("is_archived", False))
  408. )
  409. self._sql_state_manager._index_manager.upsert_entity(entity_meta, update_metadata=True)
  410. # 如果 canonical_name 改名,自动注册新名字为 alias
  411. if new_canonical_name and new_canonical_name != old_canonical_name:
  412. self._sql_state_manager.register_alias(
  413. new_canonical_name, entity_id, existing.get("type", entity_type)
  414. )
  415. elif effective_current_updates:
  416. # 只有 current 更新(包括非元数据的 top_updates)
  417. self._sql_state_manager.update_entity_current(entity_id, effective_current_updates)
  418. # 更新 last_appearance 并记录出场
  419. if patch.appearance_chapter is not None:
  420. self._sql_state_manager._update_last_appearance(entity_id, patch.appearance_chapter)
  421. # 补充 appearances 记录
  422. # 使用 skip_if_exists=True 避免覆盖已有记录的 mentions
  423. if (entity_id, patch.appearance_chapter) not in processed_appearances:
  424. self._sql_state_manager._index_manager.record_appearance(
  425. entity_id=entity_id,
  426. chapter=patch.appearance_chapter,
  427. mentions=[],
  428. confidence=1.0,
  429. skip_if_exists=True # 关键:不覆盖已有记录
  430. )
  431. # 同步别名
  432. for alias, entries in self._pending_alias_entries.items():
  433. for entry in entries:
  434. entity_type = entry.get("type")
  435. entity_id = entry.get("id")
  436. if entity_type and entity_id:
  437. self._sql_state_manager.register_alias(alias, entity_id, entity_type)
  438. # 同步状态变化
  439. for change in self._pending_state_changes:
  440. self._sql_state_manager.record_state_change(
  441. entity_id=change.get("entity_id", ""),
  442. field=change.get("field", ""),
  443. old_value=change.get("old", change.get("old_value", "")),
  444. new_value=change.get("new", change.get("new_value", "")),
  445. reason=change.get("reason", ""),
  446. chapter=change.get("chapter", 0)
  447. )
  448. # 同步关系
  449. for rel in self._pending_structured_relationships:
  450. self._sql_state_manager.upsert_relationship(
  451. from_entity=rel.get("from_entity", ""),
  452. to_entity=rel.get("to_entity", ""),
  453. type=rel.get("type", "相识"),
  454. description=rel.get("description", ""),
  455. chapter=rel.get("chapter", 0)
  456. )
  457. except Exception:
  458. pass # SQLite 同步失败时静默降级
  459. def _clear_pending_sqlite_data(self):
  460. """清空待同步的 SQLite 数据"""
  461. self._pending_sqlite_data = {
  462. "entities_appeared": [],
  463. "entities_new": [],
  464. "state_changes": [],
  465. "relationships_new": [],
  466. "chapter": None
  467. }
  468. # ==================== 进度管理 ====================
  469. def get_current_chapter(self) -> int:
  470. """获取当前章节号"""
  471. return self._state.get("progress", {}).get("current_chapter", 0)
  472. def update_progress(self, chapter: int, words: int = 0):
  473. """更新进度"""
  474. if "progress" not in self._state:
  475. self._state["progress"] = {}
  476. self._state["progress"]["current_chapter"] = chapter
  477. if words > 0:
  478. total = self._state["progress"].get("total_words", 0)
  479. self._state["progress"]["total_words"] = total + words
  480. # 记录增量:锁内合并时用 max(chapter) + words_delta 累加
  481. if self._pending_progress_chapter is None:
  482. self._pending_progress_chapter = chapter
  483. else:
  484. self._pending_progress_chapter = max(self._pending_progress_chapter, chapter)
  485. if words > 0:
  486. self._pending_progress_words_delta += int(words)
  487. # ==================== 实体管理 (v5.1 SQLite-first) ====================
  488. def get_entity(self, entity_id: str, entity_type: str = None) -> Optional[Dict]:
  489. """获取实体(v5.1 引入:优先从 SQLite 读取)"""
  490. # v5.1 引入: 优先从 SQLite 读取
  491. if self._sql_state_manager:
  492. entity = self._sql_state_manager._index_manager.get_entity(entity_id)
  493. if entity:
  494. return entity
  495. # 回退到内存 state (兼容未迁移场景)
  496. entities_v3 = self._state.get("entities_v3", {})
  497. if entity_type:
  498. return entities_v3.get(entity_type, {}).get(entity_id)
  499. # 遍历所有类型查找
  500. for type_name, entities in entities_v3.items():
  501. if entity_id in entities:
  502. return entities[entity_id]
  503. return None
  504. def get_entity_type(self, entity_id: str) -> Optional[str]:
  505. """获取实体所属类型"""
  506. # v5.1 引入: 优先从 SQLite 读取
  507. if self._sql_state_manager:
  508. entity = self._sql_state_manager._index_manager.get_entity(entity_id)
  509. if entity:
  510. return entity.get("type")
  511. # 回退到内存 state
  512. for type_name, entities in self._state.get("entities_v3", {}).items():
  513. if entity_id in entities:
  514. return type_name
  515. return None
  516. def get_all_entities(self) -> Dict[str, Dict]:
  517. """获取所有实体(扁平化视图)"""
  518. # v5.1 引入: 优先从 SQLite 读取
  519. if self._sql_state_manager:
  520. result = {}
  521. for entity_type in self.ENTITY_TYPES:
  522. entities = self._sql_state_manager._index_manager.get_entities_by_type(entity_type)
  523. for e in entities:
  524. eid = e.get("id")
  525. if eid:
  526. result[eid] = {**e, "type": entity_type}
  527. if result:
  528. return result
  529. # 回退到内存 state
  530. result = {}
  531. for type_name, entities in self._state.get("entities_v3", {}).items():
  532. for eid, e in entities.items():
  533. result[eid] = {**e, "type": type_name}
  534. return result
  535. def get_entities_by_type(self, entity_type: str) -> Dict[str, Dict]:
  536. """按类型获取实体"""
  537. # v5.1 引入: 优先从 SQLite 读取
  538. if self._sql_state_manager:
  539. entities = self._sql_state_manager._index_manager.get_entities_by_type(entity_type)
  540. if entities:
  541. return {e.get("id"): e for e in entities if e.get("id")}
  542. # 回退到内存 state
  543. return self._state.get("entities_v3", {}).get(entity_type, {})
  544. def get_entities_by_tier(self, tier: str) -> Dict[str, Dict]:
  545. """按层级获取实体"""
  546. # v5.1 引入: 优先从 SQLite 读取
  547. if self._sql_state_manager:
  548. result = {}
  549. for entity_type in self.ENTITY_TYPES:
  550. entities = self._sql_state_manager._index_manager.get_entities_by_tier(tier)
  551. for e in entities:
  552. eid = e.get("id")
  553. if eid and e.get("type") == entity_type:
  554. result[eid] = {**e, "type": entity_type}
  555. if result:
  556. return result
  557. # 回退到内存 state
  558. result = {}
  559. for type_name, entities in self._state.get("entities_v3", {}).items():
  560. for eid, e in entities.items():
  561. if e.get("tier") == tier:
  562. result[eid] = {**e, "type": type_name}
  563. return result
  564. def add_entity(self, entity: EntityState) -> bool:
  565. """添加新实体(v5.0 entities_v3 格式,v5.4 沿用)"""
  566. entity_type = entity.type
  567. if entity_type not in self.ENTITY_TYPES:
  568. entity_type = "角色"
  569. if "entities_v3" not in self._state:
  570. self._state["entities_v3"] = {t: {} for t in self.ENTITY_TYPES}
  571. if entity_type not in self._state["entities_v3"]:
  572. self._state["entities_v3"][entity_type] = {}
  573. # 检查是否已存在
  574. if entity.id in self._state["entities_v3"][entity_type]:
  575. return False
  576. # 转换为 v3 格式
  577. v3_entity = {
  578. "canonical_name": entity.name,
  579. "tier": entity.tier,
  580. "desc": "",
  581. "current": entity.attributes,
  582. "first_appearance": entity.first_appearance,
  583. "last_appearance": entity.last_appearance,
  584. "history": []
  585. }
  586. self._state["entities_v3"][entity_type][entity.id] = v3_entity
  587. # 记录实体补丁(新建:仅填充缺失字段,避免覆盖并发写入)
  588. patch = self._pending_entity_patches.get((entity_type, entity.id))
  589. if patch is None:
  590. patch = _EntityPatch(entity_type=entity_type, entity_id=entity.id)
  591. self._pending_entity_patches[(entity_type, entity.id)] = patch
  592. patch.replace = True
  593. patch.base_entity = v3_entity
  594. # v5.1 引入: 注册别名到 index.db (通过 SQLStateManager)
  595. if self._sql_state_manager:
  596. self._sql_state_manager._index_manager.register_alias(entity.name, entity.id, entity_type)
  597. for alias in entity.aliases:
  598. if alias:
  599. self._sql_state_manager._index_manager.register_alias(alias, entity.id, entity_type)
  600. return True
  601. def _register_alias_internal(self, entity_id: str, entity_type: str, alias: str):
  602. """内部方法:注册别名到 index.db(v5.1 引入)"""
  603. if not alias:
  604. return
  605. # v5.1 引入: 直接写入 SQLite
  606. if self._sql_state_manager:
  607. self._sql_state_manager._index_manager.register_alias(alias, entity_id, entity_type)
  608. def update_entity(self, entity_id: str, updates: Dict[str, Any], entity_type: str = None) -> bool:
  609. """更新实体属性(v5.0 引入,v5.4 沿用)"""
  610. # 查找实体
  611. if entity_type:
  612. if entity_id not in self._state.get("entities_v3", {}).get(entity_type, {}):
  613. return False
  614. entity = self._state["entities_v3"][entity_type][entity_id]
  615. else:
  616. entity_type = self.get_entity_type(entity_id)
  617. if not entity_type:
  618. return False
  619. entity = self._state["entities_v3"][entity_type][entity_id]
  620. for key, value in updates.items():
  621. if key == "attributes" and isinstance(value, dict):
  622. # v5.0 引入: attributes 存在 current 字段
  623. if "current" not in entity:
  624. entity["current"] = {}
  625. entity["current"].update(value)
  626. # 记录补丁(current 增量)
  627. patch = self._pending_entity_patches.get((entity_type, entity_id))
  628. if patch is None:
  629. patch = _EntityPatch(entity_type=entity_type, entity_id=entity_id)
  630. self._pending_entity_patches[(entity_type, entity_id)] = patch
  631. patch.current_updates.update(value)
  632. elif key == "current" and isinstance(value, dict):
  633. if "current" not in entity:
  634. entity["current"] = {}
  635. entity["current"].update(value)
  636. patch = self._pending_entity_patches.get((entity_type, entity_id))
  637. if patch is None:
  638. patch = _EntityPatch(entity_type=entity_type, entity_id=entity_id)
  639. self._pending_entity_patches[(entity_type, entity_id)] = patch
  640. patch.current_updates.update(value)
  641. else:
  642. entity[key] = value
  643. patch = self._pending_entity_patches.get((entity_type, entity_id))
  644. if patch is None:
  645. patch = _EntityPatch(entity_type=entity_type, entity_id=entity_id)
  646. self._pending_entity_patches[(entity_type, entity_id)] = patch
  647. patch.top_updates[key] = value
  648. return True
  649. def update_entity_appearance(self, entity_id: str, chapter: int, entity_type: str = None):
  650. """更新实体出场章节"""
  651. if not entity_type:
  652. entity_type = self.get_entity_type(entity_id)
  653. if not entity_type:
  654. return
  655. entities_v3 = self._state.get("entities_v3")
  656. if not isinstance(entities_v3, dict):
  657. entities_v3 = {t: {} for t in self.ENTITY_TYPES}
  658. self._state["entities_v3"] = entities_v3
  659. entities_v3.setdefault(entity_type, {})
  660. entity = entities_v3[entity_type].get(entity_id)
  661. if entity:
  662. if entity.get("first_appearance", 0) == 0:
  663. entity["first_appearance"] = chapter
  664. entity["last_appearance"] = chapter
  665. # 记录补丁:锁内应用 first=min(non-zero), last=max
  666. patch = self._pending_entity_patches.get((entity_type, entity_id))
  667. if patch is None:
  668. patch = _EntityPatch(entity_type=entity_type, entity_id=entity_id)
  669. self._pending_entity_patches[(entity_type, entity_id)] = patch
  670. if patch.appearance_chapter is None:
  671. patch.appearance_chapter = chapter
  672. else:
  673. patch.appearance_chapter = max(int(patch.appearance_chapter), int(chapter))
  674. # ==================== 状态变化记录 ====================
  675. def record_state_change(
  676. self,
  677. entity_id: str,
  678. field: str,
  679. old_value: Any,
  680. new_value: Any,
  681. reason: str,
  682. chapter: int
  683. ):
  684. """记录状态变化"""
  685. if "state_changes" not in self._state:
  686. self._state["state_changes"] = []
  687. change = StateChange(
  688. entity_id=entity_id,
  689. field=field,
  690. old_value=old_value,
  691. new_value=new_value,
  692. reason=reason,
  693. chapter=chapter
  694. )
  695. change_dict = asdict(change)
  696. self._state["state_changes"].append(change_dict)
  697. self._pending_state_changes.append(change_dict)
  698. # 同时更新实体属性
  699. self.update_entity(entity_id, {"attributes": {field: new_value}})
  700. def get_state_changes(self, entity_id: Optional[str] = None) -> List[Dict]:
  701. """获取状态变化历史"""
  702. changes = self._state.get("state_changes", [])
  703. if entity_id:
  704. changes = [c for c in changes if c.get("entity_id") == entity_id]
  705. return changes
  706. # ==================== 关系管理 ====================
  707. def add_relationship(
  708. self,
  709. from_entity: str,
  710. to_entity: str,
  711. rel_type: str,
  712. description: str,
  713. chapter: int
  714. ):
  715. """添加关系"""
  716. rel = Relationship(
  717. from_entity=from_entity,
  718. to_entity=to_entity,
  719. type=rel_type,
  720. description=description,
  721. chapter=chapter
  722. )
  723. # v5.0 引入: 实体关系存入 structured_relationships,避免与 relationships(人物关系字典) 冲突
  724. if "structured_relationships" not in self._state:
  725. self._state["structured_relationships"] = []
  726. rel_dict = asdict(rel)
  727. self._state["structured_relationships"].append(rel_dict)
  728. self._pending_structured_relationships.append(rel_dict)
  729. def get_relationships(self, entity_id: Optional[str] = None) -> List[Dict]:
  730. """获取关系列表"""
  731. rels = self._state.get("structured_relationships", [])
  732. if entity_id:
  733. rels = [
  734. r for r in rels
  735. if r.get("from_entity") == entity_id or r.get("to_entity") == entity_id
  736. ]
  737. return rels
  738. # ==================== 批量操作 ====================
  739. def _record_disambiguation(self, chapter: int, uncertain_items: Any) -> List[str]:
  740. """
  741. 记录消歧反馈到 state.json,便于 Writer/Context Agent 感知风险。
  742. 约定:
  743. - >= extraction_confidence_medium:写入 disambiguation_warnings(采用但警告)
  744. - < extraction_confidence_medium:写入 disambiguation_pending(需人工确认)
  745. """
  746. if not isinstance(uncertain_items, list) or not uncertain_items:
  747. return []
  748. warnings: List[str] = []
  749. now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
  750. for item in uncertain_items:
  751. if not isinstance(item, dict):
  752. continue
  753. mention = str(item.get("mention", "") or "").strip()
  754. if not mention:
  755. continue
  756. raw_conf = item.get("confidence", 0.0)
  757. try:
  758. confidence = float(raw_conf)
  759. except (TypeError, ValueError):
  760. confidence = 0.0
  761. # 候选:支持 [{"type","id"}...] 或 ["id1","id2"] 两种形式
  762. candidates_raw = item.get("candidates", [])
  763. candidates: List[Dict[str, str]] = []
  764. if isinstance(candidates_raw, list):
  765. for c in candidates_raw:
  766. if isinstance(c, dict):
  767. cid = str(c.get("id", "") or "").strip()
  768. ctype = str(c.get("type", "") or "").strip()
  769. entry: Dict[str, str] = {}
  770. if ctype:
  771. entry["type"] = ctype
  772. if cid:
  773. entry["id"] = cid
  774. if entry:
  775. candidates.append(entry)
  776. else:
  777. cid = str(c).strip()
  778. if cid:
  779. candidates.append({"id": cid})
  780. entity_type = str(item.get("type", "") or "").strip()
  781. suggested_id = str(item.get("suggested", "") or "").strip()
  782. adopted_raw = item.get("adopted", None)
  783. chosen_id = ""
  784. if isinstance(adopted_raw, str):
  785. chosen_id = adopted_raw.strip()
  786. elif adopted_raw is True:
  787. chosen_id = suggested_id
  788. else:
  789. # 兼容字段名:entity_id / chosen_id
  790. chosen_id = str(item.get("entity_id") or item.get("chosen_id") or "").strip() or suggested_id
  791. context = str(item.get("context", "") or "").strip()
  792. note = str(item.get("warning", "") or "").strip()
  793. record: Dict[str, Any] = {
  794. "chapter": int(chapter),
  795. "mention": mention,
  796. "type": entity_type,
  797. "suggested_id": suggested_id,
  798. "chosen_id": chosen_id,
  799. "confidence": confidence,
  800. "candidates": candidates,
  801. "context": context,
  802. "note": note,
  803. "created_at": now,
  804. }
  805. if confidence >= float(self.config.extraction_confidence_medium):
  806. self._state.setdefault("disambiguation_warnings", []).append(record)
  807. self._pending_disambiguation_warnings.append(record)
  808. chosen_part = f" → {chosen_id}" if chosen_id else ""
  809. warnings.append(f"消歧警告: {mention}{chosen_part} (confidence: {confidence:.2f})")
  810. else:
  811. self._state.setdefault("disambiguation_pending", []).append(record)
  812. self._pending_disambiguation_pending.append(record)
  813. warnings.append(f"消歧需人工确认: {mention} (confidence: {confidence:.2f})")
  814. return warnings
  815. def process_chapter_result(self, chapter: int, result: Dict) -> List[str]:
  816. """
  817. 处理 Data Agent 的章节处理结果(v5.1 引入,v5.4 沿用)
  818. 输入格式:
  819. - entities_appeared: 出场实体列表
  820. - entities_new: 新实体列表
  821. - state_changes: 状态变化列表
  822. - relationships_new: 新关系列表
  823. 返回警告列表
  824. """
  825. warnings = []
  826. # v5.1 引入: 记录章节号用于 SQLite 同步
  827. self._pending_sqlite_data["chapter"] = chapter
  828. # 处理出场实体
  829. for entity in result.get("entities_appeared", []):
  830. entity_id = entity.get("id")
  831. entity_type = entity.get("type")
  832. if entity_id:
  833. self.update_entity_appearance(entity_id, chapter, entity_type)
  834. # v5.1 引入: 缓存用于 SQLite 同步
  835. self._pending_sqlite_data["entities_appeared"].append(entity)
  836. # 处理新实体
  837. for entity in result.get("entities_new", []):
  838. entity_id = entity.get("suggested_id") or entity.get("id")
  839. if entity_id and entity_id != "NEW":
  840. new_entity = EntityState(
  841. id=entity_id,
  842. name=entity.get("name", ""),
  843. type=entity.get("type", "角色"),
  844. tier=entity.get("tier", "装饰"),
  845. aliases=entity.get("mentions", []),
  846. first_appearance=chapter,
  847. last_appearance=chapter
  848. )
  849. if not self.add_entity(new_entity):
  850. warnings.append(f"实体已存在: {entity_id}")
  851. # v5.1 引入: 缓存用于 SQLite 同步
  852. self._pending_sqlite_data["entities_new"].append(entity)
  853. # 处理状态变化
  854. for change in result.get("state_changes", []):
  855. self.record_state_change(
  856. entity_id=change.get("entity_id", ""),
  857. field=change.get("field", ""),
  858. old_value=change.get("old"),
  859. new_value=change.get("new"),
  860. reason=change.get("reason", ""),
  861. chapter=chapter
  862. )
  863. # v5.1 引入: 缓存用于 SQLite 同步
  864. self._pending_sqlite_data["state_changes"].append(change)
  865. # 处理关系
  866. for rel in result.get("relationships_new", []):
  867. self.add_relationship(
  868. from_entity=rel.get("from", ""),
  869. to_entity=rel.get("to", ""),
  870. rel_type=rel.get("type", ""),
  871. description=rel.get("description", ""),
  872. chapter=chapter
  873. )
  874. # v5.1 引入: 缓存用于 SQLite 同步
  875. self._pending_sqlite_data["relationships_new"].append(rel)
  876. # 处理消歧不确定项(不影响实体写入,但必须对 Writer 可见)
  877. warnings.extend(self._record_disambiguation(chapter, result.get("uncertain", [])))
  878. # 写入 chapter_meta(钩子/模式/结束状态)
  879. chapter_meta = result.get("chapter_meta")
  880. if isinstance(chapter_meta, dict):
  881. meta_key = f"{int(chapter):04d}"
  882. self._state.setdefault("chapter_meta", {})
  883. self._state["chapter_meta"][meta_key] = chapter_meta
  884. self._pending_chapter_meta[meta_key] = chapter_meta
  885. # 更新进度
  886. self.update_progress(chapter)
  887. # 同步主角状态(entities_v3 → protagonist_state)
  888. self.sync_protagonist_from_entity()
  889. return warnings
  890. # ==================== 导出 ====================
  891. def export_for_context(self) -> Dict:
  892. """导出用于上下文的精简版状态(v5.0 引入,v5.4 沿用)"""
  893. # 从 entities_v3 构建精简视图
  894. entities_flat = {}
  895. for type_name, entities in self._state.get("entities_v3", {}).items():
  896. for eid, e in entities.items():
  897. entities_flat[eid] = {
  898. "name": e.get("canonical_name", eid),
  899. "type": type_name,
  900. "tier": e.get("tier", "装饰"),
  901. "current": e.get("current", {})
  902. }
  903. return {
  904. "progress": self._state.get("progress", {}),
  905. "entities": entities_flat,
  906. # v5.1 引入: alias_index 已迁移到 index.db,这里返回空(兼容性)
  907. "alias_index": {},
  908. "recent_changes": [], # v5.1 引入: 从 index.db 查询
  909. "disambiguation": {
  910. "warnings": self._state.get("disambiguation_warnings", [])[-self.config.export_disambiguation_slice:],
  911. "pending": self._state.get("disambiguation_pending", [])[-self.config.export_disambiguation_slice:],
  912. },
  913. }
  914. # ==================== 主角同步 ====================
  915. def get_protagonist_entity_id(self) -> Optional[str]:
  916. """获取主角实体 ID(通过 is_protagonist 标记或 SQLite 查询)"""
  917. # 方式1: 通过 SQLStateManager 查询 (v5.1)
  918. if self._sql_state_manager:
  919. protagonist = self._sql_state_manager.get_protagonist()
  920. if protagonist:
  921. return protagonist.get("id")
  922. # 方式2: 通过 protagonist_state.name 查找别名
  923. protag_name = self._state.get("protagonist_state", {}).get("name")
  924. if protag_name and self._sql_state_manager:
  925. entities = self._sql_state_manager._index_manager.get_entities_by_alias(protag_name)
  926. for entry in entities:
  927. if entry.get("type") == "角色":
  928. return entry.get("id")
  929. return None
  930. def sync_protagonist_from_entity(self, entity_id: str = None):
  931. """
  932. 将主角实体的状态同步到 protagonist_state (v5.1: 从 SQLite 读取)
  933. 用于确保 consistency-checker 等依赖 protagonist_state 的组件获取最新数据
  934. """
  935. if entity_id is None:
  936. entity_id = self.get_protagonist_entity_id()
  937. if entity_id is None:
  938. return
  939. entity = self.get_entity(entity_id, "角色")
  940. if not entity:
  941. return
  942. current = entity.get("current")
  943. if not isinstance(current, dict):
  944. current = entity.get("current_json", {})
  945. if isinstance(current, str):
  946. try:
  947. current = json.loads(current) if current else {}
  948. except (json.JSONDecodeError, TypeError):
  949. current = {}
  950. if not isinstance(current, dict):
  951. current = {}
  952. protag = self._state.setdefault("protagonist_state", {})
  953. # 同步境界
  954. if "realm" in current:
  955. power = protag.setdefault("power", {})
  956. power["realm"] = current["realm"]
  957. if "layer" in current:
  958. power["layer"] = current["layer"]
  959. # 同步位置
  960. if "location" in current:
  961. loc = protag.setdefault("location", {})
  962. loc["current"] = current["location"]
  963. if "last_chapter" in current:
  964. loc["last_chapter"] = current["last_chapter"]
  965. def sync_protagonist_to_entity(self, entity_id: str = None):
  966. """
  967. 将 protagonist_state 同步到 entities_v3 中的主角实体
  968. 用于初始化或手动编辑 protagonist_state 后保持一致性
  969. """
  970. if entity_id is None:
  971. entity_id = self.get_protagonist_entity_id()
  972. if entity_id is None:
  973. return
  974. protag = self._state.get("protagonist_state", {})
  975. if not protag:
  976. return
  977. updates = {}
  978. # 同步境界
  979. power = protag.get("power", {})
  980. if power.get("realm"):
  981. updates["realm"] = power["realm"]
  982. if power.get("layer"):
  983. updates["layer"] = power["layer"]
  984. # 同步位置
  985. loc = protag.get("location", {})
  986. if loc.get("current"):
  987. updates["location"] = loc["current"]
  988. if updates:
  989. self.update_entity(entity_id, updates, "角色")
  990. # ==================== CLI 接口 ====================
  991. def main():
  992. import argparse
  993. from pydantic import ValidationError
  994. from .cli_output import print_success, print_error
  995. from .schemas import validate_data_agent_output, format_validation_error, normalize_data_agent_output
  996. from .index_manager import IndexManager
  997. parser = argparse.ArgumentParser(description="State Manager CLI (v5.4)")
  998. parser.add_argument("--project-root", type=str, help="项目根目录")
  999. subparsers = parser.add_subparsers(dest="command")
  1000. # 读取进度
  1001. subparsers.add_parser("get-progress")
  1002. # 获取实体
  1003. get_entity_parser = subparsers.add_parser("get-entity")
  1004. get_entity_parser.add_argument("--id", required=True)
  1005. # 列出实体
  1006. list_parser = subparsers.add_parser("list-entities")
  1007. list_parser.add_argument("--type", help="按类型过滤")
  1008. list_parser.add_argument("--tier", help="按层级过滤")
  1009. # 处理章节结果
  1010. process_parser = subparsers.add_parser("process-chapter")
  1011. process_parser.add_argument("--chapter", type=int, required=True, help="章节号")
  1012. process_parser.add_argument("--data", required=True, help="JSON 格式的处理结果")
  1013. args = parser.parse_args()
  1014. # 初始化
  1015. config = None
  1016. if args.project_root:
  1017. from .config import DataModulesConfig
  1018. config = DataModulesConfig.from_project_root(args.project_root)
  1019. manager = StateManager(config)
  1020. logger = IndexManager(config)
  1021. tool_name = f"state_manager:{args.command or 'unknown'}"
  1022. def emit_success(data=None, message: str = "ok"):
  1023. print_success(data, message=message)
  1024. try:
  1025. logger.log_tool_call(tool_name, True)
  1026. except Exception:
  1027. pass
  1028. def emit_error(code: str, message: str, suggestion: str | None = None):
  1029. print_error(code, message, suggestion=suggestion)
  1030. try:
  1031. logger.log_tool_call(tool_name, False, error_code=code, error_message=message)
  1032. except Exception:
  1033. pass
  1034. if args.command == "get-progress":
  1035. emit_success(manager._state.get("progress", {}), message="progress")
  1036. elif args.command == "get-entity":
  1037. entity = manager.get_entity(args.id)
  1038. if entity:
  1039. emit_success(entity, message="entity")
  1040. else:
  1041. emit_error("NOT_FOUND", f"未找到实体: {args.id}")
  1042. elif args.command == "list-entities":
  1043. if args.type:
  1044. entities = manager.get_entities_by_type(args.type)
  1045. elif args.tier:
  1046. entities = manager.get_entities_by_tier(args.tier)
  1047. else:
  1048. entities = manager.get_all_entities()
  1049. payload = [{"id": eid, **e} for eid, e in entities.items()]
  1050. emit_success(payload, message="entities")
  1051. elif args.command == "process-chapter":
  1052. data = json.loads(args.data)
  1053. validated = None
  1054. last_exc = None
  1055. for _ in range(3):
  1056. try:
  1057. validated = validate_data_agent_output(data)
  1058. break
  1059. except ValidationError as exc:
  1060. last_exc = exc
  1061. data = normalize_data_agent_output(data)
  1062. if validated is None:
  1063. err = format_validation_error(last_exc) if last_exc else {
  1064. "code": "SCHEMA_VALIDATION_FAILED",
  1065. "message": "数据结构校验失败",
  1066. "details": {"errors": []},
  1067. "suggestion": "请检查 data-agent 输出字段是否完整且类型正确",
  1068. }
  1069. emit_error(err["code"], err["message"], suggestion=err.get("suggestion"))
  1070. return
  1071. warnings = manager.process_chapter_result(args.chapter, validated.model_dump(by_alias=True))
  1072. manager.save_state()
  1073. emit_success({"chapter": args.chapter, "warnings": warnings}, message="chapter_processed")
  1074. else:
  1075. emit_error("UNKNOWN_COMMAND", "未指定有效命令", suggestion="请查看 --help")
  1076. if __name__ == "__main__":
  1077. if sys.platform == "win32":
  1078. import io
  1079. sys.stdout = io.TextIOWrapper(sys.stdout.buffer, encoding="utf-8")
  1080. sys.stderr = io.TextIOWrapper(sys.stderr.buffer, encoding="utf-8")
  1081. main()