加入发送mq状态

app/model/tasks.js

@@ -10,6 +10,7 @@ const TasksSchema = {
   type: { type: String, required: false, maxLength: 64 }, // 类别
   content: { type: String, required: false, maxLength: 64 }, // 内容
   status: { type: String, required: false, maxLength: 2 }, // 状态
+  sendstatus: { type: String, required: false, maxLength: 2, default: '0' }, // 发送
   errmsg: { type: String, required: false }, // 导入错误信息
 };
 

app/service/tasks.js

@@ -16,6 +16,7 @@ class TasksService extends CrudService {
     console.log(result);
     if (result != null) {
       const { mq } = this.ctx;
+      const task = await this.model.findById(result.id);
       if (mq) {
         const msg = requestBody.name + '上传文件' + requestBody.content;
         const parm = {
@@ -26,8 +27,12 @@ class TasksService extends CrudService {
         console.log(parm);
         console.log(msg);
         await mq.topic('stu_import', requestBody.userid, msg, parm);
+        task.sendstatus = '1';
+        await task.save();
       } else {
         this.ctx.logger.error('!!!!!!没有配置MQ插件!!!!!!');
+        task.sendstatus = '2';
+        await task.save();
       }
     }
   }