更新上期所数据

services/commodity_trade_shanghai.go

@@ -83,7 +83,7 @@ func SyncRankingFromShangHai() {
 		indexCodeMap[item.IndexName] = item.IndexCode
 	}
 	//获取新的指标信息
-	for i := 2; i >= 0; i-- {
+	for i := 3; 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)

services/task.go

@@ -37,8 +37,9 @@ func Task() {
 	//FileCoalJsm()
 	//FileCoalFirm()
 	//FileCoalCoastal()
-	FileCoalInland()
-	SyncRankingFromDalianSearch(0)
+	//FileCoalInland()
+	SyncRankingFromShangHai()
+	//SyncRankingFromDalianSearch(0)
 	fmt.Println("end crawler")
 }