create-schema.js 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448
  1. const Parse = require('parse/node');
  2. // 加载环境变量(建议使用.env文件管理敏感信息)
  3. // 1. 初始化Parse连接
  4. Parse.initialize(
  5. process.env.PARSE_APP_ID || 'ncloudmaster', // 替换为你的Parse App ID
  6. process.env.PARSE_MASTER_KEY || "SnkK12*&sunq2#@20!" // 替换为你的Parse Master Key
  7. );
  8. Parse.serverURL = process.env.PARSE_SERVER_URL || 'https://server.fmode.cn/parse'; // 替换为你的Parse Server地址
  9. Parse.masterKey = process.env.PARSE_MASTER_KEY || "SnkK12*&sunq2#@20!"; // Master Key用于Schema操作
  10. // 2. 定义所有数据表结构配置(与文档范式完全对应)
  11. const tableConfigs = [
  12. // 核心租户表:Company
  13. {
  14. className: 'Company',
  15. fields: [
  16. { name: 'name', type: 'String', required: true },
  17. { name: 'corpId', type: 'String', required: false },
  18. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  19. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  20. ],
  21. indexes: [
  22. { name: 'corpId_index', fields: { corpId: 1 } },
  23. { name: 'name_index', fields: { name: 1 } }
  24. ]
  25. },
  26. // 部门表:Department
  27. {
  28. className: 'Department',
  29. fields: [
  30. { name: 'name', type: 'String', required: true },
  31. { name: 'type', type: 'String', required: true, defaultValue: 'project' },
  32. { name: 'leader', type: 'Pointer', required: false, targetClass: 'Profile' },
  33. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  34. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  35. ],
  36. indexes: [
  37. { name: 'company_isDeleted', fields: { company: 1, isDeleted: 1 } },
  38. { name: 'leader_index', fields: { leader: 1 } }
  39. ]
  40. },
  41. // 员工档案表:Profile
  42. {
  43. className: 'Profile',
  44. fields: [
  45. { name: 'name', type: 'String', required: true },
  46. { name: 'mobile', type: 'String', required: false },
  47. { name: 'department', type: 'Pointer', required: true, targetClass: 'Department' },
  48. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  49. { name: 'userId', type: 'String', required: false },
  50. { name: 'roleName', type: 'String', required: true },
  51. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  52. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  53. ],
  54. indexes: [
  55. { name: 'company_isDeleted', fields: { company: 1, isDeleted: 1 } },
  56. { name: 'userId_company', fields: { userId: 1, company: 1 }, unique: true },
  57. { name: 'roleName_company', fields: { roleName: 1, company: 1 } },
  58. { name: 'mobile_company', fields: { mobile: 1, company: 1 } }
  59. ]
  60. },
  61. // 客户信息表:ContactInfo
  62. {
  63. className: 'ContactInfo',
  64. fields: [
  65. { name: 'name', type: 'String', required: true },
  66. { name: 'mobile', type: 'String', required: false },
  67. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  68. { name: 'external_userid', type: 'String', required: false },
  69. { name: 'source', type: 'String', required: false },
  70. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  71. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  72. ],
  73. indexes: [
  74. { name: 'company_isDeleted', fields: { company: 1, isDeleted: 1 } },
  75. { name: 'external_userid_company', fields: { external_userid: 1, company: 1 }, unique: true },
  76. { name: 'mobile_company', fields: { mobile: 1, company: 1 } },
  77. { name: 'source_company', fields: { source: 1, company: 1 } }
  78. ]
  79. },
  80. // 企微群聊表:GroupChat
  81. {
  82. className: 'GroupChat',
  83. fields: [
  84. { name: 'chat_id', type: 'String', required: true },
  85. { name: 'name', type: 'String', required: true },
  86. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  87. { name: 'project', type: 'Pointer', required: false, targetClass: 'Project' },
  88. { name: 'member_list', type: 'Array', required: false, defaultValue: [] },
  89. { name: 'joinUrl', type: 'String', required: false },
  90. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  91. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  92. ],
  93. indexes: [
  94. { name: 'chat_id_company', fields: { chat_id: 1, company: 1 }, unique: true },
  95. { name: 'project_isDeleted', fields: { project: 1, isDeleted: 1 } },
  96. { name: 'company_isDeleted', fields: { company: 1, isDeleted: 1 } }
  97. ]
  98. },
  99. // 项目群组关联表:ProjectGroup
  100. {
  101. className: 'ProjectGroup',
  102. fields: [
  103. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  104. { name: 'groupChat', type: 'Pointer', required: true, targetClass: 'GroupChat' },
  105. { name: 'isPrimary', type: 'Boolean', required: false, defaultValue: false }
  106. ],
  107. indexes: [
  108. { name: 'project_groupChat', fields: { project: 1, groupChat: 1 }, unique: true },
  109. { name: 'groupChat_index', fields: { groupChat: 1 } },
  110. { name: 'isPrimary_index', fields: { isPrimary: 1 } }
  111. ]
  112. },
  113. // 项目表:Project
  114. {
  115. className: 'Project',
  116. fields: [
  117. { name: 'title', type: 'String', required: true },
  118. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  119. { name: 'customer', type: 'Pointer', required: true, targetClass: 'ContactInfo' },
  120. { name: 'assignee', type: 'Pointer', required: false, targetClass: 'Profile' },
  121. { name: 'status', type: 'String', required: true, defaultValue: '待分配' },
  122. { name: 'currentStage', type: 'String', required: true, defaultValue: '订单分配' },
  123. { name: 'deadline', type: 'Date', required: false },
  124. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  125. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  126. ],
  127. indexes: [
  128. { name: 'company_isDeleted', fields: { company: 1, isDeleted: 1 } },
  129. { name: 'assignee_status', fields: { assignee: 1, status: 1 } },
  130. { name: 'customer_isDeleted', fields: { customer: 1, isDeleted: 1 } },
  131. { name: 'currentStage_status', fields: { currentStage: 1, status: 1 } },
  132. { name: 'deadline_index', fields: { deadline: 1 } },
  133. { name: 'updatedAt_desc', fields: { updatedAt: -1 } }
  134. ]
  135. },
  136. // 需求信息表:ProjectRequirement
  137. {
  138. className: 'ProjectRequirement',
  139. fields: [
  140. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  141. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  142. { name: 'spaces', type: 'Array', required: false, defaultValue: [] },
  143. { name: 'designRequirements', type: 'Object', required: false, defaultValue: {} },
  144. { name: 'materialAnalysis', type: 'Object', required: false, defaultValue: {} },
  145. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  146. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  147. ],
  148. indexes: [
  149. { name: 'project_unique', fields: { project: 1 }, unique: true },
  150. { name: 'company_isDeleted', fields: { company: 1, isDeleted: 1 } }
  151. ]
  152. },
  153. // 项目团队表:ProjectTeam
  154. {
  155. className: 'ProjectTeam',
  156. fields: [
  157. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  158. { name: 'profile', type: 'Pointer', required: true, targetClass: 'Profile' },
  159. { name: 'role', type: 'String', required: true },
  160. { name: 'workload', type: 'Number', required: false, defaultValue: 0 },
  161. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  162. ],
  163. indexes: [
  164. { name: 'project_isDeleted', fields: { project: 1, isDeleted: 1 } },
  165. { name: 'profile_project', fields: { profile: 1, project: 1 }, unique: true }
  166. ]
  167. },
  168. // 交付物表:Product
  169. {
  170. className: 'Product',
  171. fields: [
  172. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  173. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  174. { name: 'stage', type: 'String', required: true },
  175. { name: 'processType', type: 'String', required: false },
  176. { name: 'space', type: 'String', required: false },
  177. { name: 'fileUrl', type: 'String', required: true },
  178. { name: 'reviewStatus', type: 'String', required: true, defaultValue: 'pending' },
  179. { name: 'quotation', type: 'Object', required: false, defaultValue: {} },
  180. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  181. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  182. ],
  183. indexes: [
  184. { name: 'project_stage_isDeleted', fields: { project: 1, stage: 1, isDeleted: 1 } },
  185. { name: 'project_space', fields: { project: 1, space: 1 } },
  186. { name: 'reviewStatus_project', fields: { reviewStatus: 1, project: 1 } }
  187. ]
  188. },
  189. // 项目文件表:ProjectFile
  190. {
  191. className: 'ProjectFile',
  192. fields: [
  193. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  194. { name: 'uploadedBy', type: 'Pointer', required: true, targetClass: 'Profile' },
  195. { name: 'fileType', type: 'String', required: true },
  196. { name: 'fileUrl', type: 'String', required: true },
  197. { name: 'fileName', type: 'String', required: true },
  198. { name: 'fileSize', type: 'Number', required: false, defaultValue: 0 },
  199. { name: 'stage', type: 'String', required: false },
  200. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  201. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  202. ],
  203. indexes: [
  204. { name: 'project_fileType_isDeleted', fields: { project: 1, fileType: 1, isDeleted: 1 } },
  205. { name: 'uploadedBy_project', fields: { uploadedBy: 1, project: 1 } }
  206. ]
  207. },
  208. // 结算记录表:ProjectSettlement
  209. {
  210. className: 'ProjectSettlement',
  211. fields: [
  212. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  213. { name: 'company', type: 'Pointer', required: true, targetClass: 'Company' },
  214. { name: 'stage', type: 'String', required: true },
  215. { name: 'amount', type: 'Number', required: true },
  216. { name: 'percentage', type: 'Number', required: false, defaultValue: 0 },
  217. { name: 'status', type: 'String', required: true, defaultValue: '待结算' },
  218. { name: 'dueDate', type: 'Date', required: false },
  219. { name: 'settledAt', type: 'Date', required: false },
  220. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  221. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  222. ],
  223. indexes: [
  224. { name: 'project_stage', fields: { project: 1, stage: 1 }, unique: true },
  225. { name: 'status_company', fields: { status: 1, company: 1 } },
  226. { name: 'dueDate_index', fields: { dueDate: 1 } }
  227. ]
  228. },
  229. // 付款凭证表:ProjectVoucher
  230. {
  231. className: 'ProjectVoucher',
  232. fields: [
  233. { name: 'settlement', type: 'Pointer', required: true, targetClass: 'ProjectSettlement' },
  234. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  235. { name: 'amount', type: 'Number', required: true },
  236. { name: 'voucherUrl', type: 'String', required: true },
  237. { name: 'recognizedInfo', type: 'Object', required: false, defaultValue: {} },
  238. { name: 'verifiedBy', type: 'Pointer', required: false, targetClass: 'Profile' },
  239. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  240. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  241. ],
  242. indexes: [
  243. { name: 'settlement_project', fields: { settlement: 1, project: 1 } },
  244. { name: 'project_isDeleted', fields: { project: 1, isDeleted: 1 } }
  245. ]
  246. },
  247. // 客户反馈表:ProjectFeedback
  248. {
  249. className: 'ProjectFeedback',
  250. fields: [
  251. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  252. { name: 'customer', type: 'Pointer', required: true, targetClass: 'ContactInfo' },
  253. { name: 'stage', type: 'String', required: true },
  254. { name: 'feedbackType', type: 'String', required: true },
  255. { name: 'content', type: 'String', required: true },
  256. { name: 'rating', type: 'Number', required: false, defaultValue: 0 },
  257. { name: 'status', type: 'String', required: true, defaultValue: '待处理' },
  258. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  259. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  260. ],
  261. indexes: [
  262. { name: 'project_status_isDeleted', fields: { project: 1, status: 1, isDeleted: 1 } },
  263. { name: 'customer_project', fields: { customer: 1, project: 1 } },
  264. { name: 'feedbackType_stage', fields: { feedbackType: 1, stage: 1 } }
  265. ]
  266. },
  267. // 产品质量检查表:ProductCheck
  268. {
  269. className: 'ProductCheck',
  270. fields: [
  271. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  272. { name: 'checkType', type: 'String', required: true },
  273. { name: 'checkedBy', type: 'Pointer', required: true, targetClass: 'Profile' },
  274. { name: 'checkedAt', type: 'Date', required: true },
  275. { name: 'isPassed', type: 'Boolean', required: true },
  276. { name: 'items', type: 'Array', required: false, defaultValue: [] },
  277. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  278. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  279. ],
  280. indexes: [
  281. { name: 'project_checkType_isDeleted', fields: { project: 1, checkType: 1, isDeleted: 1 } },
  282. { name: 'checkedBy_isPassed', fields: { checkedBy: 1, isPassed: 1 } }
  283. ]
  284. },
  285. // 异常记录表:ProjectIssue
  286. {
  287. className: 'ProjectIssue',
  288. fields: [
  289. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  290. { name: 'reportedBy', type: 'Pointer', required: true, targetClass: 'Profile' },
  291. { name: 'exceptionType', type: 'String', required: true },
  292. { name: 'severity', type: 'String', required: true },
  293. { name: 'description', type: 'String', required: true },
  294. { name: 'status', type: 'String', required: true, defaultValue: '待处理' },
  295. { name: 'resolution', type: 'String', required: false },
  296. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  297. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  298. ],
  299. indexes: [
  300. { name: 'project_status_isDeleted', fields: { project: 1, status: 1, isDeleted: 1 } },
  301. { name: 'exceptionType_severity', fields: { exceptionType: 1, severity: 1 } },
  302. { name: 'reportedBy_index', fields: { reportedBy: 1 } }
  303. ]
  304. },
  305. // 跟进记录表:ContactFollow
  306. {
  307. className: 'ContactFollow',
  308. fields: [
  309. { name: 'project', type: 'Pointer', required: true, targetClass: 'Project' },
  310. { name: 'profile', type: 'Pointer', required: true, targetClass: 'Profile' },
  311. { name: 'contact', type: 'Pointer', required: true, targetClass: 'ContactInfo' },
  312. { name: 'content', type: 'String', required: true },
  313. { name: 'type', type: 'String', required: true },
  314. { name: 'stage', type: 'String', required: false },
  315. { name: 'attachments', type: 'Array', required: false, defaultValue: [] },
  316. { name: 'data', type: 'Object', required: false, defaultValue: {} },
  317. { name: 'isDeleted', type: 'Boolean', required: false, defaultValue: false }
  318. ],
  319. indexes: [
  320. { name: 'project_createdAt', fields: { project: 1, createdAt: -1 } },
  321. { name: 'profile_project', fields: { profile: 1, project: 1 } },
  322. { name: 'stage_index', fields: { stage: 1 } }
  323. ]
  324. }
  325. ];
  326. // 3. 核心工具函数:创建/更新数据表结构
  327. async function setupTableSchema(tableConfig) {
  328. const { className, fields, indexes } = tableConfig;
  329. let schema;
  330. try {
  331. // 尝试获取已有Schema
  332. schema = new Parse.Schema(className);
  333. await schema.get();
  334. console.log(`✅ 找到已有表 [${className}],开始补充缺失字段和索引`);
  335. } catch (error) {
  336. // 表不存在,创建新Schema
  337. schema = new Parse.Schema(className);
  338. console.log(`🆕 未找到表 [${className}],开始创建新表`);
  339. }
  340. // 3.1 添加/更新字段
  341. for (const field of fields) {
  342. try {
  343. // 处理Pointer类型(需特殊配置targetClass)
  344. if (field.type === 'Pointer') {
  345. schema.addPointer(field.name, field.targetClass);
  346. }
  347. // 处理普通类型
  348. else {
  349. schema.addField(field.name, field.type);
  350. }
  351. console.log(` 📝 配置字段 [${className}.${field.name}] (类型: ${field.type})`);
  352. } catch (error) {
  353. // 字段已存在时忽略错误
  354. if (error.message.includes('Field already exists')) {
  355. console.log(` ⚠️ 字段 [${className}.${field.name}] 已存在,跳过`);
  356. } else {
  357. console.error(` ❌ 配置字段 [${className}.${field.name}] 失败:`, error.message);
  358. }
  359. }
  360. }
  361. // 3.2 添加/更新索引
  362. for (const index of indexes) {
  363. try {
  364. schema.addIndex(index.name, index.fields, index.unique || false);
  365. console.log(` 🔍 配置索引 [${className}.${index.name}] (字段: ${JSON.stringify(index.fields)})`);
  366. } catch (error) {
  367. // 索引已存在时忽略错误
  368. if (error.message.includes('Index already exists')) {
  369. console.log(` ⚠️ 索引 [${className}.${index.name}] 已存在,跳过`);
  370. } else {
  371. console.error(` ❌ 配置索引 [${className}.${index.name}] 失败:`, error.message);
  372. }
  373. }
  374. }
  375. // 3.3 保存Schema变更
  376. try {
  377. await schema.save();
  378. console.log(`🎉 表 [${className}] 配置完成\n`);
  379. } catch (error) {
  380. console.error(`❌ 保存表 [${className}] 配置失败:`, error.message, '\n');
  381. }
  382. }
  383. // 4. 批量执行所有表的初始化
  384. async function initAllTables() {
  385. console.log('=====================================================');
  386. console.log('🚀 开始初始化YSS项目管理系统数据表结构');
  387. console.log(`📌 Parse Server地址: ${Parse.serverURL}`);
  388. console.log(`📌 应用ID: ${Parse.applicationId}`);
  389. console.log('=====================================================\n');
  390. // 按依赖顺序执行(先创建基础表,再创建依赖表)
  391. const dependencyOrder = [
  392. 'Company', 'Department', 'Profile', 'ContactInfo', // 基础人员表
  393. 'Project', 'ProjectRequirement', 'ProjectTeam', // 核心项目表
  394. 'GroupChat', 'ProjectGroup', // 企微关联表
  395. 'Product', 'ProjectFile', // 交付物/文件表
  396. 'ProjectSettlement', 'ProjectVoucher', // 财务表
  397. 'ProjectFeedback', 'ProductCheck', 'ProjectIssue',// 质量反馈表
  398. 'ContactFollow' // 跟进记录表
  399. ];
  400. // 按依赖顺序处理每个表
  401. for (const className of dependencyOrder) {
  402. const tableConfig = tableConfigs.find(config => config.className === className);
  403. if (tableConfig) {
  404. await setupTableSchema(tableConfig);
  405. } else {
  406. console.error(`❌ 未找到表 [${className}] 的配置,跳过\n`);
  407. }
  408. }
  409. console.log('=====================================================');
  410. console.log('🏁 所有数据表结构初始化完成!');
  411. console.log('💡 提示:请检查控制台输出,确认是否有失败的配置项');
  412. console.log('=====================================================');
  413. }
  414. // 5. 执行初始化
  415. initAllTables().catch(error => {
  416. console.error('💥 初始化过程中发生致命错误:', error.message);
  417. process.exit(1);
  418. });