|
@@ -8,6 +8,65 @@ import (
|
|
|
"time"
|
|
|
)
|
|
|
|
|
|
+// SetDataIsPermissionReq
|
|
|
+// @Description: 设置数据分类权限请求
|
|
|
+type SetDataIsPermissionReq struct {
|
|
|
+ Source int `description:"来源id"`
|
|
|
+ SubSource int `description:"子来源id"`
|
|
|
+ ClassifyIdList []int `description:"指标/图表/表格分类唯一id列表,如果为空,说明要给这些指标移除权限管控"`
|
|
|
+}
|
|
|
+
|
|
|
+// SetIsPermissionEdbChartByEdbClassifyIdList
|
|
|
+// @Description: 设置指标分类是否涉密
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-03-27 14:15:42
|
|
|
+// @param classifyIdList []int
|
|
|
+func SetIsPermissionEdbChartByEdbClassifyIdList(classifyIdList []int) (err error) {
|
|
|
+ num := len(classifyIdList)
|
|
|
+ if num <= 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ _ = o.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = o.Commit()
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+ //// 获取已经配置涉密的分类权限
|
|
|
+ //edbClassifyList := make([]*EdbClassify, 0)
|
|
|
+ //sql := `SELECT * FROM edb_classify WHERE is_join_permission = ? `
|
|
|
+ //_, err = o.Raw(sql, 1).QueryRows(&edbClassifyList)
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //edbClassifyMap := make(map[int]*EdbClassify)
|
|
|
+ //for _, v := range edbClassifyList {
|
|
|
+ // edbClassifyMap[v.ClassifyId] = v
|
|
|
+ //}
|
|
|
+
|
|
|
+ // 分类不选的情况下,说明是要给这些分类移除权限管控
|
|
|
+ if len(classifyIdList) <= 0 {
|
|
|
+ // 将所有的分类设置为不涉密
|
|
|
+ sql := `UPDATE edb_classify SET is_join_permission=?,modify_time=now() WHERE is_join_permission = 1 `
|
|
|
+ _, err = o.Raw(sql, 0, 1).Exec()
|
|
|
+ return
|
|
|
+ } else {
|
|
|
+ // 将对应的分类设置为涉密
|
|
|
+ sql := `UPDATE edb_classify SET is_join_permission=?,modify_time=now() WHERE classify_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ _, err = o.Raw(sql, 1, classifyIdList).Exec()
|
|
|
+ }
|
|
|
+
|
|
|
+ // TODO 判断是否要记录移除的分类,用于发送通知给客户
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
// SetPermissionEdbChartReq
|
|
|
// @Description: 设置数据权限请求
|
|
|
type SetPermissionEdbChartReq struct {
|
|
@@ -22,6 +81,8 @@ type SetPermissionEdbChartReq struct {
|
|
|
Keyword string `description:"关键字"`
|
|
|
}
|
|
|
|
|
|
+// EdbInfoPermission
|
|
|
+// @Description: 指标权限表
|
|
|
type EdbInfoPermission struct {
|
|
|
PermissionId int64 `json:"permission_id" orm:"column(permission_id);pk"`
|
|
|
EdbInfoId int32 `json:"edb_info_id"` // 指标id
|
|
@@ -30,6 +91,8 @@ type EdbInfoPermission struct {
|
|
|
CreateTime time.Time `json:"create_time"` // 关系建立时间
|
|
|
}
|
|
|
|
|
|
+// EdbClassifyPermission
|
|
|
+// @Description: 指标分类权限表
|
|
|
type EdbClassifyPermission struct {
|
|
|
PermissionId int64 `json:"permission_id" orm:"column(permission_id);pk"`
|
|
|
EdbClassifyId int32 `json:"edb_classify_id"` // 分类id
|
|
@@ -38,7 +101,13 @@ type EdbClassifyPermission struct {
|
|
|
CreateTime time.Time `json:"create_time"` // 关系建立时间
|
|
|
}
|
|
|
|
|
|
-// SetPermissionEdbChartByEdbIdList 根据指标ID列表设置指标的用户权限
|
|
|
+// SetPermissionEdbChartByEdbIdList
|
|
|
+// @Description: 根据指标ID列表设置指标的用户权限
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-03-27 14:03:42
|
|
|
+// @param edbIdList []string
|
|
|
+// @param userIdList []int
|
|
|
+// @return err error
|
|
|
func SetPermissionEdbChartByEdbIdList(edbIdList []string, userIdList []int) (err error) {
|
|
|
edbNum := len(edbIdList)
|
|
|
if edbNum <= 0 {
|
|
@@ -136,3 +205,108 @@ func SetPermissionEdbChartByEdbIdList(edbIdList []string, userIdList []int) (err
|
|
|
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+// SetPermissionEdbChartClassifyIdByClassifyIdList
|
|
|
+// @Description: 根据指标分类ID列表设置分类的用户权限
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-03-27 14:03:42
|
|
|
+// @param edbIdList []string
|
|
|
+// @param userIdList []int
|
|
|
+// @return err error
|
|
|
+func SetPermissionEdbChartClassifyIdByClassifyIdList(edbIdList []string, userIdList []int) (err error) {
|
|
|
+ edbNum := len(edbIdList)
|
|
|
+ if edbNum <= 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ _ = o.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = o.Commit()
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+ // 获取已经配置的指标权限用户
|
|
|
+ edbInfoPermissionList := make([]*EdbInfoPermission, 0)
|
|
|
+ sql := `SELECT * FROM edb_info_permission WHERE edb_info_id in (` + utils.GetOrmInReplace(edbNum) + `) `
|
|
|
+ _, err = o.Raw(sql, edbIdList).QueryRows(&edbInfoPermissionList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoPermissionMap := make(map[string]*EdbInfoPermission)
|
|
|
+ for _, v := range edbInfoPermissionList {
|
|
|
+ edbInfoPermissionMap[fmt.Sprint(v.EdbInfoId, "_", v.SysUserId)] = v
|
|
|
+ }
|
|
|
+
|
|
|
+ // 用户不选的情况下,说明是要给这些指标移除权限管控
|
|
|
+ if len(userIdList) <= 0 {
|
|
|
+ // 标记指标为不纳入权限管控
|
|
|
+ sql = `UPDATE edb_info SET is_join_permission=?,modify_time=now() WHERE edb_info_id in (` + utils.GetOrmInReplace(edbNum) + `) `
|
|
|
+ _, err = o.Raw(sql, 0, edbIdList).Exec()
|
|
|
+ return
|
|
|
+ } else {
|
|
|
+ // 标记指标为纳入权限管控
|
|
|
+ sql = `UPDATE edb_info SET is_join_permission=?,modify_time=now() WHERE edb_info_id in (` + utils.GetOrmInReplace(edbNum) + `) `
|
|
|
+ _, err = o.Raw(sql, 1, edbIdList).Exec()
|
|
|
+ }
|
|
|
+
|
|
|
+ // 待添加的配置项
|
|
|
+ addList := make([]*EdbInfoPermission, 0)
|
|
|
+
|
|
|
+ // 遍历待配置的指标和用户,筛选出需要添加的配置项
|
|
|
+ for _, edbInfoIdStr := range edbIdList {
|
|
|
+ edbInfoId, tmpErr := strconv.ParseInt(edbInfoIdStr, 10, 64)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, userId := range userIdList {
|
|
|
+ key := fmt.Sprint(edbInfoId, "_", userId)
|
|
|
+ if _, ok := edbInfoPermissionMap[key]; ok {
|
|
|
+ // 如果存在那么就移除,说明不需要处理了
|
|
|
+ delete(edbInfoPermissionMap, key)
|
|
|
+ } else {
|
|
|
+ // 如果不存在,那么就提那家
|
|
|
+ addList = append(addList, &EdbInfoPermission{
|
|
|
+ //PermissionId: 0,
|
|
|
+ EdbInfoId: int32(edbInfoId),
|
|
|
+ SysUserId: int32(userId),
|
|
|
+ ModifyTime: time.Now(),
|
|
|
+ CreateTime: time.Now(),
|
|
|
+ })
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加待配置项
|
|
|
+ if len(addList) > 0 {
|
|
|
+ _, err = o.InsertMulti(500, addList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 移除废弃的配置项
|
|
|
+ {
|
|
|
+ // 获取移除的配置项
|
|
|
+ deletePermissionIdList := make([]int64, 0)
|
|
|
+ for _, v := range edbInfoPermissionMap {
|
|
|
+ deletePermissionIdList = append(deletePermissionIdList, v.PermissionId)
|
|
|
+ }
|
|
|
+
|
|
|
+ deletePermissionIdNum := len(deletePermissionIdList)
|
|
|
+ if deletePermissionIdNum > 0 {
|
|
|
+ sql = "DELETE FROM edb_info_permission WHERE permission_id in (" + utils.GetOrmInReplace(deletePermissionIdNum) + ")"
|
|
|
+ _, err = o.Raw(sql, deletePermissionIdList).Exec()
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|