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

services/data/base_edb_lib.go

@@ -202,83 +202,87 @@ func RefreshEdbData(edbInfoId, source, subSource int, edbCode, startDate string)
 	param["StartDate"] = startDate
 	param["Source"] = source
 	urlStr := ``
-	switch source {
-	case utils.DATA_SOURCE_THS:
-		switch subSource {
-		case utils.DATA_SUB_SOURCE_DATE:
-			urlStr = "ths/ds/refresh"
-		case utils.DATA_SUB_SOURCE_HIGH_FREQUENCY:
-			urlStr = "ths/hf/edb/refresh"
-		default:
-			urlStr = "ths/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_STOCK_PLANT:
-		urlStr = "stock_plant/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"
-	case utils.DATA_SOURCE_ICPI:
-		urlStr = "icpi/refresh"
-	case utils.DATA_SOURCE_SCI99:
-		urlStr = "sci99/refresh"
-	case utils.DATA_SOURCE_SCI_HQ:
-		urlStr = "sci_hq/refresh"
-	default:
-		edbSource := data_manage.EdbSourceIdMap[source]
-		if edbSource != nil {
-			urlStr = edbSource.EdbRefreshMethod
-		}
+	//switch source {
+	//case utils.DATA_SOURCE_THS:
+	//	switch subSource {
+	//	case utils.DATA_SUB_SOURCE_DATE:
+	//		urlStr = "ths/ds/refresh"
+	//	case utils.DATA_SUB_SOURCE_HIGH_FREQUENCY:
+	//		urlStr = "ths/hf/edb/refresh"
+	//	default:
+	//		urlStr = "ths/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_STOCK_PLANT:
+	//	urlStr = "stock_plant/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"
+	//case utils.DATA_SOURCE_ICPI:
+	//	urlStr = "icpi/refresh"
+	//case utils.DATA_SOURCE_SCI99:
+	//	urlStr = "sci99/refresh"
+	//case utils.DATA_SOURCE_SCI_HQ:
+	//	urlStr = "sci_hq/refresh"
+	//default:
+	//	edbSource := data_manage.EdbSourceIdMap[source]
+	//	if edbSource != nil {
+	//		urlStr = edbSource.EdbRefreshMethod
+	//	}
+	//}
+	edbSource := data_manage.EdbSourceIdMap[source]
+	if edbSource != nil {
+		urlStr = edbSource.EdbRefreshMethod
 	}
 	if urlStr == "" {
 		err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口，请联系管理员"))