eta_api/services/chart_permission.go

package services

import (
	"eta/eta_api/models"
	"eta/eta_api/models/company"
	"eta/eta_api/utils"
	"fmt"
	"time"
)

// 获取权限列表
func GetChartPermissionList(cond string, pars []interface{}) (permissionList []*models.ChartPermission, err error) {
	ob := new(models.ChartPermission)
	permissionList, err = ob.GetItemsByCondition(cond, pars)
	if err != nil {
		err = fmt.Errorf("获取权限列表失败, Err: %s", err.Error())
		return
	}

	return
}

// 新增权限
func AddChartPermission(req models.PermissionAddReq) (err error, errMsg string) {
	// 重名校验
	ob := new(models.ChartPermission)
	existCond := ` AND permission_name = ? AND parent_id = ?`
	existPars := make([]interface{}, 0)
	existPars = append(existPars, req.PermissionName, req.ParentId)
	exist, e := ob.GetItemByCondition(existCond, existPars)
	if e != nil && e.Error() != utils.ErrNoRow() {
		errMsg = "操作失败"
		err = fmt.Errorf("获取重名品种权限失败, Err: " + e.Error())
		return
	}
	if exist != nil && exist.ChartPermissionId > 0 {
		errMsg = "品种名称已存在"
		err = fmt.Errorf("品种名称已存在")
		return
	}

	// 获取最大的排序值
	maxSort, e := ob.GetMaxSort()
	if e != nil {
		errMsg = "查询品种排序失败"
		err = fmt.Errorf("查询品种排序失败, Err: " + e.Error())
		return
	}
	parentPermissionName := ""
	if req.ParentId > 0 {
		//查询父级是否存在
		parent, e := ob.GetItemById(req.ParentId)
		if e != nil {
			errMsg = "查询父级品种失败"
			err = fmt.Errorf("查询父级品种失败, Err: " + e.Error())
			return
		}
		if parent.ChartPermissionId == 0 {
			errMsg = "请选择正确的父级品种"
			err = fmt.Errorf("请选择正确的父级品种")
			return
		}
		if parent.ParentId != 0 {
			errMsg = "只能选择一级品种作为父级品种"
			err = fmt.Errorf("只能选择一级品种作为父级品种")
			return
		}
		parentPermissionName = parent.PermissionName
	} else {
		parentPermissionName = req.PermissionName
	}
	// 新增
	ob.ChartPermissionName = req.PermissionName
	ob.PermissionName = req.PermissionName
	ob.Remark = req.PermissionName
	ob.ParentId = req.ParentId
	ob.ProductId = 1
	ob.IsPublic = req.IsPublic
	ob.Enabled = req.Enabled
	ob.Sort = maxSort + 1

	ob.CreatedTime = time.Now()
	ob.LastUpdatedTime = time.Now()
	if ob.ProductId == 1 {
		ob.ProductName = "ficc"
	} else {
		ob.ProductName = "权益"
	}
	ob.ProductPermissionName = ob.ProductName + ob.PermissionName
	ob.ClassifyName = parentPermissionName
	if e = ob.Create(); e != nil {
		errMsg = "操作失败"
		err = fmt.Errorf("新增品种权限失败, Err: " + e.Error())
		return
	}
	if req.ParentId > 0 && req.Enabled == 1 {
		//  更新父级品种的启用禁用
		err = ob.SetEnabledByChartPermissionId(req.ParentId, req.Enabled)
		if err != nil {
			errMsg = "更新品种启用禁用状态失败"
			err = fmt.Errorf("更新品种启用禁用状态失败, Err: " + err.Error())
			return
		}
	}
	// 同步本次变更的数据
	go func() {
		_, _ = ChartFiccPermissionSync()
	}()
	return
}

func EditChartPermission(req models.PermissionEditReq) (err error, errMsg string) {
	//查询是否存在品种
	ob := new(models.ChartPermission)
	item, e := ob.GetItemById(req.PermissionId)
	if e != nil {
		errMsg = "查询品种信息失败"
		err = fmt.Errorf("查询品种信息失败, Err: " + e.Error())
		return
	}
	if item.ChartPermissionId == 0 {
		errMsg = "请选择正确的品种"
		err = fmt.Errorf("请选择正确的品种")
		return
	}
	// 查询品种名称是否修改
	if item.PermissionName != req.PermissionName {
		existCond := ` AND permission_name = ? AND parent_id = ? AND chart_permission_id !=?`
		existPars := make([]interface{}, 0)
		existPars = append(existPars, req.PermissionName, item.ParentId, req.PermissionId)
		exist, e := ob.GetItemByCondition(existCond, existPars)
		if e != nil && e.Error() != utils.ErrNoRow() {
			errMsg = "操作失败"
			err = fmt.Errorf("获取重名品种权限失败, Err: " + e.Error())
			return
		}
		if exist != nil && exist.ChartPermissionId > 0 {
			errMsg = "品种名称已存在"
			err = fmt.Errorf("品种名称已存在")
			return
		}
	}

	//判断父级品种是否存在
	parentPermissionName := ""
	if req.ParentId > 0 {
		//查询父级是否存在
		parent, e := ob.GetItemById(req.ParentId)
		if e != nil {
			errMsg = "查询父级品种失败"
			err = fmt.Errorf("查询父级品种失败, Err: " + e.Error())
			return
		}
		if parent.ChartPermissionId == 0 {
			errMsg = "请选择正确的父级品种"
			err = fmt.Errorf("请选择正确的父级品种")
			return
		}
		if parent.ParentId != 0 {
			errMsg = "只能选择一级品种作为父级品种"
			err = fmt.Errorf("只能选择一级品种作为父级品种")
			return
		}
		parentPermissionName = parent.PermissionName
	} else {
		parentPermissionName = req.PermissionName
	}
	updateCol := []string{"PermissionName", "IsPublic", "ParentId", "ClassifyName", "LastUpdatedTime", "ProductPermissionName"}
	if item.ProductId == 1 {
		item.Remark = req.PermissionName //remark 在权益品种中用来区分主客观
		updateCol = append(updateCol, "Remark")
	}
	item.PermissionName = req.PermissionName
	item.IsPublic = req.IsPublic
	item.ParentId = req.ParentId
	item.ClassifyName = parentPermissionName
	item.ProductPermissionName = item.ProductName + item.PermissionName
	item.LastUpdatedTime = time.Now()
	err = item.Update(updateCol)
	if err != nil {
		errMsg = "更新失败"
		err = fmt.Errorf("更新品种失败, Err: " + err.Error())
		return
	}

	//判断是否是一级品种
	if item.ParentId == 0 {
		// 判断是否设置公有的二级品种
		if len(req.PublicPermissionIds) > 0 {
			// 更新二级品种的公有权限
			err = ob.SetIsPublic(req.PublicPermissionIds, item.ChartPermissionId, 1)
			if err != nil {
				errMsg = "更新品种公有权限失败"
				err = fmt.Errorf("更新品种公有权限失败, Err: " + err.Error())
				return
			}
		}
		// 更新二级的启动禁用
		err = ob.UpdateClassifyNameByParentId(item.ChartPermissionId, req.PermissionName)
		if err != nil {
			errMsg = "更新品种启用禁用状态失败"
			err = fmt.Errorf("更新品种启用禁用状态失败, Err: " + err.Error())
			return
		}
	} else if item.ParentId > 0 {
		if item.Enabled == 1 {
			//  更新父级品种的启用禁用
			err = ob.SetEnabledByChartPermissionId(item.ParentId, item.Enabled)
			if err != nil {
				errMsg = "更新品种启用禁用状态失败"
				err = fmt.Errorf("更新品种启用禁用状态失败, Err: " + err.Error())
				return
			}
		}
	}
	// 同步本次变更的数据
	go func() {
		_, _ = ChartFiccPermissionSync()
	}()
	return
}

// SetEnabledChartPermission  设置启用禁用
func SetEnabledChartPermission(req models.PermissionEnabledReq) (err error, errMsg string) {
	//查询是否存在品种
	ob := new(models.ChartPermission)
	item, e := ob.GetItemById(req.PermissionId)
	if e != nil {
		errMsg = "查询品种信息失败"
		err = fmt.Errorf("查询品种信息失败, Err: " + e.Error())
		return
	}
	if item.ChartPermissionId == 0 {
		errMsg = "请选择正确的品种"
		err = fmt.Errorf("请选择正确的品种")
		return
	}
	// 查询品种名称是否修改
	item.Enabled = req.Enabled
	item.LastUpdatedTime = time.Now()
	err = item.Update([]string{"Enabled", "LastUpdatedTime"})
	if err != nil {
		errMsg = "更新失败"
		err = fmt.Errorf("更新品种失败, Err: " + err.Error())
		return
	}

	//判断是否是一级品种
	if item.ParentId == 0 {
		// 判断是否设置公有的二级品种
		// 更新二级的启动禁用
		err = ob.SetEnabledByParentId(item.ChartPermissionId, req.Enabled)
		if err != nil {
			errMsg = "更新品种启用禁用状态失败"
			err = fmt.Errorf("更新品种启用禁用状态失败, Err: " + err.Error())
			return
		}

		//
	} else if item.ParentId > 0 {
		if req.Enabled == 1 {
			//  更新父级品种的启用禁用
			err = ob.SetEnabledByChartPermissionId(item.ParentId, req.Enabled)
			if err != nil {
				errMsg = "更新品种启用禁用状态失败"
				err = fmt.Errorf("更新品种启用禁用状态失败, Err: " + err.Error())
				return
			}
		}
	}
	// 同步本次变更的数据
	go func() {
		_, _ = ChartFiccPermissionSync()
	}()
	return
}

// MoveChartPermission 移动品种
func MoveChartPermission(req models.PermissionMoveReq) (err error, errMsg string) {
	ob := new(models.ChartPermission)
	chartPermissionId := req.PermissionId
	prevChartPermissionId := req.PrevPermissionId
	nextChartPermissionId := req.NextPermissionId

	//如果有传入 上一个兄弟节点分类id
	var (
		permissionInfo *models.ChartPermission
		prevPermission *models.ChartPermission
		nextPermission *models.ChartPermission

		prevSort int
		nextSort int
	)

	// 移动对象为分类， 判断权限
	permissionInfo, err = ob.GetItemById(chartPermissionId)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			errMsg = "当前品种不存在"
			err = fmt.Errorf("获取品种信息失败,Err:" + err.Error())
			return
		}
		errMsg = "移动失败"
		err = fmt.Errorf("获取分类信息失败,Err:" + err.Error())
		return
	} else if permissionInfo.ChartPermissionId == 0 {
		errMsg = "当前品种不存在"
		err = fmt.Errorf("获取品种信息失败,Err:" + err.Error())
		return
	}

	parentChartPermissionId := permissionInfo.ParentId
	productId := permissionInfo.ProductId
	if prevChartPermissionId > 0 {
		prevPermission, err = ob.GetItemById(prevChartPermissionId)
		if err != nil {
			errMsg = "移动失败"
			err = fmt.Errorf("获取上一个兄弟节点分类信息失败,Err:" + err.Error())
			return
		}
		prevSort = prevPermission.Sort
	}

	if nextChartPermissionId > 0 {
		//下一个兄弟节点
		nextPermission, err = ob.GetItemById(nextChartPermissionId)
		if err != nil {
			errMsg = "移动失败"
			err = fmt.Errorf("获取下一个兄弟节点分类信息失败,Err:" + err.Error())
			return
		}
		nextSort = nextPermission.Sort
	}

	err, errMsg = moveChartPermission(permissionInfo, prevPermission, nextPermission, parentChartPermissionId, prevSort, nextSort, productId)
	return
}

// moveChartPermission 移动指标分类
func moveChartPermission(permissionInfo, prevPermission, nextPermission *models.ChartPermission, parentId, prevSort, nextSort, productId int) (err error, errMsg string) {
	ob := new(models.ChartPermission)
	updateCol := make([]string, 0)

	//判断上级id是否一致，如果不一致的话，那么需要移动该分类层级
	if permissionInfo.ParentId != parentId {
		errMsg = "移动失败"
		err = fmt.Errorf("不支持目录层级变更")
		return
	}

	if prevSort > 0 {
		//如果是移动在两个兄弟节点之间
		if nextSort > 0 {
			//下一个兄弟节点
			//如果上一个兄弟与下一个兄弟的排序权重是一致的，那么需要将下一个兄弟（以及下个兄弟的同样排序权重）的排序权重+2，自己变成上一个兄弟的排序权重+1
			if prevSort == nextSort || prevSort == permissionInfo.Sort {
				//变更兄弟节点的排序
				updateSortStr := `sort + 2`

				//变更分类
				if prevPermission != nil {
					_ = models.UpdateChartPermissionSortByParentId(parentId, prevPermission.ChartPermissionId, prevPermission.Sort, updateSortStr, productId)
				} else {
					_ = models.UpdateChartPermissionSortByParentId(parentId, 0, prevSort, updateSortStr, productId)
				}

			} else {
				//如果下一个兄弟的排序权重正好是上个兄弟节点的下一层，那么需要再加一层了
				if nextSort-prevSort == 1 {
					//变更兄弟节点的排序
					updateSortStr := `sort + 1`

					//变更分类
					if prevPermission != nil {
						_ = models.UpdateChartPermissionSortByParentId(parentId, prevPermission.ChartPermissionId, prevSort, updateSortStr, productId)
					} else {
						_ = models.UpdateChartPermissionSortByParentId(parentId, 0, prevSort, updateSortStr, productId)
					}

				}
			}
		}

		permissionInfo.Sort = prevSort + 1
		permissionInfo.LastUpdatedTime = time.Now()
		updateCol = append(updateCol, "Sort", "LastUpdatedTime")
	} else if prevPermission == nil && nextPermission == nil && parentId > 0 {
		//处理只拖动到目录里，默认放到目录底部的情况
		var maxSort int
		maxSort, err = ob.GetMaxSortByParentId(parentId)
		if err != nil {
			errMsg = "移动失败"
			err = fmt.Errorf("查询组内排序信息失败,Err:" + err.Error())
			return
		}
		permissionInfo.Sort = maxSort + 1 //那就是排在组内最后一位
		permissionInfo.LastUpdatedTime = time.Now()
		updateCol = append(updateCol, "Sort", "LastUpdatedTime")
	} else {
		// 拖动到父级分类的第一位
		firstPermission, tmpErr := ob.GetFirstChartPermissionByParentId(parentId)
		if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
			errMsg = "移动失败"
			err = fmt.Errorf("获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + tmpErr.Error())
			return
		}

		//如果该分类下存在其他分类，且第一个其他分类的排序等于0，那么需要调整排序
		if firstPermission != nil && firstPermission.ChartPermissionId != 0 && firstPermission.Sort == 0 {
			updateSortStr := ` sort + 1 `
			_ = models.UpdateChartPermissionSortByParentId(parentId, firstPermission.ChartPermissionId-1, 0, updateSortStr, productId)
		}

		permissionInfo.Sort = 0 //那就是排在第一位
		permissionInfo.LastUpdatedTime = time.Now()
		updateCol = append(updateCol, "Sort", "LastUpdatedTime")
	}

	//更新
	if len(updateCol) > 0 {
		err = permissionInfo.Update(updateCol)
		if err != nil {
			errMsg = "移动失败"
			err = fmt.Errorf("修改失败,Err:" + err.Error())
			return
		}
	}

	// 同步本次变更的数据
	go func() {
		_, _ = ChartFiccPermissionSync()
	}()
	return
}

// GetChartPermissionEnabledList 查询已启用的FICC权限列表
func GetChartPermissionEnabledList() (list []*company.PermissionSetList, err error) {
	dataList, err := GetChartPermissionList(" AND enabled = 1", []interface{}{})
	if err != nil {
		return
	}
	//enabledList := make([]*models.ChartPermission, 0)
	parentList := make([]*models.ChartPermission, 0)
	enabledMap := make(map[int][]*company.PermissionSetItem)
	listMap := make(map[int]*models.ChartPermission)
	for _, v := range dataList {
		listMap[v.ChartPermissionId] = v
		if v.ParentId == 0 {
			parentList = append(parentList, v)
		}
		if v.Enabled == 1 && v.ParentId > 0 && v.PermissionType == 0 {
			//enabledList = append(enabledList, v)
			item := &company.PermissionSetItem{
				ChartPermissionId: v.ChartPermissionId,
				PermissionName:    v.PermissionName,
				PermissionType:    v.PermissionType,
			}

			enabledMap[v.ParentId] = append(enabledMap[v.ParentId], item)
		}
	}
	for _, v := range parentList {
		items, ok := enabledMap[v.ChartPermissionId]
		if !ok {
			continue
		}
		checkList := make([]int, 0)
		p := new(company.PermissionSetList)
		p.PermissionName = v.PermissionName
		p.Child = items
		if v.PermissionName == "宏观经济" {
			checkList = append(checkList, 1)
		}
		p.CheckList = checkList
		list = append(list, p)
	}
	return
}