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 mqid = uuid();
    const newdata = { ...requestBody, mqid };
    const result = await this.ctx.model.Tasks.create(newdata);
    console.log(result);
    if (result) {
      const { mq } = this.ctx;
      if (mq) {
        const msg = requestBody.name + '上传文件' + requestBody.content;
        const parm = {
          durable: true,
          headers: {
            userid: requestBody.userid,
            mqid,
          } };
        console.log(parm);
        console.log(msg);
        await mq.topic('stu_import', requestBody.userid, msg, parm);
      } else {
        this.ctx.logger.error('!!!!!!没有配置MQ插件!!!!!!');
      }
    }
  }
}

module.exports = TasksService;