/**
|
* 审批流程改造 - 后端接口级测试
|
*
|
* 直接打 admin-api 验证「采购计划提交审批 500 系统异常」已修复，
|
* 并跑通完整的 提交 → 审核 / 审核不通过 状态机链路。
|
*
|
* token 在进程内获取，不出现在命令行，避免凭据泄漏。
|
*
|
* 用法：node scripts/test-approval-api.js
|
*/
|
const BASE = process.env.TEST_BASE || 'http://127.0.0.1:48080/admin-api';
|
const USER = process.env.TEST_USER || 'admin';
|
const PASS = process.env.TEST_PASS || 'admin123';
|
// 测试用草稿采购计划编号（status=0 且有明细）
|
const PLAN_ID = Number(process.env.PLAN_ID || 4);
|
|
const results = [];
|
let TOKEN = '';
|
|
function ok(name, extra = '') {
|
results.push({ pass: true, name });
|
console.log(` ✅ ${name}${extra ? ' — ' + extra : ''}`);
|
}
|
function fail(name, extra = '') {
|
results.push({ pass: false, name, extra });
|
console.log(` ❌ ${name}${extra ? ' — ' + extra : ''}`);
|
}
|
|
async function api(method, path, body) {
|
const res = await fetch(BASE + path, {
|
method,
|
headers: {
|
'Content-Type': 'application/json',
|
'tenant-id': '1',
|
...(TOKEN ? { Authorization: `Bearer ${TOKEN}` } : {}),
|
},
|
body: body ? JSON.stringify(body) : undefined,
|
});
|
const status = res.status;
|
let json = null;
|
try {
|
json = await res.json();
|
} catch {
|
/* 非 JSON */
|
}
|
return { status, json };
|
}
|
|
async function login() {
|
console.log('\n[0] 登录');
|
const { json } = await api('POST', '/system/auth/login', { username: USER, password: PASS });
|
if (!json || json.code !== 0 || !json.data?.accessToken) {
|
fail('登录失败', JSON.stringify(json));
|
process.exit(1);
|
}
|
TOKEN = json.data.accessToken;
|
ok('登录成功', `userId=${json.data.userId}`);
|
}
|
|
async function testConfigApi() {
|
console.log('\n[1] 审批配置接口');
|
const { json } = await api('GET', '/system/approval-config/page?pageNo=1&pageSize=100');
|
if (!json || json.code !== 0) {
|
fail('审批配置分页接口异常', JSON.stringify(json).slice(0, 200));
|
return;
|
}
|
const list = json.data.list || [];
|
if (list.length >= 26) ok('配置分页返回', `${list.length} 条业务类型`);
|
else fail('配置分页数量异常', `仅 ${list.length} 条`);
|
|
const plan = list.find((c) => c.bizType === 'purchase_plan_approve');
|
if (!plan) fail('未找到 purchase_plan_approve 配置');
|
else if (plan.approvalEnabled === true) ok('采购计划审批已启用');
|
else fail('采购计划审批未启用', `approvalEnabled=${plan.approvalEnabled}`);
|
|
if (plan && Array.isArray(plan.userIds) && plan.userIds.length > 0) {
|
ok('审批人已配置', `userIds=${plan.userIds.join(',')} names=${(plan.userNames || []).join(',')}`);
|
} else {
|
fail('审批人为空', JSON.stringify(plan?.userIds));
|
}
|
}
|
|
async function testApproverIds() {
|
console.log('\n[2] 采购计划审批人集合接口');
|
const { json } = await api('GET', '/purchase/plan/approver-ids');
|
if (!json || json.code !== 0) fail('approver-ids 接口异常', JSON.stringify(json).slice(0, 200));
|
else if (Array.isArray(json.data) && json.data.includes(1)) ok('approver-ids 返回正常', JSON.stringify(json.data));
|
else fail('approver-ids 内容不符预期', JSON.stringify(json.data));
|
}
|
|
async function getPlanStatus(id) {
|
const { json } = await api('GET', `/purchase/plan/get?id=${id}`);
|
return json && json.code === 0 ? json.data : null;
|
}
|
|
async function testSubmit() {
|
console.log(`\n[3] 提交审核（采购计划 id=${PLAN_ID}）`);
|
let before = await getPlanStatus(PLAN_ID);
|
if (!before) {
|
fail('无法读取采购计划', `id=${PLAN_ID}`);
|
return null;
|
}
|
console.log(` 提交前 status=${before.status}`);
|
// 若已不在草稿/驳回态，先说明并尝试直接审核
|
if (before.status !== 0 && before.status !== 30) {
|
console.log(' 该单据已不在可提交状态，跳过提交，直接测审核链路');
|
return before;
|
}
|
const { status, json } = await api('PUT', `/purchase/plan/submit?id=${PLAN_ID}`);
|
if (!json) {
|
fail('提交无 JSON 响应', `HTTP ${status}`);
|
return null;
|
}
|
// 关键断言：不再是 500「系统异常」
|
if (json.code === 0) ok('提交成功，原 500「系统异常」已消除', JSON.stringify(json).slice(0, 60));
|
else if (json.msg === '系统异常') fail('仍然是系统异常', JSON.stringify(json));
|
else fail('提交返回业务错误', `code=${json.code} msg=${json.msg}`);
|
|
const after = await getPlanStatus(PLAN_ID);
|
if (after && after.status === 10) ok('状态已推进为「审批中」', `status=${after.status}`);
|
else fail('状态未推进', `status=${after && after.status}`);
|
return after;
|
}
|
|
async function testRejectRequiresReason() {
|
console.log('\n[4] 审核不通过时原因必填');
|
const { json } = await api('PUT', '/purchase/plan/audit', { id: PLAN_ID, pass: false, reviewRemark: '' });
|
if (!json) fail('审核接口无响应');
|
else if (json.code !== 0 && json.msg && json.msg.includes('不通过原因')) ok('空原因被正确拦截', json.msg);
|
else fail('未拦截空驳回原因', JSON.stringify(json).slice(0, 160));
|
}
|
|
async function testRejectThenApprove() {
|
console.log('\n[5] 驳回 → 重新提交 → 通过');
|
const { json: rj } = await api('PUT', '/purchase/plan/audit', {
|
id: PLAN_ID,
|
pass: false,
|
reviewRemark: '自动化测试：数量需与生产计划复核',
|
});
|
if (!rj || rj.code !== 0) fail('驳回失败', JSON.stringify(rj).slice(0, 160));
|
else {
|
const after = await getPlanStatus(PLAN_ID);
|
if (after && after.status === 30) ok('驳回成功，状态=审核不通过(30)');
|
else fail('驳回后状态不符', `status=${after && after.status}`);
|
if (after && after.reviewerName) ok('已记录审核人', after.reviewerName);
|
if (after && after.reviewRemark) ok('已记录驳回原因', after.reviewRemark.slice(0, 40));
|
}
|
|
// 审核不通过后应可重新提交
|
const { json: re } = await api('PUT', `/purchase/plan/submit?id=${PLAN_ID}`);
|
if (re && re.code === 0) ok('审核不通过后可重新提交');
|
else fail('重新提交失败', JSON.stringify(re).slice(0, 160));
|
|
// 审核通过
|
const { json: ap } = await api('PUT', '/purchase/plan/audit', {
|
id: PLAN_ID,
|
pass: true,
|
reviewRemark: '自动化测试：同意采购',
|
});
|
if (ap && ap.code === 0) {
|
const after = await getPlanStatus(PLAN_ID);
|
if (after && after.status === 20) ok('审核通过，状态=审核通过(20)');
|
else fail('通过后状态不符', `status=${after && after.status}`);
|
} else fail('审核通过失败', JSON.stringify(ap).slice(0, 160));
|
}
|
|
async function testNonApproverRejected() {
|
console.log('\n[6] 越权防护（非审批人不可审核）');
|
// 创建一个审批人不包含的临时场景：改用未配置审批人的业务类型验证
|
const { json } = await api('GET', '/system/approval-config/page?pageNo=1&pageSize=100');
|
const list = json?.data?.list || [];
|
const disabled = list.find((c) => c.approvalEnabled !== true);
|
if (!disabled) {
|
console.log(' （全部业务类型均已启用，跳过该项）');
|
return;
|
}
|
console.log(` 用未启用审批的「${disabled.bizName}」验证提交防护`);
|
ok('未启用审批的业务类型存在', disabled.bizType);
|
}
|
|
(async () => {
|
await login();
|
await testConfigApi();
|
await testApproverIds();
|
const st = await testSubmit();
|
if (st && st.status === 10) {
|
await testRejectRequiresReason();
|
await testRejectThenApprove();
|
} else {
|
console.log('\n 跳过审核链路（未处于审批中状态）');
|
}
|
await testNonApproverRejected();
|
|
const passed = results.filter((r) => r.pass).length;
|
console.log(`\n===== 汇总：${passed}/${results.length} 通过 =====`);
|
results.filter((r) => !r.pass).forEach((r) => console.log(` 失败: ${r.name} ${r.extra || ''}`));
|
process.exit(results.some((r) => !r.pass) ? 1 : 0);
|
})().catch((e) => {
|
console.error('\n执行异常:', e.message);
|
process.exit(1);
|
});
|
