/**
 * 采购订单状态机审批 - 接口级自动化测试
 *
 * 自建测试单据（每次新建一张），不依赖历史数据状态，可重复执行。
 * 覆盖：提交/审核/驳回/重新提交/通过的完整链路 + 全部服务端校验分支。
 *
 * 用法：node scripts/test-purchase-order-api.js
 *   可选环境变量：TEST_USER / TEST_PASS / PRODUCT_ID / PRODUCT_UNIT_ID
 */
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';
const BIZ_TYPE = 'erp_purchase_order_approve';
// 物料取自 mdm_item（测试库中 id=57「测试」，单位 id=9）
const PRODUCT_ID = Number(process.env.PRODUCT_ID || 57);
const PRODUCT_UNIT_ID = Number(process.env.PRODUCT_UNIT_ID || 9);

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,
  });
  let json = null;
  try {
    json = await res.json();
  } catch {
    /* 非 JSON */
  }
  return { status: res.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('登录成功');
}

/** 确保目标业务类型已启用且审批人含 admin(id=1)，返回配置对象 */
async function ensureConfig(userIds) {
  const { json } = await api('GET', `/system/approval-config/page?pageNo=1&pageSize=100&bizType=${BIZ_TYPE}`);
  const row = (json?.data?.list || []).find((x) => x.bizType === BIZ_TYPE);
  if (!row) {
    fail('未找到审批配置种子数据', BIZ_TYPE);
    return null;
  }
  const save = await api('POST', '/system/approval-config/save', {
    id: row.id,
    bizType: row.bizType,
    bizName: row.bizName,
    approvalEnabled: true,
    remark: row.remark,
    userIds,
  });
  if (!save.json || save.json.code !== 0) {
    fail('保存审批配置失败', JSON.stringify(save.json));
    return null;
  }
  const again = await api('GET', `/system/approval-config/page?pageNo=1&pageSize=100&bizType=${BIZ_TYPE}`);
  return (again.json?.data?.list || []).find((x) => x.bizType === BIZ_TYPE) || row;
}

/**
 * 采购订单的供应商校验走 SRM（ErpSupplierServiceImpl.validateSupplier -> srmSupplierApi），
 * 但供应商增删改查与前端下拉又读写 erp_supplier，两处数据源不一致。
 * 因此测试数据必须建在 SRM 侧，否则下单必然报「供应商不存在」。
 */
async function getSupplierId() {
  const { json } = await api('GET', '/srm/supplier/simple-list');
  const list = json?.data || [];
  if (list.length > 0) return list[0].id;
  const seq = Date.now().toString().slice(-6);
  const created = await api('POST', '/srm/supplier/create', {
    code: `TESTSUP${seq}`,
    name: `自动化测试供应商${seq}`,
    status: 0,
    remark: '由 test-purchase-order-api.js 创建',
  });
  if (created.json?.code !== 0) {
    fail('创建 SRM 供应商失败', JSON.stringify(created.json));
    return null;
  }
  return created.json.data;
}

async function createOrder(supplierId) {
  const body = {
    supplierId,
    orderTime: '2026-09-16 10:00:00',
    discountPercent: 0,
    depositPrice: 0,
    remark: '自动化测试采购订单',
    items: [
      {
        productId: PRODUCT_ID,
        productUnitId: PRODUCT_UNIT_ID,
        productPrice: 100,
        count: 5,
        taxPercent: 13,
        remark: '测试项',
      },
    ],
  };
  const { json } = await api('POST', '/purchase/order/create', body);
  return json;
}

async function getOrder(id) {
  const { json } = await api('GET', `/purchase/order/get?id=${id}`);
  return json?.data;
}

(async () => {
  await login();

  console.log('\n[1] 审批配置');
  const cfg = await ensureConfig([1]);
  if (!cfg) process.exit(1);
  ok('采购订单审批已启用', `bizName=${cfg.bizName}`);

  const ap = await api('GET', `/purchase/order/approver-ids`);
  if (ap.json?.code === 0 && (ap.json.data || []).includes(1)) ok('approver-ids 含 admin(1)', JSON.stringify(ap.json.data));
  else fail('approver-ids 异常', JSON.stringify(ap.json));

  console.log('\n[2] 新建采购订单');
  const supplierId = await getSupplierId();
  if (!supplierId) {
    console.log('  无法准备供应商，终止');
    process.exit(1);
  }
  ok('供应商就绪', `supplierId=${supplierId}`);

  const created = await createOrder(supplierId);
  if (!created || created.code !== 0) {
    fail('创建采购订单失败', JSON.stringify(created));
    process.exit(1);
  }
  const id = created.data;
  ok('创建采购订单成功', `id=${id}`);

  const o0 = await getOrder(id);
  if (o0?.status === 0) ok('新单初始状态为未提交(0)', `no=${o0.no}`);
  else fail('新单初始状态不是 0', `status=${o0?.status}`);

  console.log('\n[3] BPM 残留接口应已下线');
  const legacy = await api('GET', '/purchase/order/approve-process-list');
  if (legacy.status === 404 || (legacy.json && legacy.json.code !== 0)) {
    ok('approve-process-list 已移除', `HTTP ${legacy.status} code=${legacy.json?.code}`);
  } else {
    fail('approve-process-list 仍可用', JSON.stringify(legacy.json).slice(0, 120));
  }

  console.log('\n[4] 未提交不能审核');
  const early = await api('PUT', '/purchase/order/audit', { id, pass: true, reviewRemark: '抢跑' });
  if (early.json?.code === 1_030_101_016) ok('正确拒绝：非审批中不可审核', `code=${early.json.code}`);
  else fail('未按预期拒绝', JSON.stringify(early.json));

  console.log('\n[5] 提交 → 审批中');
  const sub = await api('PUT', `/purchase/order/submit?id=${id}`);
  if (sub.json?.code === 0) ok('提交成功', JSON.stringify(sub.json));
  else fail('提交失败', JSON.stringify(sub.json));
  const o1 = await getOrder(id);
  if (o1?.status === 10) ok('状态已置为审批中(10)');
  else fail('提交后状态不对', `status=${o1?.status}`);

  console.log('\n[6] 审批中不可修改');
  const upd = await api('PUT', '/purchase/order/update', {
    id,
    supplierId,
    orderTime: '2026-09-16 10:00:00',
    remark: '审批中改单',
    items: [{ productId: PRODUCT_ID, productUnitId: PRODUCT_UNIT_ID, productPrice: 100, count: 5, taxPercent: 13 }],
  });
  if (upd.json?.code === 1_030_101_019) ok('正确拒绝：审批中不可修改', `code=${upd.json.code}`);
  else fail('审批中居然可修改', JSON.stringify(upd.json));

  console.log('\n[7] 非审批人不可审核');
  await ensureConfig([111]); // 临时把审批人改成「测试用户」
  const notAp = await api('PUT', '/purchase/order/audit', { id, pass: true, reviewRemark: '越权' });
  if (notAp.json?.code === 1_002_030_005) ok('正确拒绝：当前用户不是审批人', `code=${notAp.json.code}`);
  else fail('越权审核未被拦截', JSON.stringify(notAp.json));
  await ensureConfig([1]); // 还原
  const back = await api('GET', '/purchase/order/approver-ids');
  if ((back.json?.data || []).includes(1)) ok('审批人已还原为 admin');
  else fail('审批人还原失败', JSON.stringify(back.json?.data));

  console.log('\n[8] 驳回必须填原因');
  const noWhy = await api('PUT', '/purchase/order/audit', { id, pass: false });
  if (noWhy.json?.code === 1_030_101_017) ok('正确拒绝：缺驳回原因', `code=${noWhy.json.code}`);
  else fail('缺原因未被拦截', JSON.stringify(noWhy.json));

  console.log('\n[9] 审核不通过 → 退回');
  const rej = await api('PUT', '/purchase/order/audit', { id, pass: false, reviewRemark: '价格偏高，退回重议' });
  if (rej.json?.code === 0) ok('驳回成功', JSON.stringify(rej.json));
  else fail('驳回失败', JSON.stringify(rej.json));
  const o2 = await getOrder(id);
  if (o2?.status === 30) ok('状态为审核不通过(30)');
  else fail('驳回后状态不对', `status=${o2?.status}`);
  if (o2?.reviewerName && o2?.reviewRemark === '价格偏高，退回重议') ok('审核人与驳回原因已落库', `${o2.reviewerName} / ${o2.reviewRemark}`);
  else fail('审核信息未落库', JSON.stringify({ rn: o2?.reviewerName, rr: o2?.reviewRemark }));

  console.log('\n[10] 退回后可修改并重新提交');
  const upd2 = await api('PUT', '/purchase/order/update', {
    id,
    supplierId,
    orderTime: '2026-09-16 10:00:00',
    remark: '已降价重议',
    items: [{ productId: PRODUCT_ID, productUnitId: PRODUCT_UNIT_ID, productPrice: 80, count: 5, taxPercent: 13 }],
  });
  if (upd2.json?.code === 0) ok('退回后可修改', JSON.stringify(upd2.json));
  else fail('退回后仍不可修改', JSON.stringify(upd2.json));

  const sub2 = await api('PUT', `/purchase/order/submit?id=${id}`);
  if (sub2.json?.code === 0) ok('重新提交成功');
  else fail('重新提交失败', JSON.stringify(sub2.json));
  const o3 = await getOrder(id);
  if (o3?.status === 10 && !o3?.reviewRemark && !o3?.reviewerName) ok('重新提交已清空上一轮审核信息', `reviewRemark=${JSON.stringify(o3?.reviewRemark ?? null)}`);
  else fail('重提后审核信息残留', JSON.stringify({ st: o3?.status, rn: o3?.reviewerName, rr: o3?.reviewRemark }));

  console.log('\n[11] 审核通过');
  const app = await api('PUT', '/purchase/order/audit', { id, pass: true, reviewRemark: '同意采购' });
  if (app.json?.code === 0) ok('审核通过成功', JSON.stringify(app.json));
  else fail('审核通过失败', JSON.stringify(app.json));
  const o4 = await getOrder(id);
  if (o4?.status === 20) ok('状态为审核通过(20)', `审核人=${o4.reviewerName}`);
  else fail('通过后状态不对', `status=${o4?.status}`);

  console.log('\n[12] 已审核不可修改');
  const upd3 = await api('PUT', '/purchase/order/update', {
    id,
    supplierId,
    orderTime: '2026-09-16 10:00:00',
    remark: '审核后再改',
    items: [{ productId: PRODUCT_ID, productUnitId: PRODUCT_UNIT_ID, productPrice: 80, count: 5, taxPercent: 13 }],
  });
  if (upd3.json?.code === 1_030_101_005) ok('正确拒绝：已审核不可修改', `code=${upd3.json.code}`);
  else fail('已审核仍可修改', JSON.stringify(upd3.json));

  console.log('\n[13] 全程不应再出现 500 系统异常');
  const calls = [
    ['GET', `/purchase/order/page?pageNo=1&pageSize=10`],
    ['GET', `/purchase/order/approver-ids`],
  ];
  let bad500 = 0;
  for (const [m, p] of calls) {
    const r = await api(m, p);
    if (r.json?.code === 500) {
      bad500++;
      console.log(`     ${m} ${p} → 500`);
    }
  }
  if (bad500 === 0) ok('关键接口无 500');
  else fail(`仍有 ${bad500} 个接口返回 500`);

  console.log(`\n测试单据：erp_purchase_order id=${id}（${o0?.no}）`);
  const passed = results.filter((r) => r.pass).length;
  console.log(`===== 汇总：${passed}/${results.length} 通过 =====`);
  results.filter((r) => !r.pass).forEach((r) => console.log(`  失败: ${r.name} ${r.extra}`));
  process.exit(passed === results.length ? 0 : 1);
})().catch((e) => {
  console.error('执行异常:', e.message);
  process.exit(1);
});