indexCode获取方式修改

services/commodity_trade_cffex.go

@@ -50,6 +50,13 @@ func cffexIndexCodeGenerator(shortName, indexName, suffix string) string {
 
 // SyncRankingFromCffex 中国金融期货交易所
 func SyncRankingFromCffex() {
+	allCode, err := models.GetIndexCodeFromMapping("CFFEX")
+	if err != nil {
+		fmt.Println("select Code err:", err)
+	}
+	for _, item := range allCode {
+		cffexIndexCodeMap[item.IndexName] = item.IndexCode
+	}
 	for i := 2; i > 0; i-- {
 		zzUrl := "http://www.cffex.com.cn/sj/ccpm/%s/%s/"
 		date := time.Now().AddDate(0, 0, -i)
@@ -82,9 +89,6 @@ func SyncRankingFromCffex() {
 			existDealMap[v.DealName] = v.BaseFromTradeCffexIndexId
 			existBuyMap[v.BuyName] = v.BaseFromTradeCffexIndexId
 			existSoldMap[v.SoldName] = v.BaseFromTradeCffexIndexId
-			cffexIndexCodeMap[v.DealName] = v.DealCode
-			cffexIndexCodeMap[v.BuyName] = v.BuyCode
-			cffexIndexCodeMap[v.SoldName] = v.SoldCode
 			sRank = fmt.Sprintf("%d", v.Rank)
 			time := strings.Replace(v.DataTime, "-", "", -1)
 			cffexActionCodeMap[sRank+v.ClassifyType+time] = map[string]int{"0": v.DealValue, "1": v.BuyValue, "2": v.SoldValue, "id": v.BaseFromTradeCffexIndexId}

services/commodity_trade_ine.go

@@ -95,9 +95,6 @@ func SyncRankingFromIne() {
 		for _, v := range allIndex {
 			indexKey := v.DealName + v.BuyName + v.SoldName
 			existIndexMap[indexKey] = v
-			ineIndexCodeMap[v.BuyName] = v.BuyCode
-			ineIndexCodeMap[v.SoldName] = v.SoldCode
-			ineIndexCodeMap[v.DealName] = v.DealCode
 		}
 		var itemVerifyCode int
 		//处理指标

services/commodity_trade_shanghai.go

@@ -62,6 +62,13 @@ func shIndexCodeGenerator(shortName, indexName,suffix string) string {
 
 // SyncRankingFromShangHai 上海商品交易所持单排名
 func SyncRankingFromShangHai() {
+	allCode, err := models.GetIndexCodeFromMapping("Z")
+	if err != nil {
+		fmt.Println("select Code err:", err)
+	}
+	for _, item := range allCode {
+		indexCodeMap[item.IndexName] = item.IndexCode
+	}
 	//获取新的指标信息
 	for i := 2; i > 0; i-- {
 		var message Message

services/commodity_trade_zhengzhou.go

@@ -43,7 +43,13 @@ func SyncRankingFromZhengzhou() {
 			fmt.Println("Err:" + err.Error())
 		}
 	}()
-
+	allCode, err := models.GetIndexCodeFromMapping("Z")
+	if err != nil {
+		fmt.Println("select Code err:", err)
+	}
+	for _, item := range allCode {
+		zIndexCodeMap[item.IndexName] = item.IndexCode
+	}
 	for i := 2; i > 0; i-- {
 		var itemVerifyCode int
 		zzUrl := "http://www.czce.com.cn/cn/DFSStaticFiles/Future/%s/%s/FutureDataHolding.htm"
@@ -67,9 +73,6 @@ func SyncRankingFromZhengzhou() {
 		for _, v := range allIndex {
 			indexKey := v.DealName + v.BuyName + v.SoldName
 			existIndexMap[indexKey] = v
-			zIndexCodeMap[v.DealName] = v.DealCode
-			zIndexCodeMap[v.BuyName] = v.BuyCode
-			zIndexCodeMap[v.SoldName] = v.SoldCode
 		}
 		bodyStr := string(body)
 		utils.FileLog.Info(bodyStr)