Setting.js 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  1. const mongoose = require('mongoose');
  2. const { Schema } = mongoose;
  3. const systemSettingSchema = new Schema({
  4. _id: {
  5. type: String,
  6. default: 'system' // 固定 ID
  7. },
  8. innerDefaultAmount: {
  9. type: Number,
  10. required: true,
  11. default: 10000
  12. },
  13. minProfitAmount: {
  14. type: Number,
  15. required: true,
  16. default: 0
  17. },
  18. minShowAmount: {
  19. type: Number,
  20. required: true,
  21. default: 0
  22. },
  23. innerRebateRatio: {
  24. type: Number,
  25. required: true,
  26. default: 0
  27. },
  28. obRebateRatio: {
  29. type: Number,
  30. required: true,
  31. default: 0
  32. },
  33. hgRebateRatio: {
  34. type: Number,
  35. required: true,
  36. default: 0
  37. },
  38. runWorkerEnabled: {
  39. type: Boolean,
  40. required: true,
  41. default: false
  42. }
  43. }, {
  44. toJSON: {
  45. transform(doc, ret) {
  46. delete ret._id;
  47. delete ret.__v;
  48. }
  49. },
  50. toObject: {
  51. transform(doc, ret) {
  52. delete ret._id;
  53. delete ret.__v;
  54. }
  55. }
  56. });
  57. const Setting = mongoose.model('SystemSetting', systemSettingSchema);
  58. const CALLBACKS = {
  59. update: null,
  60. };
  61. const onUpdate = (callback) => {
  62. CALLBACKS.update = callback;
  63. }
  64. const get = async () => {
  65. return await Setting.findById('system');
  66. }
  67. const update = async (fields) => {
  68. CALLBACKS.update?.(fields);
  69. return await Setting.findByIdAndUpdate(
  70. 'system',
  71. { $set: fields },
  72. { upsert: true, new: true }
  73. );
  74. }
  75. const init = async (fields = {}) => {
  76. const systemSetting = await Setting.findById('system');
  77. if (systemSetting) {
  78. return;
  79. }
  80. const setting = new Setting({
  81. _id: 'system',
  82. ...fields,
  83. });
  84. return setting.save();
  85. }
  86. module.exports = { get, update, init, onUpdate };