上期所fix

services/commodity_trade_shanghai.go

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

@@ -8,6 +8,7 @@ import (
 
 func Task() {
 	fmt.Println("start crawler")
+	SyncRankingFromShangHai()
 	refreshData := task.NewTask("refreshData", "0 0,30 16-20 * * *", RefreshData)
 	refreshEic := task.NewTask("refreshData", "0 0 2,6 * * *", RefreshEic)
 	refreshCoal := task.NewTask("refreshData", "0 0,30 17-23 * * *", RefreshCoal)
@@ -38,7 +39,6 @@ func Task() {
 	//FileCoalFirm()
 	//FileCoalCoastal()
 	//FileCoalInland()
-	SyncRankingFromShangHai()
 	//SyncRankingFromDalianSearch(0)
 	fmt.Println("end crawler")
 }