eta_api/controllers/sys_department.go

package controllers

import (
	"encoding/json"
	"eta_gn/eta_api/models"
	"eta_gn/eta_api/models/system"
	"eta_gn/eta_api/services"
	"eta_gn/eta_api/utils"
	"fmt"
	"strings"
	"time"
)

// 系统设置
type SysDepartmentController struct {
	BaseAuthController
}

// @Title 新增部门
// @Description 新增部门接口
// @Param	request	body system.SysDepartmentAddReq true "type json string"
// @Success 200 新增成功
// @router /department/add [post]
func (this *SysDepartmentController) Add() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	var req system.SysDepartmentAddReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.DepartmentName == "" {
		br.Msg = "部门名称不能为空"
		return
	}
	count, err := system.GetSysDepartmentCount(req.DepartmentName)
	if err != nil {
		br.Msg = "获取数据失败"
		br.ErrMsg = "获取数据失败"
		return
	}
	if count > 0 {
		br.Msg = "部门名称已存在,请重新输入"
		return
	}
	item := new(system.SysDepartment)
	item.DepartmentName = req.DepartmentName
	item.CreateTime = time.Now()
	_, err = system.AddSysDepartment(item)
	if err != nil {
		br.Msg = "新增失败"
		br.ErrMsg = "新增失败，Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "新增成功"
}

// @Title 修改部门
// @Description 修改部门接口
// @Param	request	body system.SysDepartmentEditReq true "type json string"
// @Success 200 修改成功
// @router /department/edit [post]
func (this *SysDepartmentController) Edit() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	var req system.SysDepartmentEditReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.DepartmentId <= 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "参数错误,DepartmentId 小于等于0 "
		return
	}
	if req.DepartmentName == "" {
		br.Msg = "部门名称不能为空"
		return
	}
	item, err := system.GetSysDepartmentByName(req.DepartmentName)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取数据失败"
		br.ErrMsg = "获取数据失败,Err:" + err.Error()
		return
	}
	if item != nil && item.DepartmentId > 0 {
		if item.DepartmentId != req.DepartmentId {
			br.Msg = "名称已存在，请重新输入"
			return
		}
	}
	err = system.ModifySysDepartment(req.DepartmentName, req.DepartmentId)
	if err != nil {
		br.Msg = "修改失败"
		br.ErrMsg = "修改失败，Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "修改成功"
}

// @Title 删除部门
// @Description 删除部门接口
// @Param	request	body system.SysDepartmentDeleteReq true "type json string"
// @Success 200 删除成功
// @router /department/delete [post]
func (this *SysDepartmentController) Delete() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	var req system.SysDepartmentDeleteReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.DepartmentId <= 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "参数错误,DepartmentId 小于等于0 "
		return
	}
	err = system.DeleteSysDepartment(req.DepartmentId)
	if err != nil {
		br.Msg = "删除失败"
		br.ErrMsg = "删除失败，Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "删除成功"
}

// @Title 获取部门列表
// @Description 获取部门列表接口
// @Success 200 {object} system.SysDepartmentListResp
// @router /department/list [get]
func (this *SysDepartmentController) ListDepartment() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		return
	}
	//list, err := system.GetDepartmentList()
	//if err != nil {
	//	br.Msg = "获取失败"
	//	br.ErrMsg = "获取失败，Err:" + err.Error()
	//	return
	//}
	//lenList := len(list)
	//for i := 0; i < lenList; i++ {
	//	departmentId := list[i].DepartmentId
	//	groupList, err := system.GetSysGroupByDepartmentId(departmentId)
	//	if err != nil {
	//		br.Msg = "获取数据失败"
	//		br.ErrMsg = "获取数据失败，Err:" + err.Error()
	//		return
	//	}
	//	list[i].Child = groupList
	//	list[i].IsDepartment = true
	//	for i2, sysGroup := range groupList {
	//		teamList, err := system.GetSysTeamByDepartmentId(sysGroup.GroupId)
	//		if err != nil {
	//			br.Msg = "获取数据失败"
	//			br.ErrMsg = "获取数据失败，Err:" + err.Error()
	//			return
	//		}
	//		groupList[i2].Child = teamList
	//		groupList[i2].IsGroup = true
	//	}
	//}

	// 获取部门
	departments, e := system.GetDepartmentList()
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = fmt.Sprintf("获取部门失败, %v", e)
		return
	}
	// 获取分组和小组
	groups, e := system.GetSysGroupList()
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = fmt.Sprintf("获取分组失败, %v", e)
		return
	}
	departmentGroup := make(map[int][]*system.SysGroupList)
	groupTeam := make(map[int][]*system.SysGroupList)
	for _, v := range groups {
		if departmentGroup[v.DepartmentId] == nil {
			departmentGroup[v.DepartmentId] = make([]*system.SysGroupList, 0)
		}
		if v.ParentId == 0 {
			departmentGroup[v.DepartmentId] = append(departmentGroup[v.DepartmentId], v)
		}
		if v.ParentId > 0 {
			if groupTeam[v.ParentId] == nil {
				groupTeam[v.ParentId] = make([]*system.SysGroupList, 0)
			}
			groupTeam[v.ParentId] = append(groupTeam[v.ParentId], &system.SysGroupList{
				GroupId:      v.GroupId,
				DepartmentId: v.DepartmentId,
				ParentId:     v.ParentId,
				GroupName:    v.GroupName,
				CreateTime:   v.CreateTime,
				IsGroup:      true,
				Child:        make([]*system.SysGroupList, 0),
			})
		}
	}

	// 数据重组
	for departmentId, groups := range departmentGroup {
		//for _, g := range groups {
		//	g.IsGroup = true
		//	if groupTeam[g.GroupId] != nil {
		//		g.Child = groupTeam[g.GroupId]
		//	} else {
		//		g.Child = make([]*system.SysTeamList, 0)
		//	}
		//}
		departmentGroup[departmentId] = buildTree(groups, groupTeam)
	}

	for _, v := range departments {
		v.IsDepartment = true
		if departmentGroup[v.DepartmentId] != nil {
			v.Child = departmentGroup[v.DepartmentId]
		} else {
			v.Child = make([]*system.SysGroupList, 0)
		}
	}

	//lenList := len(list)
	//for i := 0; i < lenList; i++ {
	//	departmentId := list[i].DepartmentId
	//	groupList, err := system.GetSysGroupByDepartmentId(departmentId)
	//	if err != nil {
	//		br.Msg = "获取数据失败"
	//		br.ErrMsg = "获取数据失败，Err:" + err.Error()
	//		return
	//	}
	//	list[i].Child = groupList
	//	list[i].IsDepartment = true
	//	for i2, sysGroup := range groupList {
	//		teamList, err := system.GetSysTeamByDepartmentId(sysGroup.GroupId)
	//		if err != nil {
	//			br.Msg = "获取数据失败"
	//			br.ErrMsg = "获取数据失败，Err:" + err.Error()
	//			return
	//		}
	//		groupList[i2].Child = teamList
	//		groupList[i2].IsGroup = true
	//	}
	//}

	resp := new(system.SysDepartmentListResp)
	resp.List = departments
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

func buildTree(groups []*system.SysGroupList, groupTeam map[int][]*system.SysGroupList) []*system.SysGroupList {
	for _, g := range groups {
		g.IsGroup = true
		if children, ok := groupTeam[g.GroupId]; ok {
			g.Child = buildTree(children, groupTeam)
		} else {
			g.Child = make([]*system.SysGroupList, 0)
		}
	}
	return groups
}

// DepartmentUserTree
// @Title 获取部门及分组用户树
// @Description 获取部门列表接口
// @Success 200 {object} system.DepartmentUserTree
// @router /department/user_tree [get]
func (this *SysDepartmentController) DepartmentUserTree() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		return
	}
	keywords := this.GetString("Keywords", "")
	keywords = strings.TrimSpace(keywords)

	// 获取部门/分组/用户
	departments, e := system.GetDepartmentList()
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取部门失败，Err:" + e.Error()
		return
	}
	groups, e := system.GetFullGroup()
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取分组失败，Err:" + e.Error()
		return
	}
	cond := ` AND enabled = 1`
	pars := make([]interface{}, 0)
	if keywords != "" {
		kw := fmt.Sprint("%", keywords, "%")
		cond += ` AND real_name LIKE ?`
		pars = append(pars, kw)
	}
	admins, e := system.GetSysAdminList(cond, pars, []string{}, "")
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取用户失败，Err:" + e.Error()
		return
	}

	// 用户map
	departmentAdmins := make(map[int][]*system.DepartmentUserTree, 0)
	groupAdmins := make(map[int][]*system.DepartmentUserTree, 0)
	for _, v := range admins {
		t := new(system.DepartmentUserTree)
		t.NodeId = v.AdminId
		t.NodeType = 3
		t.NodeName = v.RealName
		t.Children = make([]*system.DepartmentUserTree, 0)
		if groupAdmins[v.GroupId] == nil {
			groupAdmins[v.GroupId] = make([]*system.DepartmentUserTree, 0)
		}
		groupAdmins[v.GroupId] = append(groupAdmins[v.GroupId], t)

		// 直属于部门
		if v.GroupId == 0 {
			if departmentAdmins[v.DepartmentId] == nil {
				departmentAdmins[v.DepartmentId] = make([]*system.DepartmentUserTree, 0)
			}
			departmentAdmins[v.DepartmentId] = append(departmentAdmins[v.DepartmentId], t)
		}
	}

	// 构建分组树（以前这里还有个keyword匹配，不知道用作干嘛的，先去掉吧）
	groupTree := services.BuildGroupTree(groups, groupAdmins)

	// 部门
	list := make([]*system.DepartmentUserTree, 0)
	for _, v := range departments {
		// 关键词查询时不显示空部门
		if keywords != "" && groupTree[v.DepartmentId] == nil && departmentAdmins[v.DepartmentId] == nil {
			continue
		}
		t := new(system.DepartmentUserTree)
		t.NodeId = v.DepartmentId
		t.NodeType = 1
		t.NodeName = v.DepartmentName
		t.Children = make([]*system.DepartmentUserTree, 0)
		if groupTree[v.DepartmentId] != nil {
			t.Children = append(t.Children, groupTree[v.DepartmentId]...)
		}
		if departmentAdmins[v.DepartmentId] != nil {
			t.Children = append(t.Children, departmentAdmins[v.DepartmentId]...)
		}
		list = append(list, t)
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = list
}