|
@@ -5,6 +5,7 @@ import (
|
|
|
"errors"
|
|
|
"eta/eta_api/models"
|
|
|
"eta/eta_api/models/data_manage"
|
|
|
+ "eta/eta_api/models/data_manage/excel"
|
|
|
"eta/eta_api/models/system"
|
|
|
"eta/eta_api/services/alarm_msg"
|
|
|
"eta/eta_api/services/elastic"
|
|
@@ -1719,8 +1720,8 @@ func getRefreshEdbInfoListByIds(edbInfoIdList []int) (newBaseEdbInfoArr, newBase
|
|
|
}
|
|
|
|
|
|
// GetMoveEdbChartList 获取待转移的指标/图表列表
|
|
|
-// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库
|
|
|
-func GetMoveEdbChartList(source, userId int, keyword, classify string, startSize, pageSize int) (list []data_manage.MoveEdbChartList, total int, err error) {
|
|
|
+// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库 6:ETA表格
|
|
|
+func GetMoveEdbChartList(source, subSource, userId int, keyword, classify string, startSize, pageSize int) (list []data_manage.MoveEdbChartList, total int, err error) {
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
|
switch source {
|
|
@@ -1905,6 +1906,65 @@ func GetMoveEdbChartList(source, userId int, keyword, classify string, startSize
|
|
|
CreateUserName: v.SysUserRealName,
|
|
|
})
|
|
|
}
|
|
|
+ case 6: //ETA表格
|
|
|
+ if keyword != `` {
|
|
|
+ condition += " AND (excel_name like ? OR sys_user_real_name like ? ) "
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, keyword, 2)
|
|
|
+ }
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND sys_user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+ if classify != "" {
|
|
|
+ condition += ` AND excel_classify_id IN (` + classify + `) `
|
|
|
+ }
|
|
|
+
|
|
|
+ condition += " AND source = ? "
|
|
|
+ pars = append(pars, subSource)
|
|
|
+
|
|
|
+ total, err = excel.GetExcelInfoCountByCondition(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpList, tmpErr := excel.GetNoContentExcelInfoListByCondition(condition, pars, startSize, pageSize)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取所有的图表分类
|
|
|
+ firstClassifyList, tmpErr := excel.GetExcelClassifyByParentId(0, subSource)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ firstClassifyNameMap := make(map[int]string)
|
|
|
+ for _, v := range firstClassifyList {
|
|
|
+ firstClassifyNameMap[v.ExcelClassifyId] = v.ExcelClassifyName
|
|
|
+ }
|
|
|
+ secondClassList, tmpErr := excel.GetExcelClassifyBySource(subSource)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ secondClassifyNameMap := make(map[int]string)
|
|
|
+ for _, v := range secondClassList {
|
|
|
+ firstName := firstClassifyNameMap[v.ParentId]
|
|
|
+ if firstName != `` {
|
|
|
+ firstName = firstName + " / "
|
|
|
+ }
|
|
|
+ secondClassifyNameMap[v.ExcelClassifyId] = firstName + v.ExcelClassifyName
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range tmpList {
|
|
|
+ list = append(list, data_manage.MoveEdbChartList{
|
|
|
+ DataId: strconv.Itoa(v.ExcelInfoId),
|
|
|
+ Name: v.ExcelClassifyName,
|
|
|
+ ClassifyName: secondClassifyNameMap[v.ExcelClassifyId],
|
|
|
+ CreateUserId: v.SysUserId,
|
|
|
+ CreateUserName: v.SysUserRealName,
|
|
|
+ })
|
|
|
+ }
|
|
|
default:
|
|
|
return
|
|
|
}
|
|
@@ -1913,8 +1973,8 @@ func GetMoveEdbChartList(source, userId int, keyword, classify string, startSize
|
|
|
}
|
|
|
|
|
|
// MoveEdbChart 转移指标/图表创建人
|
|
|
-// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库
|
|
|
-func MoveEdbChart(source, oldUserId, newUserId int, isSelectAll bool, dataId []string, keyword, classify string) (err error, errMsg string) {
|
|
|
+// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库 6:ETA表格
|
|
|
+func MoveEdbChart(source, subSource, oldUserId, newUserId int, isSelectAll bool, dataId []string, keyword, classify string) (err error, errMsg string) {
|
|
|
adminInfo, err := system.GetSysAdminById(newUserId)
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -1931,7 +1991,7 @@ func MoveEdbChart(source, oldUserId, newUserId int, isSelectAll bool, dataId []s
|
|
|
// 需要转义的指标/图表ID列表
|
|
|
dataId = make([]string, 0)
|
|
|
// 获取所有指标/图表
|
|
|
- list, _, tmpErr := GetMoveEdbChartList(source, oldUserId, keyword, classify, 0, 100000)
|
|
|
+ list, _, tmpErr := GetMoveEdbChartList(source, subSource, oldUserId, keyword, classify, 0, 100000)
|
|
|
if tmpErr != nil {
|
|
|
err = tmpErr
|
|
|
return
|
|
@@ -2023,6 +2083,23 @@ func MoveEdbChart(source, oldUserId, newUserId int, isSelectAll bool, dataId []s
|
|
|
// 修改创建人
|
|
|
err = data_manage.ModifyChartInfoUserIdByCodeList(dataId, adminInfo.AdminId, adminInfo.RealName)
|
|
|
}
|
|
|
+ case 6: // ETA表格
|
|
|
+ tmpList, tmpErr := excel.GetNoContentExcelListGroupByUserId(dataId)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(tmpList) > 0 {
|
|
|
+ for _, v := range tmpList {
|
|
|
+ if v.SysUserId == newUserId {
|
|
|
+ errMsg = "新创建人不可和原创建人一致"
|
|
|
+ err = errors.New(errMsg)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 修改创建人
|
|
|
+ err = excel.ModifyExcelInfoUserIdByCodeList(dataId, adminInfo.AdminId, adminInfo.RealName)
|
|
|
+ }
|
|
|
default:
|
|
|
return
|
|
|
}
|
|
@@ -2834,7 +2911,7 @@ func getEdbRuleTitle(edbInfo, parentEdbInfo *data_manage.EdbInfo, childList []da
|
|
|
}
|
|
|
|
|
|
// GetEdbChartAdminList
|
|
|
-// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库
|
|
|
+// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库 6:ETA表格
|
|
|
func GetEdbChartAdminList(source int) (list []int, err error) {
|
|
|
switch source {
|
|
|
case 1: //手工数据指标
|
|
@@ -3282,49 +3359,179 @@ func EdbInfoSmmApiAdd(item *data_manage.EdbInfo) (edbInfo *data_manage.EdbInfo,
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// MoveAllEdbChart 通过原创建人转移指标/图表创建人
|
|
|
-// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库
|
|
|
-func MoveAllEdbChart(source, oldUserId, userId int) (err error, errMsg string) {
|
|
|
+// MoveAllEdbChart
|
|
|
+// @Description: 通过原创建人转移指标/图表创建人
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-03-26 15:11:12
|
|
|
+// @param sourceList []int 1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库 6:ETA表格
|
|
|
+// @param oldUserId []int
|
|
|
+// @param userId int
|
|
|
+// @return err error
|
|
|
+// @return errMsg string
|
|
|
+func MoveAllEdbChart(sourceList, oldUserIdList []int, userId int) (err error, errMsg string) {
|
|
|
adminInfo, err := system.GetSysAdminById(userId)
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- switch source {
|
|
|
- case 1: //手工数据指标
|
|
|
- // 修改创建人
|
|
|
- err = models.ModifyEdbinfoUserIdByOldUserId(oldUserId, userId)
|
|
|
+ for _, source := range sourceList {
|
|
|
+ switch source {
|
|
|
+ case 1: //手工数据指标
|
|
|
+ // 修改创建人
|
|
|
+ err = models.ModifyEdbinfoUserIdByOldUserId(oldUserIdList, userId)
|
|
|
+ case 2: //钢联化工数据库
|
|
|
+ // 修改创建人
|
|
|
+ err = data_manage.ModifyMysteelChemicalIndexUserIdByOldUserId(oldUserIdList, adminInfo.AdminId, adminInfo.RealName)
|
|
|
+ case 3: //ETA指标库
|
|
|
+ // 修改创建人
|
|
|
+ err = data_manage.ModifyEdbInfoUserIdByOldUserId(oldUserIdList, 0, adminInfo.AdminId, adminInfo.RealName)
|
|
|
+ case 4: //ETA预测指标
|
|
|
+ // 修改创建人
|
|
|
+ err = data_manage.ModifyEdbInfoUserIdByOldUserId(oldUserIdList, 1, adminInfo.AdminId, adminInfo.RealName)
|
|
|
+ case 5: //图库
|
|
|
+ // 修改创建人
|
|
|
+ err = data_manage.ModifyChartInfoUserIdByOldUserId(oldUserIdList, adminInfo.AdminId, adminInfo.RealName)
|
|
|
+ case 6: // ETA表格
|
|
|
+ // 修改创建人
|
|
|
+ err = excel.ModifyExcelInfoUserIdByOldUserId(oldUserIdList, adminInfo.AdminId, adminInfo.RealName)
|
|
|
+ default:
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- case 2: //钢联化工数据库
|
|
|
- // 修改创建人
|
|
|
- err = data_manage.ModifyMysteelChemicalIndexUserIdByOldUserId(oldUserId, adminInfo.AdminId, adminInfo.RealName)
|
|
|
- case 3: //ETA指标库
|
|
|
- // 修改创建人
|
|
|
- err = data_manage.ModifyEdbInfoUserIdByOldUserId(oldUserId, 0, adminInfo.AdminId, adminInfo.RealName)
|
|
|
- // 移除当前用户的不可操作权限
|
|
|
- //{
|
|
|
- // obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
- // for _, v := range dataId {
|
|
|
- // edbInfoId, _ := strconv.Atoi(v)
|
|
|
- // go obj.DeleteByEdbInfoIdAndAdminId(edbInfoId, adminInfo.AdminId)
|
|
|
- // }
|
|
|
- //}
|
|
|
- case 4: //ETA预测指标
|
|
|
- // 修改创建人
|
|
|
- err = data_manage.ModifyEdbInfoUserIdByOldUserId(oldUserId, 1, adminInfo.AdminId, adminInfo.RealName)
|
|
|
- // 移除当前用户的不可操作权限
|
|
|
- //{
|
|
|
- // obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
|
- // for _, v := range dataId {
|
|
|
- // edbInfoId, _ := strconv.Atoi(v)
|
|
|
- // go obj.DeleteByEdbInfoIdAndAdminId(edbInfoId, adminInfo.AdminId)
|
|
|
- // }
|
|
|
- //}
|
|
|
- case 5: //图库
|
|
|
- // 修改创建人
|
|
|
- err = data_manage.ModifyChartInfoUserIdByOldUserId(oldUserId, adminInfo.AdminId, adminInfo.RealName)
|
|
|
- default:
|
|
|
- return
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// GetMoveEdbChartCount 获取待转移的指标/图表列表
|
|
|
+// @param source 来源 :1:手工数据指标 2:钢联化工数据库 3:ETA指标库 4:ETA预测指标 5:图库 6:ETA表格
|
|
|
+func GetMoveEdbChartCount(userId int) (sourceMap map[int]int, err error) {
|
|
|
+ sourceMap = make(map[int]int)
|
|
|
+ {
|
|
|
+ // 手工数据指标
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND a.user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+
|
|
|
+ total, tmpErr := models.GetEdbinfoListCount(condition, pars, "", 0)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ sourceMap[1] = total
|
|
|
+ }
|
|
|
+
|
|
|
+ {
|
|
|
+ // 钢联化工数据库
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND sys_user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+
|
|
|
+ total, tmpErr := data_manage.GetMysteelChemicalIndexCount(condition, pars)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ sourceMap[2] = total
|
|
|
+ }
|
|
|
+
|
|
|
+ {
|
|
|
+ // 钢联化工数据库
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND sys_user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+
|
|
|
+ total, tmpErr := data_manage.GetMysteelChemicalIndexCount(condition, pars)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ sourceMap[2] = total
|
|
|
+ }
|
|
|
+
|
|
|
+ {
|
|
|
+ // ETA指标库
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND sys_user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+ //ETA指标库
|
|
|
+ condition += ` AND edb_info_type = ? `
|
|
|
+ pars = append(pars, 0)
|
|
|
+
|
|
|
+ total, tmpErr := data_manage.GetEdbInfoByConditionCount(condition, pars)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ sourceMap[3] = total
|
|
|
+ }
|
|
|
+
|
|
|
+ {
|
|
|
+ // ETA预测指标库
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND sys_user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+
|
|
|
+ //ETA预测指标
|
|
|
+ condition += ` AND edb_info_type = ? `
|
|
|
+ pars = append(pars, 1)
|
|
|
+
|
|
|
+ total, tmpErr := data_manage.GetEdbInfoByConditionCount(condition, pars)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ sourceMap[4] = total
|
|
|
+ }
|
|
|
+
|
|
|
+ {
|
|
|
+ // 图库
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND sys_user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+
|
|
|
+ total, tmpErr := data_manage.GetChartInfoCountByCondition(condition, pars)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ sourceMap[5] = total
|
|
|
+ }
|
|
|
+
|
|
|
+ {
|
|
|
+ // ETA表格
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+
|
|
|
+ if userId > 0 {
|
|
|
+ condition += ` AND sys_user_id = ? `
|
|
|
+ pars = append(pars, userId)
|
|
|
+ }
|
|
|
+
|
|
|
+ total, tmpErr := excel.GetExcelInfoCountByCondition(condition, pars)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ sourceMap[6] = total
|
|
|
}
|
|
|
|
|
|
return
|