'use strict'; const Service = require('egg').Service; const assert = require('assert'); const moment = require('moment'); // const _ = require('lodash'); class ColumnService extends Service { async create({ name, code, menuList }) { assert(name, '名称不存在'); assert(code, '编码不存在'); const { Column: model } = this.ctx.model; const createAt = moment().format('x'); try { await model.create({ name, code, menuList, createAt }); return { errmsg: '', errcode: 0 }; } catch (error) { throw new Error({ errcode: -2001, errmsg: '添加失败' }); } } async update({ name, code, id, menuList }) { assert(id, 'id不存在'); const { Column: model } = this.ctx.model; try { await model.findByIdAndUpdate(id, { name, code, menuList }); return { errmsg: '', errcode: 0 }; } catch (error) { throw new Error({ errcode: -2001, errmsg: '修改失败' }); } } async del({ id }) { assert(id, 'id不存在'); const { Column: model } = this.ctx.model; const { Content: Contentmodel } = this.ctx.model; try { // 当前数据 const res = await model.findById(id); // 复杂查询文章数据 const contentList = await Contentmodel.where('columnList').in(res.code); contentList.filter(async p => { const columnList = p.columnList.filter(e => e !== res.code); await Contentmodel.findByIdAndUpdate(p._id, { columnList }); }); await model.findByIdAndDelete(id); return { errmsg: '', errcode: 0 }; } catch (error) { throw new Error({ errcode: -2001, errmsg: '删除失败' }); } } // async query() { // const { Column: model } = this.ctx.model; // const { adminUser: usermodel } = this.ctx.model; // const jwt = this.app.middleware.jwt(this.app.config.jwt); // try { // const userInfo = await usermodel.findById(jwt.userId); // const menus = []; // userInfo.roleList.forEach(async e => { // const res = await model.where('roleLise').in(e); // menus.push(...res); // }); // const list = _.uniqWith(menus, _.isEqual); // return { errmsg: '', errcode: 0, data: list }; // } catch (error) { // throw new Error({ errcode: -2001, errmsg: '查询失败' }); // } // } async query({ skip, limit, filter }) { const { Column: 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 = ColumnService;