indexCodeMap内存优化

services/commodity_trade_ine.go

@@ -47,7 +47,7 @@ func SyncRankingFromIne() {
 	}
 	existIndexMap := make(map[string]*models.BaseFromTradeIneIndex)
 	addIndexMap := make(map[string]string)
-	indexCodeMap := make(map[string]string)
+	indexCodeMap := make(map[string]struct{})
 	for _, v := range allIndex {
 		indexKey := v.IndexName
 		existIndexMap[indexKey] = v
@@ -82,7 +82,7 @@ func SyncRankingFromIne() {
 			for {
 				indexCode = fmt.Sprintf("SHEE%s", time.Now().Format(utils.FormatDateTimeUnSpace)+strconv.Itoa(utils.GetRandInt(1, 100)))
 				if _, ok := indexCodeMap[indexCode]; !ok {
-					indexCodeMap[indexCode] = ""
+					indexCodeMap[indexCode] = struct{}{}
 					break
 				}
 			}
@@ -151,7 +151,7 @@ func SyncRankingFromIne() {
 			for {
 				indexCode = fmt.Sprintf("SHEE%s", time.Now().Format(utils.FormatDateTimeUnSpace)+strconv.Itoa(utils.GetRandInt(1, 100)))
 				if _, ok := indexCodeMap[indexCode]; !ok {
-					indexCodeMap[indexCode] = ""
+					indexCodeMap[indexCode] = struct{}{}
 					break
 				}
 			}
@@ -219,7 +219,7 @@ func SyncRankingFromIne() {
 			for {
 				indexCode = fmt.Sprintf("SHEE%s", time.Now().Format(utils.FormatDateTimeUnSpace)+strconv.Itoa(utils.GetRandInt(1, 100)))
 				if _, ok := indexCodeMap[indexCode]; !ok {
-					indexCodeMap[indexCode] = ""
+					indexCodeMap[indexCode] = struct{}{}
 					break
 				}
 			}

services/commodity_trade_shanghai.go

@@ -49,7 +49,7 @@ func SyncRankingFromShangHai() {
 	}
 	existIndexMap := make(map[string]*models.BaseFromTradeShanghaiIndex)
 	addIndexMap := make(map[string]string)
-	indexCodeMap := make(map[string]string)
+	indexCodeMap := make(map[string]struct{})
 
 	for _, v := range allIndex {
 		indexKey := v.IndexName
@@ -88,7 +88,7 @@ func SyncRankingFromShangHai() {
 				for {
 					indexCode = fmt.Sprintf("SH%s", time.Now().Format(utils.FormatDateTimeUnSpace)+strconv.Itoa(utils.GetRandInt(1, 100)))
 					if _, ok := indexCodeMap[indexCode]; !ok {
-						indexCodeMap[indexCode] = ""
+						indexCodeMap[indexCode] = struct{}{}
 						break
 					}
 				}
@@ -156,7 +156,7 @@ func SyncRankingFromShangHai() {
 				for {
 					indexCode = fmt.Sprintf("SH%s", time.Now().Format(utils.FormatDateTimeUnSpace)+strconv.Itoa(utils.GetRandInt(1, 100)))
 					if _, ok := indexCodeMap[indexCode]; !ok {
-						indexCodeMap[indexCode] = ""
+						indexCodeMap[indexCode] = struct{}{}
 						break
 					}
 				}
@@ -224,7 +224,7 @@ func SyncRankingFromShangHai() {
 				for {
 					indexCode = fmt.Sprintf("SH%s", time.Now().Format(utils.FormatDateTimeUnSpace)+strconv.Itoa(utils.GetRandInt(1, 100)))
 					if _, ok := indexCodeMap[indexCode]; !ok {
-						indexCodeMap[indexCode] = ""
+						indexCodeMap[indexCode] = struct{}{}
 						break
 					}
 				}