xinghuo/group_xinghuo_jinrong
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

feat(merge): 完成 AL-09 合并接线，整合风控模块与宿主 Wave 0

Browse Source 
- 合并 `risk-control-agent` 分支至 `merger`，实现 JWT 统一与模块 API 恢复。
- 更新 `auth_service` 和 `auth_adapter`，确保对外登录/token 统一。
- 增强 chat 模块，支持会话管理与流式对话（SSE）。
- 测试基线更新至 502 passed, 1 skipped，确保系统稳定性。

此更新标志着风控模块的成功集成，提升了系统的整体功能与可维护性。
This commit is contained in:
zhanghongyu_0626
2026-09-08 20:00:39 +08:00
parent 6d780d45c3
commit f87e11f104
12 changed files with 100 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files
docs/memory/MEMORY.md
+18 -15
View File
@@ -9,13 +9,18 @@
**项目是什么：** 金融四 Agent（客户财富 / 代理人 / 数据分析 / 风控）共用数据层与合规底座；**不**互调 LLM，跨 Agent 走 L1/L2/L3 画像与预警表。
**当前进度：** 需求与表设计已定 · **风控模块 B1~B9b 全部完成（M2 tag risk-m2），M4 复核已闭环（2026-09-07），风控阶段 B 正式完结** · **Wave 0 已完成（2026-09-07，经独立 AI 评审闭环）**：T-01 JWT 鉴权（auth_service Auth SDK + deps 工厂替换 + X-Agent-Type 准入矩阵）/ T-02 审计中间件（http_access + 独立 request_id + 4xx/500 统一错误体 + input_guard_log 双写）/ T-06 chat 最小闭环（POST /api/chat + 会话落库 + Redis 窗口）/ T-07 LangGraph StateGraph 骨架 + DeepSeek（无 key 降级）· **T-04 Core RO Tool 节点已完成（2026-09-07）**：app/tool/core_tools.py 三只读 Tool + tool_service（意图/归属校验/run_tool）+ 图 tool 节点 + agent_tool_call 落库 + `utils/authz.py` 公共鉴权留痕，**321 测试绿（首评+复审双闭环）**。风控阶段 C 已完成（2026-09-07，345 绿，tag `risk-m3`，A-6 对话线验收通过，独立 AI 评审 PASS P0=0）。T-03 输入防护已完成（2026-09-07，378 绿，独立 AI 评审 PASS with findings P0=0）：app/service/input_guard.py 注入词表 42 条纯函数检测 + oversize 4000 + actor 级 Redis 固定窗口限流 30 次/分（fail-open）；chat 链路顺序 = 鉴权→准入→空白→限流 429→注入/超长 400→归属→会话，被拒 fail-fast 不建会话，blocked 落 input_guard_log（ENUM 四值已用满）。**阶段一「对齐 main 基准」AL-01~AL-08 已完成（2026-09-07，逐项独立 commit bb244f4~b5fd52e）：适当性判定换核为 main 的 core_ro.check_suitability（C×R 矩阵表数据驱动，match_result 五值/JR-AST-012/FM-01/FM-03/JR-AST-PRO 契约，SUIT-001~008 退役）；risk_suitability_log 重建 21 列；Core 表加 is_hnw/风评七新列（expires_at）；种子 33 客户/14 产品；全量 406 passed 0 failed 0 skipped + uvicorn 冒烟三端点通过；risk-m1 已补打（指向 3c07de6）**。**下一步：阶段一验收门（**合并 main 前的最终交付检查点，非分支开发阻塞**；用户浏览器目视确认 UI）→ AL-09 合并 main → AL-10 PRD v1.2 → AL-11 docx 登记 → 阶段二 C4~C6（**已完成并打 `risk-m4` tag**）/ 前端 React 多 Agent 入口（HashRouter `web/` init）。****开发在分支 `risk-control-agent`（与 origin/main 已分叉：领先 84 提交 / 落后 0，origin/main 为分支祖先；**分支已推送远程，origin/risk-control-agent 同步于 `1d00e53`，本地跟踪已建立**；旧文档中的 `feature/risk` 为过时口径）。**
**当前进度：** 需求与表设计已定 · **风控模块 B1~B9b + 阶段 C（C1~C3）+ C4~C6（FR-8/9/10）+ 前端接入 B/C 全部完成** · **AL-09 合并接线已完成（2026-09-08，`merger` 分支）**：`risk-control-agent` 并入宿主 Wave 0；JWT 统一（`/api/auth/login` → `auth_service.issue_dev_token`，与 risk/chat 共用 `settings.jwt_issuer`）；模块版 chat/agent/memory 已恢复（含 sessions/stream）；S2 接缝 `auth_adapter.module_auth_from_host` 已接线；**502 passed 1 skipped**（`python -m pytest`）。**下一步：统筹侧 Core 公共 API v0.1 + 前端 `web/`；各 Agent 负责人并行 Tool/编排。**
**工作分支：** 团队开发在 **`merger`**（已 merge 风控模块）；历史开发分支 `risk-control-agent` 交付冻结。旧文档中「待 AL-09 合并」口径已过时。
**仓库地图：**
| 路径 | 状态 | 说明 |
| --- | --- | --- |
| `app/main.py` | **已集成** | 路由挂载 + trace 中间件（X-Trace-Id/X-Request-Id 贯通 + 500 兜底错误体）+ audit 中间件（T-02 http_access）+ lifespan（jwt_ready 校验 · Redis 网关注册 · 引擎 dispose） |
| `app/main.py` | **已集成（AL-09）** | 宿主 TraceMiddleware + 模块 audit/trace 中间件 + 路由（auth/chat/risk/simulate）+ lifespan；trace 中间件对 ApiError 等 **原样 re-raise**，仅未捕获异常 → 500 |
| `app/api/auth.py` | **已实现（AL-09）** | Mock 登录；签发走 `auth_service.issue_dev_token`（与模块 API 同一 issuer） |
| `app/api/auth_adapter.py` | **已接线（S2）** | `module_auth_from_host()`：宿主 AuthContext → 模块 AuthContext |
| `app/gateway/` | **宿主 Wave 0（并存）** | jwt_service / auth_deps / rbac / ownership；模块 API 走 `deps.py`，禁止模块 import gateway |
| `app/api/risk.py` `simulate.py` `deps.py` | **已实现** | 风控 4 API + 模拟网关路由 + **JWT 鉴权工厂（T-01：Bearer 全环境优先；debug 头仅 dev+无 RS256 公钥时兜底；AGENT_ACCESS_MATRIX 准入）** |
| `app/api/chat.py` `audit_middleware.py` | **已实现（T-06/T-02 + 前端接入 B/C）** | POST /api/chat（SessionGuard+归属+窗口+落盘）· **前端拉侧三端点**（`GET /sessions` / `GET /sessions/{id}/messages` / `POST /sessions/{id}/close`，方案 B `8328c24`）· **SSE 流式 `POST /api/chat/stream`**（OpenAI 兼容 chunk，方案 C `01ec5fc`）；守卫抽 `_guard_request`/`_prepare_turn`/`_guard_session` 同步流式共用 · http_access 访问审计 |
| `app/api/knowledge.py` `admin.py` | 空壳 | 待审计查询台与知识库 API（T-21 拍板一期只做脚本入库，上传/重建端点不做） |
@@ -34,11 +39,12 @@
| `scripts/core/*.sql` + `reset.ps1` | **已实现** | Core 模拟库 DDL + 种子 |
| `scripts/agent/` `scripts/demo/` `scripts/dev/` | **已实现** | AML 名单种子 + 风控演示数据 + subscribe_alerts/rebuild_alerts + issue_dev_token（JWT 签发） |
| `scripts/sync/*.py` | **已实现** | 归属同步 + Neo4j 全图 |
| `tests/` | **已实现** | 36 个测试模块 503 用例（sqlite 隔离；DDL 单一事实源 `_ddl.py`；`test_integration_risk.py` 走真 MySQL + TRD-TEST- 前缀隔离；pytest 依赖装在系统 Python 3.13.14；阶段一基线 425→406，前端接入 B/C 后 **482→503**）。**改路由必同步 `tests/test_main.py::test_all_routers_mounted` 的路径清单，否则必红** |
| `tests/` | **已实现** | 36+ 测试模块 **502 用例 1 skipped**（sqlite 隔离；`test_module_boundary` 宿主 D 类文件不参与跨层扫描）。改路由必同步 `tests/test_main.py::test_all_routers_mounted` |
| `docs/需求拆解/` | 已定 | 场景 P0、矩阵、合规原文 |
| `docs/PRD/PRD-风控监测Agent.md` | **已冻结（v1.1）** | 风控 PRD v1.0 + v1.1 追加 FR-8/9/10（§4A）+ 规则表附录 |
| `docs/项目框架设计/实现方案-风控追加需求v1.1-C4C6.md` | **已定稿** | C4~C6 编码依据（经独立 AI 评审修订闭环）；分支/进度速览另见项目根 `交接文档.md` |
| `docs/项目框架设计/合并注意事项-风控模块并入main.md` | **已定稿（2026-09-07）** | **给合并执行人**：基底锁定（本地 main 3995cb4，origin/main 停在 Initial commit）/ 20 冲突裁决指引 / 14 静默并入文件 / 三处硬伤处置 / 合并后必测清单 |
| `docs/项目框架设计/合并注意事项-风控模块并入main.md` | **AL-09 已执行（2026-09-08）** | 合并接线完成；接缝见《风控Agent模块边界与合并接缝标注.md》 |
| `docs/项目管理/04-从需求到公共API开发方法.md` | **已定（2026-09-08）** | 需求→矩阵→存储→Service→API→Agent 主线；Phase A Core API 清单 |
| `docs/项目框架设计/表设计/` | 已定 | Agent 共用 11 表 + agent 专用 SQL |
| `docs/项目框架设计/Core模拟底座/` | 已定 | 无真实 Core 时的 L0 方案 |
| `web/` | **不存在** | 前端 React 待 init |
@@ -54,15 +60,12 @@
5. mysql … < scripts/agent/seed-aml-list.sql # AML 名单种子
（风控演示：scripts/demo/prepare_risk_demo.sql，reset 后重跑）
6. python scripts/sync/sync_advisor_rel.py && python scripts/sync/sync_neo4j.py
7. uvicorn app.main:app --reload → GET /health；python -m pytest（406 用例，系统 Python 3.13.14）
7. uvicorn app.main:app --reload → GET /health；python -m pytest（**502 绿**，系统 Python 3.13.14）
```
> **本机 ①~⑤已执行、`.env` 已配置，勿重做**；本机状态与已知坑（mysql.exe 路径 / reset.ps1 交互式 -p / `redis`、`python-jose` 包漏装已补）见 `FLOW.md` §0 尾注。
> **演示库状态（2026-09-07）**：已按演示 SOP §2 重灌并清理冒烟数据（alerts 0 / AML 8 / 会话 0），pytest 全量可直接跑；**下次演示/走查后再按 SOP §2 重灌**（核查单⑥前置断言会对走查残留显式 fail，属防护行为）。
**AL-09 合并后架构（一句话）：** 宿主 `gateway/` + 模块 `deps.py` **双栈并存**；对外登录/token **统一**；chat/risk 均走模块鉴权；接缝 S2 用 `auth_adapter`。
**前端接入面已交付（2026-09-08，503 绿）**：**方案 B** 会话管理三端点（`GET /api/chat/sessions`、`GET /api/chat/sessions/{id}/messages`、`POST /api/chat/sessions/{id}/close`，commit `8328c24`）+ **方案 C** SSE 流式对话 `POST /api/chat/stream`（OpenAI 兼容 chunk：首帧 meta 带 disclaimer → delta → finish_reason=stop → `[DONE]`，commit `01ec5fc`）。三条硬约束：① 守卫全在返回 StreamingResponse 之前（SSE 一开改不了状态码，401/403/404/409/429/400 仍普通 JSON）；② 整轮一次性落库（`insert_turn` 同事务），断连/异常不落消息；③ risk_manager 在对话线数据面一律 403（PRD 4A.1）。遗留 P2：无心跳帧、断连留空会话、流式 429 未单测。
**下一步开发（见 TODO）：** **模块侧交付完毕（2026-09-07：全量 pytest 482 绿 + 接口实调验收通过——suitability/check 阻断+放行、simulate/trade 阻断、三条鉴权边界 401/403/403 契约零偏差；`risk-m1~m4` tag 齐）。合并 main 已移交合并执行人，操作手册《docs/项目框架设计/合并注意事项-风控模块并入main.md》（含基底锁定/20 冲突裁决/14 静默文件/三硬伤/合并后必测，实测数据编制）。模块侧开放项：chat 链路 risk_suitability_log.actor_id 落 SYSTEM 待评估 / 前端 React 多 Agent 入口（`web/` 未 init，归属待拍板）。**演示走查按 `docs/项目框架设计/演示SOP-风控模块.md`（debug 头通道仍有效；JWT 通道签发用 `scripts/dev/issue_dev_token.py`；演示库已按 AL-08 expires_at 新口径重灌）。知识库入库：`python scripts/kb/build_kb.py`（先启 Ollama；**Milvus 数据路径必须纯英文**——faiss 不支持中文路径，本机 .env 已配 C:/Users/YUAN/.jinrong/milvus/）。
**下一步（见 TODO）：** Core 公共 API v0.1（`docs/项目管理/04` Phase A）· 前端 `web/` init · 客户/代理人/分析 Agent 业务并行。
**禁止（改代码前必记）：** Core 正式 C1~C5 不可被画像覆盖 · 审计表只 INSERT · 代理人草稿不外发 · 仅 R-02 可阻断交易 · 四 Agent 不互调 LLM。
@@ -81,8 +84,8 @@
## 1. 项目简介
- **名称：** JinRong 金融四 Agent 智能管家
- **当前阶段：** **模块交付完毕（2026-09-07）+ 前端接入面交付（2026-09-08）**——阶段一 AL-01~08 + 阶段二 C4~C6 + 前端接入 B/C 全部完成，**503 绿**，接口实调验收通过（AI 代验），`risk-m1~m4` tag 齐；合并 main 已移交合并执行人（手册：《合并注意事项-风控模块并入main.md》）
- **当前优先级：** 前端 React 入口（`web/` init，后端接入面已就绪）/ 模块侧开放项（actor_id 透传评估）；合并进度由合并执行人负责，模块侧不阻塞
- **当前阶段：** **AL-09 合并接线完成（2026-09-08，`merger` 分支）**——风控 + Wave 0 宿主共存；502 测试绿；接口实调此前已通过
- **当前优先级：** Core 公共 API v0.1（统筹 P1）/ 前端 `web/` / 客户·代理人·分析 Agent 并行
------
@@ -145,7 +148,7 @@ Core 模拟：scripts/core/reset.ps1 · 文档 docs/项目框架设计/Core模
种子：scripts/agent/seed-aml-list.sql（AML 名单）· scripts/demo/prepare_risk_demo.sql（reset 后重跑）
依赖：requirements.txt（LangGraph + langchain-core/openai + FastAPI + SQLAlchemy）
启动：uvicorn app.main:app --reload → GET /health
测试：python -m pytest（503 用例；集成测试需本机演示数据，未灌库时自动 skip）
测试：python -m pytest（**502 绿** 1 skipped；集成测试需本机演示数据，未灌库时自动 skip）
运维/演示脚本：scripts/demo/subscribe_alerts.py（订阅推送演示）· rebuild_alerts.py TRD-xxx（引擎异常补偿重放）
JWT 联调：python scripts/dev/issue_dev_token.py --sub STAFF-30001 --roles risk_officer（+ Authorization: Bearer + X-Agent-Type）
配置：.env（见 .env.example）
@@ -171,7 +174,7 @@ RBAC 联调账号：scripts/dev/rbac-seed-reference.md
| `docs/项目框架设计/架构设计-风控模块.md` | 风控模块架构（§3.1 编排 / §5 service 职责） |
| `docs/需求拆解/` | 业务原文（场景、矩阵、合规） |
| `docs/项目框架设计/` | 表结构、JWT 手册、Core 模拟、技术版本 |
| `docs/业务记忆管理/` | Redis 短期 vs MySQL/Milvus/Neo4j 权威记忆 |
| `docs/项目管理/04-从需求到公共API开发方法.md` | 搭公共底座/API 前；新人 onboarding |
缺 `docs/memory/*` 文件：按 project-memory-kit 同名补回，**禁止空模板盖进度**。
@@ -189,6 +192,6 @@ RBAC 联调账号：scripts/dev/rbac-seed-reference.md
2. 改动属于 api / service / tool / repository 哪一层？
3. 是否需 customer_id 归属与 JWT RBAC？
4. Core 是模拟库只读还是 agent 库读写？
5. 如何验证？（`python -m pytest` 全量（当前 **503 绿**）· uvicorn 启动 + /health · SQL / sync 脚本 · 对照 REQUIREMENTS 验收列）
5. 如何验证？（`python -m pytest` 全量（当前 **502 绿**）· uvicorn 启动 + /health · `tests/test_module_boundary.py` 全绿 · SQL / sync 脚本 · 对照 REQUIREMENTS 验收列）
大任务：FRAMEWORK/FLOW 与实现状态不符时先更新 memory 再编码（用户确认跳过除外）。