import assert from 'node:assert/strict';
import { spawn } from 'node:child_process';
import net from 'node:net';

const DEFAULT_DATABASE_URL = 'postgresql://postgres:postgres@127.0.0.1:54322/postgres';
const MAIN_TENANT_ID = process.env.TENANT_ID || '00000000-0000-0000-0000-000000000001';
const PARTNER_TENANT_ID = process.env.PARTNER_TENANT_ID || '00000000-0000-0000-0000-000000000901';
const USER_ID = process.env.USER_ID || '00000000-0000-0000-0000-000000000101';
const TENANT_ADMIN_USER_ID = process.env.TENANT_ADMIN_USER_ID || '00000000-0000-0000-0000-000000000102';
const TENANT_OPERATOR_USER_ID = '00000000-0000-0000-0000-000000000103';
const TENANT_SALES_USER_ID = '00000000-0000-0000-0000-000000000104';
const TENANT_AGENT_USER_ID = '00000000-0000-0000-0000-000000000105';
const START_SERVER = process.argv.includes('--start-server');
const ENABLE_REAL_STORAGE_SIGN_TESTS = process.env.ENABLE_REAL_STORAGE_SIGN_TESTS === 'true';

const ids = {
  region: '00000000-0000-0000-0000-000000000301',
  subject: '00000000-0000-0000-0000-000000000501',
  category: '00000000-0000-0000-0000-000000000601',
  contentEntry: '00000000-0000-0000-0000-000000000611',
  contentNodeCulture: '00000000-0000-0000-0000-000000000612',
  contentNodeProfessional: '00000000-0000-0000-0000-000000000613',
  contentNodeSchoolTarget: '00000000-0000-0000-0000-000000000614',
  questionCollection: '00000000-0000-0000-0000-000000000615',
  practiceBlueprintSequential: '00000000-0000-0000-0000-000000000616',
  practiceBlueprintRandom: '00000000-0000-0000-0000-000000000617',
  practiceBlueprintMock: '00000000-0000-0000-0000-000000000618',
  question: '00000000-0000-0000-0000-000000000401',
  vocabularyUnit: '00000000-0000-0000-0000-000000000811',
  vocabularyWord: '00000000-0000-0000-0000-000000000812',
  scorelineSchool: '00000000-0000-0000-0000-000000000831',
};

let apiBase = process.env.API_BASE || 'http://127.0.0.1:8787';
let serverProcess = null;
let serverLogs = '';

function buildUrl(path, query = {}) {
  const target = new URL(path, apiBase);
  for (const [key, value] of Object.entries(query)) {
    if (value !== undefined && value !== null && value !== '') {
      target.searchParams.set(key, String(value));
    }
  }
  return target;
}

async function request(path, options = {}) {
  const response = await fetch(buildUrl(path, options.query), {
    method: options.method || 'GET',
    headers: {
      'content-type': 'application/json',
      ...(options.tenantId === false ? {} : { 'x-tenant-id': options.tenantId || MAIN_TENANT_ID }),
      ...(options.userId === false ? {} : { 'x-user-id': options.userId || USER_ID }),
      ...(options.headers || {}),
    },
    body: options.body ? JSON.stringify(options.body) : undefined,
  });

  const payload = await response.json().catch(() => ({}));
  if (options.expectStatus) {
    assert.equal(response.status, options.expectStatus, `${options.method || 'GET'} ${path} should return ${options.expectStatus}`);
    return payload;
  }
  if (!response.ok) {
    throw new Error(`${options.method || 'GET'} ${path} failed: ${response.status} ${JSON.stringify(payload)}`);
  }
  return payload;
}

async function check(name, fn) {
  await fn();
  console.log(`[PASS] ${name}`);
}

function getFreePort() {
  return new Promise((resolve, reject) => {
    const server = net.createServer();
    server.on('error', reject);
    server.listen(0, '127.0.0.1', () => {
      const address = server.address();
      server.close(() => resolve(address.port));
    });
  });
}

async function waitForHealth(timeoutMs = 12_000) {
  const started = Date.now();
  let lastError = null;
  while (Date.now() - started < timeoutMs) {
    try {
      const payload = await request('/health', { userId: false });
      if (payload.ok) return;
    } catch (error) {
      lastError = error;
    }
    await new Promise(resolve => setTimeout(resolve, 250));
  }
  throw new Error(`API server did not become healthy. ${lastError?.message || ''}\n${serverLogs}`);
}

async function startServerIfNeeded() {
  if (!START_SERVER) return;
  const port = Number(process.env.TEST_API_PORT || 0) || await getFreePort();
  apiBase = `http://127.0.0.1:${port}`;
  serverProcess = spawn(process.execPath, ['apps/api/dist/apps/api/src/server.js'], {
    cwd: process.cwd(),
    env: {
      ...process.env,
      PORT: String(port),
      DATABASE_URL: process.env.DATABASE_URL || DEFAULT_DATABASE_URL,
    },
    stdio: ['ignore', 'pipe', 'pipe'],
    windowsHide: true,
  });

  serverProcess.stdout.on('data', chunk => {
    serverLogs += chunk.toString();
  });
  serverProcess.stderr.on('data', chunk => {
    serverLogs += chunk.toString();
  });

  await waitForHealth();
}

function stopServer() {
  if (serverProcess && !serverProcess.killed) {
    serverProcess.kill();
  }
}

async function testCatalogAndLearning() {
  const questions = await request('/api/catalog/questions', { query: { limit: 20 } });
  const question = questions.items?.find(item => item.id === ids.question);
  assert.ok(question, 'main tenant should return smoke question');
  assert.equal(question.hasVideoExplanation, true, 'smoke question should expose video marker');
  assert.equal(question.contentNodeId, ids.contentNodeSchoolTarget, 'question should expose new content node binding');

  const entries = await request('/api/catalog/content-entries', {
    query: { regionId: ids.region, entryType: 'question_practice' },
  });
  assert.ok(entries.items?.some(item => item.id === ids.contentEntry), 'catalog should expose question practice entry');

  const rootNodes = await request('/api/catalog/content-nodes', {
    query: { entryId: ids.contentEntry, parentId: 'root' },
  });
  assert.ok(rootNodes.items?.some(item => item.id === ids.contentNodeProfessional), 'catalog should expose root professional node');

  const schoolNodes = await request('/api/catalog/content-nodes', {
    query: { entryId: ids.contentEntry, markerType: 'school', mode: 'flat' },
  });
  assert.ok(
    schoolNodes.items?.some(item => item.id === ids.contentNodeSchoolTarget && item.markerConfig?.salesIntent === true),
    'catalog should expose school target marker for sales intent',
  );

  const collections = await request('/api/catalog/question-collections', {
    query: { nodeId: ids.contentNodeSchoolTarget },
  });
  assert.ok(collections.items?.some(item => item.id === ids.questionCollection), 'catalog should expose node question collection');

  const collectionQuestions = await request('/api/catalog/question-collections/questions', {
    query: { collectionId: ids.questionCollection },
  });
  assert.ok(collectionQuestions.items?.some(item => item.id === ids.question), 'collection questions should include smoke question');

  const blueprintList = await request('/api/catalog/practice-blueprints', {
    query: { collectionId: ids.questionCollection },
  });
  assert.ok(blueprintList.items?.some(item => item.id === ids.practiceBlueprintMock), 'catalog should expose mock exam blueprint');

  const questionsByNode = await request('/api/catalog/questions', {
    query: { contentNodeId: ids.contentNodeSchoolTarget, limit: 20 },
  });
  assert.ok(questionsByNode.items?.some(item => item.id === ids.question), 'catalog questions should filter by contentNodeId');

  const session = await request('/api/learning/practice-sessions', {
    method: 'POST',
    body: { userId: USER_ID, mode: 'chapter', targetType: 'category', targetId: ids.question },
  });
  assert.ok(session.item?.id, 'practice session should be created');

  const sequentialSession = await request('/api/learning/practice-sessions', {
    method: 'POST',
    body: {
      userId: USER_ID,
      mode: 'sequential',
      collectionId: ids.questionCollection,
      questionLimit: 5,
    },
  });
  assert.equal(sequentialSession.item?.collectionId, ids.questionCollection, 'collection session should bind collection');
  assert.ok(sequentialSession.item?.questionIds?.includes(ids.question), 'collection session should snapshot question ids');

  const nodeSession = await request('/api/learning/practice-sessions', {
    method: 'POST',
    body: {
      userId: USER_ID,
      mode: 'random',
      contentNodeId: ids.contentNodeProfessional,
      questionLimit: 5,
    },
  });
  assert.equal(nodeSession.item?.contentNodeId, ids.contentNodeProfessional, 'node session should bind parent content node');
  assert.ok(nodeSession.item?.questionIds?.includes(ids.question), 'node session should include descendant questions');

  const mockSession = await request('/api/learning/practice-sessions', {
    method: 'POST',
    body: {
      userId: USER_ID,
      blueprintId: ids.practiceBlueprintMock,
    },
  });
  assert.equal(mockSession.item?.mode, 'mock_exam', 'mock blueprint should create mock_exam session');
  assert.equal(mockSession.item?.blueprintId, ids.practiceBlueprintMock, 'mock session should bind blueprint');
  assert.equal(mockSession.item?.durationMinutes, 120, 'mock session should inherit duration');
  assert.equal(Number(mockSession.item?.totalScore), 100, 'mock session should inherit total score');
  assert.ok(mockSession.item?.questionIds?.includes(ids.question), 'mock session should snapshot assembled questions');

  const answer = await request('/api/learning/answers', {
    method: 'POST',
    body: {
      userId: USER_ID,
      questionId: ids.question,
      selectedOptions: ['0'],
      practiceSessionId: session.item.id,
    },
  });
  assert.equal(answer.item?.isCorrect, false, 'wrong answer should be judged false');

  const wrong = await request('/api/learning/wrong-questions', { query: { status: 'all' } });
  assert.ok(wrong.items?.some(item => item.questionId === ids.question), 'wrong book should include smoke question');
}

async function testProfile() {
  const payload = await request('/api/profile/me');
  assert.equal(payload.item?.userId, USER_ID, 'profile should belong to smoke user');
  assert.ok(payload.item?.stats?.vocabulary?.totalWords >= 1, 'profile should include vocabulary stats');
  assert.ok(Array.isArray(payload.item?.recentPractices), 'profile should include recent practices');
}

async function testScoreline() {
  const fields = await request('/api/scoreline/fields', { query: { regionId: ids.region } });
  assert.ok(fields.items?.some(item => item.fieldKey === 'minScore'), 'scoreline fields should include minScore');

  const schools = await request('/api/scoreline/schools', { query: { regionId: ids.region } });
  assert.ok(schools.items?.some(item => item.id === ids.scorelineSchool), 'scoreline school should exist');

  const records = await request('/api/scoreline/records', { query: { regionId: ids.region, pageSize: 5 } });
  assert.ok(records.total >= 1, 'scoreline records should have data');
  assert.ok(records.items?.some(item => item.fieldValues?.minScore === 188), 'scoreline record should include dynamic field values');

  const years = await request('/api/scoreline/years', { query: { regionId: ids.region } });
  assert.ok(years.items?.includes(2026), 'scoreline years should include 2026');
}

async function testVideos() {
  const single = await request(`/api/questions/${ids.question}/videos`);
  assert.ok(single.total >= 1, 'question should have videos');

  const batch = await request('/api/questions/videos/batch', {
    method: 'POST',
    body: { questionIds: [ids.question] },
  });
  assert.equal(batch.data?.[ids.question]?.hasVideo, true, 'batch video lookup should mark question as having video');

  const search = await request('/api/videos/search', { query: { tags: '烟测' } });
  assert.ok(search.videos?.some(item => item.title === '烟测题目视频讲解'), 'general video search should find smoke video');
}

async function testVocabulary() {
  const stats = await request('/api/learning/vocabulary/stats', { query: { unitId: ids.vocabularyUnit } });
  assert.ok(stats.item?.totalWords >= 1, 'word stats should count smoke word');

  const progress = await request('/api/learning/vocabulary/progress', {
    method: 'POST',
    body: { userId: USER_ID, wordId: ids.vocabularyWord, status: 'mastered', correctDelta: 1 },
  });
  assert.equal(progress.item?.status, 'mastered', 'word progress should update to mastered');

  const favorite = await request('/api/learning/vocabulary/favorites', {
    method: 'POST',
    body: { userId: USER_ID, wordId: ids.vocabularyWord, favorite: true },
  });
  assert.equal(favorite.favorite, true, 'word favorite should be true');

  const favorites = await request('/api/learning/vocabulary/favorites', { query: { unitId: ids.vocabularyUnit } });
  assert.ok(favorites.items?.some(item => item.wordId === ids.vocabularyWord), 'favorite list should include smoke word');
}

async function testCommerce() {
  const orders = await request('/api/commerce/orders');
  assert.ok(orders.items?.some(item => item.orderNo === 'SMOKE-ORDER-20260621'), 'orders should include smoke order');

  const redeemed = await request('/api/commerce/activation-codes/redeem', {
    method: 'POST',
    body: { code: 'SMOKE20260621', regionId: ids.region },
  });
  assert.ok(redeemed.item?.entitlement?.id, 'activation code should grant an entitlement');

  const entitlements = await request('/api/commerce/entitlements');
  assert.ok(Array.isArray(entitlements.items), 'entitlements should return a list');
  assert.ok(entitlements.summary && typeof entitlements.summary.isSvip === 'boolean', 'entitlements should include summary');
  assert.equal(entitlements.summary.isSvip, true, 'redeemed activation code should make smoke user SVIP');
}

async function testTenantIsolation() {
  const partnerQuestions = await request('/api/catalog/questions', {
    tenantId: PARTNER_TENANT_ID,
    query: { limit: 20 },
  });
  assert.ok(!partnerQuestions.items?.some(item => item.id === ids.question), 'partner tenant must not see main tenant question');

  const partnerProfile = await request('/api/profile/me', {
    tenantId: PARTNER_TENANT_ID,
    expectStatus: 404,
  });
  assert.equal(partnerProfile.code, 'PROFILE_NOT_FOUND', 'partner tenant must not see main tenant student profile');

  const partnerScoreline = await request('/api/scoreline/records', {
    tenantId: PARTNER_TENANT_ID,
    query: { regionId: ids.region },
  });
  assert.equal(partnerScoreline.total, 0, 'partner tenant must not see main tenant scoreline records');

  const partnerVideos = await request('/api/questions/videos/batch', {
    tenantId: PARTNER_TENANT_ID,
    method: 'POST',
    body: { questionIds: [ids.question] },
  });
  assert.equal(partnerVideos.data?.[ids.question], undefined, 'partner tenant must not see main tenant question videos');

  const partnerWordStats = await request('/api/learning/vocabulary/stats', {
    tenantId: PARTNER_TENANT_ID,
    query: { unitId: ids.vocabularyUnit },
  });
  assert.equal(partnerWordStats.item?.totalWords, 0, 'partner tenant must not see main tenant vocabulary words');

  const partnerEntries = await request('/api/catalog/content-entries', {
    tenantId: PARTNER_TENANT_ID,
    query: { regionId: ids.region },
  });
  assert.ok(!partnerEntries.items?.some(item => item.id === ids.contentEntry), 'partner tenant must not see main tenant content entries');

  const partnerCollections = await request('/api/catalog/question-collections', {
    tenantId: PARTNER_TENANT_ID,
    query: { nodeId: ids.contentNodeSchoolTarget },
  });
  assert.ok(!partnerCollections.items?.some(item => item.id === ids.questionCollection), 'partner tenant must not see main tenant collections');

  const partnerBlueprintSession = await request('/api/learning/practice-sessions', {
    tenantId: PARTNER_TENANT_ID,
    method: 'POST',
    body: { userId: USER_ID, blueprintId: ids.practiceBlueprintMock },
    expectStatus: 404,
  });
  assert.equal(partnerBlueprintSession.code, 'PRACTICE_BLUEPRINT_NOT_FOUND', 'partner tenant must not assemble main tenant blueprint');
}

async function testTenantContentAdmin() {
  const denied = await request('/api/tenant-content/vocabulary-units', {
    method: 'PUT',
    body: { name: '学生不能写入的单元' },
    expectStatus: 403,
  });
  assert.equal(denied.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'student should not write tenant content');

  const deniedEntry = await request('/api/tenant-content/content-entries', {
    method: 'PUT',
    body: { entryKey: 'student-denied', name: '学生不能配置入口' },
    expectStatus: 403,
  });
  assert.equal(deniedEntry.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'student should not manage content navigation');

  const entry = await request('/api/tenant-content/content-entries', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryKey: 'integration-practice',
      regionId: ids.region,
      name: '集成测试刷题入口',
      entryType: 'question_practice',
      route: '/practice/integration',
      layoutConfig: { tabs: ['all', 'paper', 'chapter', 'type'] },
      order: 11,
    },
  });
  assert.equal(entry.item?.entryKey, 'integration-practice', 'tenant admin should create content entry');

  const rootNode = await request('/api/tenant-content/content-nodes', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryId: entry.item.id,
      nodeKey: 'integration-professional',
      regionId: ids.region,
      name: '专业课',
      nodeType: 'category',
      markerType: 'exam_track',
      markerConfig: { intentKey: 'professional' },
      isLeaf: false,
      order: 1,
    },
  });
  assert.equal(rootNode.item?.markerType, 'exam_track', 'tenant admin should create marked root node');

  const childNode = await request('/api/tenant-content/content-nodes', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryId: entry.item.id,
      parentId: rootNode.item.id,
      nodeKey: 'integration-school-target',
      regionId: ids.region,
      name: '集成测试学院',
      nodeType: 'school',
      markerType: 'school',
      markerConfig: { salesIntent: true, schoolName: '集成测试学院' },
      isLeaf: true,
      order: 1,
    },
  });
  assert.equal(childNode.item?.parentId, rootNode.item.id, 'tenant admin should create child node');
  assert.ok(String(childNode.item?.path || '').includes(String(rootNode.item?.path || '')), 'child node should have hierarchical path');

  const unit = await request('/api/tenant-content/vocabulary-units', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      regionId: ids.region,
      name: '集成测试单词单元',
      description: '租户后台内容维护集成测试',
      order: 99,
    },
  });
  assert.ok(unit.item?.id, 'tenant admin should create vocabulary unit');

  const word = await request('/api/tenant-content/vocabulary-words', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      unitId: unit.item.id,
      word: 'commercial',
      phonetic: '/kəˈmɜːrʃl/',
      meaning: '商业的',
      tags: ['integration'],
    },
  });
  assert.equal(word.item?.word, 'commercial', 'tenant admin should create vocabulary word');

  const video = await request('/api/tenant-content/videos', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      title: '集成测试视频',
      videoUrl: 'https://example.test/videos/integration.mp4',
      knowledgeTags: ['integration'],
      isGeneral: true,
    },
  });
  assert.ok(video.item?.id, 'tenant admin should create video');

  const question = await request('/api/tenant-content/questions', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      subjectId: '00000000-0000-0000-0000-000000000501',
      categoryId: '00000000-0000-0000-0000-000000000601',
      entryId: entry.item.id,
      contentNodeId: childNode.item.id,
      type: 'choice',
      typeLabel: '单选题',
      difficulty: 2,
      content: '集成测试题：2 + 2 = ?',
      options: [
        { label: 'A', text: '3' },
        { label: 'B', text: '4' },
      ],
      correctOptionIndex: 1,
      correctOptionIndices: [1],
      answerText: '4',
      explanation: '基础加法。',
      status: 'published',
      examMarkers: { schoolName: '集成测试学院', salesIntent: true },
    },
  });
  assert.ok(question.item?.id, 'tenant admin should create question');
  assert.equal(question.item?.currentVersion?.correctOptionIndex, 1, 'created question should have a version');

  const collection = await request('/api/tenant-content/question-collections', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryId: entry.item.id,
      nodeId: childNode.item.id,
      regionId: ids.region,
      subjectId: ids.subject,
      categoryId: ids.category,
      questionBankId: '00000000-0000-0000-0000-000000000400',
      name: '集成测试题目列表',
      collectionType: 'manual',
      sourceType: 'manual_questions',
      durationMinutes: 90,
      totalScore: 100,
      questions: [{ questionId: question.item.id, sectionKey: 'choice', order: 1, score: 2 }],
    },
  });
  assert.equal(collection.item?.questionCount, 1, 'tenant admin should create question collection with items');

  const blueprint = await request('/api/tenant-content/practice-blueprints', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryId: entry.item.id,
      nodeId: childNode.item.id,
      collectionId: collection.item.id,
      regionId: ids.region,
      name: '集成测试全真模拟',
      mode: 'mock_exam',
      assemblyType: 'collection',
      questionLimit: 10,
      durationMinutes: 90,
      totalScore: 100,
      passScore: 60,
      sections: [{ key: 'choice', questionType: 'choice', questionCount: 10, scoreEach: 2 }],
      rules: { randomize: true },
    },
  });
  assert.equal(blueprint.item?.mode, 'mock_exam', 'tenant admin should create mock exam blueprint');

  const adminNodes = await request('/api/tenant-content/content-nodes', {
    userId: TENANT_ADMIN_USER_ID,
    query: { entryId: entry.item.id, mode: 'flat' },
  });
  assert.ok(adminNodes.items?.some(item => item.id === childNode.item.id), 'tenant admin should list created navigation nodes');

  const publicCreatedCollections = await request('/api/catalog/question-collections', {
    query: { nodeId: childNode.item.id },
  });
  assert.ok(publicCreatedCollections.items?.some(item => item.id === collection.item.id), 'catalog should expose created collection');

  const createdBlueprintSession = await request('/api/learning/practice-sessions', {
    method: 'POST',
    body: { userId: USER_ID, blueprintId: blueprint.item.id },
  });
  assert.equal(createdBlueprintSession.item?.blueprintId, blueprint.item.id, 'created blueprint should assemble a practice session');
  assert.ok(createdBlueprintSession.item?.questionIds?.includes(question.item.id), 'created blueprint session should include created question');

  const binding = await request('/api/tenant-content/question-videos', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { questionId: question.item.id, videoId: video.item.id, videoType: 'specific' },
  });
  assert.equal(binding.item?.questionId, question.item.id, 'tenant admin should bind question video');

  const scoreSchool = await request('/api/tenant-content/scoreline/schools', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: { regionId: ids.region, name: '集成测试学院', shortName: '集测学院', isHot: true },
  });
  assert.ok(scoreSchool.item?.id, 'tenant admin should create scoreline school');

  const scoreMajor = await request('/api/tenant-content/scoreline/majors', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: { regionId: ids.region, schoolId: scoreSchool.item.id, name: '软件工程' },
  });
  assert.ok(scoreMajor.item?.id, 'tenant admin should create scoreline major');

  const scoreRecord = await request('/api/tenant-content/scoreline/records', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      regionId: ids.region,
      schoolId: scoreSchool.item.id,
      majorId: scoreMajor.item.id,
      year: 2026,
      schoolName: '集成测试学院',
      majorName: '软件工程',
      fieldValues: { minScore: 199 },
    },
  });
  assert.equal(scoreRecord.item?.fieldValues?.minScore, 199, 'tenant admin should create scoreline record');

  const handbookSubject = await request('/api/tenant-content/handbook-subjects', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: { regionId: ids.region, name: '集成测试手册', type: 'guide' },
  });
  assert.ok(handbookSubject.item?.id, 'tenant admin should create handbook subject');

  const handbookChapter = await request('/api/tenant-content/handbook-chapters', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: { subjectId: handbookSubject.item.id, name: '第一章' },
  });
  assert.ok(handbookChapter.item?.id, 'tenant admin should create handbook chapter');

  const handbookEntry = await request('/api/tenant-content/handbook-entries', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: { chapterId: handbookChapter.item.id, title: '商用交付标准', content: '内容维护必须可测试。' },
  });
  assert.equal(handbookEntry.item?.title, '商用交付标准', 'tenant admin should create handbook entry');

  const partnerWrite = await request('/api/tenant-content/question-videos', {
    tenantId: PARTNER_TENANT_ID,
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { questionId: question.item.id, videoId: video.item.id },
    expectStatus: 403,
  });
  assert.equal(partnerWrite.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'admin user must not administer another tenant without membership');
}

async function testTenantContentAssetsAndImports() {
  const deniedAsset = await request('/api/tenant-content/assets', {
    method: 'PUT',
    body: { title: '学生不能上传资料', cdnUrl: 'https://example.test/denied.pdf' },
    expectStatus: 403,
  });
  assert.equal(deniedAsset.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'student should not manage content assets');

  const upload = await request('/api/tenant-content/assets/sign-upload', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      fileName: 'integration-resource.pdf',
      assetType: 'pdf',
      storageProvider: 'local_dev',
      mimeType: 'application/pdf',
    },
  });
  assert.equal(upload.assetDraft?.assetType, 'pdf', 'upload signer should return asset draft');
  assert.ok(upload.upload?.objectKey?.includes(MAIN_TENANT_ID), 'upload object key should be tenant scoped');
  assert.equal(upload.upload?.signatureMode, 'local-placeholder', 'local signer should be explicit in test env');
  assert.equal(upload.upload?.headers?.['content-type'], 'application/pdf', 'upload signer should bind content-type');
  assert.ok(!JSON.stringify(upload).includes('ACCESS_KEY'), 'upload signer must not leak cloud credentials');

  if (ENABLE_REAL_STORAGE_SIGN_TESTS) {
    const tencentUpload = await request('/api/tenant-content/assets/sign-upload', {
      userId: TENANT_ADMIN_USER_ID,
      method: 'POST',
      body: {
        fileName: 'cos-resource.pdf',
        assetType: 'pdf',
        storageProvider: 'tencent_cos',
        bucket: process.env.TEST_TENCENT_COS_BUCKET || 'tenant-assets',
        objectKey: `${MAIN_TENANT_ID}/pdf/cos-resource.pdf`,
        mimeType: 'application/pdf',
      },
    });
    assert.ok(tencentUpload.upload?.url?.includes('q-sign-algorithm=sha1'), 'Tencent COS signed URL should expose XML V5 query params');
    assert.ok(!tencentUpload.upload?.url?.includes('SecretKey'), 'Tencent COS signed URL must not leak SecretKey');
  }

  const unsafeUpload = await request('/api/tenant-content/assets/sign-upload', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      fileName: 'unsafe.pdf',
      assetType: 'pdf',
      storageProvider: 'local_dev',
      objectKey: '../escape.pdf',
      mimeType: 'application/pdf',
    },
    expectStatus: 400,
  });
  assert.equal(unsafeUpload.code, 'INVALID_OBJECT_KEY', 'upload signer should reject path traversal object keys');

  const crossTenantUpload = await request('/api/tenant-content/assets/sign-upload', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      fileName: 'cross-tenant.pdf',
      assetType: 'pdf',
      storageProvider: 'local_dev',
      objectKey: `${PARTNER_TENANT_ID}/pdf/cross-tenant.pdf`,
      mimeType: 'application/pdf',
    },
    expectStatus: 400,
  });
  assert.equal(crossTenantUpload.code, 'OBJECT_KEY_TENANT_PREFIX_REQUIRED', 'upload object key should stay in current tenant prefix');

  const deniedMimeUpload = await request('/api/tenant-content/assets/sign-upload', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      fileName: 'script.html',
      assetType: 'document',
      storageProvider: 'local_dev',
      mimeType: 'text/html',
    },
    expectStatus: 400,
  });
  assert.equal(deniedMimeUpload.code, 'MIME_TYPE_NOT_ALLOWED', 'upload signer should reject unsupported mime types');

  const deniedLargeUpload = await request('/api/tenant-content/assets/sign-upload', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      fileName: 'huge-video.mp4',
      assetType: 'video',
      storageProvider: 'local_dev',
      mimeType: 'video/mp4',
      fileSizeBytes: 1024 * 1024 * 1024,
    },
    expectStatus: 400,
  });
  assert.equal(deniedLargeUpload.code, 'FILE_TOO_LARGE', 'upload signer should enforce max upload size');

  const asset = await request('/api/tenant-content/assets', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      title: '集成测试 SVIP PDF 资料',
      assetType: 'pdf',
      storageProvider: 'external_url',
      cdnUrl: 'https://example.test/resources/integration.pdf',
      previewUrl: 'https://example.test/resources/integration-preview.pdf',
      fileName: 'integration.pdf',
      mimeType: 'application/pdf',
      fileSizeBytes: 2048,
      visibility: 'svip',
      regionId: ids.region,
      subjectId: ids.subject,
      categoryId: ids.category,
      metadata: { source: 'api-integration' },
    },
  });
  assert.equal(asset.item?.visibility, 'svip', 'tenant admin should create svip asset');

  const adminAssets = await request('/api/tenant-content/assets', {
    userId: TENANT_ADMIN_USER_ID,
    query: { assetType: 'pdf', regionId: ids.region },
  });
  assert.ok(adminAssets.items?.some(item => item.id === asset.item.id), 'tenant admin should list own asset');
  assert.ok(!JSON.stringify(adminAssets).includes('apiV3Key'), 'asset list should not expose unrelated secrets');

  const publicAssets = await request('/api/catalog/assets', {
    userId: false,
    query: { assetType: 'pdf', regionId: ids.region, includeLocked: true },
  });
  assert.ok(!publicAssets.items?.some(item => item.id === asset.item.id), 'anonymous catalog should not list locked svip asset');

  const lockedAssets = await request('/api/catalog/assets', {
    query: { assetType: 'pdf', regionId: ids.region, includeLocked: true },
  });
  assert.ok(lockedAssets.items?.some(item => item.id === asset.item.id), 'student catalog should list locked svip asset');

  const download = await request('/api/catalog/assets/download', {
    query: { assetId: asset.item.id },
  });
  assert.equal(download.item?.id, asset.item.id, 'svip student should receive asset download');
  assert.equal(download.access?.svip, true, 'asset download should report svip access');
  assert.equal(download.download?.url, 'https://example.test/resources/integration.pdf', 'external asset download should use cdn url');
  assert.equal(download.download?.signatureMode, 'public-or-provider-managed', 'external asset should be marked provider managed');

  const localAsset = await request('/api/tenant-content/assets', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      title: '集成测试本地对象资料',
      assetType: 'pdf',
      storageProvider: 'local_dev',
      bucket: upload.assetDraft.bucket,
      objectKey: upload.assetDraft.objectKey,
      fileName: upload.assetDraft.fileName,
      mimeType: upload.assetDraft.mimeType,
      fileSizeBytes: upload.assetDraft.fileSizeBytes,
      visibility: 'tenant',
      status: 'active',
    },
  });
  assert.equal(localAsset.item?.objectKey, upload.assetDraft.objectKey, 'asset upsert should keep normalized object key');

  const localDownload = await request('/api/catalog/assets/download', {
    query: { assetId: localAsset.item.id },
  });
  assert.equal(localDownload.download?.method, 'GET', 'object asset download should sign GET');
  assert.equal(localDownload.download?.signatureMode, 'local-placeholder', 'local object asset should use local placeholder signer');
  assert.ok(localDownload.download?.url?.includes(encodeURIComponent(localAsset.item.bucket)), 'object asset download should include bucket');

  const invalidObjectAsset = await request('/api/tenant-content/assets', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      title: '非法对象键',
      assetType: 'pdf',
      storageProvider: 'local_dev',
      bucket: 'tenant-assets',
      objectKey: `${PARTNER_TENANT_ID}/pdf/unsafe.pdf`,
      fileName: 'unsafe.pdf',
      mimeType: 'application/pdf',
      visibility: 'tenant',
      status: 'active',
    },
    expectStatus: 400,
  });
  assert.equal(invalidObjectAsset.code, 'OBJECT_KEY_TENANT_PREFIX_REQUIRED', 'asset upsert should reject cross-tenant object keys');

  const partnerAssetList = await request('/api/tenant-content/assets', {
    tenantId: PARTNER_TENANT_ID,
    userId: TENANT_ADMIN_USER_ID,
    expectStatus: 403,
  });
  assert.equal(partnerAssetList.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'asset admin must be tenant isolated');

  const deniedImport = await request('/api/tenant-content/imports/preview/questions', {
    method: 'POST',
    body: {
      subjectId: ids.subject,
      categoryId: ids.category,
      items: [{ type: 'choice', content: '学生不能预览导入', options: ['A', 'B'], correctOptionIndices: [0] }],
    },
    expectStatus: 403,
  });
  assert.equal(deniedImport.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'student should not preview content import');

  const invalidPreview = await request('/api/tenant-content/imports/preview/questions', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      sourceName: 'invalid-question-import.json',
      subjectId: ids.subject,
      categoryId: ids.category,
      regionId: ids.region,
      items: [
        {
          type: 'choice',
          content: '错误导入题：缺少选项和答案',
          options: [],
          correctOptionIndices: [],
        },
      ],
    },
  });
  assert.equal(invalidPreview.job?.errorCount > 0, true, 'invalid preview should record errors');
  assert.ok(invalidPreview.issues?.some(issue => issue.code === 'OPTIONS_REQUIRED'), 'invalid preview should include option issue');

  const invalidIssues = await request('/api/tenant-content/imports/issues', {
    userId: TENANT_ADMIN_USER_ID,
    query: { jobId: invalidPreview.job.id },
  });
  assert.ok(invalidIssues.items?.some(item => item.code === 'OPTIONS_REQUIRED'), 'import issues API should return validation issues');

  const rejectedImport = await request('/api/tenant-content/imports/questions', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { previewJobId: invalidPreview.job.id },
    expectStatus: 409,
  });
  assert.equal(rejectedImport.code, 'IMPORT_HAS_ERRORS', 'invalid import should be rejected without allowPartial');

  const validPreview = await request('/api/tenant-content/imports/preview/questions', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      sourceName: 'valid-question-import.json',
      subjectId: ids.subject,
      categoryId: ids.category,
      regionId: ids.region,
      entryId: ids.contentEntry,
      contentNodeId: ids.contentNodeSchoolTarget,
      collectionId: ids.questionCollection,
      items: [
        {
          legacyId: 'integration-import-choice-001',
          type: 'choice',
          typeLabel: '单选题',
          content: '批量导入题：企业级 SaaS 应优先使用哪种数据库？',
          options: ['SQLite', 'PostgreSQL', '纯 JSON 文件', '浏览器缓存'],
          correctOptionIndices: [1],
          explanation: 'PostgreSQL 更适合多租户商用场景。',
          difficulty: 2,
          tags: ['integration', 'import'],
        },
        {
          legacyId: 'integration-import-reading-001',
          type: 'reading',
          content: '阅读材料：多租户系统需要隔离租户数据。',
          sub_questions: [
            {
              type: 'choice',
              content: '多租户系统最重要的边界是什么？',
              options: ['颜色主题', '数据隔离', '页面动画', '字体大小'],
              correctOptionIndices: [1],
            },
          ],
          tags: ['integration', 'reading'],
        },
      ],
    },
  });
  assert.equal(validPreview.job?.errorCount, 0, 'valid preview should have no errors');
  assert.equal(validPreview.job?.validCount, 2, 'valid preview should count valid rows');

  const imported = await request('/api/tenant-content/imports/questions', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { previewJobId: validPreview.job.id },
  });
  assert.equal(imported.item?.status, 'completed', 'valid import should complete');
  assert.equal(
    (imported.item?.insertedCount || 0) + (imported.item?.updatedCount || 0) + (imported.item?.skippedCount || 0),
    2,
    'valid import should process all valid questions idempotently',
  );

  const jobs = await request('/api/tenant-content/imports', {
    userId: TENANT_ADMIN_USER_ID,
    query: { importType: 'questions', limit: 10 },
  });
  assert.ok(jobs.items?.some(item => item.id === validPreview.job.id && item.status === 'completed'), 'import job list should include completed job');

  const importedQuestions = await request('/api/catalog/questions', {
    query: { collectionId: ids.questionCollection, limit: 100 },
  });
  assert.ok(
    importedQuestions.items?.some(item => item.content === '批量导入题：企业级 SaaS 应优先使用哪种数据库？'),
    'catalog should expose imported question through the new collection binding',
  );

  const vocabEntry = await request('/api/tenant-content/content-entries', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryKey: 'integration-vocabulary',
      regionId: ids.region,
      name: '集成测试背单词入口',
      entryType: 'vocabulary',
      route: '/vocabulary',
      order: 21,
    },
  });
  const vocabRoot = await request('/api/tenant-content/content-nodes', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryId: vocabEntry.item.id,
      regionId: ids.region,
      nodeKey: 'integration-vocabulary-root',
      name: '英语核心词',
      nodeType: 'category',
      isLeaf: false,
    },
  });

  const deniedVocabularyPreview = await request('/api/tenant-content/imports/preview/vocabulary', {
    method: 'POST',
    body: {
      units: [{ name: '学生不能导入单词', words: [{ word: 'deny', meaning: '拒绝' }] }],
    },
    expectStatus: 403,
  });
  assert.equal(deniedVocabularyPreview.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'student should not preview vocabulary import');

  const invalidVocabularyPreview = await request('/api/tenant-content/imports/preview/vocabulary', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      sourceName: 'invalid-vocabulary-import.json',
      entryId: vocabEntry.item.id,
      contentNodeId: vocabRoot.item.id,
      vocabulary_units_示例数据: [
        { legacyId: 'integration-vocab-invalid-unit', name: '旧格式错误单词单元', order: 1 },
      ],
      vocabulary_示例数据: [
        { unitId: 'integration-vocab-invalid-unit', word: '', meaning: '', order: 1 },
      ],
    },
  });
  assert.ok(invalidVocabularyPreview.issues?.some(issue => issue.code === 'VOCABULARY_WORD_REQUIRED'), 'invalid vocabulary preview should validate word');
  assert.ok(invalidVocabularyPreview.issues?.some(issue => issue.code === 'VOCABULARY_MEANING_REQUIRED'), 'invalid vocabulary preview should validate meaning');

  const rejectedVocabularyImport = await request('/api/tenant-content/imports/vocabulary', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { previewJobId: invalidVocabularyPreview.job.id },
    expectStatus: 409,
  });
  assert.equal(rejectedVocabularyImport.code, 'IMPORT_HAS_ERRORS', 'invalid vocabulary import should be rejected');

  const vocabularyPreview = await request('/api/tenant-content/imports/preview/vocabulary', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      sourceName: 'legacy-vocabulary-import.json',
      regionId: ids.region,
      entryId: vocabEntry.item.id,
      contentNodeId: vocabRoot.item.id,
      vocabulary_units_示例数据: [
        {
          legacyId: 'integration-vocab-unit-001',
          name: 'Unit 1 - 高频核心词',
          description: '旧模板字段导入验证',
          order: 1,
          isActive: true,
        },
      ],
      vocabulary_示例数据: [
        {
          legacyId: 'integration-vocab-word-abandon',
          unitId: 'integration-vocab-unit-001',
          word: 'abandon',
          phonetic: '/əˈbændən/',
          meaning: 'v. 放弃，抛弃',
          example: 'He had to abandon his car in the snow.',
          exampleTranslation: '他不得不把车丢弃在雪地里。',
          difficulty: 3,
          tags: ['高频词', '考纲核心'],
          order: 1,
          isActive: true,
        },
      ],
    },
  });
  assert.equal(vocabularyPreview.job?.errorCount, 0, 'valid vocabulary preview should have no errors');

  const vocabularyImport = await request('/api/tenant-content/imports/vocabulary', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { previewJobId: vocabularyPreview.job.id },
  });
  assert.equal(vocabularyImport.item?.status, 'completed', 'valid vocabulary import should complete');
  assert.ok(
    (vocabularyImport.item?.insertedCount || 0) + (vocabularyImport.item?.updatedCount || 0) + (vocabularyImport.item?.skippedCount || 0) >= 2,
    'vocabulary import should process unit and word idempotently',
  );

  const vocabularyUnits = await request('/api/catalog/vocabulary-units', {
    query: { regionId: ids.region },
  });
  const importedVocabularyUnit = vocabularyUnits.items?.find(item => item.legacyId === 'integration-vocab-unit-001');
  assert.ok(importedVocabularyUnit, 'catalog should expose imported vocabulary unit');
  assert.equal(importedVocabularyUnit.entryId, vocabEntry.item.id, 'vocabulary unit should bind content entry');

  const vocabularyWords = await request('/api/catalog/vocabulary-words', {
    query: { unitId: importedVocabularyUnit.id },
  });
  assert.ok(vocabularyWords.items?.some(item => item.word === 'abandon' && item.contentNodeId), 'catalog should expose imported vocabulary word with node binding');

  const handbookEntry = await request('/api/tenant-content/content-entries', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryKey: 'integration-handbook',
      regionId: ids.region,
      name: '集成测试知识手册入口',
      entryType: 'handbook',
      route: '/handbook',
      order: 22,
    },
  });
  const handbookRoot = await request('/api/tenant-content/content-nodes', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      entryId: handbookEntry.item.id,
      regionId: ids.region,
      nodeKey: 'integration-handbook-root',
      name: '文化课',
      nodeType: 'category',
      isLeaf: false,
    },
  });

  const handbookPreview = await request('/api/tenant-content/imports/preview/handbook', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      sourceName: 'handbook-nested-import.json',
      regionId: ids.region,
      entryId: handbookEntry.item.id,
      contentNodeId: handbookRoot.item.id,
      subjects: [
        {
          legacyId: 'integration-handbook-chinese',
          name: '大学语文',
          type: 'guide',
          icon: 'book-open',
          color: '#10B981',
          chapters: [
            {
              legacyId: 'integration-handbook-chapter-outline',
              name: '一、语文考纲',
              sections: [
                {
                  legacyId: 'integration-handbook-section-outline',
                  name: '考纲解读',
                  entries: [
                    {
                      legacyId: 'integration-handbook-entry-outline',
                      title: '2024年天津专升本语文考试大纲',
                      summary: '全面解读语文考试要求和考点分布',
                      content: '一、考试性质\n\n天津市高职升本科招生统一考试是选拔性考试。',
                      tags: ['考纲', '必读'],
                      order: 1,
                    },
                  ],
                },
              ],
            },
          ],
        },
      ],
    },
  });
  assert.equal(handbookPreview.job?.errorCount, 0, 'valid handbook preview should have no errors');

  const handbookImport = await request('/api/tenant-content/imports/handbook', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { previewJobId: handbookPreview.job.id },
  });
  assert.equal(handbookImport.item?.status, 'completed', 'valid handbook import should complete');
  assert.ok(
    (handbookImport.item?.insertedCount || 0) + (handbookImport.item?.updatedCount || 0) + (handbookImport.item?.skippedCount || 0) >= 3,
    'handbook import should process subject, chapter, and entry idempotently',
  );

  const handbookSubjects = await request('/api/catalog/handbook-subjects', {
    query: { regionId: ids.region },
  });
  const importedHandbookSubject = handbookSubjects.items?.find(item => item.legacyId === 'integration-handbook-chinese');
  assert.ok(importedHandbookSubject, 'catalog should expose imported handbook subject');
  assert.equal(importedHandbookSubject.entryId, handbookEntry.item.id, 'handbook subject should bind content entry');

  const handbookChapters = await request('/api/catalog/handbook-chapters', {
    query: { subjectId: importedHandbookSubject.id },
  });
  const importedHandbookChapter = handbookChapters.items?.find(item => item.legacyId === 'integration-handbook-chapter-outline');
  assert.ok(importedHandbookChapter, 'catalog should expose imported handbook chapter');

  const handbookEntries = await request('/api/catalog/handbook-entries', {
    query: { chapterId: importedHandbookChapter.id, includeContent: true },
  });
  assert.ok(
    handbookEntries.items?.some(item => item.legacyId === 'integration-handbook-entry-outline' && item.content?.includes('选拔性考试')),
    'catalog should expose imported handbook entry content',
  );

  const importJobs = await request('/api/tenant-content/imports', {
    userId: TENANT_ADMIN_USER_ID,
    query: { importType: 'vocabulary', limit: 10 },
  });
  assert.ok(importJobs.items?.some(item => item.id === vocabularyPreview.job.id && item.status === 'completed'), 'import job list should include completed vocabulary job');

  const partnerImports = await request('/api/tenant-content/imports', {
    tenantId: PARTNER_TENANT_ID,
    userId: TENANT_ADMIN_USER_ID,
    expectStatus: 403,
  });
  assert.equal(partnerImports.code, 'TENANT_CONTENT_EDITOR_REQUIRED', 'import jobs must be tenant isolated');
}

async function testTenantAdminOps() {
  const denied = await request('/api/tenant-admin/branding', {
    method: 'PUT',
    body: { brandName: '学生不能改品牌' },
    expectStatus: 403,
  });
  assert.equal(denied.code, 'TENANT_ADMIN_REQUIRED', 'student should not access tenant admin config');

  const overview = await request('/api/tenant-admin/overview', {
    userId: TENANT_ADMIN_USER_ID,
  });
  assert.equal(overview.item?.id, MAIN_TENANT_ID, 'tenant admin overview should belong to main tenant');

  const branding = await request('/api/tenant-admin/branding', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      brandName: '集成测试品牌',
      shortName: '集测题库',
      slogan: '一套前端服务多个合作商',
      logoUrl: 'https://example.test/logo.png',
      theme: { primaryColor: '#0f766e' },
      publicAssets: { h5Logo: 'https://example.test/h5-logo.png' },
    },
  });
  assert.equal(branding.item?.brandName, '集成测试品牌', 'tenant admin should update branding');

  const publicSecretRejected = await request('/api/tenant-admin/auth-providers', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      provider: 'wechat-miniapp',
      status: 'testing',
      configPublic: {
        appId: 'wx-smoke-appid',
        appSecret: 'must-not-be-public',
      },
    },
    expectStatus: 400,
  });
  assert.equal(publicSecretRejected.code, 'PUBLIC_CONFIG_SECRET_REJECTED', 'public config should reject secret-like keys');

  const authProvider = await request('/api/tenant-admin/auth-providers', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      provider: 'wechat-miniapp',
      displayName: '微信小程序登录',
      status: 'testing',
      configPublic: {
        appId: 'wx-smoke-appid',
        envVersion: 'trial',
      },
      secret: {
        secretValue: 'wechat-app-secret-smoke',
      },
    },
  });
  assert.equal(authProvider.item?.provider, 'wechat-miniapp', 'tenant admin should upsert auth provider');
  assert.equal(authProvider.item?.configPublic?.secretRef, 'app_private.tenant_secrets:oauth:wechat-miniapp', 'auth provider should expose only secretRef');
  assert.equal(authProvider.item?.secret?.hasSecretValue, true, 'auth provider should report masked secret status');
  assert.ok(!JSON.stringify(authProvider).includes('wechat-app-secret-smoke'), 'auth provider response must not include secret plaintext');

  const paymentAccount = await request('/api/tenant-admin/payment-accounts', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      provider: 'wechat_pay',
      mode: 'tenant_collect',
      displayName: '合作商微信商户',
      status: 'pending',
      configPublic: {
        merchantId: '1900000001',
        appId: 'wx-smoke-appid',
        notifyUrl: 'https://pay.example.test/wechat/notify',
      },
      secret: {
        secretJson: {
          apiV3Key: 'wechat-pay-api-v3-key',
          merchantSerialNo: 'serial-smoke',
        },
      },
    },
  });
  assert.equal(paymentAccount.item?.provider, 'wechat_pay', 'tenant admin should upsert payment account');
  assert.equal(paymentAccount.item?.configPublic?.secretRef, 'app_private.tenant_secrets:payment:wechat_pay', 'payment account should expose only secretRef');
  assert.ok(!JSON.stringify(paymentAccount).includes('wechat-pay-api-v3-key'), 'payment response must not include secret json values');

  const secrets = await request('/api/tenant-admin/secrets', {
    userId: TENANT_ADMIN_USER_ID,
    query: { scope: 'payment' },
  });
  assert.ok(secrets.items?.some(item => item.secretRef === 'app_private.tenant_secrets:payment:wechat_pay'), 'masked secret list should include payment secretRef');
  assert.ok(!JSON.stringify(secrets).includes('wechat-pay-api-v3-key'), 'secret list must not leak secret json values');

  const banner = await request('/api/tenant-admin/banners', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      regionId: ids.region,
      title: '集成测试活动',
      subtitle: '租户自有活动位',
      content: '合作商可配置自己的首页 Banner',
      buttonText: '查看会员',
      buttonLink: '/store',
      order: 7,
      isActive: true,
    },
  });
  assert.equal(banner.item?.title, '集成测试活动', 'tenant admin should upsert banner');

  const faq = await request('/api/tenant-admin/faqs', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      regionId: ids.region,
      question: '合作商能否配置自己的支付商户？',
      answer: '可以，密钥写入私密表，前端只拿公开配置。',
      order: 8,
    },
  });
  assert.equal(faq.item?.question, '合作商能否配置自己的支付商户？', 'tenant admin should upsert faq');

  const announcement = await request('/api/tenant-admin/announcements', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      content: '集成测试公告',
      link: '/announcements/integration',
      bgColor: '#f0fdfa',
      order: 9,
    },
  });
  assert.equal(announcement.item?.content, '集成测试公告', 'tenant admin should upsert announcement');

  const publicBanners = await request('/api/catalog/banners', {
    query: { regionId: ids.region },
  });
  assert.ok(publicBanners.items?.some(item => item.title === '集成测试活动'), 'public catalog should expose active tenant banner');

  const batch = await request('/api/tenant-admin/code-batches', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      name: '集成测试激活码批次',
      saleType: 'saas_partner',
      channel: 'offline',
      campaignName: 'partner-onboarding',
      defaultUnitPriceCents: 9900,
      days: 365,
      regionId: ids.region,
      remark: '用于租户后台接口测试',
    },
  });
  assert.ok(batch.item?.id, 'tenant admin should create code batch');

  const generated = await request('/api/tenant-admin/activation-codes/generate', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      batchId: batch.item.id,
      count: 2,
      prefix: 'IT',
      soldTo: 'integration-partner',
    },
  });
  assert.equal(generated.count, 2, 'tenant admin should batch generate activation codes');
  assert.ok(generated.items?.every(item => String(item.code).startsWith('IT')), 'generated codes should use prefix');

  const activationCode = await request('/api/tenant-admin/activation-codes', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      code: 'IT-MANUAL-001',
      days: 30,
      batchId: batch.item.id,
      soldTo: 'manual-customer',
      remark: 'manual integration code',
    },
  });
  assert.equal(activationCode.item?.code, 'IT-MANUAL-001', 'tenant admin should upsert activation code');

  const coupon = await request('/api/tenant-admin/coupons', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      code: 'IT-COUPON-001',
      planId: '00000000-0000-0000-0000-000000000201',
      discountType: 'fixed',
      discountValue: 10,
      maxUses: 100,
      source: 'integration-test',
    },
  });
  assert.equal(coupon.item?.code, 'IT-COUPON-001', 'tenant admin should upsert coupon');

  const partnerDenied = await request('/api/tenant-admin/auth-providers', {
    tenantId: PARTNER_TENANT_ID,
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      provider: 'qq-oauth',
      configPublic: { appId: 'qq-smoke' },
    },
    expectStatus: 403,
  });
  assert.equal(partnerDenied.code, 'TENANT_ADMIN_REQUIRED', 'tenant admin must not administer another tenant without membership');
}

async function testTenantMemberPermissionsAndAudit() {
  const permissionMatrix = await request('/api/tenant-admin/permissions', {
    userId: TENANT_ADMIN_USER_ID,
  });
  assert.ok(permissionMatrix.permissions?.some(item => item.key === 'marketing:write'), 'permission matrix should expose marketing permission');
  assert.ok(permissionMatrix.roleDefaults?.tenant_operator?.includes('marketing:*'), 'permission matrix should include role defaults');

  const operator = await request('/api/tenant-admin/members', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      userId: TENANT_OPERATOR_USER_ID,
      username: 'integration_operator',
      phone: '13800000003',
      name: 'Integration Operator',
      role: 'tenant_operator',
      status: 'active',
      permissions: {
        'marketing:*': true,
        'tenant:payment:*': false,
      },
    },
  });
  assert.equal(operator.item?.role, 'tenant_operator', 'tenant admin should create operator membership');

  const members = await request('/api/tenant-admin/members', {
    userId: TENANT_ADMIN_USER_ID,
    query: { keyword: 'Integration Operator' },
  });
  assert.ok(members.items?.some(item => item.userId === TENANT_OPERATOR_USER_ID), 'member list should find operator');

  const operatorBanner = await request('/api/tenant-admin/banners', {
    userId: TENANT_OPERATOR_USER_ID,
    method: 'PUT',
    body: {
      regionId: ids.region,
      title: '运营角色活动位',
      content: '运营成员可以维护活动内容',
      order: 17,
    },
  });
  assert.equal(operatorBanner.item?.title, '运营角色活动位', 'operator should write marketing content');

  const operatorPaymentDenied = await request('/api/tenant-admin/payment-accounts', {
    userId: TENANT_OPERATOR_USER_ID,
    method: 'PUT',
    body: {
      provider: 'alipay',
      mode: 'tenant_collect',
      configPublic: { appId: 'alipay-appid' },
    },
    expectStatus: 403,
  });
  assert.equal(operatorPaymentDenied.code, 'TENANT_PERMISSION_REQUIRED', 'operator should not write payment config');

  const grantAdminDenied = await request('/api/tenant-admin/members', {
    userId: TENANT_OPERATOR_USER_ID,
    method: 'PUT',
    body: {
      userId: TENANT_SALES_USER_ID,
      role: 'tenant_admin',
      permissions: { '*': true },
    },
    expectStatus: 403,
  });
  assert.equal(grantAdminDenied.code, 'TENANT_PERMISSION_REQUIRED', 'operator should not manage members without permission');

  const sales = await request('/api/tenant-admin/members', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      userId: TENANT_SALES_USER_ID,
      username: 'integration_sales',
      phone: '13800000004',
      name: 'Integration Sales',
      role: 'sales',
      status: 'active',
      permissions: {
        'codes:*': true,
        'coupons:*': true,
      },
    },
  });
  assert.equal(sales.item?.role, 'sales', 'tenant admin should create sales membership');

  const salesBatch = await request('/api/tenant-admin/code-batches', {
    userId: TENANT_SALES_USER_ID,
    method: 'PUT',
    body: {
      name: '销售角色批次',
      saleType: 'sales',
      defaultUnitPriceCents: 19900,
      days: 180,
    },
  });
  assert.ok(salesBatch.item?.id, 'sales role should create code batch');

  const salesBrandingDenied = await request('/api/tenant-admin/branding', {
    userId: TENANT_SALES_USER_ID,
    method: 'PUT',
    body: {
      brandName: '销售不能改品牌',
    },
    expectStatus: 403,
  });
  assert.equal(salesBrandingDenied.code, 'TENANT_PERMISSION_REQUIRED', 'sales role should not update branding');

  const disableSales = await request('/api/tenant-admin/members/disable', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: { membershipId: sales.item.id },
  });
  assert.equal(disableSales.item?.status, 'disabled', 'tenant admin should disable sales membership');

  const disabledSalesDenied = await request('/api/tenant-admin/code-batches', {
    userId: TENANT_SALES_USER_ID,
    method: 'PUT',
    body: {
      name: '禁用后不能新建批次',
      days: 10,
    },
    expectStatus: 403,
  });
  assert.equal(disabledSalesDenied.code, 'TENANT_ADMIN_REQUIRED', 'disabled sales membership should lose tenant admin access');

  const auditLogs = await request('/api/tenant-admin/audit-logs', {
    userId: TENANT_ADMIN_USER_ID,
    query: { action: 'tenant.member', limit: 20 },
  });
  assert.ok(auditLogs.items?.some(item => item.action === 'tenant.member.upserted'), 'audit logs should include member upsert');
  assert.ok(auditLogs.items?.some(item => item.action === 'tenant.member.disabled'), 'audit logs should include member disable');

  const partnerAuditDenied = await request('/api/tenant-admin/audit-logs', {
    tenantId: PARTNER_TENANT_ID,
    userId: TENANT_ADMIN_USER_ID,
    expectStatus: 403,
  });
  assert.equal(partnerAuditDenied.code, 'TENANT_ADMIN_REQUIRED', 'tenant audit logs must be tenant isolated');
}

async function testReferralAndCrmGrowth() {
  const salesMember = await request('/api/tenant-admin/members', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      userId: TENANT_SALES_USER_ID,
      username: 'integration_sales',
      phone: '13800000004',
      name: 'Integration Sales',
      role: 'sales',
      status: 'active',
      permissions: {
        'codes:*': true,
        'coupons:*': true,
        'referral:*': true,
      },
    },
  });
  assert.equal(salesMember.item?.status, 'active', 'tenant admin should reactivate sales membership for referral tests');

  const agent = await request('/api/tenant-admin/members', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      userId: TENANT_AGENT_USER_ID,
      username: 'integration_agent',
      phone: '13800000005',
      name: 'Integration Agent',
      role: 'agent',
      status: 'active',
      permissions: {
        'referral:self': true,
      },
    },
  });
  assert.equal(agent.item?.role, 'agent', 'tenant admin should create agent membership');

  const salesCode = await request('/api/referral/invite-code', {
    userId: TENANT_SALES_USER_ID,
    method: 'POST',
  });
  assert.ok(/^[A-Z0-9]{6}$/.test(salesCode.inviteCode), 'sales should get an invite code');

  const agentCode = await request('/api/referral/invite-code', {
    userId: TENANT_AGENT_USER_ID,
    method: 'POST',
  });
  assert.ok(/^[A-Z0-9]{6}$/.test(agentCode.inviteCode), 'agent should get an invite code');

  const resolved = await request('/api/referral/resolve', {
    userId: false,
    method: 'POST',
    body: { code: salesCode.inviteCode },
  });
  assert.equal(resolved.valid, true, 'invite code should resolve');
  assert.equal(resolved.inviterId, TENANT_SALES_USER_ID, 'invite code should resolve to sales user');

  const crmConfig = await request('/api/crm/config', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      enabled: true,
      url: 'https://crm.example.test/webhook',
      secret: 'crm-secret-smoke',
      formName: '集成测试客资',
      examType: '专升本',
      delaySec: 1,
    },
  });
  assert.equal(crmConfig.item?.enabled, true, 'tenant admin should enable CRM config');
  assert.ok(!JSON.stringify(crmConfig).includes('crm-secret-smoke'), 'CRM config response should not leak secret');

  const tracked = await request('/api/referral/track-event', {
    userId: false,
    method: 'POST',
    body: {
      eventType: 'register',
      refCode: salesCode.inviteCode,
      targetUserId: USER_ID,
      source: 'qrcode',
      metadata: { page: 'pages/index/index' },
    },
  });
  assert.equal(tracked.item?.refUserId, TENANT_SALES_USER_ID, 'tracking event should resolve referrer');
  assert.equal(tracked.lead?.bound, true, 'first referral event should bind lead');
  assert.equal(tracked.lead?.item?.referrerUserId, TENANT_SALES_USER_ID, 'lead should be bound to sales user');
  assert.ok(tracked.crmQueue?.id, 'first lead binding should enqueue CRM task');

  const secondBind = await request('/api/referral/bind', {
    method: 'POST',
    body: {
      userId: USER_ID,
      refCode: agentCode.inviteCode,
      source: 'qrcode',
    },
  });
  assert.equal(secondBind.lead?.bound, false, 'second referral bind should be blocked by first-binding protection');
  assert.equal(secondBind.lead?.item?.referrerUserId, TENANT_SALES_USER_ID, 'protected lead should remain with first sales user');

  const salesStats = await request('/api/referral/stats', {
    userId: TENANT_SALES_USER_ID,
  });
  assert.equal(salesStats.item?.leadCount, 1, 'sales should see own lead count');

  const salesClients = await request('/api/referral/sales-clients', {
    userId: TENANT_SALES_USER_ID,
  });
  assert.ok(salesClients.items?.some(item => item.studentUserId === USER_ID), 'sales should see own protected client');

  const agentClients = await request('/api/referral/sales-clients', {
    userId: TENANT_AGENT_USER_ID,
  });
  assert.ok(!agentClients.items?.some(item => item.studentUserId === USER_ID), 'agent should not see sales protected client');

  const allStats = await request('/api/referral/sales-stats', {
    userId: TENANT_ADMIN_USER_ID,
  });
  assert.ok(allStats.items?.some(item => item.referrerUserId === TENANT_SALES_USER_ID && item.leadCount >= 1), 'tenant admin should see all referral stats');

  const manual = await request('/api/referral/manual-bind', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'POST',
    body: {
      studentUserId: USER_ID,
      referrerUserId: TENANT_AGENT_USER_ID,
      force: true,
      source: 'manual',
    },
  });
  assert.equal(manual.lead?.bound, true, 'tenant admin should be able to force manual bind');
  assert.equal(manual.lead?.item?.referrerUserId, TENANT_AGENT_USER_ID, 'manual bind should move lead to agent');

  const qrcode = await request('/api/referral/qrcode', {
    userId: TENANT_AGENT_USER_ID,
    method: 'POST',
    body: {
      page: 'pages/index/index',
    },
  });
  assert.equal(qrcode.item?.refCode, agentCode.inviteCode, 'qrcode should use agent invite code');
  assert.equal(qrcode.item?.status, 'ready', 'qrcode placeholder should be ready locally');

  const team = await request('/api/referral/team', {
    userId: TENANT_ADMIN_USER_ID,
    method: 'PUT',
    body: {
      leaderUserId: TENANT_SALES_USER_ID,
      memberUserId: TENANT_AGENT_USER_ID,
      relationType: 'agent_network',
    },
  });
  assert.equal(team.item?.leaderUserId, TENANT_SALES_USER_ID, 'tenant admin should assign agent leader');

  const teamList = await request('/api/referral/team', {
    userId: TENANT_SALES_USER_ID,
    query: { leaderUserId: TENANT_SALES_USER_ID },
  });
  assert.ok(teamList.items?.some(item => item.memberUserId === TENANT_AGENT_USER_ID), 'sales should see own agent team');

  const crmQueue = await request('/api/crm/queue', {
    userId: TENANT_ADMIN_USER_ID,
    query: { status: 'pending' },
  });
  assert.ok(crmQueue.items?.some(item => item.leadId === manual.lead.item.id || item.leadId === tracked.lead.item.id), 'CRM queue should include referral lead task');
  assert.ok(!JSON.stringify(crmQueue).includes('crm-secret-smoke'), 'CRM queue should not leak secret');

  const partnerReferralDenied = await request('/api/referral/sales-stats', {
    tenantId: PARTNER_TENANT_ID,
    userId: TENANT_SALES_USER_ID,
    expectStatus: 403,
  });
  assert.equal(partnerReferralDenied.code, 'TENANT_ADMIN_REQUIRED', 'sales user must not see another tenant referral stats');
}

async function main() {
  try {
    await startServerIfNeeded();
    console.log(`[INFO] API integration target: ${apiBase}`);

    await check('health', () => request('/health', { userId: false }).then(payload => assert.equal(payload.ok, true)));
    await check('catalog and learning', testCatalogAndLearning);
    await check('profile', testProfile);
    await check('scoreline', testScoreline);
    await check('question videos', testVideos);
    await check('vocabulary', testVocabulary);
    await check('commerce', testCommerce);
    await check('tenant isolation', testTenantIsolation);
    await check('tenant content admin', testTenantContentAdmin);
    await check('tenant content assets and imports', testTenantContentAssetsAndImports);
    await check('tenant admin operations', testTenantAdminOps);
    await check('tenant member permissions and audit', testTenantMemberPermissionsAndAudit);
    await check('referral and CRM growth', testReferralAndCrmGrowth);

    console.log('API integration tests complete.');
  } finally {
    stopServer();
  }
}

main().catch(error => {
  console.error(error);
  if (serverLogs) console.error(serverLogs);
  process.exitCode = 1;
});