service-dataimport/app/service/tasks.js

'use strict';

const _ = require('lodash');
const uuid = require('uuid');

const { CrudService } = require('naf-framework-mongoose/lib/service');

class TasksService extends CrudService {
  constructor(ctx) {
    super(ctx);
    this.model = this.ctx.model.Tasks;
  }

  async create(requestBody) {
    console.log(requestBody);
    // this.ctx.model.create
    const result = await this.ctx.model.Tasks.create(requestBody);
    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 = {
          durable: true,
          headers: {
            userid: requestBody.userid,
            mqid: uuid(),
          } };
        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();
      }
    }
  }
}

module.exports = TasksService;