magazine-service/service-naf/app/service/role.js

'use strict';

const assert = require('assert');
const Service = require('egg').Service;
class RoleService extends Service {
  constructor(ctx) {
    super(ctx);
    this.model = this.ctx.model.Role;
    this.UserBindRoleModel = this.ctx.model.UserBindRole;
    this.RoleBindMenuModel = this.ctx.model.RoleBindMenu;
  }
  async create({ name, code }) {
    assert(name, '缺少名称');
    assert(code, '缺少编码');
    const role = await this.model.findOne({ code });
    if (role) return { errcode: -1001, errmsg: '编码已存在' };
    try {
      const res = await this.model.create({ name, code });
      return { errcode: 0, errmsg: '', data: res };
    } catch (error) {
      throw error;
    }
  }
  async update({ id, name }) {
    assert(id, '缺少ID');
    try {
      const user = await this.model.findOne({ _id: id });
      if (!user) return { errcode: -1001, errmsg: '角色不存在', data: '' };
      await this.model.updateOne({ _id: id }, { name });
      return { errcode: 0, errmsg: '', data: 'update' };
    } catch (error) {
      throw error;
    }
  }
  async delete({ id }) {
    assert(id, '缺少ID');
    try {
      const role = await this.model.findOne({ _id: id });
      if (!role) return { errcode: -1001, errmsg: '角色不存在', data: '' };
      await this.UserBindRoleModel.find({ roleCode: role.code }).remove();
      await this.RoleBindMenuModel.find({ roleCode: role.code }).remove();
      await this.model.deleteOne({ _id: id });
      return { errcode: 0, errmsg: 'ok', data: 'delete' };
    } catch (error) {
      throw error;
    }
  }
  async query({ skip, limit, name, code }) {
    const filter = {};
    if (name || code) filter.$or = [];
    if (code) filter.$or.push({ code: { $regex: code } });
    if (name) filter.$or.push({ name: { $regex: name } });
    try {
      const total = await this.model.find({ ...filter });
      let res;
      if (skip && limit) {
        res = await this.model.find({ ...filter }).skip(Number(skip) * Number(limit)).limit(Number(limit));
      } else {
        res = await this.model.find({ ...filter });
      }
      return { errcode: 0, errmsg: 'ok', data: res, total: total.length };
    } catch (error) {
      throw error;
    }
  }
}
module.exports = RoleService;