fix

services/sync_hz_data.go

@@ -13,7 +13,7 @@ func SyncHzDataIndex(cont context.Context) (err error) {
 	fmt.Println("郑州交易所 start:", time.Now().Format(utils.FormatDateTime))
 	//郑州交易所
 	SyncRankingFromZhengzhou()
-	return
+
 	//if err != nil {
 	//	fmt.Println("SyncRankingFromZhengzhou Err:" + err.Error())
 	//	return

services/trade_shanghai.go

@@ -10,20 +10,29 @@ import (
 
 // 上海商品交易所持单排名
 func SyncRankingFromShanghai() (err error) {
-	var startDate string
 	maxDate, err := data_manage.GetBaseFromTradeShangHaiIndexMaxDate()
 	if err != nil || maxDate.IsZero() {
-		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
-		startDate = `1900-01-01 00:00:00`
-	} else {
-		startDate = maxDate.Format(utils.FormatDate) + " 00:00:00"
+		maxDate = time.Date(1900, 1, 1, 0, 0, 0, 0, time.Local)
 	}
 
+	for tmpDate := maxDate; !tmpDate.After(time.Now()); tmpDate = tmpDate.AddDate(0, 0, 1) {
+		endDate := tmpDate.AddDate(0, 0, 1)
+		err = syncRankingFromShanghai(tmpDate.Format(utils.FormatDateTime), endDate.Format(utils.FormatDateTime))
+		if err != nil {
+			fmt.Println(tmpDate.Format(utils.FormatDate), "执行异常，err：", err)
+		}
+		time.Sleep(10 * time.Second)
+	}
+	return err
+}
+
+func syncRankingFromShanghai(startDate, endDate string) (err error) {
+
 	method := `index/list`
 	data := make(map[string]interface{})
 	data["Source"] = utils.DATA_SOURCE_SH
 	data["StartDate"] = startDate
-	//data["EndDate"] = endDate
+	data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromShanghai", method, data)
 	//utils.FileLog.Info(result)
 	//fmt.Println(result)

services/trade_zhengzhou.go

@@ -25,7 +25,7 @@ func SyncRankingFromZhengzhou() (err error) {
 		if err != nil {
 			fmt.Println(tmpDate.Format(utils.FormatDate), "执行异常，err：", err)
 		}
-		time.Sleep(10 * time.Second)
+		time.Sleep(2 * time.Second)
 	}
 
 	return