初始化逻辑图中的引用配置

services/edb_refresh.go

@@ -609,7 +609,11 @@ func DisableEdbRefresh() (err error) {
 	obj := new(models.BusinessConf)
 	conf, err := obj.GetItemByConfKey("EdbStopRefreshRule")
 	if err != nil {
-		return err
+		if err.Error() == utils.ErrNoRow() {
+			err = fmt.Errorf("未找到配置项，无需处理")
+			return
+		}
+		return
 	}
 	//将json转为结构体
 	rule := new(models.EdbStopRefreshRule)
@@ -671,7 +675,7 @@ func DisableEdbRefresh() (err error) {
 				if _, ok := edbMap[indexItem.IndexCode]; !ok {
 					stopRefreshIds = append(stopRefreshIds, indexItem.BaseFromMysteelChemicalIndexId)
 					if len(stopRefreshIds) > 100 {
-						//	err = data_manage.SetStopRefreshMysteelChemicalIndex(stopRefreshIds)
+						err = data_manage.SetStopRefreshMysteelChemicalIndex(stopRefreshIds)
 						if err != nil {
 							err = fmt.Errorf("设置禁止刷新失败：%v", err)
 							return
@@ -683,7 +687,7 @@ func DisableEdbRefresh() (err error) {
 		}
 		// 未被创建，则设置禁止刷新
 		if len(stopRefreshIds) > 0 {
-			//err = data_manage.SetStopRefreshMysteelChemicalIndex(stopRefreshIds)
+			err = data_manage.SetStopRefreshMysteelChemicalIndex(stopRefreshIds)
 			if err != nil {
 				err = fmt.Errorf("设置禁止刷新失败：%v", err)
 				return
@@ -742,12 +746,12 @@ func DisableEdbRefresh() (err error) {
 					}
 					// 更新指标禁止刷新状态
 					if len(stopRefreshIds) > 100 {
-						_, tmpErr := data_manage.GetAllCalculateEdbIdsByEdbInfoIds(stopRefreshIds)
+						calculateEdbIds, tmpErr := data_manage.GetAllCalculateEdbIdsByEdbInfoIds(stopRefreshIds)
 						if tmpErr != nil {
 							err = fmt.Errorf("查询计算指标信息失败：%v", tmpErr)
 							return
 						}
-						//err = data_manage.ModifyEdbUpdateStatus(stopRefreshIds, stopRefreshMysteelCode, calculateEdbIds)
+						err = data_manage.ModifyEdbUpdateStatus(stopRefreshIds, stopRefreshMysteelCode, calculateEdbIds)
 						if err != nil {
 							err = fmt.Errorf("更新指标禁止刷新状态失败：%v", err)
 							return
@@ -761,12 +765,12 @@ func DisableEdbRefresh() (err error) {
 
 		// 更新指标禁止刷新状态
 		if len(stopRefreshIds) > 0 {
-			_, tmpErr := data_manage.GetAllCalculateEdbIdsByEdbInfoIds(stopRefreshIds)
+			calculateEdbIds, tmpErr := data_manage.GetAllCalculateEdbIdsByEdbInfoIds(stopRefreshIds)
 			if tmpErr != nil {
 				err = fmt.Errorf("查询计算指标信息失败：%v", tmpErr)
 				return
 			}
-			//	err = data_manage.ModifyEdbUpdateStatus(stopRefreshIds, stopRefreshMysteelCode, calculateEdbIds)
+			err = data_manage.ModifyEdbUpdateStatus(stopRefreshIds, stopRefreshMysteelCode, calculateEdbIds)
 			if err != nil {
 				err = fmt.Errorf("更新指标禁止刷新状态失败：%v", err)
 				return

services/edb_relation.go

@@ -21,6 +21,7 @@ func InitEdbRelation() {
 func InitChartEdbRelation() {
 	fmt.Println("开始处理图表中的指标引用")
 	var err error
+	var addNum int
 	defer func() {
 		if err != nil {
 			msg := fmt.Sprintf("初始化指标在图表中的引用失败 InitChartEdbRelation  err: %v", err)
@@ -141,6 +142,7 @@ func InitChartEdbRelation() {
 						err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 						return
 					}
+					addNum += len(addList)
 					addList = make([]*data_manage.EdbInfoRelation, 0)
 				}
 			}
@@ -153,14 +155,16 @@ func InitChartEdbRelation() {
 			err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 			return
 		}
+		addNum += len(addList)
 	}
-	fmt.Println("图表引用记录处理完成")
+	fmt.Printf("图表指标引用记录处理完成, 新增%d条记录\n", addNum)
 	return
 }
 
 // InitChartCrossVariety 处理特殊图表，跨品种分析图表
 func InitChartCrossVariety() {
 	fmt.Println("开始跨品种分析图表中的指标引用")
+	var addNum int
 	var err error
 	defer func() {
 		if err != nil {
@@ -328,6 +332,7 @@ func InitChartCrossVariety() {
 							err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 							return
 						}
+						addNum += len(addList)
 						addList = make([]*data_manage.EdbInfoRelation, 0)
 					}
 				}
@@ -341,14 +346,16 @@ func InitChartCrossVariety() {
 			err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 			return
 		}
+		addNum += len(addList)
 	}
-	fmt.Println("跨品种分析图表引用记录处理完成")
+	fmt.Printf("跨品种分析图表指标引用记录处理完成, 新增%d条记录\n", addNum)
 	return
 }
 
 // 初始化事件日历中的指标引用
 func initCalendarIndicatorRelation() {
 	fmt.Println("开始处理事件日历中的指标引用")
+	var addNum int
 	var err error
 	defer func() {
 		if err != nil {
@@ -458,6 +465,7 @@ func initCalendarIndicatorRelation() {
 								err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 								return
 							}
+							addNum += len(addList)
 							addList = make([]*data_manage.EdbInfoRelation, 0)
 						}
 					}
@@ -473,8 +481,9 @@ func initCalendarIndicatorRelation() {
 			err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 			return
 		}
+		addNum += len(addList)
 	}
-	fmt.Println("事件日历指标引用记录处理完成")
+	fmt.Printf("事件日历指标引用记录处理完成, 新增%d条记录\n", addNum)
 	return
 }
 
@@ -482,6 +491,7 @@ func initCalendarIndicatorRelation() {
 func initSandBoxEdbRelation() {
 	fmt.Println("开始处理逻辑图中的指标引用")
 	var err error
+	var addNum int
 	defer func() {
 		if err != nil {
 			msg := fmt.Sprintf("初始化指标在逻辑图中的引用失败 initSandBoxEdbRelation  err: %v", err)
@@ -518,16 +528,23 @@ func initSandBoxEdbRelation() {
 		edbInfoIds := make([]int, 0)
 		edbSandboxMap := make(map[int][]*sandbox.Sandbox)
 		for _, v := range list {
+			if v.Content == "" {
+				continue
+			}
 			edbInfoIdsTmp, e := getSandBoxEdbIdsByContent(v.Content)
 			if e != nil {
-				err = fmt.Errorf("查询逻辑图关联的指标Id失败 Err:%s", e)
-				return
+				continue
+				//err = fmt.Errorf("查询逻辑图关联的指标Id失败 Err:%s", e)
+				//return
 			}
 			for _, edbId := range edbInfoIdsTmp {
 				edbInfoIds = append(edbInfoIds, edbId)
 				edbSandboxMap[edbId] = append(edbSandboxMap[edbId], v)
 			}
 		}
+		if len(edbInfoIds) <= 0 {
+			continue
+		}
 		// 查询指标信息表
 		edbInfoList, e := data_manage.GetEdbInfoByIdListAndSource(edbInfoIds, []int{utils.DATA_SOURCE_WIND, utils.DATA_SOURCE_MYSTEEL_CHEMICAL})
 		if e != nil {
@@ -588,6 +605,7 @@ func initSandBoxEdbRelation() {
 							err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 							return
 						}
+						addNum += len(addList)
 						addList = make([]*data_manage.EdbInfoRelation, 0)
 					}
 				}
@@ -601,8 +619,9 @@ func initSandBoxEdbRelation() {
 			err = fmt.Errorf("新增引用记录失败 Err:%s", err)
 			return
 		}
+		addNum += len(addList)
 	}
-	fmt.Println("逻辑图指标引用记录处理完成")
+	fmt.Printf("逻辑图指标引用记录处理完成, 新增%d条记录\n", addNum)
 	return
 }