添加计算指标的间接引用记录

services/edb_relation.go

@@ -124,7 +124,11 @@ func InitChartEdbRelation() {
 				if !ok2 {
 					continue
 				}
-				//todo 引用时间
+				// 去掉预测指标
+				if edbInfo.EdbInfoType == 1 {
+					continue
+				}
+
 				tmp := &data_manage.EdbInfoRelation{
 					ReferObjectId:      v.ChartInfoId,
 					ReferObjectType:    utils.EDB_RELATION_CHART,
@@ -152,7 +156,7 @@ func InitChartEdbRelation() {
 							continue
 						}
 						name1 := fmt.Sprintf("%d-%d", v.ChartInfoId, childEdbMapping.FromEdbInfoId)
-						if _, ok2 := existRelationMap[name1]; !ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
+						if _, ok2 := existRelationMap[name1]; ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
 							continue
 						}
 						tmp1 := &data_manage.EdbInfoRelation{
@@ -358,7 +362,10 @@ func InitChartCrossVariety() {
 					if !ok2 {
 						continue
 					}
-					//todo 引用时间
+					// 去掉预测指标
+					if edbInfo.EdbInfoType == 1 {
+						continue
+					}
 					tmp := &data_manage.EdbInfoRelation{
 						ReferObjectId:      item.ChartInfoId,
 						ReferObjectType:    utils.EDB_RELATION_CHART,
@@ -386,7 +393,7 @@ func InitChartCrossVariety() {
 								continue
 							}
 							name1 := fmt.Sprintf("%d-%d", item.ChartInfoId, childEdbMapping.FromEdbInfoId)
-							if _, ok2 := existRelationMap[name1]; !ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
+							if _, ok2 := existRelationMap[name1]; ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
 								continue
 							}
 
@@ -531,6 +538,10 @@ func InitCalendarIndicatorRelation() {
 			existRelationMap[name] = struct{}{}
 		}
 		for edbInfoId, edbInfo := range edbInfoMap {
+			// 去掉预测指标
+			if edbInfo.EdbInfoType == 1 {
+				continue
+			}
 			nowTime := time.Now()
 			items, ok := edbInfoMatterMap[edbInfoId]
 			if ok {
@@ -564,7 +575,7 @@ func InitCalendarIndicatorRelation() {
 									continue
 								}
 								name1 := fmt.Sprintf("%d-%d", v.FeCalendarMatterId, childEdbMapping.FromEdbInfoId)
-								if _, ok2 := existRelationMap[name1]; !ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
+								if _, ok2 := existRelationMap[name1]; ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
 									continue
 								}
 								tmp1 := &data_manage.EdbInfoRelation{
@@ -704,7 +715,10 @@ func InitExcelEdbRelation() {
 				if !ok2 {
 					continue
 				}
-				//todo 引用时间
+				// 去掉预测指标
+				if edbInfo.EdbInfoType == 1 {
+					continue
+				}
 				tmp := &data_manage.EdbInfoRelation{
 					ReferObjectId:      v.ExcelInfoId,
 					ReferObjectType:    utils.EDB_RELATION_TABLE,
@@ -732,7 +746,7 @@ func InitExcelEdbRelation() {
 							continue
 						}
 						name1 := fmt.Sprintf("%d-%d", v.ExcelInfoId, childEdbMapping.FromEdbInfoId)
-						if _, ok2 := existRelationMap[name1]; !ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
+						if _, ok2 := existRelationMap[name1]; ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
 							continue
 						}
 						tmp1 := &data_manage.EdbInfoRelation{
@@ -886,7 +900,10 @@ func InitSandBoxEdbRelation() {
 					if !ok2 {
 						continue
 					}
-					//todo 引用时间
+					// 去掉预测指标
+					if edbInfo.EdbInfoType == 1 {
+						continue
+					}
 					tmp := &data_manage.EdbInfoRelation{
 						ReferObjectId:   v.SandboxId,
 						ReferObjectType: utils.EDB_RELATION_SANDBOX,
@@ -913,7 +930,7 @@ func InitSandBoxEdbRelation() {
 								continue
 							}
 							name1 := fmt.Sprintf("%d-%d", v.SandboxId, childEdbMapping.FromEdbInfoId)
-							if _, ok2 := existRelationMap[name1]; !ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
+							if _, ok2 := existRelationMap[name1]; ok2 { //如果已经被直接引用了，则无需添加到间接引用记录中
 								continue
 							}
 							tmp1 := &data_manage.EdbInfoRelation{