server/app/controller/home.js

'use strict';

const Controller = require('egg').Controller;
class HomeController extends Controller {
  async index() {
    const { ctx } = this;
    ctx.body = 'hi, egg';
    await this.ctx.service.util.rabbitMq.initTestQueue();
    await this.ctx.service.util.rabbitMq.toDead();
  }
  async m1() {
    const { taskMqConfig } = this.app.config;
    const body = this.ctx.request.body;
    await this.ctx.service.util.rabbitMq.makeTask(taskMqConfig.queue, body);
    this.ctx.ok();
  }

  async makeCoupons() {
    const dictDataModel = this.ctx.model.Dev.DictData;
    const couponModel = this.ctx.model.Trade.Coupon;
    // 过期字典
    const expList = await dictDataModel.find({ code: 'coupon_expire_type' });
    // 减免字典
    const disList = await dictDataModel.find({ code: 'coupon_discount_type' });
    // 使用字典
    const useList = await dictDataModel.find({ code: 'coupon_use_limit' });
    // 领取字典
    const getList = await dictDataModel.find({ code: 'coupon_get_limit' });

    const arr = [];
    for (const e of expList) {
      const { value: expire_type, label: el } = e;
      for (const d of disList) {
        const { value: discount_type, label: dl } = d;
        for (const u of useList) {
          const { value: use_limit, label: ul } = u;
          for (const g of getList) {
            const { value: get_limit, label: gl } = g;
            const obj = { issue: '0', expire_type, discount_type, use_limit, get_limit, num: 100, status: '0' };
            obj.name = `平台测试优惠券-${el}-${dl}-${ul}-${gl}`;
            arr.push(obj);
          }
        }
      }
    }
    await couponModel.insertMany(arr);
    return arr;
  }
}

module.exports = HomeController;