'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, uri }) { 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, uri }); 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 }) { const { Menu: model } = this.ctx.model; try { let res; if (skip !== undefined && limit !== undefined) { res = await model.find().skip(skip * limit).limit(limit); } else { res = await model.find(); } return { errmsg: '', errcode: 0, data: res }; } catch (error) { console.log(error); throw new Error({ errcode: -2001, errmsg: '查询失败' }); } } } module.exports = MenuService;