Roc 11 місяців тому
батько
коміт
0bd09c48ae
2 змінених файлів з 8 додано та 2 видалено
  1. 7 1
      services/eta_bridge/handle_data.go
  2. 1 1
      services/eta_bridge/xiangyu.go

+ 7 - 1
services/eta_bridge/handle_data.go

@@ -68,8 +68,9 @@ type OrigInfo struct {
 // @param source int
 // @param subSource int
 // @param edbCode string
+// @param edbName string
 // @return origInfo OrigInfo
-func getOrigInfo(source, subSource int, edbCode string) (origInfo OrigInfo) {
+func getOrigInfo(source, subSource int, edbCode, edbName string) (origInfo OrigInfo) {
 	switch source {
 	case utils.DATA_SOURCE_THS, utils.DATA_SOURCE_WIND: // 同花顺、wind
 		origInfo.SourceName = "经济数据库"
@@ -93,6 +94,11 @@ func getOrigInfo(source, subSource int, edbCode string) (origInfo OrigInfo) {
 		origInfo.SourceName = edbInfo.Interface
 	}
 
+	// 如果原始名称为空,则使用ETA指标库的名称作为原始名称
+	if origInfo.EdbName == `` {
+		origInfo.EdbName = edbName
+	}
+
 	return
 }
 

+ 1 - 1
services/eta_bridge/xiangyu.go

@@ -269,7 +269,7 @@ func SyncIndexList(num int) (err error) {
 	pushEdbClassifyItemReqList := make([]*PushEdbClassifyItemReq, 0)
 	for k, edbInfo := range list {
 		// 获取数据源中指标的基础信息
-		origInfo := getOrigInfo(edbInfo.Source, edbInfo.SubSource, edbInfo.EdbCode)
+		origInfo := getOrigInfo(edbInfo.Source, edbInfo.SubSource, edbInfo.EdbCode, edbInfo.EdbName)
 		// 指标信息
 		pushIndexData := &PushIndexParamDataReq{
 			SourceIndexCode: edbInfo.EdbCode,