移除基础指标更新，只走gn

services/data/base_edb_lib.go

@@ -19,70 +19,71 @@ func RefreshEdbData(edbInfoId, source, subSource int, edbCode, startDate string)
 	param["StartDate"] = startDate
 	param["Source"] = source
 	urlStr := ``
-	switch source {
-	case utils.DATA_SOURCE_THS:
-		if subSource == 0 {
-			urlStr = "ths/refresh"
-		} else {
-			urlStr = "ths/ds/refresh"
-		}
-	case utils.DATA_SOURCE_WIND:
-		if subSource == 0 {
-			urlStr = "wind/refresh"
-		} else {
-			urlStr = "wind/wsd/refresh"
-		}
-	case utils.DATA_SOURCE_PB:
-		urlStr = "pb/refresh"
-	case utils.DATA_SOURCE_PB_FINANCE:
-		urlStr = "pb_finance/refresh"
-	case utils.DATA_SOURCE_MANUAL:
-		urlStr = "manual/refresh"
-	case utils.DATA_SOURCE_LZ:
-		urlStr = "lz/refresh"
-	case utils.DATA_SOURCE_YS:
-		urlStr = "smm/refresh"
-	case utils.DATA_SOURCE_GL:
-		urlStr = "mysteel/refresh"
-	case utils.DATA_SOURCE_ZZ:
-		urlStr = "zz/refresh"
-	case utils.DATA_SOURCE_DL:
-		urlStr = "dl/refresh"
-	case utils.DATA_SOURCE_SH:
-		urlStr = "sh/refresh"
-	case utils.DATA_SOURCE_CFFEX:
-		urlStr = "cffex/refresh"
-	case utils.DATA_SOURCE_SHFE:
-		urlStr = "shfe/refresh"
-	case utils.DATA_SOURCE_GIE:
-		urlStr = "gie/refresh"
-	case utils.DATA_SOURCE_LT:
-		urlStr = "lt/refresh"
-	case utils.DATA_SOURCE_COAL:
-		urlStr = "coal/refresh"
-	case utils.DATA_SOURCE_GOOGLE_TRAVEL:
-		urlStr = "google_travel/refresh"
-	case utils.DATA_SOURCE_MYSTEEL_CHEMICAL:
-		urlStr = "mysteel_chemical/refresh"
-	case utils.DATA_SOURCE_EIA_STEO:
-		urlStr = "eia_steo/refresh"
-	case utils.DATA_SOURCE_PREDICT:
-		urlStr = "predict/refresh"
-	case utils.DATA_SOURCE_COM_TRADE:
-		urlStr = "com_trade/refresh"
-	case utils.DATA_SOURCE_SCI:
-		urlStr = "sci/refresh"
-	case utils.DATA_SOURCE_BAIINFO:
-		urlStr = "baiinfo/refresh"
-	case utils.DATA_SOURCE_NATIONAL_STATISTICS:
-		urlStr = "national_statistics/refresh"
-	case utils.DATA_SOURCE_FUBAO:
-		urlStr = "fubao/refresh"
-	case utils.DATA_SOURCE_GFEX:
-		urlStr = "gz/refresh"
-	default:
-		urlStr = data_manage.GetEdbSourceRefreshMethodBySourceId(source) // 没有对应的从edb_source中取
-	}
+	//switch source {
+	//case utils.DATA_SOURCE_THS:
+	//	if subSource == 0 {
+	//		urlStr = "ths/refresh"
+	//	} else {
+	//		urlStr = "ths/ds/refresh"
+	//	}
+	//case utils.DATA_SOURCE_WIND:
+	//	if subSource == 0 {
+	//		urlStr = "wind/refresh"
+	//	} else {
+	//		urlStr = "wind/wsd/refresh"
+	//	}
+	//case utils.DATA_SOURCE_PB:
+	//	urlStr = "pb/refresh"
+	//case utils.DATA_SOURCE_PB_FINANCE:
+	//	urlStr = "pb_finance/refresh"
+	//case utils.DATA_SOURCE_MANUAL:
+	//	urlStr = "manual/refresh"
+	//case utils.DATA_SOURCE_LZ:
+	//	urlStr = "lz/refresh"
+	//case utils.DATA_SOURCE_YS:
+	//	urlStr = "smm/refresh"
+	//case utils.DATA_SOURCE_GL:
+	//	urlStr = "mysteel/refresh"
+	//case utils.DATA_SOURCE_ZZ:
+	//	urlStr = "zz/refresh"
+	//case utils.DATA_SOURCE_DL:
+	//	urlStr = "dl/refresh"
+	//case utils.DATA_SOURCE_SH:
+	//	urlStr = "sh/refresh"
+	//case utils.DATA_SOURCE_CFFEX:
+	//	urlStr = "cffex/refresh"
+	//case utils.DATA_SOURCE_SHFE:
+	//	urlStr = "shfe/refresh"
+	//case utils.DATA_SOURCE_GIE:
+	//	urlStr = "gie/refresh"
+	//case utils.DATA_SOURCE_LT:
+	//	urlStr = "lt/refresh"
+	//case utils.DATA_SOURCE_COAL:
+	//	urlStr = "coal/refresh"
+	//case utils.DATA_SOURCE_GOOGLE_TRAVEL:
+	//	urlStr = "google_travel/refresh"
+	//case utils.DATA_SOURCE_MYSTEEL_CHEMICAL:
+	//	urlStr = "mysteel_chemical/refresh"
+	//case utils.DATA_SOURCE_EIA_STEO:
+	//	urlStr = "eia_steo/refresh"
+	//case utils.DATA_SOURCE_PREDICT:
+	//	urlStr = "predict/refresh"
+	//case utils.DATA_SOURCE_COM_TRADE:
+	//	urlStr = "com_trade/refresh"
+	//case utils.DATA_SOURCE_SCI:
+	//	urlStr = "sci/refresh"
+	//case utils.DATA_SOURCE_BAIINFO:
+	//	urlStr = "baiinfo/refresh"
+	//case utils.DATA_SOURCE_NATIONAL_STATISTICS:
+	//	urlStr = "national_statistics/refresh"
+	//case utils.DATA_SOURCE_FUBAO:
+	//	urlStr = "fubao/refresh"
+	//case utils.DATA_SOURCE_GFEX:
+	//	urlStr = "gz/refresh"
+	//default:
+	//	urlStr = data_manage.GetEdbSourceRefreshMethodBySourceId(source) // 没有对应的从edb_source中取
+	//}
+	urlStr = data_manage.GetEdbSourceRefreshMethodBySourceId(source) // 没有对应的从edb_source中取
 	if urlStr == "" {
 		err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口，请联系管理员"))
 		return

services/eta_bridge/gn.go

@@ -79,6 +79,7 @@ func SyncGnIndex(cont context.Context) (err error) {
 	}
 	for _, v := range indexIds {
 		strId := strconv.Itoa(v)
+		fmt.Printf("正在同步IndexId: %s\n", strId)
 		err, errMsgList = syncGnIndexV2(1, 1, lastUpdateTimeStr, strId)
 		if err != nil {
 			errMsg := strings.Join(errMsgList, "\n")

static/gn_index_ids.json

@@ -0,0 +1 @@
+[]