fix 结构体修改

services/commodity_trade_ine.go

@@ -91,7 +91,7 @@ func SyncRankingFromIne() {
 		ineIndexCodeMap[item.IndexName] = item.IndexCode
 	}
 	//获取新的指标信息
-	for i := 2; i >= 0; i-- {
+	for i := 10; i >= 0; i-- {
 		var message Message
 		var item = new(models.BaseFromTradeIneIndex)
 		zzUrl := "http://www.ine.com.cn/data/dailydata/kx/pm%s.dat"
@@ -143,23 +143,23 @@ func SyncRankingFromIne() {
 				item.ModifyTime = time.Now()
 				item.DataTime = tradeDate
 
-				if deal, ok := p.Deal.(int); ok{
-					item.DealValue = deal
+				if deal, ok := p.Deal.(float64); ok{
+					item.DealValue = int(deal)
 				}
-				if change1, ok := p.Change1.(int); ok{
-					item.DealChange = change1
+				if change1, ok := p.Change1.(float64); ok{
+					item.DealChange = int(change1)
 				}
-				if buyIn, ok := p.BuyIn.(int); ok{
-					item.BuyValue = buyIn
+				if buyIn, ok := p.BuyIn.(float64); ok{
+					item.BuyValue = int(buyIn)
 				}
-				if change2, ok := p.Change2.(int); ok{
-					item.BuyChange = change2
+				if change2, ok := p.Change2.(float64); ok{
+					item.BuyChange = int(change2)
 				}
-				if soldOut, ok := p.SoldOut.(int); ok{
-					item.SoldValue = soldOut
+				if soldOut, ok := p.SoldOut.(float64); ok{
+					item.SoldValue = int(soldOut)
 				}
-				if change3, ok := p.Change3.(int); ok{
-					item.SoldChange = change3
+				if change3, ok := p.Change3.(float64); ok{
+					item.SoldChange = int(change3)
 				}
 
 				itemVerifyCode = item.BuyValue + item.DealValue + item.SoldValue
@@ -195,23 +195,23 @@ func SyncRankingFromIne() {
 				item.ModifyTime = time.Now()
 				item.DataTime = tradeDate
 
-				if deal, ok := p.Deal.(int); ok{
-					item.DealValue = deal
+				if deal, ok := p.Deal.(float64); ok{
+					item.DealValue = int(deal)
 				}
-				if change1, ok := p.Change1.(int); ok{
-					item.DealChange = change1
+				if change1, ok := p.Change1.(float64); ok{
+					item.DealChange = int(change1)
 				}
-				if buyIn, ok := p.BuyIn.(int); ok{
-					item.BuyValue = buyIn
+				if buyIn, ok := p.BuyIn.(float64); ok{
+					item.BuyValue = int(buyIn)
 				}
-				if change2, ok := p.Change2.(int); ok{
-					item.BuyChange = change2
+				if change2, ok := p.Change2.(float64); ok{
+					item.BuyChange = int(change2)
 				}
-				if soldOut, ok := p.SoldOut.(int); ok{
-					item.SoldValue = soldOut
+				if soldOut, ok := p.SoldOut.(float64); ok{
+					item.SoldValue = int(soldOut)
 				}
-				if change3, ok := p.Change3.(int); ok{
-					item.SoldChange = change3
+				if change3, ok := p.Change3.(float64); ok{
+					item.SoldChange = int(change3)
 				}
 
 				itemVerifyCode = item.BuyValue + item.DealValue + item.SoldValue

services/commodity_trade_shanghai.go

@@ -93,7 +93,7 @@ func SyncRankingFromShangHai() {
 		indexCodeMap[item.IndexName] = item.IndexCode
 	}
 	//获取新的指标信息
-	for i := 3; i >= 0; i-- {
+	for i := 10; i >= 0; i-- {
 		var message Message
 		zzUrl := "http://www.shfe.com.cn/data/dailydata/kx/pm%s.dat"
 		date := time.Now().AddDate(0, 0, -i)
@@ -151,23 +151,23 @@ func SyncRankingFromShangHai() {
 					item.ModifyTime = time.Now()
 					item.DataTime = tradeDate
 
-					if deal, ok := p.Deal.(int); ok{
-						item.DealValue = deal
+					if deal, ok := p.Deal.(float64); ok{
+						item.DealValue = int(deal)
 					}
-					if change1, ok := p.Change1.(int); ok{
-						item.DealChange = change1
+					if change1, ok := p.Change1.(float64); ok{
+						item.DealChange = int(change1)
 					}
-					if buyIn, ok := p.BuyIn.(int); ok{
-						item.BuyValue = buyIn
+					if buyIn, ok := p.BuyIn.(float64); ok{
+						item.BuyValue = int(buyIn)
 					}
-					if change2, ok := p.Change2.(int); ok{
-						item.BuyChange = change2
+					if change2, ok := p.Change2.(float64); ok{
+						item.BuyChange = int(change2)
 					}
-					if soldOut, ok := p.SoldOut.(int); ok{
-						item.SoldValue = soldOut
+					if soldOut, ok := p.SoldOut.(float64); ok{
+						item.SoldValue = int(soldOut)
 					}
-					if change3, ok := p.Change3.(int); ok{
-						item.SoldChange = change3
+					if change3, ok := p.Change3.(float64); ok{
+						item.SoldChange = int(change3)
 					}
 
 					itemVerifyCode = item.BuyValue + item.DealValue + item.SoldValue
@@ -207,23 +207,23 @@ func SyncRankingFromShangHai() {
 					item.ModifyTime = time.Now()
 					item.DataTime = tradeDate
 
-					if deal, ok := p.Deal.(int); ok{
-						item.DealValue = deal
+					if deal, ok := p.Deal.(float64); ok{
+						item.DealValue = int(deal)
 					}
-					if change1, ok := p.Change1.(int); ok{
-						item.DealChange = change1
+					if change1, ok := p.Change1.(float64); ok{
+						item.DealChange = int(change1)
 					}
-					if buyIn, ok := p.BuyIn.(int); ok{
-						item.BuyValue = buyIn
+					if buyIn, ok := p.BuyIn.(float64); ok{
+						item.BuyValue = int(buyIn)
 					}
-					if change2, ok := p.Change2.(int); ok{
-						item.BuyChange = change2
+					if change2, ok := p.Change2.(float64); ok{
+						item.BuyChange = int(change2)
 					}
-					if soldOut, ok := p.SoldOut.(int); ok{
-						item.SoldValue = soldOut
+					if soldOut, ok := p.SoldOut.(float64); ok{
+						item.SoldValue = int(soldOut)
 					}
-					if change3, ok := p.Change3.(int); ok{
-						item.SoldChange = change3
+					if change3, ok := p.Change3.(float64); ok{
+						item.SoldChange = int(change3)
 					}
 
 					itemVerifyCode = item.BuyValue + item.DealValue + item.SoldValue