smoke-admin-functions.mjs 98 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870
  1. #!/usr/bin/env node
  2. import { randomBytes } from 'node:crypto';
  3. import { readFile } from 'node:fs/promises';
  4. const APP_ID = process.env.XIAOSHU_PARSE_APP_ID || '7pIbDBJmKx_main';
  5. const MASTER_KEY = process.env.XIAOSHU_MASTER_KEY || '';
  6. const PARSE_URL = (process.env.XIAOSHU_PARSE_URL || 'https://server.xiaoshu.pro/parse').replace(/\/$/, '');
  7. const FUNCTION_URL = (process.env.XIAOSHU_FUNCTION_URL || 'https://server.xiaoshu.pro/api/functions').replace(/\/$/, '');
  8. if (!MASTER_KEY) throw new Error('缺少 XIAOSHU_MASTER_KEY');
  9. async function jsonRequest(url, init = {}, master = false) {
  10. const response = await fetch(url, {
  11. ...init,
  12. headers: {
  13. 'X-Parse-Application-Id': APP_ID,
  14. ...(master ? { 'X-Parse-Master-Key': MASTER_KEY } : {}),
  15. 'Content-Type': 'application/json',
  16. ...(init.headers || {}),
  17. },
  18. });
  19. const payload = await response.json().catch(() => ({}));
  20. if (!response.ok) {
  21. const detail = payload.message || payload.error || payload;
  22. throw new Error(`${response.status}: ${typeof detail === 'string' ? detail : JSON.stringify(detail)}`);
  23. }
  24. return payload;
  25. }
  26. async function callFunction(path, token, params) {
  27. const payload = await jsonRequest(`${FUNCTION_URL}/${path}`, {
  28. method: 'POST',
  29. body: JSON.stringify({ token, params }),
  30. });
  31. if (!payload.success) throw new Error(payload.message || `${path} 返回失败`);
  32. return payload.data;
  33. }
  34. async function callFunctionError(path, token, params, expectedStatus) {
  35. const response = await fetch(`${FUNCTION_URL}/${path}`, {
  36. method: 'POST',
  37. headers: { 'X-Parse-Application-Id': APP_ID, 'Content-Type': 'application/json' },
  38. body: JSON.stringify({ token, params }),
  39. });
  40. const payload = await response.json().catch(() => ({}));
  41. if (response.status !== expectedStatus || payload.success !== false) throw new Error(`${path} 期望 ${expectedStatus} 失败,实际 ${response.status}: ${payload.message || payload.error || ''}`);
  42. return payload;
  43. }
  44. async function callLegacyFunction(token, params, expectedStatus = 200) {
  45. const response = await fetch(`${FUNCTION_URL}/xiaoshu/app/gateway`, {
  46. method: 'POST',
  47. headers: { 'X-Parse-Application-Id': APP_ID, 'Content-Type': 'application/json' },
  48. body: JSON.stringify({ ...(token ? { token } : {}), params }),
  49. });
  50. const payload = await response.json().catch(() => ({}));
  51. if (response.status !== expectedStatus) throw new Error(`app gateway ${params.action} 期望 ${expectedStatus},实际 ${response.status}: ${payload.retmsg || payload.error || ''}`);
  52. return payload;
  53. }
  54. async function sourceActions() {
  55. const source = await readFile(new URL('../src/app/core/source-parity.generated.ts', import.meta.url), 'utf8');
  56. const match = source.match(/export const SOURCE_API_ACTIONS = (\[[\s\S]*?\]) as const;/);
  57. if (!match) throw new Error('无法读取 SOURCE_API_ACTIONS');
  58. return JSON.parse(match[1]);
  59. }
  60. let userId = '';
  61. let adminCreatedUserId = '';
  62. let temporaryGroupObjectId = '';
  63. const temporaryNodeObjectIds = [];
  64. const temporarySpecialObjectIds = [];
  65. const temporaryGuestCategoryObjectIds = [];
  66. const temporaryExamClassObjectIds = [];
  67. const temporaryExamPointObjectIds = [];
  68. const temporaryKnowledgeObjectIds = [];
  69. let temporaryExamTeacherId = '';
  70. const temporaryDictionaryCategoryIds = [];
  71. const temporaryDictionaryItemIds = [];
  72. const temporaryGradeCategoryIds = [];
  73. const temporaryGradeOptionIds = [];
  74. let temporaryModelObjectId = '';
  75. const temporaryModelFieldObjectIds = [];
  76. let registeredUserId = '';
  77. let memberId = '';
  78. let memberLegacyId = 0;
  79. let teamChildId = '';
  80. let coachId = '';
  81. let coachLegacyId = 0;
  82. let temporaryAppointmentId = '';
  83. let temporaryAppointmentObjectId = '';
  84. let temporaryGuestbookId = '';
  85. let temporaryGuestbookReplyId = '';
  86. let temporaryGuestBarId = '';
  87. let contentHitObjectId = '';
  88. let contentHitOriginal = 0;
  89. let adZoneRestore = null;
  90. let adInfoRestore = null;
  91. const temporaryLessonIds = [];
  92. try {
  93. const sample = await jsonRequest(`${PARSE_URL}/classes/Company?limit=1&keys=objectId`, {}, true);
  94. const companyId = sample.results?.[0]?.objectId;
  95. if (!companyId) throw new Error('没有可用于帐套隔离测试的 Company');
  96. const company = { __type: 'Pointer', className: 'Company', objectId: companyId };
  97. const username = `codex_admin_smoke_${Date.now()}`;
  98. const password = randomBytes(24).toString('base64url');
  99. const created = await jsonRequest(`${PARSE_URL}/users`, {
  100. method: 'POST',
  101. body: JSON.stringify({ username, password, isAdmin: true, roles: ['admin'], company }),
  102. }, true);
  103. userId = created.objectId;
  104. const login = await jsonRequest(`${PARSE_URL}/login`, {
  105. method: 'POST',
  106. body: JSON.stringify({ username, password }),
  107. });
  108. if (!login.sessionToken) throw new Error('临时管理员登录未返回 sessionToken');
  109. const registeredUsername = `codex_register_smoke_${Date.now()}`;
  110. const registered = await callLegacyFunction('', { action: 'user_register', name: registeredUsername, passwd: 'Ab1234' });
  111. registeredUserId = String(registered.result?.objectId || '');
  112. const registeredLegacyId = Number(registered.result?.userId);
  113. if (!registeredUserId || !registeredLegacyId || !registered.result?.sessionToken || Number(registered.result?.groupId) !== 1 || Number(registered.addon?.parentUserId) !== 0) throw new Error(`新用户注册基础字段异常:${JSON.stringify(registered)}`);
  114. const registeredInfo = await callLegacyFunction(registered.result.sessionToken, { action: 'user_get', uid: registeredLegacyId });
  115. if (Number(registeredInfo.result?.userId) !== registeredLegacyId || Number(registeredInfo.result?.groupId) !== 1 || Number(registeredInfo.addon?.Purse) !== 0 || Number(registeredInfo.addon?.UserPoint) !== 0) throw new Error('新用户注册后自查异常');
  116. const registeredByName = await callLegacyFunction('', { action: 'user_info_name', uname: registeredUsername });
  117. if (registeredByName.result?.objectId !== registeredUserId) throw new Error('新用户用户名查重异常');
  118. await jsonRequest(`${PARSE_URL}/users/${registeredUserId}`, { method: 'DELETE' }, true);
  119. registeredUserId = '';
  120. const memberUsername = `codex_member_smoke_${Date.now()}`;
  121. const memberPassword = randomBytes(24).toString('base64url');
  122. memberLegacyId = 900000000 + Math.floor(Date.now() / 1000) % 90000000;
  123. const member = await jsonRequest(`${PARSE_URL}/users`, {
  124. method: 'POST',
  125. body: JSON.stringify({ username: memberUsername, password: memberPassword, legacyUserId: memberLegacyId, legacyGroupId: 1, legacyUserData: { UserID: memberLegacyId, UserName: memberUsername, HoneyName: '冒烟学员', GroupID: 1, ParentUserID: 0, VIP: 2, Purse: 2, SilverCoin: 2, UserExp: 2, UserPoint: 2 }, company }),
  126. }, true);
  127. memberId = member.objectId;
  128. const childLegacyId = memberLegacyId + 2;
  129. const child = await jsonRequest(`${PARSE_URL}/users`, {
  130. method: 'POST',
  131. body: JSON.stringify({ username: `codex_team_child_${Date.now()}`, password: randomBytes(24).toString('base64url'), legacyUserId: childLegacyId, legacyGroupId: 3, legacyUserData: { UserID: childLegacyId, UserName: `team_child_${childLegacyId}`, HoneyName: '冒烟团队成员', GroupID: 3, ParentUserID: memberLegacyId, VIP: 3, UserExp: 5, UserPwd: 'must-not-leak' }, company }),
  132. }, true);
  133. teamChildId = child.objectId;
  134. const coachUsername = `codex_coach_smoke_${Date.now()}`;
  135. const coachPassword = randomBytes(24).toString('base64url');
  136. coachLegacyId = memberLegacyId + 1;
  137. const coach = await jsonRequest(`${PARSE_URL}/users`, {
  138. method: 'POST',
  139. body: JSON.stringify({ username: coachUsername, password: coachPassword, legacyUserId: coachLegacyId, legacyGroupId: 3, company }),
  140. }, true);
  141. coachId = coach.objectId;
  142. for (const lessonType of [1, 2, 3]) {
  143. const lesson = await jsonRequest(`${PARSE_URL}/classes/LessonRecord`, {
  144. method: 'POST',
  145. body: JSON.stringify({ company, sourceKey: `cloud:smoke-lesson:${coachLegacyId}:${lessonType}`, jsmz: String(coachLegacyId), kclx: String(lessonType) }),
  146. }, true);
  147. temporaryLessonIds.push(lesson.objectId);
  148. }
  149. const memberLogin = await jsonRequest(`${PARSE_URL}/login`, {
  150. method: 'POST',
  151. body: JSON.stringify({ username: memberUsername, password: memberPassword }),
  152. });
  153. const coachLogin = await jsonRequest(`${PARSE_URL}/login`, {
  154. method: 'POST',
  155. body: JSON.stringify({ username: coachUsername, password: coachPassword }),
  156. });
  157. const feedbackModel = { UserID: memberLegacyId, Title: '冒烟学员 反馈的意见', TContent: '2026-08-19 请假一天', Cateid: 22 };
  158. const feedback = await callLegacyFunction(memberLogin.sessionToken, { action: 'guestbook_add', model: JSON.stringify(feedbackModel) });
  159. temporaryGuestbookId = String(feedback.result?.objectId || '');
  160. if (!temporaryGuestbookId || Number(feedback.result?.UserID) !== memberLegacyId || feedback.result?.Title !== feedbackModel.Title || feedback.result?.TContent !== feedbackModel.TContent || Number(feedback.result?.Cateid) !== 22) throw new Error(`旧版 model 留言写入异常:${JSON.stringify(feedback)}`);
  161. await callLegacyFunction(memberLogin.sessionToken, { action: 'guestbook_add', model: JSON.stringify({ ...feedbackModel, UserID: coachLegacyId }) }, 403);
  162. const profileModel = { honeyName: '冒烟资料更新', trueName: '测试学员', userFace: '/UploadFiles/smoke-avatar.png', sex: '女', birthday: '2000-01-02', mobile: '13800138000', Email: `${memberUsername}@example.test`, seturl: '/member/smoke', Position: '词汇小英雄' };
  163. const updatedProfile = await callLegacyFunction(memberLogin.sessionToken, { action: 'user_update', uid: memberLegacyId, mu: JSON.stringify(profileModel), inviCode: '' });
  164. if (updatedProfile.result?.honeyName !== profileModel.honeyName || updatedProfile.result?.userFace !== profileModel.userFace || updatedProfile.result?.email !== profileModel.Email || updatedProfile.result?.seturl !== profileModel.seturl) throw new Error(`旧版 mu 用户资料更新异常:${JSON.stringify(updatedProfile)}`);
  165. await callLegacyFunction(memberLogin.sessionToken, { action: 'user_update', uid: coachLegacyId, mu: JSON.stringify({ honeyName: '越权' }) }, 403);
  166. await callLegacyFunction(memberLogin.sessionToken, { action: 'user_update_pwd', uid: memberLegacyId, vcode: '123456', newPass: 'Ab1234', reNewPass: 'Ab1234' }, 501);
  167. await callLegacyFunction(memberLogin.sessionToken, { action: 'user_update_pwdall', uid: memberLegacyId, login: 'Ab1234', pay: '123456' }, 501);
  168. const createdAppointment = await callLegacyFunction(login.sessionToken, { action: 'content_add', content: JSON.stringify({ ModelID: 54, nodeId: 29, inputer: coachUsername, status: 99, title: memberUsername }), addon: JSON.stringify({ szyh: memberLegacyId, kcid: 16, dslx: 1, dszt: 0, pl: coachLegacyId, fxpl: coachLegacyId, sdsd: '19:00' }) });
  169. temporaryAppointmentId = String(createdAppointment.result);
  170. const appointmentSourceKey = `cloud:content_add:${memberLegacyId}:${temporaryAppointmentId}`;
  171. const appointmentWhere = encodeURIComponent(JSON.stringify({ sourceKey: appointmentSourceKey }));
  172. const appointmentRows = await jsonRequest(`${PARSE_URL}/classes/CourseAppointment?where=${appointmentWhere}&limit=1`, {}, true);
  173. temporaryAppointmentObjectId = appointmentRows.results?.[0]?.objectId || '';
  174. if (!temporaryAppointmentObjectId) throw new Error('临时预约副表创建失败');
  175. const appointmentCommonRows = await jsonRequest(`${PARSE_URL}/classes/CommonModel?where=${appointmentWhere}&limit=1`, {}, true);
  176. const temporaryAppointmentCommonObjectId = String(appointmentCommonRows.results?.[0]?.objectId || '');
  177. if (!temporaryAppointmentCommonObjectId) throw new Error('临时预约主内容创建失败');
  178. const meta = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'meta' });
  179. if (meta.identity?.objectId !== userId || !meta.cloudFunctions) throw new Error('管理员 meta 校验失败');
  180. const dashboard = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'dashboard' });
  181. if (!Array.isArray(dashboard.metrics) || dashboard.metrics.length !== 8) throw new Error('dashboard 指标校验失败');
  182. const catalog = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'catalog' });
  183. if (!Array.isArray(catalog.resources) || catalog.resources.length < 90 || catalog.resources.some((item) => ['_Session', 'Function'].includes(item.className))) throw new Error('后台规范化类目录校验失败');
  184. const managedUsername = `codex_admin_created_${Date.now()}`;
  185. const managedPassword = randomBytes(24).toString('base64url');
  186. const managed = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'createUser', username: managedUsername, password: managedPassword, displayName: '后台开户冒烟', mobile: '13800138001', isAdmin: true, roles: ['admin'] });
  187. adminCreatedUserId = String(managed.objectId || '');
  188. if (!adminCreatedUserId || !Number(managed.userId) || Number(managed.groupId) !== 1 || managed.isAdmin === true || managed.roles?.includes?.('admin') || managed.sessionToken) throw new Error(`管理员开户响应异常:${JSON.stringify(managed)}`);
  189. const managedStored = await jsonRequest(`${PARSE_URL}/users/${adminCreatedUserId}`, {}, true);
  190. if (managedStored.username !== managedUsername || managedStored.isAdmin === true || managedStored.roles?.includes?.('admin') || Number(managedStored.legacyUserId) !== Number(managed.userId) || Number(managedStored.legacyGroupId) !== 1 || Number(managedStored.legacyUserData?.UserID) !== Number(managed.userId) || Number(managedStored.legacyUserData?.Purse) !== 0) throw new Error('管理员开户持久化约束校验失败');
  191. const managedLogin = await jsonRequest(`${PARSE_URL}/login`, { method: 'POST', body: JSON.stringify({ username: managedUsername, password: managedPassword }) });
  192. if (!managedLogin.sessionToken) throw new Error('后台开户用户登录失败');
  193. const locked = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'userBatch', className: '_User', action: 'lock', objectIds: [adminCreatedUserId], reason: '云函数冒烟' });
  194. if (locked.updated !== 1 || locked.results?.[0]?.isDisabled !== true || Number(locked.results?.[0]?.legacyUserData?.State) !== 0 || Number(locked.revokedSessions) < 1) throw new Error(`用户停用与会话撤销异常:${JSON.stringify(locked)}`);
  195. await callLegacyFunction('', { action: 'user_login_passwd', name: managedUsername, passwd: managedPassword }, 403);
  196. const unlocked = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'userBatch', className: '_User', action: 'unlock', objectIds: [adminCreatedUserId], reason: '恢复冒烟用户' });
  197. if (unlocked.updated !== 1 || unlocked.results?.[0]?.isDisabled !== false || Number(unlocked.results?.[0]?.legacyUserData?.State) !== 1) throw new Error(`用户解锁异常:${JSON.stringify(unlocked)}`);
  198. const temporaryGroup = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGroup', className: 'Group', fields: { groupName: '云函数冒烟临时组', description: '验证帐套内原子组编号', parentGroupId: 0, regSelect: false } });
  199. temporaryGroupObjectId = String(temporaryGroup.objectId || '');
  200. const temporaryGroupNumber = Number(temporaryGroup.groupId);
  201. if (!temporaryGroupObjectId || !temporaryGroupNumber) throw new Error('临时用户组创建失败');
  202. const moved = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'userBatch', className: '_User', action: 'move', objectIds: [adminCreatedUserId], groupId: temporaryGroupNumber });
  203. if (moved.updated !== 1 || Number(moved.results?.[0]?.legacyGroupId) !== temporaryGroupNumber || Number(moved.results?.[0]?.legacyUserData?.GroupID) !== temporaryGroupNumber) throw new Error(`用户组同步异常:${JSON.stringify(moved)}`);
  204. const groupDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'Group', objectId: temporaryGroupObjectId }, 409);
  205. if (!String(groupDeleteBlocked.message).includes('仍有用户')) throw new Error('用户组引用删除保护未返回明确原因');
  206. const managedAppLogin = await callLegacyFunction('', { action: 'user_login_passwd', name: managedUsername, passwd: managedPassword });
  207. if (!managedAppLogin.result?.sessionToken || Number(managedAppLogin.addon?.State) !== 1) throw new Error('解锁后旧版登录异常');
  208. await jsonRequest(`${PARSE_URL}/users/${adminCreatedUserId}`, { method: 'DELETE' }, true);
  209. adminCreatedUserId = '';
  210. const deletedGroup = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'Group', objectId: temporaryGroupObjectId });
  211. if (deletedGroup.objectId !== temporaryGroupObjectId) throw new Error('无引用用户组删除失败');
  212. temporaryGroupObjectId = '';
  213. const schema = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'schema', className: 'CourseAppointment' });
  214. if (schema.className !== 'CourseAppointment' || !Array.isArray(schema.fields)) throw new Error('schema 校验失败');
  215. const contentSchema = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'schema', className: 'CommonModel' });
  216. const contentFieldMap = Object.fromEntries((contentSchema.fields || []).map((field) => [field.name, field]));
  217. if (contentSchema.creatable !== false || contentFieldMap.status?.writable !== false || contentFieldMap.modelId?.writable !== false || contentFieldMap.itemId?.writable !== false || contentFieldMap.nodeId?.writable !== false) throw new Error('内容结构字段未从通用创建/编辑中隔离');
  218. const nodeSchema = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'schema', className: 'Node' });
  219. const nodeFieldMap = Object.fromEntries((nodeSchema.fields || []).map((field) => [field.name, field]));
  220. if (nodeFieldMap.nodeId?.writable !== false || nodeFieldMap.parentId?.writable !== false || nodeFieldMap.depth?.writable !== false || nodeFieldMap.zstatus?.writable !== false || nodeFieldMap.sourceKey?.writable !== false) throw new Error('栏目结构字段未从通用编辑中隔离');
  221. const holidaySchema = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'schema', className: 'SysHoliday' });
  222. const holidayFieldMap = Object.fromEntries((holidaySchema.fields || []).map((field) => [field.name, field]));
  223. if (holidaySchema.creatable !== false || ['id','cdate','cadminId','cuserId','sourceKey'].some((name) => holidayFieldMap[name]?.writable !== false)) throw new Error('节假日系统字段未从新增或通用编辑中隔离');
  224. const holidayPage = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'list', className: 'SysHoliday', page: 1, pageSize: 20 });
  225. if (!Array.isArray(holidayPage.results)) throw new Error('节假日列表返回异常');
  226. const searchNavigationSchema = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'schema', className: 'Search' });
  227. const searchNavigationFieldMap = Object.fromEntries((searchNavigationSchema.fields || []).map((field) => [field.name, field]));
  228. if (searchNavigationSchema.creatable !== false || ['id','type','state','time','adminId','orderId','linkType','linkState','sourceKey'].some((name) => searchNavigationFieldMap[name]?.writable !== false)) throw new Error('快捷入口结构字段未从新增或通用编辑中隔离');
  229. const searchNavigationPage = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'searchNavigations', className: 'Search', type: 1, state: -100, elite: -100, page: 1, pageSize: 20 });
  230. if (!Array.isArray(searchNavigationPage.results) || !searchNavigationPage.results.length || searchNavigationPage.results.some((entry) => Number(entry.type) !== 1)) throw new Error('后台快捷入口筛选列表返回异常');
  231. const apiCatalog = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'apiCatalog' });
  232. if (!Array.isArray(apiCatalog.results) || apiCatalog.results.length < 9 || apiCatalog.results.some((entry) => !String(entry.path || '').startsWith('xiaoshu/') || Object.prototype.hasOwnProperty.call(entry, 'code'))) throw new Error('云函数接口目录缺失或泄露了源码');
  233. const adZoneSchema = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'schema', className: 'AdZone' });
  234. const adZoneFieldMap = Object.fromEntries((adZoneSchema.fields || []).map((field) => [field.name, field]));
  235. if (adZoneSchema.creatable !== false || ['id','cdate','cadmin','image','sourceKey'].some((name) => adZoneFieldMap[name]?.writable !== false)) throw new Error('广告位系统字段未从新增或通用编辑中隔离');
  236. const adInfoSchema = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'schema', className: 'AdInfo' });
  237. const adInfoFieldMap = Object.fromEntries((adInfoSchema.fields || []).map((field) => [field.name, field]));
  238. if (adInfoSchema.creatable !== false || ['id','cdate','zoneId','ztype','extend1','extend2','extend3','sourceKey'].some((name) => adInfoFieldMap[name]?.writable !== false)) throw new Error('广告内容系统字段未从新增或通用编辑中隔离');
  239. const adZonePage = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'adZones', className: 'AdZone', page: 1, pageSize: 20, status: -100, type: '' });
  240. const sampleAdZone = adZonePage.results?.[0]; if (!sampleAdZone?.objectId || !sampleAdZone.id) throw new Error('广告位专用列表没有返回历史广告位');
  241. const adInfoPage = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'adInfos', className: 'AdInfo', page: 1, pageSize: 20, status: -100, zoneId: String(sampleAdZone.id) });
  242. const sampleAdInfo = adInfoPage.results?.[0]; if (!sampleAdInfo?.objectId || String(sampleAdInfo.zoneId) !== String(sampleAdZone.id)) throw new Error('广告内容按广告位筛选异常');
  243. const zoneCreateBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveAdZone', className: 'AdZone', fields: {} }, 501);
  244. const infoCreateBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveAdInfo', className: 'AdInfo', fields: {} }, 501);
  245. if (!String(zoneCreateBlocked.message).includes('AdZone.id') || !String(infoCreateBlocked.message).includes('AdInfo.id')) throw new Error('广告新增未返回旧 ID 明确阻塞原因');
  246. adZoneRestore = { objectId: sampleAdZone.objectId, remind: String(sampleAdZone.remind || ''), zstatus: Number(sampleAdZone.zstatus) };
  247. const zoneProbeRemind = `${adZoneRestore.remind} [angular-smoke]`.trim();
  248. const updatedAdZone = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveAdZone', className: 'AdZone', objectId: sampleAdZone.objectId, fields: { ...sampleAdZone, remind: zoneProbeRemind } });
  249. if (updatedAdZone.remind !== zoneProbeRemind) throw new Error('广告位专用编辑未写入备注');
  250. const zoneToggleAction = adZoneRestore.zstatus === 99 ? 'pause' : 'active'; const toggledZone = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'adZoneBatch', className: 'AdZone', action: zoneToggleAction, objectIds: [sampleAdZone.objectId] });
  251. if (Number(toggledZone.results?.[0]?.zstatus) !== (zoneToggleAction === 'active' ? 99 : 0)) throw new Error('广告位启停批量操作异常');
  252. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveAdZone', className: 'AdZone', objectId: sampleAdZone.objectId, fields: { ...sampleAdZone, remind: adZoneRestore.remind, zstatus: adZoneRestore.zstatus } }); adZoneRestore = null;
  253. adInfoRestore = { objectId: sampleAdInfo.objectId, remind: String(sampleAdInfo.remind || ''), zstatus: Number(sampleAdInfo.zstatus) };
  254. const infoProbeRemind = `${adInfoRestore.remind} [angular-smoke]`.trim();
  255. const updatedAdInfo = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveAdInfo', className: 'AdInfo', objectId: sampleAdInfo.objectId, zoneId: String(sampleAdInfo.zoneId), fields: { ...sampleAdInfo, remind: infoProbeRemind } });
  256. if (updatedAdInfo.remind !== infoProbeRemind) throw new Error('广告内容专用编辑未写入备注');
  257. const infoToggleAction = adInfoRestore.zstatus === 99 ? 'unaudit' : 'audit'; const toggledInfo = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'adInfoBatch', className: 'AdInfo', action: infoToggleAction, objectIds: [sampleAdInfo.objectId] });
  258. if (Number(toggledInfo.results?.[0]?.zstatus) !== (infoToggleAction === 'audit' ? 99 : 0)) throw new Error('广告内容审核批量操作异常');
  259. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveAdInfo', className: 'AdInfo', objectId: sampleAdInfo.objectId, zoneId: String(sampleAdInfo.zoneId), fields: { ...sampleAdInfo, remind: adInfoRestore.remind, zstatus: adInfoRestore.zstatus } }); adInfoRestore = null;
  260. const adPreview = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'adPreview', zoneObjectId: sampleAdZone.objectId }); if (!adPreview.zone?.objectId || !Array.isArray(adPreview.results)) throw new Error('广告位当前生效广告预览异常');
  261. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'save', className: 'Node', fields: { nodeName: '禁止通用新增' } }, 400);
  262. const nodeSuffix = Date.now().toString(36);
  263. const rootNode = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveNode', className: 'Node', parentId: 0, fields: { nodeName: `云函数冒烟栏目-${nodeSuffix}`, nodeDir: `smoke-${nodeSuffix}`, nodeType: 1, contentModel: '54' } });
  264. temporaryNodeObjectIds.push(String(rootNode.objectId || ''));
  265. const rootNodeId = Number(rootNode.nodeId);
  266. if (!temporaryNodeObjectIds[0] || !rootNodeId || Number(rootNode.parentId) !== 0 || Number(rootNode.depth) !== 1 || rootNode.sourceKey !== `[["NodeID",${rootNodeId}]]`) throw new Error(`栏目原子创建异常:${JSON.stringify(rootNode)}`);
  267. const childNode = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveNode', className: 'Node', parentId: rootNodeId, fields: { nodeName: `云函数冒烟子栏目-${nodeSuffix}`, nodeDir: `smoke-child-${nodeSuffix}`, nodeType: 1, contentModel: '54' } });
  268. temporaryNodeObjectIds.push(String(childNode.objectId || ''));
  269. const childNodeId = Number(childNode.nodeId);
  270. if (!temporaryNodeObjectIds[1] || !childNodeId || Number(childNode.parentId) !== rootNodeId || Number(childNode.depth) !== 2) throw new Error(`子栏目层级创建异常:${JSON.stringify(childNode)}`);
  271. const duplicateNode = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveNode', className: 'Node', parentId: 0, fields: { nodeName: `云函数冒烟栏目-${nodeSuffix}`, nodeDir: `another-${nodeSuffix}` } }, 409);
  272. if (!String(duplicateNode.message).includes('不能重复')) throw new Error('栏目同级重名保护未返回明确原因');
  273. const cycleNode = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveNode', className: 'Node', objectId: rootNode.objectId, parentId: childNodeId, fields: { ...rootNode, nodeName: rootNode.nodeName, nodeDir: rootNode.nodeDir } }, 409);
  274. if (!String(cycleNode.message).includes('自身或其下级')) throw new Error('栏目层级循环保护未返回明确原因');
  275. const movedNode = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'nodeBatch', className: 'Node', action: 'move', objectIds: [childNode.objectId], parentId: 0 });
  276. if (movedNode.updated !== 1 || Number(movedNode.results?.[0]?.parentId) !== 0) throw new Error('栏目批量迁移失败');
  277. const recycledNode = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'nodeBatch', className: 'Node', action: 'recycle', objectIds: [rootNode.objectId] });
  278. if (Number(recycledNode.results?.[0]?.zstatus) !== -2) throw new Error('栏目回收站状态更新失败');
  279. const recoveredNode = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'nodeBatch', className: 'Node', action: 'recover', objectIds: [rootNode.objectId] });
  280. if (Number(recoveredNode.results?.[0]?.zstatus) !== 99) throw new Error('栏目回收站恢复失败');
  281. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'nodeBatch', className: 'Node', action: 'purge', objectIds: [childNode.objectId] });
  282. temporaryNodeObjectIds.pop();
  283. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'nodeBatch', className: 'Node', action: 'purge', objectIds: [rootNode.objectId] });
  284. temporaryNodeObjectIds.pop();
  285. const specialSuffix = Date.now().toString(36);
  286. const rootSpecial = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveSpecial', className: 'Special', pid: 0, fields: { specName: `云函数冒烟专题-${specialSuffix}`, specDir: `special-${specialSuffix}`, specCate: 0, specDesc: '专题生命周期验证' } });
  287. temporarySpecialObjectIds.push(String(rootSpecial.objectId || ''));
  288. const rootSpecId = Number(rootSpecial.specId);
  289. if (!temporarySpecialObjectIds[0] || !rootSpecId || Number(rootSpecial.pid) !== 0 || rootSpecial.sourceKey !== `[["SpecID",${rootSpecId}]]`) throw new Error(`专题原子创建异常:${JSON.stringify(rootSpecial)}`);
  290. const childSpecial = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveSpecial', className: 'Special', pid: rootSpecId, fields: { specName: `云函数冒烟子专题-${specialSuffix}`, specDir: `special-child-${specialSuffix}` } });
  291. temporarySpecialObjectIds.push(String(childSpecial.objectId || ''));
  292. const childSpecId = Number(childSpecial.specId);
  293. if (!temporarySpecialObjectIds[1] || !childSpecId || Number(childSpecial.pid) !== rootSpecId) throw new Error(`子专题创建异常:${JSON.stringify(childSpecial)}`);
  294. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveSpecial', className: 'Special', pid: 0, fields: { specName: rootSpecial.specName, specDir: `special-other-${specialSuffix}` } }, 409);
  295. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveSpecial', className: 'Special', objectId: rootSpecial.objectId, pid: childSpecId, fields: { ...rootSpecial, specName: rootSpecial.specName, specDir: rootSpecial.specDir } }, 409);
  296. const specialDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'Special', objectId: rootSpecial.objectId }, 409);
  297. if (!String(specialDeleteBlocked.message).includes('下级专题')) throw new Error('专题子级引用删除保护未返回明确原因');
  298. const movedSpecial = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'specialBatch', className: 'Special', action: 'move', objectIds: [childSpecial.objectId], pid: 0 });
  299. if (movedSpecial.updated !== 1 || Number(movedSpecial.results?.[0]?.pid) !== 0) throw new Error('专题批量迁移失败');
  300. const mergeBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'specialBatch', className: 'Special', action: 'merge', objectIds: [childSpecial.objectId], targetId: rootSpecId }, 501);
  301. if (!String(mergeBlocked.message).includes('specialId')) throw new Error('专题合并数据阻塞未返回明确原因');
  302. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'Special', objectId: childSpecial.objectId });
  303. temporarySpecialObjectIds.pop();
  304. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'Special', objectId: rootSpecial.objectId });
  305. temporarySpecialObjectIds.pop();
  306. const categorySuffix = Date.now().toString(36);
  307. const rootCategory = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGuestCategory', className: 'Guestcate', gtype: 1, parentId: 0, fields: { catename: `冒烟贴吧版块-${categorySuffix}`, desc: '分类生命周期验证', needLog: 1 } });
  308. temporaryGuestCategoryObjectIds.push(String(rootCategory.objectId || ''));
  309. const rootCateid = Number(rootCategory.cateid);
  310. if (!temporaryGuestCategoryObjectIds[0] || !rootCateid || Number(rootCategory.gtype) !== 1 || rootCategory.sourceKey !== `[["Cateid",${rootCateid}]]`) throw new Error(`贴吧分类原子创建异常:${JSON.stringify(rootCategory)}`);
  311. const childCategory = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGuestCategory', className: 'Guestcate', gtype: 1, parentId: rootCateid, fields: { catename: `冒烟子版块-${categorySuffix}` } });
  312. temporaryGuestCategoryObjectIds.push(String(childCategory.objectId || ''));
  313. const childCateid = Number(childCategory.cateid);
  314. if (!temporaryGuestCategoryObjectIds[1] || !childCateid || Number(childCategory.parentId) !== rootCateid) throw new Error('贴吧子分类创建失败');
  315. const guestCategory = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGuestCategory', className: 'Guestcate', gtype: 0, parentId: 0, fields: { catename: `冒烟留言分类-${categorySuffix}`, status: 1 } });
  316. temporaryGuestCategoryObjectIds.push(String(guestCategory.objectId || ''));
  317. const barAuthorizationBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barAuthorization', cateId: rootCateid }, 501);
  318. if (!String(barAuthorizationBlocked.message).includes('ZL_Guest_BarAuth')) throw new Error('贴吧逐用户权限数据阻塞未返回明确原因');
  319. const barMedalBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barMedal', objectId: 'missing-post' }, 501);
  320. if (!String(barMedalBlocked.message).includes('ZL_Guest_Medals')) throw new Error('贴吧勋章数据阻塞未返回明确原因');
  321. const temporaryBar = await jsonRequest(`${PARSE_URL}/classes/GuestBar`, { method: 'POST', body: JSON.stringify({ sourceKey: `cloud:smoke-bar:${categorySuffix}`, company, cateId: rootCateid, pid: 0, title: '后台贴吧工作流冒烟', msgContent: '冒烟正文', status: 0, orderFlag: 0, postFlag: '', cdate: { __type: 'Date', iso: new Date().toISOString() } }) }, true);
  322. temporaryGuestBarId = String(temporaryBar.objectId || '');
  323. const barAudited = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barBatch', className: 'GuestBar', action: 'audit', objectIds: [temporaryGuestBarId] });
  324. if (Number(barAudited.results?.[0]?.status) !== 99) throw new Error('贴吧帖子审核失败');
  325. const barElite = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barBatch', className: 'GuestBar', action: 'elite', objectIds: [temporaryGuestBarId] });
  326. if (!String(barElite.results?.[0]?.postFlag).includes('Recommend')) throw new Error('贴吧帖子加精失败');
  327. const barTop = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barBatch', className: 'GuestBar', action: 'top-global', objectIds: [temporaryGuestBarId] });
  328. if (Number(barTop.results?.[0]?.orderFlag) !== 2) throw new Error('贴吧帖子全局置顶失败');
  329. const barMoved = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barBatch', className: 'GuestBar', action: 'move', objectIds: [temporaryGuestBarId], cateId: childCateid });
  330. if (Number(barMoved.results?.[0]?.cateId) !== childCateid) throw new Error('贴吧帖子移动版块失败');
  331. const barRecycled = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barBatch', className: 'GuestBar', action: 'recycle', objectIds: [temporaryGuestBarId] });
  332. if (Number(barRecycled.results?.[0]?.status) !== -2) throw new Error('贴吧帖子回收失败');
  333. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'barBatch', className: 'GuestBar', action: 'recover', objectIds: [temporaryGuestBarId] });
  334. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGuestCategory', className: 'Guestcate', gtype: 1, parentId: 0, fields: { catename: rootCategory.catename } }, 409);
  335. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGuestCategory', className: 'Guestcate', objectId: rootCategory.objectId, gtype: 0, parentId: childCateid, fields: { ...rootCategory, catename: rootCategory.catename } }, 409);
  336. const recommendedCategory = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'guestCategoryBatch', className: 'Guestcate', action: 'recommend', objectIds: [rootCategory.objectId] });
  337. if (recommendedCategory.results?.[0]?.barInfo !== 'Recommend') throw new Error('贴吧分类推荐失败');
  338. const categoryDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'Guestcate', objectId: rootCategory.objectId }, 409);
  339. if (!String(categoryDeleteBlocked.message).includes('引用')) throw new Error('分类子级引用删除保护未返回明确原因');
  340. await jsonRequest(`${PARSE_URL}/classes/GuestBar/${temporaryGuestBarId}`, { method: 'DELETE' }, true);
  341. temporaryGuestBarId = '';
  342. for (const category of [childCategory, rootCategory, guestCategory]) {
  343. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'Guestcate', objectId: category.objectId });
  344. temporaryGuestCategoryObjectIds.splice(temporaryGuestCategoryObjectIds.indexOf(String(category.objectId)), 1);
  345. }
  346. const examClassSuffix = Date.now().toString(36);
  347. const rootExamClass = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamClass', className: 'ExamClass', parentId: 0, classType: 1, orderId: 0, fields: { cClassName: `冒烟试题分类-${examClassSuffix}` } });
  348. temporaryExamClassObjectIds.push(String(rootExamClass.objectId || ''));
  349. const rootExamClassId = Number(rootExamClass.cId);
  350. if (!temporaryExamClassObjectIds[0] || !rootExamClassId || rootExamClass.sourceKey !== `[["C_id",${rootExamClassId}]]`) throw new Error(`试题分类原子创建异常:${JSON.stringify(rootExamClass)}`);
  351. const childExamClass = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamClass', className: 'ExamClass', parentId: rootExamClassId, classType: 2, orderId: 0, fields: { cClassName: `冒烟子试题分类-${examClassSuffix}` } });
  352. temporaryExamClassObjectIds.push(String(childExamClass.objectId || ''));
  353. const childExamClassId = Number(childExamClass.cId);
  354. if (!childExamClassId || Number(childExamClass.cClassid) !== rootExamClassId || Number(childExamClass.cClassType) !== 2) throw new Error('子试题分类创建失败');
  355. const examChildren = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'examClassChildren', className: 'ExamClass', parentId: rootExamClassId });
  356. if (!examChildren.results?.some((entry) => entry.objectId === childExamClass.objectId)) throw new Error('试题子分类接口未返回目标记录');
  357. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamClass', className: 'ExamClass', parentId: 0, classType: 1, orderId: 0, fields: { cClassName: rootExamClass.cClassName } }, 409);
  358. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamClass', className: 'ExamClass', objectId: rootExamClass.objectId, parentId: childExamClassId, classType: 1, orderId: Number(rootExamClass.cOrderBy) || 0, fields: { cClassName: rootExamClass.cClassName } }, 409);
  359. const examClassDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ExamClass', objectId: rootExamClass.objectId }, 409);
  360. if (!String(examClassDeleteBlocked.message).includes('下级分类')) throw new Error('试题分类子级引用删除保护未返回明确原因');
  361. const movedExamClass = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamClass', className: 'ExamClass', objectId: childExamClass.objectId, parentId: 0, classType: 2, orderId: Number(childExamClass.cOrderBy) || 0, fields: { cClassName: childExamClass.cClassName } });
  362. if (Number(movedExamClass.cClassid) !== 0) throw new Error('试题分类结构移动失败');
  363. const knowledgeSuffix = Date.now().toString(36);
  364. const rootKnowledge = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveKnowledge', className: 'QuestionsKnowledge', classId: rootExamClassId, parentId: 0, orderId: 0, fields: { kName: `冒烟知识点-${knowledgeSuffix}`, status: 1, grade: 0, isSys: 0 } });
  365. temporaryKnowledgeObjectIds.push(String(rootKnowledge.objectId || ''));
  366. const rootKnowledgeId = Number(rootKnowledge.kId);
  367. if (!temporaryKnowledgeObjectIds[0] || !rootKnowledgeId || rootKnowledge.sourceKey !== `[["k_id",${rootKnowledgeId}]]`) throw new Error(`知识点原子创建异常:${JSON.stringify(rootKnowledge)}`);
  368. const childKnowledge = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveKnowledge', className: 'QuestionsKnowledge', classId: rootExamClassId, parentId: rootKnowledgeId, orderId: 0, fields: { kName: `冒烟子知识点-${knowledgeSuffix}`, status: 1, grade: 0, isSys: 0 } });
  369. temporaryKnowledgeObjectIds.push(String(childKnowledge.objectId || ''));
  370. const childKnowledgeId = Number(childKnowledge.kId);
  371. if (!childKnowledgeId || Number(childKnowledge.pid) !== rootKnowledgeId || Number(childKnowledge.kClassId) !== rootExamClassId) throw new Error('子知识点创建失败');
  372. const knowledgeChildren = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'knowledgeChildren', className: 'QuestionsKnowledge', classId: rootExamClassId, parentId: rootKnowledgeId });
  373. if (!knowledgeChildren.results?.some((entry) => entry.objectId === childKnowledge.objectId)) throw new Error('知识点子级接口未返回目标记录');
  374. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveKnowledge', className: 'QuestionsKnowledge', classId: rootExamClassId, parentId: 0, orderId: 0, fields: { kName: rootKnowledge.kName, status: 1, grade: 0, isSys: 0 } }, 409);
  375. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveKnowledge', className: 'QuestionsKnowledge', objectId: rootKnowledge.objectId, classId: rootExamClassId, parentId: childKnowledgeId, orderId: Number(rootKnowledge.kOrderBy) || 0, fields: { kName: rootKnowledge.kName, status: 1, grade: 0, isSys: 0 } }, 409);
  376. const knowledgeDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'QuestionsKnowledge', objectId: rootKnowledge.objectId }, 409);
  377. if (!String(knowledgeDeleteBlocked.message).includes('下级知识点')) throw new Error('知识点子级引用删除保护未返回明确原因');
  378. const movedKnowledge = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveKnowledge', className: 'QuestionsKnowledge', objectId: childKnowledge.objectId, classId: rootExamClassId, parentId: 0, orderId: Number(childKnowledge.kOrderBy) || 0, fields: { kName: childKnowledge.kName, status: 1, grade: 0, isSys: 0 } });
  379. if (Number(movedKnowledge.pid) !== 0) throw new Error('知识点结构移动失败');
  380. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'QuestionsKnowledge', objectId: childKnowledge.objectId });
  381. temporaryKnowledgeObjectIds.pop();
  382. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'QuestionsKnowledge', objectId: rootKnowledge.objectId });
  383. temporaryKnowledgeObjectIds.pop();
  384. const examTeacher = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamTeacher', className: 'ExTeacher', classId: rootExamClassId, fields: { tname: `冒烟考试教师-${examClassSuffix}`, post: '测试岗位', teach: '测试科目', fileUpload: '', remark: '教师生命周期验证' } });
  385. temporaryExamTeacherId = String(examTeacher.objectId || '');
  386. const examTeacherLegacyId = Number(examTeacher.id);
  387. if (!temporaryExamTeacherId || !examTeacherLegacyId || Number(examTeacher.tclsss) !== rootExamClassId || examTeacher.sourceKey !== `[["ID",${examTeacherLegacyId}]]`) throw new Error(`考试教师原子创建异常:${JSON.stringify(examTeacher)}`);
  388. const updatedExamTeacher = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamTeacher', className: 'ExTeacher', objectId: temporaryExamTeacherId, classId: childExamClassId, fields: { tname: examTeacher.tname, post: '更新岗位', teach: '更新科目', fileUpload: '', remark: '已更新' } });
  389. if (Number(updatedExamTeacher.tclsss) !== childExamClassId || updatedExamTeacher.post !== '更新岗位') throw new Error('考试教师更新失败');
  390. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ExTeacher', objectId: temporaryExamTeacherId });
  391. temporaryExamTeacherId = '';
  392. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ExamClass', objectId: childExamClass.objectId });
  393. temporaryExamClassObjectIds.pop();
  394. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ExamClass', objectId: rootExamClass.objectId });
  395. temporaryExamClassObjectIds.pop();
  396. const dictionarySuffix = Date.now().toString(36);
  397. const existingDictionaryItems = await jsonRequest(`${PARSE_URL}/classes/Datadic?limit=1000`, {}, true);
  398. const highestExistingCategoryRef = Math.max(0, ...(existingDictionaryItems.results || []).map((entry) => Number(entry.diccate) || 0));
  399. const dictionaryCategory = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveDictionaryCategory', className: 'Datadiccategory', fields: { categoryname: `冒烟字典分类-${dictionarySuffix}`, isused: true } });
  400. temporaryDictionaryCategoryIds.push(String(dictionaryCategory.objectId || ''));
  401. const dictionaryCategoryId = Number(dictionaryCategory.diccateid);
  402. if (!temporaryDictionaryCategoryIds[0] || dictionaryCategoryId <= highestExistingCategoryRef || dictionaryCategory.sourceKey !== `[["Diccateid",${dictionaryCategoryId}]]`) throw new Error(`字典分类原子编号或既有引用避让异常:${JSON.stringify(dictionaryCategory)}`);
  403. const selectableCategories = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'dictionaryCategories', enabledOnly: true });
  404. if (!selectableCategories.results?.some((entry) => entry.objectId === dictionaryCategory.objectId)) throw new Error('字典分类选择接口未返回新建分类');
  405. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveDictionaryCategory', className: 'Datadiccategory', fields: { categoryname: dictionaryCategory.categoryname, isused: true } }, 409);
  406. const dictionaryItem = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveDictionaryItem', className: 'Datadic', categoryId: dictionaryCategoryId, fields: { dicname: `冒烟字典项-${dictionarySuffix}`, isused: true } });
  407. temporaryDictionaryItemIds.push(String(dictionaryItem.objectId || ''));
  408. const dictionaryItemId = Number(dictionaryItem.dicid);
  409. if (!temporaryDictionaryItemIds[0] || !dictionaryItemId || Number(dictionaryItem.diccate) !== dictionaryCategoryId || dictionaryItem.sourceKey !== `[["Dicid",${dictionaryItemId}]]`) throw new Error(`字典项原子创建异常:${JSON.stringify(dictionaryItem)}`);
  410. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveDictionaryItem', className: 'Datadic', categoryId: dictionaryCategoryId, fields: { dicname: dictionaryItem.dicname, isused: true } }, 409);
  411. const dictionaryCategoryDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'dictionaryBatch', className: 'Datadiccategory', action: 'delete', objectIds: [dictionaryCategory.objectId] }, 409);
  412. if (!String(dictionaryCategoryDeleteBlocked.message).includes('仍有字典项')) throw new Error('字典分类引用删除保护未返回明确原因');
  413. const dictionaryDisabled = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'dictionaryBatch', className: 'Datadic', action: 'disable', objectIds: [dictionaryItem.objectId] });
  414. if (dictionaryDisabled.results?.[0]?.isused !== false) throw new Error('字典项批量停用失败');
  415. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'dictionaryBatch', className: 'Datadic', action: 'enable', objectIds: [dictionaryItem.objectId] });
  416. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'dictionaryBatch', className: 'Datadic', action: 'delete', objectIds: [dictionaryItem.objectId] });
  417. temporaryDictionaryItemIds.pop();
  418. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'dictionaryBatch', className: 'Datadiccategory', action: 'delete', objectIds: [dictionaryCategory.objectId] });
  419. temporaryDictionaryCategoryIds.pop();
  420. const gradeSuffix = Date.now().toString(36);
  421. const gradeCategory = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGradeCategory', className: 'GradeCate', fields: { cateName: `冒烟多级字典-${gradeSuffix}`, remark: '多级字典生命周期验证', gradeField: '省份|城市' } });
  422. temporaryGradeCategoryIds.push(String(gradeCategory.objectId || ''));
  423. const gradeCategoryId = Number(gradeCategory.cateId);
  424. if (!temporaryGradeCategoryIds[0] || !gradeCategoryId || gradeCategory.sourceKey !== `[["CateID",${gradeCategoryId}]]` || gradeCategory.gradeField !== '省份|城市') throw new Error(`多级字典分类原子创建异常:${JSON.stringify(gradeCategory)}`);
  425. const gradeCategoryList = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'gradeCategories' });
  426. if (!gradeCategoryList.results?.some((entry) => entry.objectId === gradeCategory.objectId)) throw new Error('多级字典分类选择接口未返回新建分类');
  427. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGradeCategory', className: 'GradeCate', fields: { cateName: gradeCategory.cateName, gradeField: '一级|二级' } }, 409);
  428. const rootGrade = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGradeOption', className: 'Grade', categoryId: gradeCategoryId, parentId: 0, fields: { gradeName: `冒烟省份-${gradeSuffix}` } });
  429. temporaryGradeOptionIds.push(String(rootGrade.objectId || ''));
  430. const rootGradeId = Number(rootGrade.gradeId);
  431. if (!temporaryGradeOptionIds[0] || !rootGradeId || Number(rootGrade.grade) !== 1 || Number(rootGrade.parentId) !== 0 || rootGrade.sourceKey !== `[["GradeID",${rootGradeId}]]`) throw new Error(`一级字典选项创建异常:${JSON.stringify(rootGrade)}`);
  432. const childGrade = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGradeOption', className: 'Grade', categoryId: gradeCategoryId, parentId: rootGradeId, fields: { gradeName: `冒烟城市-${gradeSuffix}` } });
  433. temporaryGradeOptionIds.push(String(childGrade.objectId || ''));
  434. const childGradeId = Number(childGrade.gradeId);
  435. if (!childGradeId || Number(childGrade.parentId) !== rootGradeId || Number(childGrade.grade) !== 2 || Number(childGrade.cate) !== gradeCategoryId) throw new Error('二级字典选项创建失败');
  436. const gradePage = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'gradeOptions', categoryId: gradeCategoryId, parentId: rootGradeId, page: 1, pageSize: 20 });
  437. if (!gradePage.results?.some((entry) => entry.objectId === childGrade.objectId)) throw new Error('多级字典分层列表未返回子选项');
  438. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGradeOption', className: 'Grade', categoryId: gradeCategoryId, parentId: rootGradeId, fields: { gradeName: childGrade.gradeName } }, 409);
  439. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGradeOption', className: 'Grade', categoryId: gradeCategoryId, parentId: childGradeId, fields: { gradeName: '越界三级选项' } }, 409);
  440. const updatedChildGrade = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGradeOption', className: 'Grade', objectId: childGrade.objectId, categoryId: 999999, parentId: 0, fields: { gradeName: `${childGrade.gradeName}-更新`, cate: 999999, parentId: 0, grade: 1 } });
  441. if (Number(updatedChildGrade.cate) !== gradeCategoryId || Number(updatedChildGrade.parentId) !== rootGradeId || Number(updatedChildGrade.grade) !== 2) throw new Error('多级字典选项编辑篡改了结构字段');
  442. const gradeCategoryDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'gradeBatch', className: 'GradeCate', action: 'delete', objectIds: [gradeCategory.objectId] }, 409);
  443. if (!String(gradeCategoryDeleteBlocked.message).includes('仍有选项')) throw new Error('多级字典分类引用删除保护未返回明确原因');
  444. const rootGradeDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'gradeBatch', className: 'Grade', action: 'delete', objectIds: [rootGrade.objectId] }, 409);
  445. if (!String(rootGradeDeleteBlocked.message).includes('下级选项')) throw new Error('多级字典子级删除保护未返回明确原因');
  446. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'gradeBatch', className: 'Grade', action: 'delete', objectIds: [childGrade.objectId] }); temporaryGradeOptionIds.pop();
  447. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'gradeBatch', className: 'Grade', action: 'delete', objectIds: [rootGrade.objectId] }); temporaryGradeOptionIds.pop();
  448. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'gradeBatch', className: 'GradeCate', action: 'delete', objectIds: [gradeCategory.objectId] }); temporaryGradeCategoryIds.pop();
  449. const currencyCreateBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveCurrency', className: 'Currency', fields: { title: '禁止无旧 ID 货币', currencyName: 'TST', currencySymbol: 'T$', currentExchange: 1.25, remark: '应被阻塞' } }, 501);
  450. if (!String(currencyCreateBlocked.message).includes('保留 id')) throw new Error('货币新增未返回明确旧 ID 阻塞原因');
  451. const holidayCreateBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveHoliday', className: 'SysHoliday', fields: { name: '禁止无旧 ID 节假日' } }, 501);
  452. if (!String(holidayCreateBlocked.message).includes('保留 id')) throw new Error('节假日新增未返回明确旧 ID 阻塞原因');
  453. const searchNavigationCreateBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveSearchNavigation', className: 'Search', fields: { name: '禁止无旧 ID 快捷入口' } }, 501);
  454. if (!String(searchNavigationCreateBlocked.message).includes('保留 id')) throw new Error('快捷入口新增未返回明确旧 ID 阻塞原因');
  455. const searchNavigationStartBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'searchNavigationBatch', className: 'Search', action: 'starturl', objectIds: ['not-used'] }, 501);
  456. if (!String(searchNavigationStartBlocked.message).includes('SiteConfig')) throw new Error('快捷入口全局起始页未返回明确阻塞原因');
  457. for (const action of ['APIInfo_Submit','APIInfo_SwaggerClose','APIInfo_SwaggerOpen','LicenceFile_API','close_system','Hotkey','HotkeyAdd','HotkeyAdd_Submit','Hotkey_API','Prize','Prize_Submit']) {
  458. const configBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'legacyConfigBlocker', action }, 501);
  459. if (!String(configBlocked.message).startsWith('migration_blocked:')) throw new Error(`旧配置动作 ${action} 未返回明确阻塞原因`);
  460. }
  461. if (dictionaryCategory.company?.__type !== 'Pointer' || JSON.stringify(dictionaryCategory).match(/accessToken|mch_key|"ak"|"sk"/i)) throw new Error('后台响应展开了帐套敏感配置');
  462. const examPointSuffix = Date.now().toString(36);
  463. const rootExamPoint = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamPoint', className: 'ExamPoint', parentId: 0, orderId: 0, fields: { testPoint: `冒烟考点-${examPointSuffix}` } });
  464. temporaryExamPointObjectIds.push(String(rootExamPoint.objectId || ''));
  465. const rootExamPointId = Number(rootExamPoint.id);
  466. if (!temporaryExamPointObjectIds[0] || !rootExamPointId || rootExamPoint.sourceKey !== `[["ID",${rootExamPointId}]]`) throw new Error(`考点原子创建异常:${JSON.stringify(rootExamPoint)}`);
  467. const childExamPoint = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamPoint', className: 'ExamPoint', parentId: rootExamPointId, orderId: 0, fields: { testPoint: `冒烟子考点-${examPointSuffix}` } });
  468. temporaryExamPointObjectIds.push(String(childExamPoint.objectId || ''));
  469. const childExamPointId = Number(childExamPoint.id);
  470. if (!childExamPointId || Number(childExamPoint.tid) !== rootExamPointId) throw new Error('子考点创建失败');
  471. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamPoint', className: 'ExamPoint', parentId: 0, orderId: 0, fields: { testPoint: rootExamPoint.testPoint } }, 409);
  472. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamPoint', className: 'ExamPoint', objectId: rootExamPoint.objectId, parentId: childExamPointId, orderId: Number(rootExamPoint.orderBy) || 0, fields: { testPoint: rootExamPoint.testPoint } }, 409);
  473. const examPointDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ExamPoint', objectId: rootExamPoint.objectId }, 409);
  474. if (!String(examPointDeleteBlocked.message).includes('下级考点')) throw new Error('考点子级引用删除保护未返回明确原因');
  475. const movedExamPoint = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveExamPoint', className: 'ExamPoint', objectId: childExamPoint.objectId, parentId: 0, orderId: Number(childExamPoint.orderBy) || 0, fields: { testPoint: childExamPoint.testPoint } });
  476. if (Number(movedExamPoint.tid) !== 0) throw new Error('考点结构移动失败');
  477. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ExamPoint', objectId: childExamPoint.objectId });
  478. temporaryExamPointObjectIds.pop();
  479. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ExamPoint', objectId: rootExamPoint.objectId });
  480. temporaryExamPointObjectIds.pop();
  481. const metadataSuffix = Date.now().toString(36);
  482. const temporaryModelId = 800000000 + Math.floor(Date.now() / 1000) % 100000000;
  483. const tempModel = await jsonRequest(`${PARSE_URL}/classes/Model`, { method: 'POST', body: JSON.stringify({ sourceKey: `cloud:smoke-model:${metadataSuffix}`, company, modelId: temporaryModelId, modelName: `冒烟模型-${metadataSuffix}`, tableName: `ZL_C_Smoke_${metadataSuffix}`, modelType: 1, itemName: '记录', itemUnit: '条', multiFlag: true }) }, true);
  484. temporaryModelObjectId = String(tempModel.objectId || '');
  485. const updatedModel = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveModelMetadata', className: 'Model', objectId: temporaryModelObjectId, fields: { modelName: `冒烟模型更新-${metadataSuffix}`, description: '仅元数据更新', tableName: 'malicious_table', modelId: 1 } });
  486. if (Number(updatedModel.modelId) !== temporaryModelId || updatedModel.tableName !== `ZL_C_Smoke_${metadataSuffix}` || updatedModel.description !== '仅元数据更新') throw new Error(`模型结构字段隔离异常:${JSON.stringify(updatedModel)}`);
  487. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveModelMetadata', className: 'Model', fields: { modelName: '禁止新增模型' } }, 501);
  488. for (let index = 0; index < 2; index++) {
  489. const field = await jsonRequest(`${PARSE_URL}/classes/ModelField`, { method: 'POST', body: JSON.stringify({ sourceKey: `cloud:smoke-model-field:${metadataSuffix}:${index}`, company, fieldId: temporaryModelId + index + 1, modelId: temporaryModelId, fieldName: `smokeField${index}`, fieldAlias: `冒烟字段${index}`, fieldType: 'TextType', orderId: index, isShow: true }) }, true);
  490. temporaryModelFieldObjectIds.push(String(field.objectId || ''));
  491. }
  492. const updatedField = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveModelFieldMetadata', className: 'ModelField', objectId: temporaryModelFieldObjectIds[0], fields: { fieldAlias: '更新后的字段别名', fieldTips: '仅展示元数据', fieldName: 'maliciousField', fieldType: 'SqlType', modelId: 1 } });
  493. if (updatedField.fieldAlias !== '更新后的字段别名' || updatedField.fieldName !== 'smokeField0' || updatedField.fieldType !== 'TextType' || Number(updatedField.modelId) !== temporaryModelId) throw new Error(`模型字段结构隔离异常:${JSON.stringify(updatedField)}`);
  494. const reorderedFields = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'modelFieldOrder', className: 'ModelField', items: [{ objectId: temporaryModelFieldObjectIds[0], orderId: 2 }, { objectId: temporaryModelFieldObjectIds[1], orderId: 1 }] });
  495. if (reorderedFields.updated !== 2 || Number(reorderedFields.modelId) !== temporaryModelId) throw new Error('模型字段排序失败');
  496. await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'delete', className: 'ModelField', objectId: temporaryModelFieldObjectIds[0] }, 501);
  497. const updatedGuestbook = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'saveGuestbook', className: 'Guestbook', objectId: temporaryGuestbookId, fields: { title: feedbackModel.Title, tcontent: '管理员规范化编辑', gid: 999, status: -2, cateid: 999 } });
  498. if (updatedGuestbook.tcontent !== '管理员规范化编辑' || Number(updatedGuestbook.gid) === 999 || Number(updatedGuestbook.cateid) === 999 || Number(updatedGuestbook.status) === -2) throw new Error(`留言结构字段隔离异常:${JSON.stringify(updatedGuestbook)}`);
  499. const guestUnaudited = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'guestbookBatch', className: 'Guestbook', action: 'unaudit', objectIds: [temporaryGuestbookId] });
  500. if (Number(guestUnaudited.results?.[0]?.status) !== 0) throw new Error('留言取消审核失败');
  501. const guestRecycled = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'guestbookBatch', className: 'Guestbook', action: 'recycle', objectIds: [temporaryGuestbookId] });
  502. if (Number(guestRecycled.results?.[0]?.status) !== -2) throw new Error('留言回收失败');
  503. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'guestbookBatch', className: 'Guestbook', action: 'recover', objectIds: [temporaryGuestbookId] });
  504. const guestReply = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'guestbookReply', className: 'Guestbook', parentObjectId: temporaryGuestbookId, title: '管理员冒烟回复', content: '云函数回复正文' });
  505. temporaryGuestbookReplyId = String(guestReply.objectId || '');
  506. if (!temporaryGuestbookReplyId || Number(guestReply.parentid) !== Number(updatedGuestbook.gid) || Number(guestReply.status) !== 99 || !Number(guestReply.gid)) throw new Error(`管理员留言回复异常:${JSON.stringify(guestReply)}`);
  507. const guestDeleteBlocked = await callFunctionError('xiaoshu/admin/gateway', login.sessionToken, { operation: 'guestbookBatch', className: 'Guestbook', action: 'purge', objectIds: [temporaryGuestbookId] }, 409);
  508. if (!String(guestDeleteBlocked.message).includes('仍有回复')) throw new Error('留言回复引用删除保护未返回明确原因');
  509. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'guestbookBatch', className: 'Guestbook', action: 'purge', objectIds: [temporaryGuestbookReplyId] });
  510. temporaryGuestbookReplyId = '';
  511. const contentPending = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'contentBatch', className: 'CommonModel', action: 'status', objectIds: [temporaryAppointmentCommonObjectId], status: 0 });
  512. if (contentPending.updated !== 1 || Number(contentPending.results?.[0]?.status) !== 0) throw new Error('内容待审核状态更新失败');
  513. const contentRecycled = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'contentBatch', className: 'CommonModel', action: 'recycle', objectIds: [temporaryAppointmentCommonObjectId] });
  514. if (Number(contentRecycled.results?.[0]?.status) !== -2) throw new Error('内容回收站状态更新失败');
  515. const contentRecovered = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'contentBatch', className: 'CommonModel', action: 'recover', objectIds: [temporaryAppointmentCommonObjectId] });
  516. if (Number(contentRecovered.results?.[0]?.status) !== 0) throw new Error('内容回收站恢复失败');
  517. const contentMoved = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'contentBatch', className: 'CommonModel', action: 'move', objectIds: [temporaryAppointmentCommonObjectId], nodeId: 29 });
  518. if (Number(contentMoved.results?.[0]?.nodeId) !== 29) throw new Error('内容节点移动失败');
  519. await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'contentBatch', className: 'CommonModel', action: 'status', objectIds: [temporaryAppointmentCommonObjectId], status: 99 });
  520. const page = await callFunction('xiaoshu/admin/gateway', login.sessionToken, { operation: 'list', className: 'CourseAppointment', page: 1, pageSize: 2 });
  521. if (!Array.isArray(page.results) || page.pageSize !== 2) throw new Error('资源分页校验失败');
  522. const normalized = await callFunction('xiaoshu/cms/content-normalizer', login.sessionToken, { content: '<p>中文&nbsp;<strong>内容</strong></p><script>alert(1)</script>' });
  523. if (normalized.content !== '中文 内容') throw new Error(`内容清理结果异常:${normalized.content}`);
  524. const exams = await callFunction('xiaoshu/cms/exams/classes', login.sessionToken, { page: 1, pageSize: 2 });
  525. if (!Array.isArray(exams.results)) throw new Error('考试班级投影校验失败');
  526. const guest = await callFunction('xiaoshu/cms/guest/bar', login.sessionToken, { page: 1, pageSize: 2 });
  527. if (!Array.isArray(guest.results)) throw new Error('互动社区投影校验失败');
  528. const migration = await callLegacyFunction('', { action: 'migration_status' });
  529. const sourceActionList = await sourceActions();
  530. const implementedActions = migration.result?.implemented || [];
  531. const blockedActions = Object.keys(migration.result?.blocked || {});
  532. const covered = new Set([...implementedActions, ...blockedActions]);
  533. const missing = sourceActionList.filter((action) => !covered.has(action));
  534. if (missing.length) throw new Error(`app gateway 迁移矩阵缺少:${missing.join(', ')}`);
  535. const sourceBlocked = blockedActions.filter((action) => sourceActionList.includes(action));
  536. const compatibilityActions = blockedActions.filter((action) => !sourceActionList.includes(action)).sort();
  537. const sourceImplemented = implementedActions.filter((action) => sourceActionList.includes(action));
  538. const compatibilityImplemented = implementedActions.filter((action) => !sourceActionList.includes(action)).sort();
  539. if (sourceImplemented.length !== 28 || sourceBlocked.length !== 63) throw new Error(`app gateway 源 action 计数异常:${sourceImplemented.length} 已映射 / ${sourceBlocked.length} 阻塞`);
  540. if (compatibilityImplemented.join(',') !== 'content_add_zt') throw new Error(`app gateway 已实现兼容 action 计数异常:${compatibilityImplemented.join(',')}`);
  541. if (compatibilityActions.join(',') !== 'product_add,product_upd') throw new Error(`app gateway 阻塞兼容 action 计数异常:${compatibilityActions.join(',')}`);
  542. const content = await callLegacyFunction('', { action: 'content_list', page: 1, pageSize: 2 });
  543. if (!Array.isArray(content.result) || content.result.length !== 2 || Number(content.page?.itemCount) < 89000) throw new Error('公开内容分页校验失败');
  544. const contentExact = await callLegacyFunction('', { action: 'content_list', page: 1, pageSize: 1, objectId: content.result[0].objectId });
  545. if (contentExact.result?.[0]?.objectId !== content.result[0].objectId || contentExact.page?.itemCount !== 1) throw new Error('内容 objectId 精确查询校验失败');
  546. const contentDetail = await callLegacyFunction('', { action: 'content_get', id: content.result[0].objectId });
  547. if (!Array.isArray(contentDetail.result) || contentDetail.result[0]?.objectId !== content.result[0].objectId) throw new Error('内容详情旧数组契约校验失败');
  548. contentHitObjectId = String(content.result[0].objectId);
  549. contentHitOriginal = Number(content.result[0].hits ?? content.result[0].Hits ?? 0);
  550. const contentHit = await callLegacyFunction('', { action: 'content_uphis', id: contentHitObjectId, num: 999 });
  551. if (Number(contentHit.result?.hits) !== contentHitOriginal + 1) throw new Error(`公开内容浏览量未固定原子加一:${JSON.stringify(contentHit)}`);
  552. await jsonRequest(`${PARSE_URL}/classes/CommonModel/${contentHitObjectId}`, { method: 'PUT', body: JSON.stringify({ hits: contentHitOriginal }) }, true);
  553. contentHitObjectId = '';
  554. await callLegacyFunction('', { action: 'content_uphis', id: temporaryAppointmentId }, 401);
  555. const appUpdate = await callLegacyFunction('', { action: 'app_update' });
  556. if (Number(appUpdate.result?.ver) !== 113 || appUpdate.result?.nver !== '1.1.8' || !String(appUpdate.result?.path).startsWith('https://') || appUpdate.result?.size !== null || appUpdate.result?.sizeUnavailable !== true) throw new Error(`应用版本旧契约别名异常:${JSON.stringify(appUpdate)}`);
  557. const gameNode = await callLegacyFunction('', { action: 'node_get', id: 77 });
  558. if (gameNode.result?.NodeID === undefined || gameNode.result?.ConsumePoint === undefined || gameNode.result?.ConsumeDeposit === undefined) throw new Error(`栏目详情游戏消费字段别名异常:${JSON.stringify(gameNode.result)}`);
  559. const words = await callLegacyFunction('', { action: 'content_list', modelId: 52, page: 1, pageSize: 1 });
  560. if (Number(words.page?.itemCount) < 89000 || !words.result?.[0]?.GeneralID || words.result?.[0]?.sy === undefined) throw new Error('词库 addon 联表校验失败');
  561. const privateContent = await callLegacyFunction('', { action: 'content_list', modelId: 56, page: 1, pageSize: 1 }, 401);
  562. if (!String(privateContent.retmsg).includes('登录')) throw new Error('学习记录未阻止匿名访问');
  563. const learning = await callLegacyFunction(login.sessionToken, { action: 'content_list', modelId: 56, page: 1, pageSize: 1 });
  564. if (!learning.result?.[0]?.GeneralID || learning.result?.[0]?.xxqs === undefined) throw new Error('学习记录 addon 联表校验失败');
  565. const recordDetail = await callLegacyFunction(login.sessionToken, { action: 'e_record_detail', id: learning.result[0].GeneralID });
  566. if (!Array.isArray(recordDetail.result) || !recordDetail.result.length || !recordDetail.result[0]?.detail?.[0]?.Title) throw new Error('学习记录单词详情联查校验失败');
  567. const appointments = await callLegacyFunction(login.sessionToken, { action: 'content_list', modelId: 54, page: 1, pageSize: 1 });
  568. const appointment = await callLegacyFunction(login.sessionToken, { action: 'e_order_detail', id: appointments.result?.[0]?.GeneralID });
  569. if (!appointment.result?.[0]?.GeneralID || appointment.result[0].kcid === undefined) throw new Error('预约详情联查校验失败');
  570. const memberProfile = await callLegacyFunction(memberLogin.sessionToken, { action: 'user_get', uid: memberLegacyId });
  571. if (memberProfile.result?.honeyName !== profileModel.honeyName || memberProfile.addon?.vip !== 2 || memberProfile.addon?.silverCoin !== 2 || JSON.stringify(memberProfile).includes('must-not-leak')) throw new Error('用户旧契约字段或敏感字段过滤异常');
  572. const teamMembers = await callLegacyFunction(memberLogin.sessionToken, { action: 'user_list', puid: memberLegacyId, cpage: 1, psize: 10 });
  573. if (teamMembers.page?.itemCount !== 1 || Number(teamMembers.result?.[0]?.ParentUserID) !== memberLegacyId || Number(teamMembers.result?.[0]?.VIP) !== 3) throw new Error(`团队成员列表异常:${JSON.stringify(teamMembers)}`);
  574. const teamSummary = await callLegacyFunction(memberLogin.sessionToken, { action: 'user_dept', uid: memberLegacyId });
  575. if (teamSummary.result?.childs !== 1 || teamSummary.result?.v3 !== 1) throw new Error(`团队会员统计异常:${JSON.stringify(teamSummary.result)}`);
  576. const childProfile = await callLegacyFunction(memberLogin.sessionToken, { action: 'user_get', uid: childLegacyId });
  577. if (childProfile.result?.userId !== childLegacyId || childProfile.result?.puid !== memberLegacyId || JSON.stringify(childProfile).includes('must-not-leak')) throw new Error('团队成员详情或密码字段过滤异常');
  578. await callLegacyFunction(coachLogin.sessionToken, { action: 'user_get', uid: childLegacyId }, 403);
  579. const coachStudents = await callLegacyFunction(coachLogin.sessionToken, { action: 'e_user_list', cpage: 1, psize: 10 });
  580. if (coachStudents.page?.itemCount !== 1 || Number(coachStudents.result?.[0]?.szyh) !== memberLegacyId || coachStudents.result?.[0]?.honeyname !== profileModel.honeyName) throw new Error(`陪练学员分组列表异常:${JSON.stringify(coachStudents)}`);
  581. const newWords = await callLegacyFunction(login.sessionToken, { action: 'e_words_list', uid: 58, page: 1, pageSize: 2 });
  582. if (Number(newWords.page?.itemCount) < 1 || !newWords.result?.[0]?.detail?.[0]?.Title) throw new Error('用户生词联查校验失败');
  583. const courseWords = await callLegacyFunction(login.sessionToken, { action: 'e_ck_list', uid: 58, nids: 40, page: 1, pageSize: 1000 });
  584. const learnedWord = courseWords.result?.find((word) => Number(word.GeneralID) === 2505);
  585. if (Number(courseWords.page?.itemCount) < 1 || !courseWords.result?.[0]?.detail?.Title || Number(learnedWord?.w_learned) !== 7) throw new Error('课程词库学习进度联查校验失败');
  586. const memory = await callLegacyFunction(login.sessionToken, { action: 'e_get_21list', uid: 58, page: 1, pageSize: 2 });
  587. if (Number(memory.page?.itemCount) < 1 || !memory.result?.[0]?.GeneralID || memory.result[0].learned === undefined) throw new Error('21 天抗遗忘联查校验失败');
  588. const incomeBlocked = await callLegacyFunction(login.sessionToken, { action: 'e_get_21list_tj', uid: 58 }, 501);
  589. if (!String(incomeBlocked.retmsg).includes('计价规则')) throw new Error('复习收入缺失规则未显式阻塞');
  590. const ownEmpty = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_list', modelId: 56, myfield2: `UserId=${memberLegacyId}`, page: 1, pageSize: 1 });
  591. if (!Array.isArray(ownEmpty.result) || ownEmpty.page?.itemCount !== 0) throw new Error('普通用户本人记录权限校验失败');
  592. const ownCourseWords = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_ck_list', uid: memberLegacyId, nids: 40, page: 1, pageSize: 1 });
  593. if (!Array.isArray(ownCourseWords.result) || ownCourseWords.result[0]?.w_learned !== 0) throw new Error('普通用户本人课程词库权限校验失败');
  594. const learnedWrite = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_add_words', uid: memberLegacyId, wordsId: '2505', kcid: 16, save: 1 });
  595. if (learnedWrite.result?.created !== 1 || learnedWrite.result?.learnedIncremented !== 1) throw new Error('首次学习词进度写入校验失败');
  596. await callLegacyFunction('', { action: 'node_list', pid: 16, ifunit: 1, userId: memberLegacyId }, 401);
  597. const unitNodes = await callLegacyFunction(memberLogin.sessionToken, { action: 'node_list', pid: 16, ifunit: 1, userId: memberLegacyId, pageSize: 100 });
  598. const learnedUnit = unitNodes.result?.find((node) => Number(node.NodeID) === 40);
  599. if (!learnedUnit || Number(learnedUnit.total) < 1 || Number(learnedUnit.yx_word) !== 1 || Number(learnedUnit.process) !== Math.round(100 / Number(learnedUnit.total))) throw new Error(`单元已学进度异常:${JSON.stringify(learnedUnit)}`);
  600. const learnedRead = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_ck_list', uid: memberLegacyId, nids: 40, page: 1, pageSize: 1000 });
  601. if (Number(learnedRead.result?.find((word) => Number(word.GeneralID) === 2505)?.w_learned) !== 1) throw new Error('学习次数写后读校验失败');
  602. await callLegacyFunction(memberLogin.sessionToken, { action: 'e_add_words', uid: memberLegacyId, wordsId: '2505', kcid: 16, ifnew: 1 });
  603. const addedNewWord = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_words_list', uid: memberLegacyId, page: 1, pageSize: 10 });
  604. if (addedNewWord.page?.itemCount !== 1 || Number(addedNewWord.result?.[0]?.detail?.[0]?.GeneralID) !== 2505) throw new Error('加入生词写后读校验失败');
  605. await callLegacyFunction(memberLogin.sessionToken, { action: 'e_add_words', uid: memberLegacyId, wordsId: '2505', kcid: 16, ifnew: 0 });
  606. const removedNewWord = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_words_list', uid: memberLegacyId, page: 1, pageSize: 10 });
  607. if (removedNewWord.page?.itemCount !== 0) throw new Error('移出生词写后读校验失败');
  608. const scheduledStudy = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_add_zt', content: JSON.stringify({ ModelID: 56, nodeId: 291, inputer: memberUsername, status: 99, Hits: 1, title: memberUsername }), addon: JSON.stringify({ UserID: memberLegacyId, dqrq: '20991231', learned: 1, xxqs: JSON.stringify([{ GeneralID: 2505, Title: 'woman', check: 0 }]) }) });
  609. if (!/^\d{15}$/.test(String(scheduledStudy.result))) throw new Error('带复习计划的学习记录创建结果异常');
  610. const scheduledDetail = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_get', id: scheduledStudy.result });
  611. const reviewDates = String(scheduledDetail.result?.[0]?.fxrl || '').split(',').filter(Boolean);
  612. if (reviewDates.length !== 15 || !reviewDates.every((date) => /^\d{8}$/.test(date))) throw new Error('15 段抗遗忘复习日期生成失败');
  613. await callLegacyFunction(coachLogin.sessionToken, { action: 'content_update', content: JSON.stringify({ GeneralID: scheduledStudy.result }), addon: JSON.stringify({ con: '越权更新' }) }, 403);
  614. const scheduledUpdate = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_update', content: JSON.stringify({ GeneralID: scheduledStudy.result, Title: '已更新学习记录' }), addon: JSON.stringify({ con: '规范化内容更新', learned: 1 }) });
  615. if (String(scheduledUpdate.result) !== String(scheduledStudy.result)) throw new Error('规范化内容更新返回值异常');
  616. const updatedScheduledDetail = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_get', id: scheduledStudy.result });
  617. if (updatedScheduledDetail.result?.[0]?.con !== '规范化内容更新' || updatedScheduledDetail.result?.[0]?.Title !== '已更新学习记录') throw new Error('规范化内容双表更新写后读失败');
  618. const assessment = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_add', content: JSON.stringify({ ModelID: 61, nodeId: 389, inputer: memberUsername, status: 99, Hits: 1, title: memberUsername }), addon: JSON.stringify({ UserID: memberLegacyId, askid: 1, prev_score: 0, totalScore: 10, wrong: 2, dontKnow: 1, answerid: 7, df: 7 }) });
  619. if (!/^\d{15}$/.test(String(assessment.result))) throw new Error('规范化测评内容新增结果异常');
  620. const assessmentDetail = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_get', id: assessment.result });
  621. if (String(assessmentDetail.result?.[0]?.df) !== '7' || String(assessmentDetail.result?.[0]?.prevScore) !== '0' || Number(assessmentDetail.result?.[0]?.UserID ?? assessmentDetail.result?.[0]?.userId) !== memberLegacyId) throw new Error('规范化测评内容新增写后读失败');
  622. const missingSchemaCreate = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_add', content: JSON.stringify({ ModelID: 55, nodeId: 255 }), addon: JSON.stringify({ UserID: memberLegacyId, scnr: '[]' }) }, 501);
  623. if (!String(missingSchemaCreate.retmsg).includes('未迁移内容模型 55')) throw new Error('缺 Schema 内容新增未明确拒绝');
  624. const studyAddon = { con: '云函数学习记录冒烟测试', dqrq: '20260818', fxrl: '20260819,20260820', UserID: memberLegacyId, learned: 1, ygg: 0, djq: 0, xxqs: JSON.stringify([{ GeneralID: 2505, Title: 'woman', check: 0 }]) };
  625. const createdStudy = await callLegacyFunction(memberLogin.sessionToken, { action: 'stu_record_update_v2', orderId: temporaryAppointmentId, uid: memberLegacyId, inputer: memberUsername, addon: JSON.stringify(studyAddon) });
  626. if (!createdStudy.result?.created || !createdStudy.result?.GeneralID || !createdStudy.result?.recordObjectId) throw new Error('预约学习记录首次双表写入校验失败');
  627. const studyDetail = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_record_detail', id: createdStudy.result.GeneralID });
  628. if (studyDetail.result?.[0]?.detail?.[0]?.Title !== 'woman') throw new Error('预约学习记录写后详情校验失败');
  629. studyAddon.xxqs = JSON.stringify([{ GeneralID: 2505, Title: 'woman', check: 1 }]);
  630. const updatedStudy = await callLegacyFunction(memberLogin.sessionToken, { action: 'stu_record_update_v2', orderId: temporaryAppointmentId, uid: memberLegacyId, inputer: memberUsername, addon: JSON.stringify(studyAddon) });
  631. if (updatedStudy.result?.created || updatedStudy.result?.GeneralID !== createdStudy.result.GeneralID) throw new Error('预约学习记录幂等更新校验失败');
  632. const studyList = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_list', modelId: 56, myfield2: `UserId=${memberLegacyId}|dsid=${temporaryAppointmentId}`, page: 1, pageSize: 2 });
  633. if (studyList.page?.itemCount !== 1 || Number(studyList.result?.[0]?.ygg) !== 1 || Number(studyList.result?.[0]?.learned) !== 1) throw new Error('预约学习记录聚合字段写后读校验失败');
  634. const orderContent = JSON.stringify({ GeneralID: temporaryAppointmentId, UpDateTime: '2026-08-18 13:30' });
  635. await callLegacyFunction(memberLogin.sessionToken, { action: 'e_order_update_v2', uid: memberLegacyId, status: 10, content: orderContent }, 403);
  636. const startedOrder = await callLegacyFunction(coachLogin.sessionToken, { action: 'e_order_update_v2', uid: coachLegacyId, status: 10, content: orderContent });
  637. if (startedOrder.result?.previousStatus !== 0 || startedOrder.result?.status !== 10) throw new Error('预约开始状态迁移失败');
  638. const endedOrder = await callLegacyFunction(coachLogin.sessionToken, { action: 'e_order_update_v2', uid: coachLegacyId, status: 11, content: orderContent });
  639. if (endedOrder.result?.reviewCount !== 2 || !endedOrder.result?.periodDeducted) throw new Error('预约结束课时与抗遗忘副作用失败');
  640. const repeatedEnd = await callLegacyFunction(coachLogin.sessionToken, { action: 'e_order_update_v2', uid: coachLegacyId, status: 11, content: orderContent });
  641. if (!repeatedEnd.result?.unchanged) throw new Error('预约结束状态未保持幂等');
  642. const updatedMember = await jsonRequest(`${PARSE_URL}/users/${memberId}`, {}, true);
  643. if (Number(updatedMember.legacyUserData?.Purse) !== 1 || Number(updatedMember.legacyUserData?.UserPoint) !== 1.5) throw new Error(`预约结束课时扣减异常:${JSON.stringify(updatedMember.legacyUserData)}`);
  644. const sideEffectWhere = encodeURIComponent(JSON.stringify({ sourceKey: { $regex: `^cloud:e_order_update:${temporaryAppointmentId}:` } }));
  645. const [periodLogs, pointLogs, memoryRows, memoryCommonRows] = await Promise.all([
  646. jsonRequest(`${PARSE_URL}/classes/UserExpDomP?where=${sideEffectWhere}&count=1&limit=0`, {}, true),
  647. jsonRequest(`${PARSE_URL}/classes/UserUserPoint?where=${sideEffectWhere}&count=1&limit=0`, {}, true),
  648. jsonRequest(`${PARSE_URL}/classes/MemoryPracticeRecord?where=${sideEffectWhere}&count=1&limit=0`, {}, true),
  649. jsonRequest(`${PARSE_URL}/classes/CommonModel?where=${sideEffectWhere}&count=1&limit=0`, {}, true),
  650. ]);
  651. if (periodLogs.count !== 1 || pointLogs.count !== 1 || memoryRows.count !== 2 || memoryCommonRows.count !== 2) throw new Error(`预约结束账本/抗遗忘数量异常:${periodLogs.count}/${pointLogs.count}/${memoryRows.count}/${memoryCommonRows.count}`);
  652. const purseHistory = await callLegacyFunction(memberLogin.sessionToken, { action: 'user_point_list', uid: memberLegacyId, stype: 1, cpage: 1, psize: 10 });
  653. if (purseHistory.page?.itemCount !== 1 || Number(purseHistory.result?.[0]?.score) !== -1 || !purseHistory.result?.[0]?.ExpHisID || purseHistory.result?.[0]?.Detail === undefined || purseHistory.addon?.purseFeeRuleUnavailable !== true) throw new Error(`余额账本读取异常:${JSON.stringify(purseHistory)}`);
  654. const couponHistory = await callLegacyFunction(memberLogin.sessionToken, { action: 'user_point_list', uid: memberLegacyId, stype: 4, cpage: 1, psize: 10 });
  655. if (couponHistory.page?.itemCount !== 1 || Number(couponHistory.result?.[0]?.score) !== -0.5 || !couponHistory.result?.[0]?.HisTime) throw new Error(`点券账本读取异常:${JSON.stringify(couponHistory)}`);
  656. await callLegacyFunction(memberLogin.sessionToken, { action: 'user_point_list', uid: memberLegacyId, stype: 7 }, 400);
  657. await callLegacyFunction(coachLogin.sessionToken, { action: 'e_order_update_v2', uid: coachLegacyId, status: 20, content: orderContent }, 403);
  658. await callLegacyFunction(memberLogin.sessionToken, { action: 'e_order_update_v2', uid: memberLegacyId, status: 20, content: orderContent });
  659. await callLegacyFunction(coachLogin.sessionToken, { action: 'e_order_update_v2', uid: coachLegacyId, status: 30, content: orderContent });
  660. const completedOrder = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_order_detail', id: temporaryAppointmentId });
  661. if (Number(completedOrder.result?.[0]?.dszt) !== 30) throw new Error('预约状态机写后读失败');
  662. const coachStats = await callLegacyFunction(coachLogin.sessionToken, { action: 'e_order_tongji', uid: coachLegacyId });
  663. if (coachStats.result?.t30 !== '1' || coachStats.result?.t60 !== '1' || coachStats.result?.t_tiyan !== '1' || coachStats.result?.t_total !== '3' || coachStats.result?.t_shichang !== '2.5' || coachStats.result?.t_yongji !== '100') throw new Error('陪练预约统计公式校验失败');
  664. const memberStats = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_order_tongji', uid: memberLegacyId });
  665. if (memberStats.result?.t30 !== '1' || memberStats.result?.t60 !== '0' || memberStats.result?.t_tiyan !== '0' || memberStats.result?.t_total !== '1' || memberStats.result?.t_shichang !== '0.5' || memberStats.result?.t_yongji !== '0') throw new Error(`学员预约与生词统计公式校验失败:${JSON.stringify(memberStats.result)}`);
  666. const deniedCourseWords = await callLegacyFunction(memberLogin.sessionToken, { action: 'e_ck_list', uid: 58, nids: 40, page: 1, pageSize: 1 }, 403);
  667. if (!String(deniedCourseWords.retmsg).includes('无权')) throw new Error('普通用户跨用户课程词库未被拒绝');
  668. const denied = await callLegacyFunction(memberLogin.sessionToken, { action: 'content_list', modelId: 56, myfield2: 'UserId=3', page: 1, pageSize: 1 }, 403);
  669. if (!String(denied.retmsg).includes('无权')) throw new Error('普通用户跨用户记录未被拒绝');
  670. const profile = await callLegacyFunction(login.sessionToken, { action: 'user_get' });
  671. if (profile.retcode !== 0 || profile.result?.objectId !== userId) throw new Error('app gateway 用户会话校验失败');
  672. const blocked = await callLegacyFunction('', { action: 'cart_list' }, 501);
  673. if (!String(blocked.retmsg).startsWith('migration_blocked:')) throw new Error('阻塞接口未返回 migration_blocked');
  674. const productBlocked = await callLegacyFunction('', { action: 'product_list' }, 501);
  675. if (!String(productBlocked.retmsg).includes('ZL_Commodities')) throw new Error('缺商品主表的读取接口未明确阻塞');
  676. console.log('Cloud smoke passed: admin auth/tenant/account lifecycle/group sync/node/special/guest-category/bar/exam-class/exam-point/knowledge/exam-teacher/dictionary/grade-dictionary/currency/holiday/search-navigation/advertising/api-catalog/config-blockers/model/guestbook lifecycle/content workflow/CRUD reads, CMS projections, normalized learning joins, app action coverage, public content, session scope, explicit blocked APIs.');
  677. } finally {
  678. if (adZoneRestore) await jsonRequest(`${PARSE_URL}/classes/AdZone/${adZoneRestore.objectId}`, { method: 'PUT', body: JSON.stringify({ remind: adZoneRestore.remind, zstatus: adZoneRestore.zstatus }) }, true).catch((error) => { console.error(`广告位冒烟数据恢复失败:${error.message}`); process.exitCode = 1; });
  679. if (adInfoRestore) await jsonRequest(`${PARSE_URL}/classes/AdInfo/${adInfoRestore.objectId}`, { method: 'PUT', body: JSON.stringify({ remind: adInfoRestore.remind, zstatus: adInfoRestore.zstatus }) }, true).catch((error) => { console.error(`广告内容冒烟数据恢复失败:${error.message}`); process.exitCode = 1; });
  680. if (contentHitObjectId) await jsonRequest(`${PARSE_URL}/classes/CommonModel/${contentHitObjectId}`, { method: 'PUT', body: JSON.stringify({ hits: contentHitOriginal }) }, true).catch((error) => {
  681. console.error(`公开内容浏览量恢复失败:${error.message}`);
  682. process.exitCode = 1;
  683. });
  684. if (registeredUserId) await jsonRequest(`${PARSE_URL}/users/${registeredUserId}`, { method: 'DELETE' }, true).catch((error) => {
  685. console.error(`临时注册用户清理失败:${error.message}`);
  686. process.exitCode = 1;
  687. });
  688. if (adminCreatedUserId) await jsonRequest(`${PARSE_URL}/users/${adminCreatedUserId}`, { method: 'DELETE' }, true).catch((error) => {
  689. console.error(`管理员开户临时用户清理失败:${error.message}`);
  690. process.exitCode = 1;
  691. });
  692. if (temporaryGroupObjectId) await jsonRequest(`${PARSE_URL}/classes/Group/${temporaryGroupObjectId}`, { method: 'DELETE' }, true).catch((error) => {
  693. console.error(`临时用户组清理失败:${error.message}`);
  694. process.exitCode = 1;
  695. });
  696. for (const nodeId of temporaryNodeObjectIds) if (nodeId) await jsonRequest(`${PARSE_URL}/classes/Node/${nodeId}`, { method: 'DELETE' }, true).catch((error) => {
  697. console.error(`临时栏目清理失败:${error.message}`);
  698. process.exitCode = 1;
  699. });
  700. for (const specialId of temporarySpecialObjectIds) if (specialId) await jsonRequest(`${PARSE_URL}/classes/Special/${specialId}`, { method: 'DELETE' }, true).catch((error) => {
  701. console.error(`临时专题清理失败:${error.message}`);
  702. process.exitCode = 1;
  703. });
  704. for (const categoryId of temporaryGuestCategoryObjectIds) if (categoryId) await jsonRequest(`${PARSE_URL}/classes/Guestcate/${categoryId}`, { method: 'DELETE' }, true).catch((error) => {
  705. console.error(`临时留言/贴吧分类清理失败:${error.message}`);
  706. process.exitCode = 1;
  707. });
  708. for (const knowledgeId of [...temporaryKnowledgeObjectIds].reverse()) if (knowledgeId) await jsonRequest(`${PARSE_URL}/classes/QuestionsKnowledge/${knowledgeId}`, { method: 'DELETE' }, true).catch((error) => {
  709. console.error(`临时知识点清理失败:${error.message}`);
  710. process.exitCode = 1;
  711. });
  712. if (temporaryExamTeacherId) await jsonRequest(`${PARSE_URL}/classes/ExTeacher/${temporaryExamTeacherId}`, { method: 'DELETE' }, true).catch((error) => {
  713. console.error(`临时考试教师清理失败:${error.message}`);
  714. process.exitCode = 1;
  715. });
  716. for (const dictionaryItemId of temporaryDictionaryItemIds) if (dictionaryItemId) await jsonRequest(`${PARSE_URL}/classes/Datadic/${dictionaryItemId}`, { method: 'DELETE' }, true).catch((error) => {
  717. console.error(`临时字典项清理失败:${error.message}`);
  718. process.exitCode = 1;
  719. });
  720. for (const dictionaryCategoryId of temporaryDictionaryCategoryIds) if (dictionaryCategoryId) await jsonRequest(`${PARSE_URL}/classes/Datadiccategory/${dictionaryCategoryId}`, { method: 'DELETE' }, true).catch((error) => {
  721. console.error(`临时字典分类清理失败:${error.message}`);
  722. process.exitCode = 1;
  723. });
  724. for (const gradeOptionId of [...temporaryGradeOptionIds].reverse()) if (gradeOptionId) await jsonRequest(`${PARSE_URL}/classes/Grade/${gradeOptionId}`, { method: 'DELETE' }, true).catch((error) => {
  725. console.error(`临时多级字典选项清理失败:${error.message}`);
  726. process.exitCode = 1;
  727. });
  728. for (const gradeCategoryId of temporaryGradeCategoryIds) if (gradeCategoryId) await jsonRequest(`${PARSE_URL}/classes/GradeCate/${gradeCategoryId}`, { method: 'DELETE' }, true).catch((error) => {
  729. console.error(`临时多级字典分类清理失败:${error.message}`);
  730. process.exitCode = 1;
  731. });
  732. for (const examClassId of [...temporaryExamClassObjectIds].reverse()) if (examClassId) await jsonRequest(`${PARSE_URL}/classes/ExamClass/${examClassId}`, { method: 'DELETE' }, true).catch((error) => {
  733. console.error(`临时试题分类清理失败:${error.message}`);
  734. process.exitCode = 1;
  735. });
  736. for (const examPointId of [...temporaryExamPointObjectIds].reverse()) if (examPointId) await jsonRequest(`${PARSE_URL}/classes/ExamPoint/${examPointId}`, { method: 'DELETE' }, true).catch((error) => {
  737. console.error(`临时考点清理失败:${error.message}`);
  738. process.exitCode = 1;
  739. });
  740. for (const fieldId of temporaryModelFieldObjectIds) if (fieldId) await jsonRequest(`${PARSE_URL}/classes/ModelField/${fieldId}`, { method: 'DELETE' }, true).catch((error) => {
  741. console.error(`临时模型字段清理失败:${error.message}`);
  742. process.exitCode = 1;
  743. });
  744. if (temporaryModelObjectId) await jsonRequest(`${PARSE_URL}/classes/Model/${temporaryModelObjectId}`, { method: 'DELETE' }, true).catch((error) => {
  745. console.error(`临时模型清理失败:${error.message}`);
  746. process.exitCode = 1;
  747. });
  748. if (temporaryGuestbookId) await jsonRequest(`${PARSE_URL}/classes/Guestbook/${temporaryGuestbookId}`, { method: 'DELETE' }, true).catch((error) => {
  749. console.error(`临时留言清理失败:${error.message}`);
  750. process.exitCode = 1;
  751. });
  752. if (temporaryGuestbookReplyId) await jsonRequest(`${PARSE_URL}/classes/Guestbook/${temporaryGuestbookReplyId}`, { method: 'DELETE' }, true).catch((error) => {
  753. console.error(`临时管理员留言回复清理失败:${error.message}`);
  754. process.exitCode = 1;
  755. });
  756. if (temporaryGuestBarId) await jsonRequest(`${PARSE_URL}/classes/GuestBar/${temporaryGuestBarId}`, { method: 'DELETE' }, true).catch((error) => {
  757. console.error(`临时贴吧帖子清理失败:${error.message}`);
  758. process.exitCode = 1;
  759. });
  760. for (const lessonId of temporaryLessonIds) await jsonRequest(`${PARSE_URL}/classes/LessonRecord/${lessonId}`, { method: 'DELETE' }, true).catch((error) => {
  761. console.error(`临时陪练课次清理失败:${error.message}`);
  762. process.exitCode = 1;
  763. });
  764. if (memberLegacyId) {
  765. const commonWhere = encodeURIComponent(JSON.stringify({ sourceKey: { $regex: `^cloud:(stu_record|content_add_zt|content_add):${memberLegacyId}:` } }));
  766. const commonRows = await jsonRequest(`${PARSE_URL}/classes/CommonModel?where=${commonWhere}&limit=1000`, {}, true).catch(() => ({ results: [] }));
  767. for (const row of commonRows.results || []) await jsonRequest(`${PARSE_URL}/classes/CommonModel/${row.objectId}`, { method: 'DELETE' }, true).catch((error) => {
  768. console.error(`临时学习主记录清理失败:${error.message}`);
  769. process.exitCode = 1;
  770. });
  771. const studyWhere = encodeURIComponent(JSON.stringify({ userId: memberLegacyId }));
  772. const studyRows = await jsonRequest(`${PARSE_URL}/classes/DailyStudyRecord?where=${studyWhere}&limit=1000`, {}, true).catch(() => ({ results: [] }));
  773. for (const row of studyRows.results || []) await jsonRequest(`${PARSE_URL}/classes/DailyStudyRecord/${row.objectId}`, { method: 'DELETE' }, true).catch((error) => {
  774. console.error(`临时学习 addon 清理失败:${error.message}`);
  775. process.exitCode = 1;
  776. });
  777. }
  778. if (temporaryAppointmentObjectId) await jsonRequest(`${PARSE_URL}/classes/CourseAppointment/${temporaryAppointmentObjectId}`, { method: 'DELETE' }, true).catch((error) => {
  779. console.error(`临时预约清理失败:${error.message}`);
  780. process.exitCode = 1;
  781. });
  782. if (temporaryAppointmentId) {
  783. const sideEffectWhere = encodeURIComponent(JSON.stringify({ sourceKey: { $regex: `^cloud:e_order_update:${temporaryAppointmentId}:` } }));
  784. for (const className of ['CommonModel', 'MemoryPracticeRecord', 'UserExpDomP', 'UserUserPoint']) {
  785. const rows = await jsonRequest(`${PARSE_URL}/classes/${className}?where=${sideEffectWhere}&limit=1000`, {}, true).catch(() => ({ results: [] }));
  786. for (const row of rows.results || []) await jsonRequest(`${PARSE_URL}/classes/${className}/${row.objectId}`, { method: 'DELETE' }, true).catch((error) => {
  787. console.error(`临时预约副作用清理失败(${className}):${error.message}`);
  788. process.exitCode = 1;
  789. });
  790. }
  791. }
  792. if (memberLegacyId) {
  793. const assessmentWhere = encodeURIComponent(JSON.stringify({ sourceKey: { $regex: `^cloud:content_add:${memberLegacyId}:` } }));
  794. const assessments = await jsonRequest(`${PARSE_URL}/classes/AssessmentProfile?where=${assessmentWhere}&limit=1000`, {}, true).catch(() => ({ results: [] }));
  795. for (const assessment of assessments.results || []) await jsonRequest(`${PARSE_URL}/classes/AssessmentProfile/${assessment.objectId}`, { method: 'DELETE' }, true).catch((error) => {
  796. console.error(`临时测评记录清理失败:${error.message}`);
  797. process.exitCode = 1;
  798. });
  799. }
  800. if (memberLegacyId) {
  801. const where = encodeURIComponent(JSON.stringify({ yhid: String(memberLegacyId) }));
  802. const practices = await jsonRequest(`${PARSE_URL}/classes/PracticeRecord?where=${where}&limit=1000`, {}, true).catch(() => ({ results: [] }));
  803. for (const practice of practices.results || []) await jsonRequest(`${PARSE_URL}/classes/PracticeRecord/${practice.objectId}`, { method: 'DELETE' }, true).catch((error) => {
  804. console.error(`临时学习进度清理失败:${error.message}`);
  805. process.exitCode = 1;
  806. });
  807. }
  808. if (teamChildId) {
  809. await jsonRequest(`${PARSE_URL}/users/${teamChildId}`, { method: 'DELETE' }, true).catch((error) => {
  810. console.error(`临时团队成员清理失败:${error.message}`);
  811. process.exitCode = 1;
  812. });
  813. }
  814. if (memberId) {
  815. await jsonRequest(`${PARSE_URL}/users/${memberId}`, { method: 'DELETE' }, true).catch((error) => {
  816. console.error(`临时普通用户清理失败:${error.message}`);
  817. process.exitCode = 1;
  818. });
  819. }
  820. if (coachId) {
  821. await jsonRequest(`${PARSE_URL}/users/${coachId}`, { method: 'DELETE' }, true).catch((error) => {
  822. console.error(`临时陪练用户清理失败:${error.message}`);
  823. process.exitCode = 1;
  824. });
  825. }
  826. if (userId) {
  827. await jsonRequest(`${PARSE_URL}/users/${userId}`, { method: 'DELETE' }, true).catch((error) => {
  828. console.error(`临时管理员清理失败:${error.message}`);
  829. process.exitCode = 1;
  830. });
  831. }
  832. }