zhaoshang_client_ui/harness/tools/verify-dms-chat-storage.mjs

/**
 * 端到端验证「会话 / 问答记录 / 反馈」在 DMS 里的读写（栏目 1887 / 1889）。
 *
 * 存储粒度约定（2026-09-17 用户最终确认）：
 *   - 1887 助手会话：一个会话一行（标题、归属、更新时间）
 *   - 1889 助手问答记录：**一问一答一条**（幂等键 c_record_id），
 *     c_question / c_answer 各存一半；反馈写在该行的 c_feedback_* 列上
 *   （曾一度改成「一个会话一行、整段对话 JSON」，按用户要求已改回本版）
 *
 * 验证什么：前端真实调用的那些函数（引用 src 里同一份实现，不是复制逻辑）
 *   打到真实 DMS 上能否正确 增/改/查/删，尤其是：
 *   ① 反复保存同一轮**只有一行**（不是每问一次多一行）
 *   ② 补 answer 时不覆盖 question、不变成两行
 *   ③ 反馈能命中该轮那一行
 *
 * 怎么跑（需要 dev server 起着，代理会注入 token）：
 *   1) npm run dev
 *   2) npx esbuild harness/tools/_entry-dms.ts --bundle --format=esm \
 *        --outfile=harness/tools/_dms.mjs --alias:@=./src --define:import.meta.env='{}'
 *   3) node harness/tools/verify-dms-chat-storage.mjs https://localhost:8083/dms-api
 *
 * 脚本**不持有 token**——和浏览器一样只打代理地址。
 */

process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0';

const base = process.argv[2] || 'https://localhost:8083/dms-api';
globalThis.VITE_DMS_API = base;

const {
  upsertDmsSession,
  upsertDmsRecord,
  fetchDmsSessions,
  fetchDmsSessionRecords,
  deleteDmsSession,
  writeDmsFeedback,
  resolveDmsCreditCode,
  parseDmsTimestamp,
  nowDmsTimestamp,
  searchDmsContents,
  deleteDmsContent,
  DMS_COLUMN_SESSION,
  DMS_COLUMN_RECORD,
  enterpriseInfo,
  resolveVisitorLabel,
} = await import('./_dms.mjs');

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

const TEST_CREDIT = `verify_cc_${Date.now().toString(36)}`;
const SESSION_ID = `verify_sess_${Date.now().toString(36)}`;
const REC_1 = 'rec1_' + Date.now().toString(36);
const REC_2 = 'rec2_' + Date.now().toString(36);
const TITLE_A = '验证会话标题';
const TITLE_B = '验证会话标题（改过）';
const Q1 = '高新技术企业的奖励是多少？';
const A1 = '<!-- POLICY_TABLE {"data":[]} -->\n<scope title="思考中">\n</scope>\n第一轮回答。';
const Q2 = '那申报条件呢？';
const A2 = '第二轮回答，带换行。\n第二行。';

console.log(`\nDMS 会话/问答记录/反馈 端到端验证\n  代理地址: ${base}\n  测试标记: ${TEST_CREDIT}\n`);

const rowsForSession = () =>
  searchDmsContents(DMS_COLUMN_RECORD, {
    search: [{ field: 'c_session_id', searchType: 1, content: { value: SESSION_ID } }],
    page: 0,
    pageSize: 50,
  });

const cleanup = async () => {
  await deleteDmsSession(SESSION_ID);
  for (const col of [DMS_COLUMN_SESSION, DMS_COLUMN_RECORD]) {
    const rows = await searchDmsContents(col, {
      search: [{ field: 'c_credit_code', searchType: 1, content: { value: TEST_CREDIT } }],
      page: 0,
      pageSize: 50,
    });
    for (const row of rows) if (row.id) await deleteDmsContent(col, String(row.id));
  }
};

try {
  // ── 1. 会话行 ──────────────────────────────────────────────────────
  // ⚠️ 先置登录态：1887 的读取会**排除访客行**（c_is_login="0"），
  //    这一段测的是「企业自己的会话」，所以照登录态造数据。
  console.log('【1】会话（1887）');
  enterpriseInfo.value = { credit_code: TEST_CREDIT, name: '验证企业' };
  check('upsertDmsSession 新增', (await upsertDmsSession({ sessionId: SESSION_ID, sessionTitle: TITLE_A, creditCode: TEST_CREDIT })) === true);
  let sessions = await fetchDmsSessions(TEST_CREDIT);
  check('列表能查到', sessions.some((s) => s.session_id === SESSION_ID));
  check('updated_at 合理', Math.abs((sessions.find((s) => s.session_id === SESSION_ID)?.updated_at || 0) - Date.now()) < 10 * 60 * 1000);

  // 标题规则（用户 2026-09-22）：**c_title 不写**（标题由运营侧生成）；
  // DMS 系统字段 `title` 只在创建那一刻带上会话标题（不写会落成字符串 "null"，1889 踩过）。
  let rowSession = (await searchDmsContents(DMS_COLUMN_SESSION, {
    search: [{ field: 'c_session_id', searchType: 1, content: { value: SESSION_ID } }],
    page: 0,
    pageSize: 1,
  }))[0];
  check('创建时带上了系统 title', rowSession?.title === TITLE_A, JSON.stringify(rowSession?.title));
  check('**c_title 不写**（前端不碰标题）', !rowSession?.c_title, JSON.stringify(rowSession?.c_title));

  await upsertDmsSession({ sessionId: SESSION_ID, sessionTitle: TITLE_B, creditCode: TEST_CREDIT });
  sessions = await fetchDmsSessions(TEST_CREDIT);
  check('再次 upsert 只有一行', sessions.filter((s) => s.session_id === SESSION_ID).length === 1);
  rowSession = (await searchDmsContents(DMS_COLUMN_SESSION, {
    search: [{ field: 'c_session_id', searchType: 1, content: { value: SESSION_ID } }],
    page: 0,
    pageSize: 1,
  }))[0];
  check('**再 upsert 也不写 c_title**', !rowSession?.c_title, JSON.stringify(rowSession?.c_title));
  check('系统 title 保持创建时的值（只在创建那一刻初始化）', rowSession?.title === TITLE_A, JSON.stringify(rowSession?.title));

  // ── 2. 粒度：一问一答一条 ──────────────────────────────────────────
  console.log('\n【2】问答记录（1889）—— 粒度必须是「一问一答一条」');
  await upsertDmsRecord({ recordId: REC_1, sessionId: SESSION_ID, creditCode: TEST_CREDIT, question: Q1 });
  let rows = await rowsForSession();
  check('第 1 轮提交后：1 行', rows.length === 1, `实际 ${rows.length} 行`);
  check('c_question 正确', rows[0]?.c_question === Q1, JSON.stringify(rows[0]?.c_question));
  check('c_record_id 存的是该轮标识', rows[0]?.c_record_id === REC_1, String(rows[0]?.c_record_id));
  check('此时 c_answer 为空', !rows[0]?.c_answer, JSON.stringify(rows[0]?.c_answer));

  // 回答完成 → 补 answer，不能变成两行、不能冲掉 question
  await upsertDmsRecord({ recordId: REC_1, sessionId: SESSION_ID, creditCode: TEST_CREDIT, answer: A1 });
  rows = await rowsForSession();
  check('补 answer 后仍是 1 行', rows.length === 1, `实际 ${rows.length} 行`);
  check('answer 完整往返（含协议标记）', rows[0]?.c_answer === A1, `长 ${String(rows[0]?.c_answer || '').length}/${A1.length}`);
  check('question 未被覆盖', rows[0]?.c_question === Q1, JSON.stringify(rows[0]?.c_question));

  // 第 2 轮 → 应该是**新的一行**（一问一答一条）
  await upsertDmsRecord({ recordId: REC_2, sessionId: SESSION_ID, creditCode: TEST_CREDIT, question: Q2 });
  await upsertDmsRecord({ recordId: REC_2, sessionId: SESSION_ID, creditCode: TEST_CREDIT, answer: A2 });
  rows = await rowsForSession();
  check('第 2 轮后：2 行（一问一答一条）', rows.length === 2, `实际 ${rows.length} 行`);

  // ── 3. 历史读回 ───────────────────────────────────────────────────
  console.log('\n【3】历史读回（按创建时间正序）');
  const records = await fetchDmsSessionRecords(SESSION_ID);
  check('读出两轮', records.length === 2, `实际 ${records.length} 轮`);
  check('第一轮 question/answer 正确', records[0]?.question === Q1 && records[0]?.answer === A1);
  check('第二轮 question/answer 正确', records[1]?.question === Q2 && records[1]?.answer === A2);
  check('record_id 回填（反馈闭环）', records[0]?.record_id === REC_1 && records[1]?.record_id === REC_2, `${records[0]?.record_id} / ${records[1]?.record_id}`);
  check('created_at 被解析成合理时间戳', Math.abs((records[0]?.created_at || 0) - Date.now()) < 10 * 60 * 1000, String(records[0]?.created_at));

  // ── 4. 反馈：写在该轮那一行 ────────────────────────────────────────
  console.log('\n【4】反馈（写在第 2 轮那一行）');
  await writeDmsFeedback({ recordId: REC_2, sessionId: SESSION_ID, status: 2, option: '没有回答我的问题', remark: '验证备注' });
  rows = await rowsForSession();
  const target = rows.find((r) => r.c_record_id === REC_2);
  const untouched = rows.find((r) => r.c_record_id === REC_1);
  check('行数不变（仍 2 行）', rows.length === 2, `实际 ${rows.length} 行`);
  check('c_feedback_status = 2', Number(target?.c_feedback_status) === 2, String(target?.c_feedback_status));
  check('c_feedback_option 正确', target?.c_feedback_option === '没有回答我的问题', JSON.stringify(target?.c_feedback_option));
  check('c_feedback_remark 正确', target?.c_feedback_remark === '验证备注', JSON.stringify(target?.c_feedback_remark));
  check('c_feedback_at 已写入', !!target?.c_feedback_at, String(target?.c_feedback_at));
  check('**另一轮未被误改**', untouched && untouched.c_feedback_status == null, JSON.stringify(untouched?.c_feedback_status));
  check('问答内容未被反馈覆盖', target?.c_question === Q2 && target?.c_answer === A2);

  await writeDmsFeedback({ recordId: REC_2, sessionId: SESSION_ID, status: 0 });
  rows = await rowsForSession();
  check('取消反馈 status=0', Number(rows.find((r) => r.c_record_id === REC_2)?.c_feedback_status) === 0);

  const before = (await rowsForSession()).length;
  await writeDmsFeedback({ recordId: 'not_exist_rec', sessionId: SESSION_ID, status: 1 });
  check('定位不到时不新增行', (await rowsForSession()).length === before);

  // ── 5. 删除 ───────────────────────────────────────────────────────
  console.log('\n【5】删除会话');
  check('deleteDmsSession 返回 true', (await deleteDmsSession(SESSION_ID)) === true);
  check('会话行已删', !(await fetchDmsSessions(TEST_CREDIT)).some((s) => s.session_id === SESSION_ID));
  check('问答记录已连带删除', (await rowsForSession()).length === 0);

  // ── 6. 工具函数 ───────────────────────────────────────────────────
  console.log('\n【6】时间戳与访客归属');
  check('nowDmsTimestamp 格式', /^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$/.test(nowDmsTimestamp()), nowDmsTimestamp());
  check('parseDmsTimestamp 毫秒', parseDmsTimestamp(1789651800000) === 1789651800000);
  check('parseDmsTimestamp 秒', parseDmsTimestamp(1789651800) === 1789651800000);
  check('parseDmsTimestamp 字符串', parseDmsTimestamp('2026-09-17 21:30:00') === 1789651800000, String(parseDmsTimestamp('2026-09-17 21:30:00')));
  enterpriseInfo.value = null; // 下面这条断言的是**未登录**时的归属形态
  check('访客归属形态 访客_<id>', /^访客_.+/.test(resolveDmsCreditCode()), resolveDmsCreditCode());

  // ── 8. 1887 的企业字段（2026-09-22 用户要求）──────────────────────
  // 规则：登录态的值优先级最高（覆盖）；对话带出的 company_info **只填空**（未登录不修改）；
  //       归属键 c_credit_code 不变（公司代码另存 c_chat_credit_code 一列）。
  console.log('\n【8】1887 企业字段（名称 / 公司代码 / 图片 / 是否登录）');
  const SID8 = `verify_ent_${Date.now().toString(36)}`;
  const sessionRowOf = async (sid) =>
    (
      await searchDmsContents(DMS_COLUMN_SESSION, {
        search: [{ field: 'c_session_id', searchType: 1, content: { value: sid } }],
        page: 0,
        pageSize: 1,
      })
    )[0];
  const COMPANY_A = {
    profile: { data: { Name: '甲测试公司', CreditCode: '91310000AAAAAAAAAA', ImageUrl: 'https://example.com/a.png' } },
  };
  const COMPANY_B = {
    profile: { data: { Name: '乙测试公司', CreditCode: '91310000BBBBBBBBBB', ImageUrl: 'https://example.com/b.png' } },
  };

  // 8.1 未登录 + company_info → 填进 1887（c_credit_code 放**真实**代码，访客标识进 c_ip）
  enterpriseInfo.value = null;
  await upsertDmsSession({ sessionId: SID8, sessionTitle: '企业字段验证', companyInfo: COMPANY_A });
  let entRow = await sessionRowOf(SID8);
  check('未登录：企业名称已填', entRow?.c_ent_name === '甲测试公司', JSON.stringify(entRow?.c_ent_name));
  check(
    '未登录：真实信用代码写进 c_credit_code',
    entRow?.c_credit_code === '91310000AAAAAAAAAA',
    JSON.stringify(entRow?.c_credit_code)
  );
  check('未登录：**访客标识进 c_ip**', /^访客_/.test(String(entRow?.c_ip)), JSON.stringify(entRow?.c_ip));
  check('未登录：企业图片已填', entRow?.c_ent_image_url === 'https://example.com/a.png', JSON.stringify(entRow?.c_ent_image_url));
  check('未登录：是否登录 = "0"', entRow?.c_is_login === '0', JSON.stringify(entRow?.c_is_login));
  // ⚠️ 不断言「等于 resolveVisitorLabel() 的当前返回值」：node 里没有 localStorage，
  //    每次调用都会新生成一个访客 id（浏览器里有 localStorage，是稳定的）。只查前缀形态。

  // 8.2 未登录再来一轮、带的是**另一家**公司 → **值不同就更新**（用户 2026-09-22 修订）
  await upsertDmsSession({ sessionId: SID8, companyInfo: COMPANY_B });
  entRow = await sessionRowOf(SID8);
  check('未登录：值不同 → 企业名称被更新', entRow?.c_ent_name === '乙测试公司', JSON.stringify(entRow?.c_ent_name));
  check('未登录：值不同 → 信用代码被更新', entRow?.c_credit_code === '91310000BBBBBBBBBB', JSON.stringify(entRow?.c_credit_code));

  // 8.2b 同一家公司再来一轮（值相同）→ 不该产生无谓写入：读回值不变即可
  await upsertDmsSession({ sessionId: SID8, companyInfo: COMPANY_B });
  entRow = await sessionRowOf(SID8);
  check('未登录：值相同 → 保持原值', entRow?.c_ent_name === '乙测试公司', JSON.stringify(entRow?.c_ent_name));

  // 8.3 登录 → 登录态的值优先级最高，**覆盖**库里已有的
  enterpriseInfo.value = { credit_code: '91310000LOGIN000001', name: '登录态公司' };
  await upsertDmsSession({ sessionId: SID8, companyInfo: COMPANY_B });
  entRow = await sessionRowOf(SID8);
  check('登录：企业名称被登录值**覆盖**', entRow?.c_ent_name === '登录态公司', JSON.stringify(entRow?.c_ent_name));
  check('登录：归属键被登录值**覆盖**', entRow?.c_credit_code === '91310000LOGIN000001', JSON.stringify(entRow?.c_credit_code));
  check('登录：是否登录 = "1"', entRow?.c_is_login === '1', JSON.stringify(entRow?.c_is_login));
  check(
    '登录：对话带出的公司代码**不会**顶掉登录信用代码',
    entRow?.c_credit_code === '91310000LOGIN000001',
    JSON.stringify(entRow?.c_credit_code)
  );

  // 8.4 退出登录后再写（对话里是**另一家**公司）→ 这行已被登录态认领，公司字段**不许被改**
  //     否则会把这行改到别的公司名下、而 c_is_login 还是 "1" → 串台
  enterpriseInfo.value = null;
  await upsertDmsSession({ sessionId: SID8, companyInfo: COMPANY_B });
  entRow = await sessionRowOf(SID8);
  check('退出后：登录认领过的行，企业名称**不被**对话值改写', entRow?.c_ent_name === '登录态公司', JSON.stringify(entRow?.c_ent_name));
  check('退出后：信用代码**不被**对话值改写', entRow?.c_credit_code === '91310000LOGIN000001', JSON.stringify(entRow?.c_credit_code));
  check('退出后：是否登录仍为 "1"（该字段只填空）', entRow?.c_is_login === '1', JSON.stringify(entRow?.c_is_login));

  // 8.4b **纯访客行**（从没被登录认领过）→ 公司字段跟着对话走，值不同就更新
  const SID_GUEST = `verify_guest_${Date.now().toString(36)}`;
  const COMPANY_C = { profile: { data: { Name: '丙测试公司', CreditCode: '91310000CCCCCCCCCC' } } };
  const COMPANY_D = { profile: { data: { Name: '丁测试公司', CreditCode: '91310000DDDDDDDDDD' } } };
  await upsertDmsSession({ sessionId: SID_GUEST, sessionTitle: '纯访客', companyInfo: COMPANY_C });
  await upsertDmsSession({ sessionId: SID_GUEST, companyInfo: COMPANY_D });
  const guestRow = await sessionRowOf(SID_GUEST);
  check('纯访客行：值不同 → 企业名称更新', guestRow?.c_ent_name === '丁测试公司', JSON.stringify(guestRow?.c_ent_name));
  check('纯访客行：值不同 → 信用代码更新', guestRow?.c_credit_code === '91310000DDDDDDDDDD', JSON.stringify(guestRow?.c_credit_code));
  check('纯访客行：是否登录 = "0"', guestRow?.c_is_login === '0', JSON.stringify(guestRow?.c_is_login));
  // 8.5 访客行**不该**出现在那家公司的会话列表里（用户 2026-09-22 明确要求挡住）
  // ⚠️ 要查**纯访客行实际带着的**公司代码（第一版查错了代码 → 断言恒真 = 假通过；
  //    第二版查 SID8 → 它已被登录认领，不更新是对的）
  const guestRows = await fetchDmsSessions('91310000DDDDDDDDDD');
  check(
    '**企业登录后看不到访客的会话**（按 c_is_login 过滤）',
    !guestRows.some((r) => r.session_id === SID_GUEST),
    `列表里有 ${guestRows.filter((r) => r.session_id === SID_GUEST).length} 行命中`
  );
  // 反向：登录态造的行**能**查到（否则就是过滤写反了）
  // ⚠️ 用新建的行，别用 SESSION_ID —— 它在【5】删除会话那节已经被删掉了
  const SID9 = `verify_login_${Date.now().toString(36)}`;
  enterpriseInfo.value = { credit_code: TEST_CREDIT, name: '验证企业' };
  await upsertDmsSession({ sessionId: SID9, sessionTitle: '登录态会话' });
  const ownRows = await fetchDmsSessions(TEST_CREDIT);
  check('登录态造的会话**能**查到（过滤没写反）', ownRows.some((r) => r.session_id === SID9), `共 ${ownRows.length} 行`);
  enterpriseInfo.value = null;
  await deleteDmsSession(SID9);
  await deleteDmsSession(SID_GUEST);
  await deleteDmsSession(SID8);
} finally {
  console.log('\n【清理】');
  await cleanup();
  const left = [
    ...(await searchDmsContents(DMS_COLUMN_SESSION, { search: [{ field: 'c_credit_code', searchType: 1, content: { value: TEST_CREDIT } }], page: 0, pageSize: 50 })),
    ...(await searchDmsContents(DMS_COLUMN_RECORD, { search: [{ field: 'c_credit_code', searchType: 1, content: { value: TEST_CREDIT } }], page: 0, pageSize: 50 })),
  ];
  console.log(`  测试数据已清理（残留 ${left.length} 行）`);
}

// ── 7. title 字段（2026-09-17 用户要求：改名要跟随、记录写问题文本）──────
console.log('\n【7】title 字段');
{
  const SID2 = SESSION_ID + '_t';
  const REC3 = 'rec3_' + Date.now().toString(36);
  const rowOf = async (columnId, field, value) =>
    (await searchDmsContents(columnId, {
      search: [{ field, searchType: 1, content: { value } }],
      page: 0,
      pageSize: 1,
    }))[0];

  await upsertDmsSession({ sessionId: SID2, sessionTitle: '标题甲', creditCode: TEST_CREDIT });
  let row = await rowOf(DMS_COLUMN_SESSION, 'c_session_id', SID2);
  check('新建会话带上了系统 title', row?.title === '标题甲', JSON.stringify(row?.title));
  // 四个必填运营字段（summary/qpyszx/qyzt/rzqpyx）**故意传空值/默认值**：
  // 它们是 must=true（不带就 214），但取值属业务口径、前端不猜。
  // 所以这里断言的是「写进去了、且确实是空的」——而不是断言某个业务值。
  check('摘要字段已写入**且为空**（不猜业务值）', row?.summary === '', JSON.stringify(row?.summary));
  check('三个布尔运营字段为默认 false', row?.qpyszx === false && row?.qyzt === false && row?.rzqpyx === false,
    JSON.stringify([row?.qpyszx, row?.qyzt, row?.rzqpyx]));

  await upsertDmsSession({ sessionId: SID2, sessionTitle: '标题乙', creditCode: TEST_CREDIT });
  row = await rowOf(DMS_COLUMN_SESSION, 'c_session_id', SID2);
  check('再 upsert 仍不写 c_title', !row?.c_title, JSON.stringify(row?.c_title));
  check('系统 title 保持创建时的值', row?.title === '标题甲', JSON.stringify(row?.title));

  await upsertDmsRecord({ recordId: REC3, sessionId: SID2, creditCode: TEST_CREDIT, question: '记录的问题文本' });
  const recRow = await rowOf(DMS_COLUMN_RECORD, 'c_record_id', REC3);
  check('记录的系统 title = 问题文本（原先写的是 "null"）', recRow?.title === '记录的问题文本', JSON.stringify(recRow?.title));
  // 1889 的模型里**没有** summary 字段（只有 1887 有），DMS 会静默忽略未知字段 ——
  // 所以写入仍成功，但读回来不会有这个键。这条断言把这个差异钉下来。
  check(
    '1889 无 summary 字段，多发的字段被 DMS 忽略（写入不受影响）',
    recRow !== undefined && recRow.summary === undefined,
    JSON.stringify(recRow?.summary)
  );

  await deleteDmsSession(SID2);
}

console.log(`\n===== 通过 ${pass} 项，失败 ${fail} 项 =====`);
process.exit(fail ? 1 : 0);