通知

app/controller/patent/.notice.js

@@ -0,0 +1,38 @@
+module.exports = {
+  create: {
+    requestBody: ["to", "content", "is_read"],
+  },
+  destroy: {
+    params: ["!id"],
+    service: "delete",
+  },
+  update: {
+    params: ["!id"],
+    requestBody: ["to", "content", "is_read"],
+  },
+  show: {
+    parameters: {
+      params: ["!id"],
+    },
+    service: "fetch",
+  },
+  index: {
+    parameters: {
+      query: {
+        to: "to",
+        content: "content",
+        is_read: "is_read",
+      },
+      // options: {
+      //   "meta.state": 0 // 默认条件
+      // },
+    },
+    service: "query",
+    options: {
+      query: ["skip", "limit"],
+      sort: ["meta.createdAt"],
+      desc: true,
+      count: true,
+    },
+  },
+};

app/controller/patent/notice.js

@@ -0,0 +1,13 @@
+'use strict';
+const meta = require('./.notice.js');
+const Controller = require('egg').Controller;
+const { CrudController } = require('naf-framework-mongoose/lib/controller');
+
+// 消息通知
+class NoticeController extends Controller {
+  constructor(ctx) {
+    super(ctx);
+    this.service = this.ctx.service.patent.notice;
+  }
+}
+module.exports = CrudController(NoticeController, meta);

app/model/patent/notice.js

@@ -0,0 +1,22 @@
+'use strict';
+const Schema = require('mongoose').Schema;
+const moment = require('moment');
+const metaPlugin = require('naf-framework-mongoose/lib/model/meta-plugin');
+const { ObjectId } = require('mongoose').Types;
+// 专利运营通知表
+const notice = {
+  to: { type: ObjectId }, // 接收人
+  content: { type: String }, // 内容
+  is_read: { type: Boolean, default: false }, // 是否已读
+  remark: { type: String },
+};
+const schema = new Schema(notice, { toJSON: { virtuals: true } });
+schema.index({ id: 1 });
+schema.index({ to: 1 });
+schema.index({ is_read: 1 });
+schema.index({ 'meta.createdAt': 1 });
+schema.plugin(metaPlugin);
+module.exports = app => {
+  const { mongoose } = app;
+  return mongoose.model('DisclosureNotice', schema, 'disclosure_notice');
+};

app/router.js

@@ -72,4 +72,5 @@ module.exports = app => {
   // 专利运营
   require('./router/patent/disclosure')(app); // 交底表
   require('./router/patent/report')(app); // 评估报告
+  require('./router/patent/notice')(app); // 消息通知
 };

app/router/patent/notice.js

@@ -0,0 +1,12 @@
+'use strict';
+
+
+module.exports = app => {
+  const { router, controller } = app;
+  const profix = '/api/live/';
+  const vision = 'v0';
+  const index = 'patent';
+  const target = 'notice';
+  router.resources(target, `${profix}${vision}/${index}/${target}`, controller[index][target]); // index、create、show、destroy
+  router.post(target, `${profix}${vision}/${index}/${target}/update/:id`, controller[index][target].update);
+};

app/service/patent/disclosure.js

@@ -11,6 +11,7 @@ class DisclosureService extends CrudService {
   constructor(ctx) {
     super(ctx, 'disclosure');
     this.model = this.ctx.model.Patent.Disclosure;
+    this.notice = this.ctx.model.Patent.Notice;
   }
 
   /**
@@ -111,7 +112,55 @@ class DisclosureService extends CrudService {
       remark,
     };
     data.record.push(obj);
-    return await data.save();
+    const res = await data.save();
+    this.toNotice(id, method);
+    return res;
+  }
+
+  async toNotice(id, code) {
+    const data = await this.model.findById(id);
+    if (!data) return;
+    const { user_id, admin_id, mechanism_id, status, name, apply_name } = data;
+    let content = '';
+    let to = '';
+    switch (code) {
+      case 'create':
+        content = `${apply_name}提交了专利申请书(${name})的申报,请及时前往申请管理进行处理`;
+        if (status === '1') {
+          to = mechanism_id;
+        } else {
+          to = admin_id;
+        }
+        break;
+      case 'update':
+        content = `${apply_name}重新提交了专利申请书(${name})的申报,请及时前往申请管理进行处理`;
+        if (status === '1') {
+          to = mechanism_id;
+        } else {
+          to = admin_id;
+        }
+        break;
+      case '-1':
+        content = `您的专利申请书(${name})未通过机构的审核,请您及时修改,重新申请`;
+        to = user_id;
+        break;
+      case '-2':
+        content = `您的专利申请书(${name})未通过管理员的评估,请您及时修改,重新申请`;
+        to = user_id;
+        break;
+      case '3':
+        content = `您的专利申请书(${name})已通过机构的审核,请您耐心等待上传至国家专利库中`;
+        to = user_id;
+        break;
+      case '4':
+        content = `您的专利申请书(${name})已上传至国家专利库中`;
+        to = user_id;
+        break;
+      default:
+        break;
+    }
+    const obj = { to, content };
+    await this.notice.create(obj);
   }
 }
 

app/service/patent/notice.js

@@ -0,0 +1,15 @@
+'use strict';
+const { CrudService } = require('naf-framework-mongoose/lib/service');
+const { BusinessError, ErrorCode } = require('naf-core').Error;
+const _ = require('lodash');
+const assert = require('assert');
+
+// 消息通知
+class NoticeService extends CrudService {
+  constructor(ctx) {
+    super(ctx, 'notice');
+    this.model = this.ctx.model.Patent.Notice;
+  }
+}
+
+module.exports = NoticeService;