fix

services/sync_hz_data.go

@@ -13,6 +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_zhengzhou.go

@@ -10,22 +10,33 @@ import (
 
 // 郑州商品交易所持单排名
 func SyncRankingFromZhengzhou() (err error) {
-
-	var startDate string
 	maxDate, err := data_manage.GetBaseFromTradeZhengzhouIndexMaxDate()
 	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`
+		//startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+		//startDate = `1900-01-01 00:00:00`
+		maxDate = time.Date(1900, 1, 1, 0, 0, 0, 0, time.Local)
 	} else {
-		startDate = maxDate.Format(utils.FormatDate) + " 00:00:00"
+		//startDate = maxDate.Format(utils.FormatDate) + " 00:00:00"
 	}
 
+	for tmpDate := maxDate; !tmpDate.After(time.Now()); tmpDate = tmpDate.AddDate(0, 0, 1) {
+		endDate := tmpDate.AddDate(0, 0, 1)
+		err = syncRankingFromZhengzhou(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
+}
+func syncRankingFromZhengzhou(startDate, endDate string) (err error) {
 	method := `index/list`
 	data := make(map[string]interface{})
 	//data["Source"] = utils.DATA_SOURCE_DL
 	data["Source"] = utils.DATA_SOURCE_ZZ
 	data["StartDate"] = startDate
-	//data["EndDate"] = endDate
+	data["EndDate"] = endDate
 	result, err := HttpPost("SyncRankingFromZhengzhou", method, data)
 	if err != nil {
 		fmt.Println("SyncRankingFromZhengzhou HttpPost Err:", err.Error())