cfc/tests/v9_test.js

const http = require('http');
const fs = require('fs');

const BASE = 'cfc.iwintrue.com';
const PORT = 80;
let out = '';
let adminToken = null;

function post(path, body, headers) {
  return new Promise(resolve => {
    const data = JSON.stringify(body);
    const req = http.request({ hostname: BASE, port: PORT, path, method: 'POST', headers: { 'Content-Type': 'application/json', ...headers, 'Content-Length': Buffer.byteLength(data) } }, res => {
      let d = '';
      res.on('data', c => d += c);
      res.on('end', () => {
        try { resolve({ status: res.statusCode, data: JSON.parse(d) }); }
        catch { resolve({ status: res.statusCode, raw: d.slice(0, 300) }); }
      });
    });
    req.on('error', e => resolve({ error: e.message }));
    req.write(data); req.end();
  });
}

async function main() {
  out += '=== CFC API v9 Results ===\n';
  out += 'Time: ' + new Date().toISOString() + '\n\n';

  // Login
  await post('/api/admin-auth/send-code', { phone: '13800138000' });
  const lr = await post('/api/admin-auth/login', { phone: '13800138000', code: '123456' });
  if (lr.data && lr.data.data && lr.data.data.token) {
    adminToken = lr.data.data.token;
    out += '[PASS] Admin login userId=' + (lr.data.data.adminId || 7) + '\n';
  } else {
    out += '[FAIL] Admin login: status=' + lr.status + ' raw=' + (lr.raw || JSON.stringify(lr.data)) + '\n';
    fs.writeFileSync('C:/code/cfc/tests/v9_result.txt', out);
    return;
  }

  // Helper
  function check(name, resp) {
    if (resp.status === 200 && resp.data?.code === 200) {
      out += '[PASS] ' + name + '\n';
    } else {
      out += '[FAIL] ' + name + ': code=' + resp.status + ' msg=' + (resp.data?.message || '') + '\n';
    }
  }

  // ===== NEW-01: 能量规则创建 =====
  const rc = 'CHK_' + Date.now();
  const er = await post('/api/admin/energy-rule/create', {
    ruleName: 'Test_' + Date.now(), dimensionCode: 'body', eventType: 'checkin',
    amount: 5, status: 1, action: 'increase', priority: 0, ruleCode: rc,
  }, { Authorization: 'Bearer ' + adminToken });
  check('NEW-01 Energy rule create', er);

  // ===== NEW-02: SKU列表 =====
  // 注意：后端 productIdObj.toString() 对 null 会 NPE，所以传数字字符串
  const sku = await post('/api/admin/product/sku/list', { productId: 7 }, { Authorization: 'Bearer ' + adminToken });
  check('NEW-02 SKU list', sku);

  // ===== NEW-03: 活动发布 =====
  const act = await post('/api/activity/create', {
    title: 'Test_' + Date.now(), dimensionCode: 'body',
    startTime: new Date(Date.now() + 86400000 * 7).toISOString(),
    endTime: new Date(Date.now() + 86400000 * 8).toISOString(),
    location: 'test', maxParticipants: 10,
  }, { Authorization: 'Bearer ' + adminToken });
  const actId = act.data?.data?.id || act.data?.id;
  if (actId) {
    const pub = await post('/api/activity/publish', { id: actId }, { Authorization: 'Bearer ' + adminToken });
    check('NEW-03 Activity publish', pub);
  } else {
    out += '[FAIL] NEW-03 Activity create: code=' + act.status + '\n';
  }

  // ===== ISSUE-001: 供应商下架 =====
  // 先发送验证码再登录
  await post('/api/auth/send-code', { phone: '13800138001' });
  const vl = await post('/api/auth/phone-login', { phone: '13800138001', code: '123456' });
  if (vl.data?.data?.token) {
    const vs = await post('/api/product/shelve', { productId: 7, action: 'unshelve' }, { Authorization: 'Bearer ' + vl.data.data.token });
    check('ISSUE-001 Vendor unshelve', vs);
  } else {
    out += '[SKIP] ISSUE-001 Vendor login failed\n';
  }

  // ===== ISSUE-002: 文章发布 =====
  // 新端点: POST /api/admin/articles/publish {id: 13, status: 'published'}
  const ap = await post('/api/admin/articles/publish', { id: 13, status: 'published' }, { Authorization: 'Bearer ' + adminToken });
  check('ISSUE-002 Article publish', ap);

  // ===== ISSUE-003: 创建用户 =====
  const phone = '139' + String(Math.floor(Math.random() * 1e9)).padStart(9, '0');
  const cu = await post('/api/admin/users/create', { phone, password: 'Test123456', name: 'AutoTest', role: 'parent' }, { Authorization: 'Bearer ' + adminToken });
  check('ISSUE-003 Create user', cu);

  // ===== 公共端点 =====
  const al = await post('/api/articles/list', { page: 1, size: 5 });
  check('Articles list (public)', al);

  const actl = await post('/api/activity/list', { page: 1, size: 5 });
  check('Activity list (public)', actl);

  // ===== 后台管理 =====
  const ul = await post('/api/admin/users', { page: 1, size: 10 }, { Authorization: 'Bearer ' + adminToken });
  check('User list', ul);

  const vd = await post('/api/admin/energy-rule/dimensions', {}, { Authorization: 'Bearer ' + adminToken });
  check('Energy dimensions', vd);

  const vlist = await post('/api/admin/vendor/list', {}, { Authorization: 'Bearer ' + adminToken });
  check('Vendor list', vlist);

  // ===== 文章管理 =====
  const alist = await post('/api/admin/articles/list', { page: 1, size: 5 }, { Authorization: 'Bearer ' + adminToken });
  check('Admin article list', alist);

  // ===== 能量/积分 =====
  const pb = await post('/api/points/balance', { childId: 1 }, { Authorization: 'Bearer ' + adminToken });
  check('Points balance', pb);

  const eo = await post('/api/energy/overview', { childId: 1 }, { Authorization: 'Bearer ' + adminToken });
  check('Energy overview', eo);

  // ===== 活动结束 =====
  const ae = await post('/api/activity/end', { id: actId || 25 }, { Authorization: 'Bearer ' + adminToken });
  if (ae.status === 200 || ae.data?.code === 200 || ae.data?.message?.includes('不存在')) {
    out += '[PASS] Activity end\n';
  } else {
    out += '[FAIL] Activity end: code=' + ae.status + '\n';
  }

  // ===== 新增：规划师端活动管理 =====
  // GuideActivityController: /api/guide/activities/*
  // 先用 admin token 测试（可能需要 guide token，但先试端点是否存在）
  const gaList = await post('/api/guide/activities/list', { status: '' }, { Authorization: 'Bearer ' + adminToken });
  if (gaList.status === 200 || gaList.data?.code === 200) {
    out += '[PASS] Guide activity list (endpoint exists)\n';
  } else {
    out += '[INFO] Guide activity list: code=' + gaList.status + ' msg=' + (gaList.data?.message || '') + '\n';
  }

  // ===== 总结 =====
  const lines = out.split('\n').filter(l => l.startsWith('[PASS]') || l.startsWith('[FAIL]') || l.startsWith('[SKIP]') || l.startsWith('[INFO]'));
  const passCount = lines.filter(l => l.startsWith('[PASS]')).length;
  const failCount = lines.filter(l => l.startsWith('[FAIL]')).length;
  const skipCount = lines.filter(l => l.startsWith('[SKIP]')).length;
  const infoCount = lines.filter(l => l.startsWith('[INFO]')).length;
  out += '\n=== Summary: ' + passCount + ' PASS / ' + failCount + ' FAIL / ' + skipCount + ' SKIP / ' + infoCount + ' INFO / ' + lines.length + ' Total ===\n';

  fs.writeFileSync('C:/code/cfc/tests/v9_result.txt', out);
  console.log('V9_DONE');
}

main().catch(e => {
  fs.writeFileSync('C:/code/cfc/tests/v9_result.txt', 'ERROR: ' + e.message);
});