fix:路透指标新增频度选择

controllers/data_manage/edb_info.go

@@ -52,6 +52,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 	edbCode = strings.Replace(edbCode, "\t", "", -1)
 	subSource, _ := this.GetInt("SubSource")
 	stockCode := this.GetString("StockCode")
+	frequency := this.GetString("Frequency")
 
 	if source <= 0 {
 		br.Msg = "无效的数据来源"
@@ -193,7 +194,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 					//	br.ErrMsg = "获取失败,Err:" + err.Error()
 					//	return
 					//}
-					respItem, err := data.AddEdbData(source, edbCode)
+					respItem, err := data.AddEdbData(source, edbCode, frequency)
 					if err != nil {
 						br.Msg = "获取失败"
 						br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -266,7 +267,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 					//	br.ErrMsg = "wind 获取失败,Err:" + err.Error()
 					//	return
 					//}
-					respItem, err := data.AddEdbData(source, edbCode)
+					respItem, err := data.AddEdbData(source, edbCode, frequency)
 					if err != nil {
 						br.Msg = "获取失败"
 						br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -345,7 +346,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	br.ErrMsg = "彭博数据获取失败,Err:" + err.Error()
 				//	return
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -386,7 +387,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	br.ErrMsg = "获取失败,Err:" + err.Error()
 				//	return
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -441,7 +442,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	br.ErrMsg = "获取隆众数据失败,Err:" + err.Error()
 				//	return
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -514,7 +515,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -568,7 +569,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	br.ErrMsg = "获取钢联数据失败,Err:" + err.Error()
 				//	return
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -635,7 +636,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -714,7 +715,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -793,7 +794,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -872,7 +873,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -951,7 +952,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1046,7 +1047,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.EndDate = maxDate
 				//}
 
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1149,7 +1150,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	br.ErrMsg = "lt 获取失败,Err:" + err.Error()
 				//	return
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1209,7 +1210,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1261,7 +1262,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 					searchItem.EndDate = item.MaxDate
 				}
 			} else {
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1301,7 +1302,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	br.ErrMsg = "获取钢联数据失败,Err:" + err.Error()
 				//	return
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1346,7 +1347,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				searchItem.StartDate = item.MinDate
 				searchItem.EndDate = item.MaxDate
 			} else {
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1391,7 +1392,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				searchItem.StartDate = item.MinDate
 				searchItem.EndDate = item.MaxDate
 			} else {
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1458,7 +1459,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1518,7 +1519,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				//	searchItem.StartDate = minDate
 				//	searchItem.EndDate = maxDate
 				//}
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1565,7 +1566,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				searchItem.StartDate = item.MinDate
 				searchItem.EndDate = item.MaxDate
 			} else {
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1612,7 +1613,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				searchItem.StartDate = minDate
 				searchItem.EndDate = maxDate
 			} else {
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败," + respItem.Msg
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1645,7 +1646,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				searchItem.StartDate = minDate
 				searchItem.EndDate = maxDate
 			} else {
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1692,7 +1693,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				searchItem.StartDate = minDate
 				searchItem.EndDate = maxDate
 			} else {
-				respItem, err := data.AddEdbData(source, edbCode)
+				respItem, err := data.AddEdbData(source, edbCode, frequency)
 				if err != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + err.Error()
@@ -1750,7 +1751,7 @@ func (this *EdbInfoController) EdbInfoSearch() {
 				}
 			} else {
 				// 新增指标数据
-				addRes, e := data.AddEdbData(source, edbCode)
+				addRes, e := data.AddEdbData(source, edbCode, frequency)
 				if e != nil {
 					br.Msg = "获取失败"
 					br.ErrMsg = "获取失败,Err:" + e.Error()
@@ -5810,7 +5811,7 @@ func (this *EdbInfoController) EdbInfoSmmSearch() {
 	}
 	if len(needAddCodeArr) > 0 {
 		edbCode = strings.Join(needAddCodeArr, ",")
-		respItem, err := data.AddEdbData(utils.DATA_SOURCE_YS, edbCode)
+		respItem, err := data.AddEdbData(utils.DATA_SOURCE_YS, edbCode, "")
 		if err != nil {
 			br.Msg = "获取失败"
 			br.ErrMsg = "获取失败,Err:" + err.Error()

services/data/base_edb_lib.go

@@ -13,10 +13,11 @@ import (
 )
 
 // AddEdbData 新增指标数据
-func AddEdbData(source int, edbCode string) (resp *models.BaseResponse, err error) {
+func AddEdbData(source int, edbCode, frequency string) (resp *models.BaseResponse, err error) {
 	param := make(map[string]interface{})
 	param["EdbCode"] = edbCode
 	param["Source"] = source
+	param["Frequency"] = frequency
 	urlStr := ``
 	switch source {
 	case utils.DATA_SOURCE_THS: