zhaoshang_client_ui/harness/tools/verify-dms-payload-fields.mjs

/**
 * 验证写 DMS 时**到底发了哪些字段**（不需要 token，也不碰真实 DMS）。
 *
 * 为什么要单独测这个：写入字段的规矩是**踩出来的**——
 * 1887 的模型把 summary/qpyszx/qyzt/rzqpyx 设为 must=true（不带就 214），
 * 但它们**只能传空值**（业务口径由业务方定，前端不猜）；而 1889 不需要这些字段。
 * 多发/少发字段没有直观的行为反馈、极易被"顺手"改掉，所以直接把请求体抓下来断言。
 *
 * 做法：把 `globalThis.fetch` 打桩，捕获模块真实发出的 form body，
 * 解析出 `content` 的键集合，断言「不多不少」。
 *
 * 怎么跑（在项目根目录）：
 *   npx esbuild harness/tools/_entry-dms.ts --bundle --format=esm \
 *     --outfile=harness/tools/_dms.mjs --alias:@=./src --define:import.meta.env='{}'
 *   node harness/tools/verify-dms-payload-fields.mjs
 */

globalThis.VITE_DMS_API = 'http://dms.invalid/dms'; // 只为让 base 非空；请求会被打桩拦住
globalThis.VITE_GATEWAY_API = '/ip-api'; // 后端网关（取 IP / NLS）；下面同样打桩
const STUB_IP = '203.0.113.9'; // TEST-NET-3 段，不会与真实 IP 混淆

// ── 打桩 fetch：捕获请求，返回可控响应 ────────────────────────────────
const captured = [];
const json = (obj) => new Response(JSON.stringify(obj), { status: 200, headers: { 'Content-Type': 'application/json' } });

globalThis.fetch = async (url, init = {}) => {
  const body = init.body ? String(init.body) : '';
  captured.push({ url: String(url), body });

  // 取 IP 的接口：返回**纯文本 IP**（真实服务也是裸 IP，不带 JSON）
  if (String(url).includes('/proxy/verify/getIPByBrowser')) {
    return new Response(STUB_IP, { status: 200, headers: { 'Content-Type': 'application/json' } });
  }

  if (String(url).includes('/content/selectContentList')) {
    return json({ code: 202, message: '数据不存在', content: '数据不存在' }); // 空 → 走新增分支
  }
  if (String(url).includes('/content/addContent')) {
    return json({ code: 200, message: '成功', content: 'stub-uuid-0001' });
  }
  if (String(url).includes('/content/updateContent')) {
    return json({ code: 200, message: '成功', content: '执行成功' });
  }
  return json({ code: 200, message: '成功', content: '' });
};

import { readFileSync } from 'node:fs';

const { upsertDmsSession, upsertDmsRecord } = await import('./_dms.mjs');

let pass = 0;
let fail = 0;
const check = (name, cond, extra = '') => {
  if (cond) {
    pass++;
    console.log('  ok   ' + name);
  } else {
    fail++;
    console.log('  FAIL ' + name + '  ' + extra);
  }
};

/** 取出最近一次某端点的请求体里 content 的字段名（排序后） */
const keysOfLast = (endpoint) => {
  const hit = [...captured].reverse().find((c) => c.url.includes(endpoint));
  if (!hit) return null;
  const params = new URLSearchParams(hit.body);
  const content = JSON.parse(params.get('content') || '{}');
  return Object.keys(content).sort();
};

const DISALLOWED = ['summary', 'qpyszx', 'qyzt', 'rzqpyx'];

console.log('\n【1】会话新增：字段必须「不多不少」');
await upsertDmsSession({ sessionId: 'sess-A', sessionTitle: '会话标题甲', creditCode: '91310118TEST' });
let keys = keysOfLast('/content/addContent');
const EXPECT_SESSION_ADD = [
  'c_created_at', 'c_credit_code', 'c_session_id', 'c_source', 'c_updated_at',
  // 访客标识（2026-09-22 起进 c_ip）与登录标记
  'c_ip', 'c_is_login',
  // DMS 的系统字段：只在创建那一刻带，不带会落成字符串 "null"
  'title',
  // 1887 的模型把这四个设为 must=true，四个全带才写得进去（少一个就 214）；
  // 值故意留空 —— 运营口径由业务方定，前端不猜
  'summary', 'qpyszx', 'qyzt', 'rzqpyx',
].sort();
check('字段集合与预期完全一致', JSON.stringify(keys) === JSON.stringify(EXPECT_SESSION_ADD), `实际 ${JSON.stringify(keys)}`);
check('**带系统 title**（不带会落成字符串 "null"）', keys?.includes('title') === true);
check('**不带 c_title**（用户 2026-09-22：标题由运营侧生成）', keys?.includes('c_title') !== true, JSON.stringify(keys));

console.log('\n【2】会话更新：不碰标题、不带运营字段、已有值不重写');
captured.length = 0;
// 让这次走「更新」分支：search 返回一行，且 c_ip / c_is_login 都已有值
const existingRow = { id: 'row-uuid', c_session_id: 'sess-A', c_ip: '访客_既有值', c_is_login: '0', c_ent_name: '甲测试公司' };
globalThis.fetch = async (url, init = {}) => {
  const body = init.body ? String(init.body) : '';
  captured.push({ url: String(url), body });
  if (String(url).includes('/content/selectContentList')) {
    return json({ code: 200, message: '成功', content: { data: [existingRow], count: 1 } });
  }
  return json({ code: 200, message: '成功', content: '执行成功' });
};
await upsertDmsSession({ sessionId: 'sess-A', sessionTitle: '会话标题乙', creditCode: '91310118TEST' });
keys = keysOfLast('/content/updateContent');
check('更新走的是 updateContent', keys !== null);
check('**更新不带 title / c_title**（前端不碰标题）', !keys?.includes('title') && !keys?.includes('c_title'), JSON.stringify(keys));
check('**更新不带这四个字段**（否则会把后端回填的值冲成空）', !DISALLOWED.some((k) => keys?.includes(k)), JSON.stringify(keys));
check('**c_ip 已有值 → 不重写**（可能是后端回填的真实 IP）', !keys?.includes('c_ip'), JSON.stringify(keys));
check('**c_is_login 已有值 → 不重写**', !keys?.includes('c_is_login'), JSON.stringify(keys));

console.log('\n【2b】值不同就更新 / 值相同不写');
{
  await upsertDmsSession({
    sessionId: 'sess-A',
    sessionTitle: '会话标题乙',
    creditCode: '91310118TEST',
    companyInfo: { profile: { data: { Name: '乙测试公司', CreditCode: '91310118CHAT' } } },
  });
  keys = keysOfLast('/content/updateContent');
  check('**值不同 → 企业名称写进 patch**', keys?.includes('c_ent_name'), JSON.stringify(keys));
  check('**值不同 → 真实信用代码写进 patch**', keys?.includes('c_credit_code'), JSON.stringify(keys));

  existingRow.c_ent_name = '乙测试公司';
  existingRow.c_credit_code = '91310118CHAT';
  await upsertDmsSession({
    sessionId: 'sess-A',
    sessionTitle: '会话标题乙',
    companyInfo: { profile: { data: { Name: '乙测试公司', CreditCode: '91310118CHAT' } } },
  });
  keys = keysOfLast('/content/updateContent');
  check('**值相同 → 不写 c_ent_name**（不产生无谓写入）', !keys?.includes('c_ent_name'), JSON.stringify(keys));
  check('**值相同 → 不写 c_credit_code**', !keys?.includes('c_credit_code'), JSON.stringify(keys));
}
console.log('\n【2c】登录认领过的行：对话值不许改它的公司字段');
{
  // 否则：用户登录过、之后退登又问到别的公司 → 这行会被改到那家公司名下，
  // 而 c_is_login 仍是 "1" → 既串台、又会被读侧当登录行返回（用户 2026-09-22 要挡住的）
  existingRow.c_is_login = '1';
  existingRow.c_credit_code = 'LOGIN-CODE-0001';
  await upsertDmsSession({
    sessionId: 'sess-A',
    sessionTitle: '会话标题乙',
    companyInfo: { profile: { data: { Name: '别家公司', CreditCode: 'ANOTHER-CODE' } } },
  });
  keys = keysOfLast('/content/updateContent');
  check('**不写 c_ent_name**（登录认领过的行）', !keys?.includes('c_ent_name'), JSON.stringify(keys));
  check('**不写 c_credit_code**', !keys?.includes('c_credit_code'), JSON.stringify(keys));
}

console.log('\n【3】问答记录新增：title = 问题文本，且不多发字段');
captured.length = 0;
globalThis.fetch = async (url, init = {}) => {
  const body = init.body ? String(init.body) : '';
  captured.push({ url: String(url), body });
  if (String(url).includes('/content/selectContentList')) return json({ code: 202, message: '数据不存在', content: '数据不存在' });
  if (String(url).includes('/content/addContent')) return json({ code: 200, message: '成功', content: 'stub-uuid-0002' });
  return json({ code: 200, message: '成功', content: '' });
};
await upsertDmsRecord({ recordId: 'rec-A', sessionId: 'sess-A', creditCode: '91310118TEST', question: '这是问题文本' });
keys = keysOfLast('/content/addContent');
const EXPECT_RECORD_ADD = ['c_created_at', 'c_credit_code', 'c_question', 'c_record_id', 'c_session_id', 'c_source', 'title'].sort();
check('字段集合与预期完全一致', JSON.stringify(keys) === JSON.stringify(EXPECT_RECORD_ADD), `实际 ${JSON.stringify(keys)}`);
check('不含 summary 等多余字段', !DISALLOWED.some((k) => keys?.includes(k)), JSON.stringify(keys));

const hit = [...captured].reverse().find((c) => c.url.includes('/content/addContent'));
const content = JSON.parse(new URLSearchParams(hit.body).get('content'));
check('**title 的值就是问题文本**', content.title === '这是问题文本', JSON.stringify(content.title));

console.log('\n【4】会话写入（1887）只在回答完成处发生一次 —— 源码级断言');
{
  // 2026-09-22：1887 改为写企业字段，触发点**只有一处** —— 回答完成的 totalResponse
  // （那时才知道本轮有没有 company_info）。
  // 曾经在 sendMessage / submitQuestionAnswers 里也各写一次，那会让同一次会话写两遍，
  // 极易在后续改动里被顺手恢复，所以在源码上钉死。
  const file = 'src/components/business-assistant/useBusinessAssistantChat.ts';
  const src = readFileSync(file, 'utf8');
  const lines = src.split('\n');
  const live = lines
    .map((l, i) => ({ l, n: i + 1 }))
    .filter(({ l }) => !l.trim().startsWith('//') && /upsertDmsSession\s*\(/.test(l));
  check('活跃调用点只有 1 处', live.length === 1, live.map(({ l, n }) => `第${n}行: ${l.trim()}`).join(' | '));

  // 它必须在 totalResponse 监听器之后、下一个 addEventListener 之前
  const at = live.length ? live[0].n - 1 : -1;
  const totalResponseAt = lines.findIndex((l) => l.includes("addEventListener('totalResponse'"));
  const nextListenerAt = lines.findIndex((l, i) => i > totalResponseAt && l.includes("addEventListener('"));
  check(
    '那一处在 totalResponse 监听器内（回答完成时才写）',
    at > totalResponseAt && (nextListenerAt === -1 || at < nextListenerAt),
    `调用@第${at + 1}行 / totalResponse@第${totalResponseAt + 1}行 / 下一个监听器@第${nextListenerAt + 1}行`
  );
}
console.log(`\n===== 通过 ${pass} 项，失败 ${fail} 项 =====`);
process.exit(fail ? 1 : 0);