Compare commits

...

1 Commits

Author SHA1 Message Date
6135f17ca2 补充体系表结构与模块重构规范
加入负责人提供的达梦建表脚本和模块重构说明,统一后续 1.3 形式化模块对正式体系版本表的理解与落库目标。

Made-with: Cursor
2026-04-24 17:36:43 +08:00
2 changed files with 375 additions and 0 deletions

248
CreatTable.sql Normal file
View File

@@ -0,0 +1,248 @@
-- ==============================================================================
-- 体系推演底层数据架构 (支持多租户、三维度索引、三元组、全维属性约束)
-- 兼容: 达梦数据库 (Dameng)
-- ==============================================================================
-- ---------------------------------------------------------
-- 第一步:创建上下文环境变量 (达梦标准语法:必须绑定包)
-- ---------------------------------------------------------
-- 1.1 创建管理包头
CREATE OR REPLACE PACKAGE PKG_SYSTEM_CTX AS
PROCEDURE SET_USER_ID(P_ID VARCHAR(50));
END;
/
-- 1.2 创建管理包体
CREATE OR REPLACE PACKAGE BODY PKG_SYSTEM_CTX AS
PROCEDURE SET_USER_ID(P_ID VARCHAR(50)) AS
BEGIN
DBMS_SESSION.SET_CONTEXT('SYSTEM_CTX', 'USER_ID', P_ID);
END;
END;
/
-- 1.3 创建上下文对象 (注意:达梦不能加 OR REPLACE)
-- 如果提示“对象已存在”忽略即可,说明已经建好了
CREATE CONTEXT SYSTEM_CTX USING PKG_SYSTEM_CTX;
-- ---------------------------------------------------------
-- 第二步:创建基础属性字典表 (无外键依赖,最先创建)
-- ---------------------------------------------------------
-- 1. 实体详情属性表 (存储单兵级物理参数、图片与新闻)
CREATE TABLE ENTITY_ATTR_DETAIL (
attr_id VARCHAR(50) PRIMARY KEY,
longitude DECIMAL(15, 6), -- 经度
latitude DECIMAL(15, 6), -- 纬度
speed DECIMAL(10, 2), -- 速度
entity_value DECIMAL(10, 2), -- 价值
image_url VARCHAR(500), -- 图片 (路径或URL)
news_content CLOB, -- 新闻 (文本或HTML)
extra_json CLOB -- 备用扩展属性 (JSON)
);
-- 2. 体系整体属性表 (存储整个体系的评估属性)
CREATE TABLE SYSTEM_ATTR_DETAIL (
sys_attr_id VARCHAR(50) PRIMARY KEY,
effectiveness_score DECIMAL(10, 4), -- 体系效能
extra_props CLOB -- 其他体系属性 (JSON)
);
-- ---------------------------------------------------------
-- 第三步:创建核心体系索引与三元组数据表 (带有强约束)
-- ---------------------------------------------------------
-- 3. 体系数据版本总表 (所有数据的根索引:用户+战略任务+时间)
CREATE TABLE SYSTEM_VERSION_MASTER (
version_id VARCHAR(50) PRIMARY KEY,
user_id VARCHAR(50) NOT NULL, -- 索引维度1所属用户
strat_task_id VARCHAR(50) NOT NULL, -- 索引维度2战略任务ID
sys_date DATE NOT NULL, -- 索引维度3体系对应日期 (年月日)
save_timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP, -- 上传保存时间戳
-- 体系类型强约束
sys_type VARCHAR(50) CHECK (sys_type IN (
'常规体系', '关系推理后的体系', '形式化后的体系', '历史体系',
'当前体系', '预测体系', '指控体系', '重构体系'
)),
-- 体系任务强约束
system_task VARCHAR(50) CHECK (system_task IN (
'综合防御任务', '火力打击任务', '后勤保障任务', '医疗救援任务', '紧急疏散任务'
)),
-- 国家/地区约束
country_region VARCHAR(10) CHECK (country_region IN ('', '', '', '', '')),
sys_attr_id VARCHAR(50) REFERENCES SYSTEM_ATTR_DETAIL(sys_attr_id)
);
-- 建立三维联合索引,极大提升查询检索效率
CREATE INDEX idx_sys_version_lookup ON SYSTEM_VERSION_MASTER(user_id, strat_task_id, sys_date);
-- 4. 实体节点表 (三元组之头/尾节点)
CREATE TABLE SYSTEM_ENTITY (
entity_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
entity_name VARCHAR(100) NOT NULL,
-- 实体角色强约束 (7种)
entity_role VARCHAR(20) CHECK (entity_role IN (
'信息获取', '信息传输', '指挥控制', '信息对抗', '协同打击', '部署平台', '综合保障'
)),
-- 实体国家/地区强约束
entity_country VARCHAR(10) CHECK (entity_country IN ('', '', '', '', '')),
-- 实体可能执行的任务
entity_task VARCHAR(50) CHECK (entity_task IN (
'综合防御任务', '火力打击任务', '后勤保障任务', '医疗救援任务', '紧急疏散任务'
)),
-- 指控类型 (OODA仅在指控体系中有效允许为空)
c2_type VARCHAR(10) CHECK (c2_type IN ('Observe', 'Orient', 'Decide', 'Act', NULL)),
-- 实体可能存在的关系 (存贮格式由后端决定,如 "情报保障,指挥控制")
possible_relations VARCHAR(255),
attr_id VARCHAR(50) REFERENCES ENTITY_ATTR_DETAIL(attr_id)
);
-- 5. 实体连线关系表 (三元组之边)
CREATE TABLE SYSTEM_RELATION (
rel_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
head_entity_id VARCHAR(50) REFERENCES SYSTEM_ENTITY(entity_id),
tail_entity_id VARCHAR(50) REFERENCES SYSTEM_ENTITY(entity_id),
-- 关系类型强约束 (5种选其一)
rel_type VARCHAR(20) CHECK (rel_type IN (
'情报保障', '指挥控制', '状态反馈', '平台部署', '协同作战'
))
);
-- ---------------------------------------------------------
-- 第四步:创建 9 大体系计算分析结果表 (全指向 version_id)
-- ---------------------------------------------------------
CREATE TABLE RES_TARGET_RECOGNITION (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
entity_id VARCHAR(50) REFERENCES SYSTEM_ENTITY(entity_id),
confidence_score DECIMAL(5, 4),
metrics_json CLOB
);
CREATE TABLE RES_NODE_VALUE (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
entity_id VARCHAR(50) REFERENCES SYSTEM_ENTITY(entity_id),
value_result_json CLOB
);
CREATE TABLE RES_REL_REASONING (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
reasoning_data CLOB
);
CREATE TABLE RES_FORMAL_ANALYSIS (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
formal_data CLOB
);
CREATE TABLE RES_SYS_ANALYSIS (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
analysis_data CLOB
);
CREATE TABLE RES_SYS_EVO_PREDICT (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
predict_data CLOB
);
CREATE TABLE RES_SYS_EFFECTIVENESS (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
effectiveness_data CLOB
);
CREATE TABLE RES_LINK_COG (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
link_cog_data CLOB
);
CREATE TABLE RES_NODE_COG (
res_id VARCHAR(50) PRIMARY KEY,
version_id VARCHAR(50) REFERENCES SYSTEM_VERSION_MASTER(version_id) ON DELETE CASCADE,
node_cog_data CLOB
);
-- ---------------------------------------------------------
-- 第五步:当前体系专用覆盖表
-- ---------------------------------------------------------
-- 用于单独保存“当前体系”的快照,逻辑上同用户、同任务只有唯一一份
CREATE TABLE CURRENT_SYSTEM_SNAPSHOT (
snapshot_id VARCHAR(50) PRIMARY KEY,
user_id VARCHAR(50) NOT NULL,
strat_task_id VARCHAR(50) NOT NULL,
sys_date DATE NOT NULL,
save_timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
full_system_json CLOB,
CONSTRAINT uq_current_sys UNIQUE(user_id, strat_task_id)
);
-- ---------------------------------------------------------
-- 第六步:建立上下文安全视图 (极重要:实现后端模块免传 user_id)
-- ---------------------------------------------------------
-- 主表与三元组视图
CREATE OR REPLACE VIEW V_MY_SYSTEM_VERSION AS
SELECT * FROM SYSTEM_VERSION_MASTER
WHERE user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_SYSTEM_ENTITY AS
SELECT e.* FROM SYSTEM_ENTITY e
JOIN SYSTEM_VERSION_MASTER v ON e.version_id = v.version_id
WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_SYSTEM_RELATION AS
SELECT r.* FROM SYSTEM_RELATION r
JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id
WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
-- 9 大分析结果视图
CREATE OR REPLACE VIEW V_MY_RES_TARGET_RECOGNITION AS
SELECT r.* FROM RES_TARGET_RECOGNITION r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_NODE_VALUE AS
SELECT r.* FROM RES_NODE_VALUE r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_REL_REASONING AS
SELECT r.* FROM RES_REL_REASONING r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_FORMAL_ANALYSIS AS
SELECT r.* FROM RES_FORMAL_ANALYSIS r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_SYS_ANALYSIS AS
SELECT r.* FROM RES_SYS_ANALYSIS r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_SYS_EVO_PREDICT AS
SELECT r.* FROM RES_SYS_EVO_PREDICT r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_SYS_EFFECTIVENESS AS
SELECT r.* FROM RES_SYS_EFFECTIVENESS r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_LINK_COG AS
SELECT r.* FROM RES_LINK_COG r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');
CREATE OR REPLACE VIEW V_MY_RES_NODE_COG AS
SELECT r.* FROM RES_NODE_COG r JOIN SYSTEM_VERSION_MASTER v ON r.version_id = v.version_id WHERE v.user_id = SYS_CONTEXT('SYSTEM_CTX', 'USER_ID');

127
prompt.md Normal file
View File

@@ -0,0 +1,127 @@
非常感谢你的指正!确实,将**统一的数据库连接配置项**以及**核心表的真实插入格式参考**放入 Prompt 中,能够极大程度上防止大模型在生成代码时“自由发挥”,从而保证各个模块连接达梦数据库时的绝对一致性。
我已将这两块关键信息补充进了 `prompt.md` 的核心架构规范中。以下是为你更新后的、更加完美的 `prompt.md` 文件:
---
--- START OF FILE prompt.md ---
# 🤖 体系推演平台模块重构指令 (Meta-Prompt)
## 📌 背景说明
你现在是一名资深的全栈开发工程师与数据库架构师。当前系统是一个基于 Flask + 原生 JS + 达梦数据库 (Dameng) 的军事体系推演与分析平台。
系统正处于架构升级阶段,核心目标是:**实现基于 JWT Token 的多租户数据隔离、全面接入达梦数据库、以及在数据库异常或数据缺失时具备本地模拟兜底机制。**
你需要根据本文件的规范,将我提供的【原始前后端代码】重构为符合新架构的代码。
---
## 🏗️ 核心架构与通用方法规范(重构必读)
### 1. 鉴权与租户隔离规范 (JWT + 战略任务ID)
* **前端规范**:必须拦截原生的 `fetch` 请求,从 URL 中获取 `207.SSO_TOKEN`,并在所有以 `/api/` 开头的请求 Header 中注入 `Authorization: Bearer <Token>`
* **后端解析规范**:使用 `pyjwt` 解析 Header 中的 Token 获取 `user_id`(解析失败则兜底使用 `'ADMIN'``'default_user'`)。同时从请求参数中获取 `strat_task_id`战略任务ID`'TASK_FULL_KB'`)。
* **数据库隔离规范**:所有涉及达梦数据库的连接,在获取 `cursor` 后,**必须第一时间调用存储过程设置上下文**
```python
cur.execute("CALL PKG_SYSTEM_CTX.SET_USER_ID(?)", (user_id,))
```
设置完成后,所有对视图(`V_MY_*`)的查询将自动实现行级隔离。
### 2. 数据库连接、读取与写入规范 (DB Connector 模式)
* **数据库连接配置标准**:请统一使用环境变量与兜底配置初始化达梦数据库连接句柄(`DMInterface` 或对应的 Connector
```python
dm_handler = DMInterface(
host=os.getenv("DM_HOST", "127.0.0.1"),
port=os.getenv("DM_PORT", 9080),
user=os.getenv("DM_USER", "SYSDBA"),
password=os.getenv("DM_PASS", "Dm508508")
)
```
* **数据插入格式参考 (核心表结构)**:在写入 `SYSTEM_VERSION_MASTER` 时,请严格遵守以下 SQL 格式和强约束字段(注意时间转换与类型):
```sql
INSERT INTO SYSTEM_VERSION_MASTER (version_id, user_id, strat_task_id, sys_date, sys_type, system_task, country_region, sys_attr_id)
VALUES ('V_FULL_KB_001', 'ADMIN', 'TASK_FULL_KB', DATE '2026-04-15', '当前体系', '综合防御任务', '台', 'ATTR_FULL_KB');
```
* **业务逻辑解耦**:严禁在核心业务逻辑中写散装 SQL必须封装在 `db_connector.py` 或模块专属的 DB 类中。
* **数据挂载关系**:体系数据的存取**必须以版本version_id为核心**。体系包含三个层级:
1. `SYSTEM_VERSION_MASTER` (版本总表)
2. `SYSTEM_ENTITY` (实体表:挂载在 version_id 下)
3. `SYSTEM_RELATION` (三元组关系表:挂载在 version_id 下)
* **分析结果写入**:分析结果的存取必须写入对应的 `RES_*` 表,并将结果序列化为 JSON 存入 `CLOB` 字段。
### 3. 双轨运行与模拟兜底机制 (Fallback 机制)
与预测模块一样,本模块必须具备极强的鲁棒性:
* **读取时**:如果数据库连接失败,或数据库中查不到所需数据,必须能够回退到读取本地 `pkl/json/xlsx` 文件。
* **如果连本地文件都没有**:必须基于内置的军事规则(如实体角色、作战编制规范)**动态生成模拟数据**供算法消费,绝不能直接抛出异常崩溃。
* **写入时**:所有新生成的数据(体系数据、分析结果)必须**先保存在本地工作区目录**,然后再执行数据库的 `INSERT/UPDATE` 操作。如果数据库上传失败,仅打印警告,不影响前端展示。
---
## 🎯 各业务模块专属重构逻辑指引
请根据我当前要求你重构的模块,匹配以下业务逻辑进行代码修改:
### 模块 1.1:目标识别模块
* **数据流向**:前端传入实体名集合 -> 触发上层知识库接口(模拟) -> 知识库将图片、新闻、属性存入数据库 `ENTITY_ATTR_DETAIL` 表。
* **计算逻辑**:模块从数据库读取这些属性进行数据融合与目标识别。
* **入库操作**:识别出实体的国家、角色、任务后,执行 `UPDATE SYSTEM_ENTITY`(如果实体已存在)或覆盖写入。结果明细写入 `RES_TARGET_RECOGNITION`。
### 模块 1.6-1.7:节点价值分析模块
* **数据流向**:通过 `user_id` 和 `strat_task_id` 从数据库中提取所有实体及对应的 `ENTITY_ATTR_DETAIL`。
* **计算逻辑**:执行价值计算算法。
* **入库操作**:将计算出的最终价值分数 `UPDATE ENTITY_ATTR_DETAIL SET entity_value = ?`。分析报告 JSON 存入 `RES_NODE_VALUE`。
### 模块 2.1:关系推理模块
* **数据流向**:读取实体库、实体可能的关系 (`possible_relations`) 以及实体属性。
* **入库操作**:将推理出的全新三元组数据,作为全新的体系快照入库。
* 在 `SYSTEM_VERSION_MASTER` 中插入新记录,且 **`sys_type` 必须标记为 `'关系推理后的体系'`**。
* 将推理详情日志存入 `RES_REL_REASONING`。
### 模块 1.3:形式化模块
* **数据流向**:默认从数据库中读取 `sys_type = '关系推理后的体系'` 的数据。
* **入库操作**:形式化计算完成后,将结果作为全新的体系入库,**`sys_type` 标记为 `'形式化后的体系'`**。详细规则存入 `RES_FORMAL_ANALYSIS`。
### 模块 1.4:体系构建模块 (核心中枢)
* **读取逻辑**:默认拉取 `sys_type = '形式化后的体系'` 用于可视化。前端需新增接口,拉取该任务下 **所有版本** 的体系列表供用户切换查看。
* **定时保存功能**:后端需支持定时任务,触发时将当前画板体系存入数据库,**`sys_type` 默认为 `'历史体系'`**。
* **手动保存功能**:前端提供下拉框,允许用户自由选择 8 种体系类型之一进行保存。
* **设为当前体系**:前端左下角新增【确认构建为当前体系】按钮,点击后将当前数据覆盖或新建为 **`sys_type = '当前体系'`**。
### 模块 1.5:体系分析模块
* **数据流向**:强制读取 `sys_type = '当前体系'` 的数据及实体属性。
* **入库操作**
* 将包含 OODA 角色的体系存为 **`sys_type = '指控体系'`**(更新 `SYSTEM_ENTITY` 中的 `c2_type` 字段为 Observe/Orient/Decide/Act
* 分析报告存入 `RES_SYS_ANALYSIS`。
### 模块 3.1, 3.2, 3.3:失效机制与体系效能模块
* **数据流向**:全部强制读取 `sys_type = '当前体系'` 的数据。
* **入库操作**
* 模块 3.2(体系重构)执行完毕后,将结果生成新版本,**`sys_type` 标记为 `'重构体系'`**。
* 模块 3.1 / 3.3 算出的效能指标,更新到 `SYSTEM_ATTR_DETAIL` 表中,详细报告存入 `RES_SYS_EFFECTIVENESS`。
### 模块 3.4, 3.5:重心分析模块
* **数据流向**:强制读取 `sys_type = '当前体系'`。
* **入库操作**:链路重心结果存入 `RES_LINK_COG`,节点重心结果存入 `RES_NODE_COG`。
---
## ⚠️ 数据库表结构校验指令 (非常重要)
在重构代码前,请你仔细审阅我提供的 `CreatTable.sql` 文件。
如果你发现在上述业务逻辑中,**有部分属性、字段或关联关系在 `CreatTable.sql` 中不存在**(例如:某个模块需要保存一种特殊格式的 JSON但对应表没有 CLOB 字段;或者缺少了知识库中间表),请你**务必在输出代码前明确指出**,并为我提供用于达梦数据库的补充 SQL 语句(`CREATE TABLE` 或 `ALTER TABLE`)。
---
## 💻 你的任务
现在,我已经将本模块的 **前端 JS、HTML、后端 Python 逻辑** 上传给了你。
请你严格遵守以上《体系推演平台模块重构指令》,一步步思考,并输出:
1. **数据库结构审查报告**(是否需要补充 SQL 表?若需要,请给出 SQL
2. **后端的重构代码**(包含 Python API 路由接收参数、Token 解析、DB 调用与 Fallback 生成逻辑)。
3. **前端的重构代码**(包含 Token 注入、接口参数适配、以及模块特定如1.4模块)的 UI 按钮与下拉框新增)。
请确保输出的代码完整、注释清晰,并且变量名符合原代码的上下文风格。
--- END OF FILE prompt.md ---