eta_mini_crm/services/sys_department.go

package services

import (
	"eta/eta_mini_crm/models"
	"eta/eta_mini_crm/models/response"
	"strconv"
	"strings"
)

// GetSysDepartmentTree 递归获取部门目录树
func GetSysDepartmentTree(list []*models.SysDepartmentList, parentId int) []*models.SysDepartmentList {
	res := make([]*models.SysDepartmentList, 0)
	for _, v := range list {
		if v.ParentId == parentId {
			t := new(models.SysDepartmentList)
			t.SysDepartmentId = v.SysDepartmentId
			t.SysDepartmentName = v.SysDepartmentName
			t.Level = v.Level
			t.ParentId = v.ParentId
			t.Child = GetSysDepartmentTree(list, v.SysDepartmentId)
			res = append(res, t)
		}
	}
	return res
}

// DeleteSysDepartmentById 根据部门id去删除部门下的所有子目录，并清除用户的关联信息
func DeleteSysDepartmentById(sysDepartmentId, level int) (err error) {
	sysDepartmentIds := make([]string, 0)
	sysDepartmentIds = append(sysDepartmentIds, strconv.Itoa(sysDepartmentId))
	var curIds = sysDepartmentIds
	var curStringIds string
	for i := level; i < 3; i++ {
		// 从当前层部门依次向下遍历子部门
		curStringIds = strings.Join(curIds, ",")
		sysDepartments, er := models.GetChildSysDepartmentListByIds(curStringIds)

		if er != nil {
			return er
		}
		curIds = make([]string, 0)
		for _, dep := range sysDepartments {
			sysDepartmentIds = append(sysDepartmentIds, strconv.Itoa(dep.SysDepartmentId))
			curIds = append(curIds, strconv.Itoa(dep.SysDepartmentId))
		}
	}
	err = models.DeleteSysDepartmentByIdV2(sysDepartmentIds, level)
	return
}

// GetSysDepartmentPathIdsById 根据当前部门id获取，部门层级列表pathIds [3]int，0索引表示1级部门id，1表示2级部门id...
func GetSysDepartmentPathIdsById(sysDepartmentId int) (pathIds []int, err error) {
	sysDepartment, err := models.GetSysDepartmentById(sysDepartmentId)
	if err != nil {
		return
	}

	pathIds = make([]int, 3)
	pathIds[sysDepartment.Level-1] = sysDepartmentId
	curSysDepartmentId := sysDepartment.ParentId
	for curLevel := sysDepartment.Level - 1; curLevel >= 1; curLevel-- {
		upSysDepartment, er := models.GetSysDepartmentListByParentId(curSysDepartmentId)
		if er != nil {
			return
		}
		curSysDepartmentId = upSysDepartment.ParentId
		pathIds[curLevel-1] = upSysDepartment.SysDepartmentId
	}
	return
}

// GetSysDepartmentAndSellerById 根据当前部门id，获取部门下的子目录以及销售（系统用户）
func GetSysDepartmentAndSellerById(sysDepartmentId int, enabled bool) (items []*response.DepartmentSellers, err error) {
	depList, err := models.GetChildSysDepartmentListById(sysDepartmentId)
	if err != nil {
		return
	}
	for _, dep := range depList {
		depItem := &response.DepartmentSellers{
			SysDepartmentId:   dep.SysDepartmentId,
			SysDepartmentName: dep.SysDepartmentName,
		}
		items = append(items, depItem)
	}
	userList, err := models.GetSysUserByDepartmentId(sysDepartmentId, enabled)
	if err != nil {
		return
	}
	for _, user := range userList {
		userItem := &response.DepartmentSellers{
			SysUserId:   user.SysUserId,
			SysRealName: user.SysRealName,
		}
		items = append(items, userItem)
	}
	return
}