// 一次性脚本：把档案管理模块（yudao-module-archive）并入 config_export_all_20260929.sql 的阶段一
|
// 用法：node _merge_archive.js
|
const fs = require('node:fs');
|
const path = require('node:path');
|
const os = require('node:os');
|
|
const DIR = __dirname;
|
const TARGET = path.join(DIR, 'config_export_all_20260929.sql');
|
const MODULE = path.join(DIR, 'archive_module.sql');
|
const BPM = path.join(DIR, '_archive_bpm_export.sql');
|
const TMP = path.join(os.homedir(), 'AppData', 'Local', 'Temp');
|
|
const raw = fs.readFileSync(TARGET, 'utf8');
|
if (!raw.includes('\r\n')) throw new Error('目标文件不是 CRLF');
|
let doc = raw.replace(/\r\n/g, '\n');
|
|
const norm = (s) => s.replace(/\r\n/g, '\n');
|
const moduleLines = norm(fs.readFileSync(MODULE, 'utf8')).split('\n');
|
const bpmLines = norm(fs.readFileSync(BPM, 'utf8')).split('\n');
|
|
/** 断言锚点唯一 */
|
function anchor(text) {
|
const n = doc.split(text).length - 1;
|
if (n !== 1) throw new Error(`锚点出现 ${n} 次，期望 1 次：${text.slice(0, 90)}`);
|
}
|
/** 在锚点前插入（插入内容与锚点之间留一个空行） */
|
function insertBefore(text, before) {
|
anchor(text);
|
doc = doc.replace(text, before + '\n\n' + text);
|
}
|
/** 替换一次 */
|
function replaceOnce(from, to) {
|
anchor(from);
|
doc = doc.replace(from, to);
|
}
|
|
// ---------------------------------------------------------------- 数据行风格归一
|
/** 按顶层逗号切分 VALUES 元组（尊重单引号与反斜杠转义） */
|
function splitTuple(s) {
|
const out = [];
|
let cur = '';
|
let inS = false;
|
for (let i = 0; i < s.length; i++) {
|
const c = s[i];
|
if (inS) {
|
cur += c;
|
if (c === '\\' && i + 1 < s.length) {
|
cur += s[++i];
|
} else if (c === "'") {
|
if (s[i + 1] === "'") cur += s[++i];
|
else inS = false;
|
}
|
} else if (c === "'") {
|
inS = true;
|
cur += c;
|
} else if (c === ',') {
|
out.push(cur.trim());
|
cur = '';
|
} else {
|
cur += c;
|
}
|
}
|
if (cur.trim()) out.push(cur.trim());
|
return out;
|
}
|
|
/**
|
* 把从库 JDBC 导出的 INSERT 行改写成本文件的既有风格：
|
* 字符串/数字/日期一律加单引号，bit 列 deleted 出 X'00'，NULL 保持 NULL。
|
*/
|
function restyle(line) {
|
const m = line.match(/^INSERT INTO `([^`]+)` \(([^)]+)\) VALUES \((.*)\);$/);
|
if (!m) throw new Error(`无法解析数据行：${line.slice(0, 90)}`);
|
const [, table, colText, valsText] = m;
|
const cols = colText.split(',').map((c) => c.trim().replace(/`/g, ''));
|
const vals = splitTuple(valsText);
|
if (cols.length !== vals.length) {
|
throw new Error(`${table} 列数 ${cols.length} 与值数 ${vals.length} 不符`);
|
}
|
const out = vals.map((v, i) => {
|
if (v === 'NULL') return 'NULL';
|
if (cols[i] === 'deleted') {
|
if (v !== '0') throw new Error(`${table}.deleted 期望 0，实际 ${v}`);
|
return "X'00'";
|
}
|
return v.startsWith("'") ? v : `'${v}'`;
|
});
|
return `INSERT INTO \`${table}\` (${cols.map((c) => '`' + c + '`').join(', ')}) VALUES (${out.join(', ')});`;
|
}
|
|
function readRows(file) {
|
const text = norm(fs.readFileSync(path.join(TMP, file), 'utf8'));
|
const rows = text
|
.split('\n')
|
.map((l) => l.trim())
|
.filter((l) => l.startsWith('INSERT INTO '))
|
.map(restyle);
|
return rows;
|
}
|
|
const CATEGORY_ROWS = readRows('archive_category_rows.sql');
|
const DICT_TYPE_ROWS = readRows('archive_dict_type_rows.sql');
|
const DICT_DATA_ROWS = readRows('archive_dict_data_rows.sql');
|
const BPM_CATEGORY_ROWS = readRows('archive_bpm_category_row.sql');
|
if (CATEGORY_ROWS.length !== 6) throw new Error(`分类数据 ${CATEGORY_ROWS.length} 行，期望 6`);
|
if (DICT_TYPE_ROWS.length !== 6) throw new Error(`字典类型 ${DICT_TYPE_ROWS.length} 行，期望 6`);
|
if (DICT_DATA_ROWS.length !== 19) throw new Error(`字典数据 ${DICT_DATA_ROWS.length} 行，期望 19`);
|
if (BPM_CATEGORY_ROWS.length !== 1) throw new Error(`BPM 分类 ${BPM_CATEGORY_ROWS.length} 行，期望 1`);
|
|
// ================================================================ 1. 表数量 427 → 430
|
replaceOnce(
|
'-- 范围：全库 BASE TABLE 共 427 张（0918 的 419 张 + 2 张 finance_* + 2 张 ums_* + 4 张 research_*），全部输出 CREATE TABLE；',
|
'-- 范围：全库 BASE TABLE 共 430 张（0918 的 419 张 + 2 张 finance_* + 2 张 ums_* + 4 张 research_* + 3 张 archive_*），全部输出 CREATE TABLE；',
|
);
|
|
// ============================================= 2. 带数据表清单补 ⑦（档案管理模块）
|
insertBefore(
|
'-- ⑥ AI 配置（仅模型+key）+ 基础设施配置管理：ai_model、ai_api_key、infra_config、infra_job、infra_file_config、infra_data_source_config、infra_codegen_table、infra_codegen_column',
|
'-- ⑦ 档案管理模块（1 张带初始数据 + 2 张仅结构）：archive_category（初始 6 条分类）、archive_document、archive_borrow',
|
);
|
|
// ============================================================== 3. 补丁登记块
|
const PREAMBLE = [
|
'-- 补丁内容（2026-09-29，档案管理模块 yudao-module-archive）：',
|
'-- ① 补 3 张 archive_* 表结构（档案分类 / 档案主表 / 借阅单），其中 archive_category 带初始 6 条分类数据：',
|
'-- archive_category、archive_document、archive_borrow',
|
'-- ② 补 6 个字典类型 + 19 条字典数据（并入阶段一的 system_dict_type / system_dict_data）：',
|
'-- archive_category_status（启用/停用）',
|
'-- archive_document_status（在库/借出中）',
|
'-- archive_secret_level（公开/内部/保密）',
|
'-- archive_carrier_type（电子/实体/电子+实体）',
|
'-- archive_source_type（手工录入/课题归档/会员归档/财务归档）',
|
'-- archive_borrow_status（草稿/审批中/借出中/已归还/已驳回）',
|
'-- ③ 补 1 条 BPM 分类（并入阶段一的 bpm_category）：',
|
'-- id=8003 \'档案借阅审批\' / code=\'archive_borrow_approve\'',
|
'-- ④ 补 1 条 BPM 流程定义（档案借阅两级审批：档案管理员审核→分管领导审批），',
|
'-- 分别落 act_re_deployment / act_re_procdef / act_ge_bytearray(3 条) / act_re_model /',
|
'-- bpm_process_definition_info 五张表，流程 key=\'archive_borrow_approve\'。',
|
'-- bpm_process_definition_info.form_type=20（自定义表单），',
|
'-- form_custom_create_path=/archive/borrow/index、',
|
'-- form_custom_view_path=/archive/borrow/detail/approve/index.vue。',
|
'-- ⚠ 该流程的 BPMN 为手写两节点，**不是** bpm_deploy_flow_from_template 生成的单节点流程。',
|
'-- ⑤ 补 3 张来源表各 1 列 archive_document_id（bigint NULL，归档联动回写档案 ID）：',
|
'-- research_application（课题申报单）、ums_member（会员）、finance_reimbursement（报销单）。',
|
'-- 列可空、不影响既有数据；「是否已归档」以该列为硬标记（另有 archive_document 侧',
|
'-- source_type+source_id 幂等兜底）。',
|
'-- ⑥ 补 24 条档案管理菜单：1075600「档案管理」（**顶级目录**，parent_id=0，path=/archive）',
|
'-- + 1075601「档案分类」/ 1075602「档案管理」/ 1075603「借阅登记」/ 1075604「档案统计」',
|
'-- + 1075610~1075613（分类查询/创建/更新/删除）、',
|
'-- 1075620~1075625（档案查询/创建/更新/删除/导出/保密档案查看）、',
|
'-- 1075630~1075635（借阅查询/登记/修改/删除/提交审批/归还登记）、',
|
'-- 1075640（档案统计查询）、',
|
'-- 1075536（课题申报归档，挂 1075512 课题申报下）、',
|
'-- 1075504（会员归档，挂 1075492 会员列表下）。',
|
'-- 财务归档复用既有 finance:reimbursement:archive（1075424），不新增权限点。',
|
'-- **菜单段本文件无需为此改动**：阶段② 的写法是 `INSERT INTO system_menu SELECT *',
|
'-- FROM \\`mom-jssm\\`.system_menu WHERE deleted=b\'0\'`，是执行期跨库全量拷贝，',
|
'-- 只要来源库 mom-jssm 有这几行就会被带过去 —— 与阶段一的字面量 INSERT 不同。',
|
'-- 在此登记只为说明「这版文件确实覆盖了该变更」，避免后来者以为漏了。',
|
'-- ⚠ 档案模块的 BPMN 部署产物（④）为**先部署后导出**：新库初始化时依赖本文件的字面量 INSERT，',
|
'-- 若重跑导出请勿遗漏五张表（含 act_ge_bytearray 的 3 条：bpmn / png / source）。',
|
].join('\n');
|
insertBefore('-- 历史补丁内容（2026-09-18）：', PREAMBLE);
|
|
// ======================================== 4. 3 张 archive_* 表 DDL + 初始分类数据
|
function ddlBlock(fromLine, toLine, tableName, rows) {
|
const body = moduleLines.slice(fromLine - 1, toLine).join('\n');
|
const titles = rows ? `导出 ${rows.length} 行` : '仅 DDL，无数据';
|
return [`-- ============ 表：${tableName}（${titles}） ============`, body, ...(rows || []), ''].join('\n');
|
}
|
const ARCHIVE_DDL = [
|
'-- ***********************************************************************',
|
'-- ⑦ 档案管理模块（yudao-module-archive：分类树 + 档案主表 + 借阅单）',
|
'-- ***********************************************************************',
|
'',
|
ddlBlock(9, 28, 'archive_category', CATEGORY_ROWS),
|
ddlBlock(31, 67, 'archive_document', null),
|
ddlBlock(70, 104, 'archive_borrow', null),
|
].join('\n');
|
insertBefore(
|
['-- ***********************************************************************', '-- 其余 382 张表（仅表结构，无数据）', '-- ***********************************************************************'].join('\n'),
|
ARCHIVE_DDL,
|
);
|
|
// ===================================== 5. 三张来源表各补 1 列 archive_document_id
|
const ARCHIVE_COL =
|
" `archive_document_id` bigint DEFAULT NULL COMMENT '归档生成的档案 ID（archive_document.id，归档联动回写）',";
|
// 5.1 research_application（放在 notice_id 之后）
|
replaceOnce(
|
" `notice_id` bigint DEFAULT NULL COMMENT '已发布的立项通知公告 ID',",
|
" `notice_id` bigint DEFAULT NULL COMMENT '已发布的立项通知公告 ID',\n" + ARCHIVE_COL,
|
);
|
// 5.2 ums_member（放在 status 之后；两行锚点以消歧）
|
replaceOnce(
|
" `expire_date` date DEFAULT NULL COMMENT '有效期至',\n" +
|
" `status` tinyint NOT NULL DEFAULT '1' COMMENT '状态：1-正常 0-暂停',",
|
" `expire_date` date DEFAULT NULL COMMENT '有效期至',\n" +
|
" `status` tinyint NOT NULL DEFAULT '1' COMMENT '状态：1-正常 0-暂停',\n" +
|
ARCHIVE_COL,
|
);
|
// 5.3 finance_reimbursement（放在 archive_time 之后；两行锚点以消歧）
|
replaceOnce(
|
" `process_instance_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT 'BPM流程实例ID',\n" +
|
" `archive_time` datetime DEFAULT NULL COMMENT '归档时间',",
|
" `process_instance_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL COMMENT 'BPM流程实例ID',\n" +
|
" `archive_time` datetime DEFAULT NULL COMMENT '归档时间',\n" +
|
ARCHIVE_COL,
|
);
|
|
// "其余 382 张表" → 384（⑦ 已插入 3 张，其中 2 张无数据故不进带数据清单）
|
replaceOnce(
|
['-- ***********************************************************************', '-- 其余 382 张表（仅表结构，无数据）', '-- ***********************************************************************'].join('\n'),
|
['-- ***********************************************************************', '-- 其余 384 张表（仅表结构，无数据）', '-- ***********************************************************************'].join('\n'),
|
);
|
|
// ===================================================== 6. BPM 部署产物（7 条 INSERT）
|
const bpmInserts = bpmLines.filter((l) => l.startsWith('INSERT INTO '));
|
if (bpmInserts.length !== 7) throw new Error(`BPM INSERT 条数 ${bpmInserts.length}，期望 7`);
|
const pick = (table) => bpmInserts.filter((l) => l.startsWith(`INSERT INTO \`${table}\``));
|
const insProcdef = pick('act_re_procdef');
|
const insDeployment = pick('act_re_deployment');
|
const insBytearray = pick('act_ge_bytearray');
|
const insModel = pick('act_re_model');
|
const insProcInfo = pick('bpm_process_definition_info');
|
if (
|
insProcdef.length !== 1 ||
|
insDeployment.length !== 1 ||
|
insBytearray.length !== 3 ||
|
insModel.length !== 1 ||
|
insProcInfo.length !== 1
|
) {
|
throw new Error('BPM INSERT 分类数量不符');
|
}
|
|
// 6.1 act_re_procdef（23 → 24 行）
|
insertBefore('-- ============ 表：act_re_deployment（导出 23 行） ============', insProcdef.join('\n'));
|
replaceOnce(
|
'-- ============ 表：act_re_procdef（导出 23 行） ============',
|
'-- ============ 表：act_re_procdef（导出 24 行） ============',
|
);
|
// 6.2 act_re_deployment（23 → 24 行）
|
insertBefore('-- ============ 表：act_ge_bytearray（导出 28 行） ============', insDeployment.join('\n'));
|
replaceOnce(
|
'-- ============ 表：act_re_deployment（导出 23 行） ============',
|
'-- ============ 表：act_re_deployment（导出 24 行） ============',
|
);
|
// 6.3 act_ge_bytearray（28 → 31 行，bpmn / png / source 三条）
|
insertBefore('-- ============ 表：act_re_model（导出 23 行） ============', insBytearray.join('\n'));
|
replaceOnce(
|
'-- ============ 表：act_ge_bytearray（导出 28 行） ============',
|
'-- ============ 表：act_ge_bytearray（导出 31 行） ============',
|
);
|
// 6.4 act_re_model（23 → 24 行）
|
insertBefore('-- ============ 表：bpm_process_definition_info（导出 23 行） ============', insModel.join('\n'));
|
replaceOnce(
|
'-- ============ 表：act_re_model（导出 23 行） ============',
|
'-- ============ 表：act_re_model（导出 24 行） ============',
|
);
|
// 6.5 bpm_process_definition_info（23 → 24 行，插在 ② 分组横幅之前）
|
insertBefore(
|
['-- ***********************************************************************', '-- ② 协同（业务附件配置 + 分类 + 表单 + 扩展配置）（DDL + 数据）', '-- ***********************************************************************'].join(
|
'\n',
|
),
|
insProcInfo.join('\n'),
|
);
|
replaceOnce(
|
'-- ============ 表：bpm_process_definition_info（导出 23 行） ============',
|
'-- ============ 表：bpm_process_definition_info（导出 24 行） ============',
|
);
|
|
// ===================================================== 7. bpm_category 补 8003（25 → 26 行）
|
insertBefore('-- ============ 表：bpm_form（导出 4 行） ============', BPM_CATEGORY_ROWS.join('\n'));
|
replaceOnce(
|
'-- ============ 表：bpm_category（导出 25 行） ============',
|
'-- ============ 表：bpm_category（导出 26 行） ============',
|
);
|
|
// ================================================ 8. 字典类型 6 条（254 → 260 行）
|
insertBefore('-- ============ 表：system_dict_data（导出 1205 行） ============', DICT_TYPE_ROWS.join('\n'));
|
replaceOnce(
|
'-- ============ 表：system_dict_type（导出 254 行） ============',
|
'-- ============ 表：system_dict_type（导出 260 行） ============',
|
);
|
// ================================================ 9. 字典数据 19 条（1205 → 1224 行）
|
insertBefore('-- ============ 表：system_tenant（导出 3 行） ============', DICT_DATA_ROWS.join('\n'));
|
replaceOnce(
|
'-- ============ 表：system_dict_data（导出 1205 行） ============',
|
'-- ============ 表：system_dict_data（导出 1224 行） ============',
|
);
|
|
// ---------------------------------------------------------------- 写出
|
doc = doc.replace(/\n/g, '\r\n');
|
fs.writeFileSync(TARGET, doc, 'utf8');
|
console.log(`合并完成 → ${path.basename(TARGET)}（${doc.split('\r\n').length} 行）`);
|
