浏览代码

fix:相关性计算

Roc 1 年之前
父节点
当前提交
6bef3fd970
共有 1 个文件被更改,包括 11 次插入6 次删除
  1. 11 6
      services/data/correlation/chart_info.go

+ 11 - 6
services/data/correlation/chart_info.go

@@ -281,16 +281,13 @@ func GetChartDataByEdbInfo(edbInfoMappingA, edbInfoMappingB *data_manage.ChartEd
 				return
 			}
 			changeDataList = tmpNewChangeDataList
-
-			// 基础指标不用变
 			baseDataList = aDataList
 			for _, v := range baseDataList {
 				baseDataMap[v.DataTime] = v.Value
 			}
-		}
 
-		// 如果B指标是高频,那么就需要对A指标进行升频
-		if frequencyIntMap[edbInfoMappingA.Frequency] > frequencyIntMap[edbInfoMappingB.Frequency] {
+		} else if frequencyIntMap[edbInfoMappingA.Frequency] > frequencyIntMap[edbInfoMappingB.Frequency] {
+			// 如果B指标是高频,那么就需要对A指标进行升频
 			tmpNewChangeDataList, e := HandleDataByLinearRegression(aDataList, baseDataMap)
 			if e != nil {
 				err = fmt.Errorf("获取变频指标插值法Map失败, Err: %s", e.Error())
@@ -298,7 +295,15 @@ func GetChartDataByEdbInfo(edbInfoMappingA, edbInfoMappingB *data_manage.ChartEd
 			}
 			baseDataList = tmpNewChangeDataList
 
-			// B指标不用变
+			changeDataList = bDataList
+			for _, v := range changeDataList {
+				changeDataMap[v.DataTime] = v.Value
+			}
+		} else {
+			baseDataList = aDataList
+			for _, v := range baseDataList {
+				baseDataMap[v.DataTime] = v.Value
+			}
 			changeDataList = bDataList
 			for _, v := range changeDataList {
 				changeDataMap[v.DataTime] = v.Value