cms-service/app/service/menu.js

'use strict';

const Service = require('egg').Service;
const assert = require('assert');
const moment = require('moment');
class MenuService extends Service {
  async create({ name, code, state, type }) {
    assert(name, '名称不存在');
    assert(code, '编码不存在');
    assert(state, '状态不存在');
    assert(type, '类型不存在');
    const { Menu: model } = this.ctx.model;
    const createAt = moment().format('x');
    try {
      await model.create({ name, code, createAt, state, type });
      return { errmsg: '', errcode: 0 };
    } catch (error) {
      throw new Error({ errcode: -2001, errmsg: '添加失败' });
    }
  }
  async update({ name, state, id }) {
    assert(id, 'id不存在');
    const { Menu: model } = this.ctx.model;
    try {
      await model.findByIdAndUpdate(id, { name, state });
      return { errmsg: '', errcode: 0 };
    } catch (error) {
      throw new Error({ errcode: -2001, errmsg: '修改失败' });
    }
  }
  async del({ id }) {
    assert(id, 'id不存在');
    const { Menu: model } = this.ctx.model;
    const { Role: Rolemodel } = this.ctx.model;
    const { Page: Pagemodel } = this.ctx.model;
    const { Column: Columnmodel } = this.ctx.model;
    try {
      const menu = await model.findById(id);
      const roleList = await Rolemodel.where('adminMenuList').in(menu.code);
      switch (menu.type) {
        case 0: {
          // 栏目
          const menuList = await Columnmodel.where('menuList').in(menu.code);
          menuList.filter(async p => {
            const menuList = p.menuList.filter(p => p !== menu.code);
            await Columnmodel.findByIdAndUpdate(p._id, { menuList });
          });
          break;
        }
        case 2: {
          // 单页
          const pageList = await Pagemodel.find({ menu: menu.code });
          pageList.filter(async p => {
            await Pagemodel.findByIdAndUpdate(p._id, { menu: null });
          });
          break;
        }
        case 3: {
          // 父级
          const pmenu = await model.find({ pid: menu.code });
          if (pmenu.length > 0) {
            return { errmsg: '存在子级菜单，请先删除子级菜单', errcode: -1001 };
          }
          break;
        }
        default: {
          break;
        }
      }
      await model.findOneAndDelete(id);
      roleList.forEach(async e => {
        const adminMenuList = e.adminMenuList.filter(p => p !== menu.code);
        await Rolemodel.findByIdAndUpdate(e._id, { adminMenuList });
      });
      return { errmsg: '', errcode: 0 };
    } catch (error) {
      throw new Error({ errcode: -2001, errmsg: '删除失败' });
    }
  }
  async query({ skip, limit, filter }) {
    const { Menu: model } = this.ctx.model;
    try {
      let res;
      if (skip && limit) {
        res = await model.find(filter).skip(skip * limit).limit(limit);
      } else {
        res = await model.find(filter);
      }
      return { errmsg: '', errcode: 0, data: res };
    } catch (error) {
      throw new Error({ errcode: -2001, errmsg: '查询失败' });
    }
  }
}

module.exports = MenuService;