fix

services/data/trade_position_analysis.go

@@ -12,32 +12,28 @@ import (
 
 // InitPositionTask 统计今日交易所的持仓分析数据
 func InitPositionTask(cont context.Context) (err error) {
-	exchanges := []string{"zhengzhou", "dalian", "shanghai", "cffex", "ine"} //郑商所，大商所，上期所，中金所，上期能源
+	exchanges := []string{"zhengzhou","dalian","shanghai","cffex","ine"} //郑商所，大商所，上期所，中金所，上期能源
+	startDate := time.Now().Format(utils.FormatDate)
+	endDate := startDate
+	for _, v := range exchanges {
+		exchange := v
+		err = nil
+		fmt.Println("InitPositionTask:	启动："+exchange)
+		utils.FileLog.Info("InitPositionTask:	启动："+exchange)
 
-	for i := 20; i >= 0; i-- {
-		startDate := time.Now().AddDate(0, 0, -i).Format(utils.FormatDate)
-		endDate := startDate
-		for _, v := range exchanges {
-			exchange := v
-			err = nil
-			fmt.Println("InitPositionTask:	启动：" + exchange)
-			utils.FileLog.Info("InitPositionTask:	启动：" + exchange)
-
-			fmt.Println("开始" + startDate + "结束" + endDate)
-			utils.FileLog.Info(fmt.Sprintf("InitTradePosition:开始:%s; 结束:%s", startDate, endDate))
-			tErr, errMsg := InitTradePosition(exchange, startDate, endDate)
-			if tErr != nil {
-				err = tErr
-				fmt.Println("InitTradePosition: 操作失败：" + errMsg + tErr.Error())
-				utils.FileLog.Info(fmt.Sprintf("InitTradePosition: 操作失败：%s:%s", errMsg, tErr.Error()))
-				continue
-			}
-
-			fmt.Println("InitTradePosition:" + exchange + "已完成")
-			utils.FileLog.Info("InitTradePosition:" + exchange + "已完成")
+		fmt.Println("开始"+startDate+"结束"+endDate)
+		utils.FileLog.Info(fmt.Sprintf("InitTradePosition:开始:%s; 结束:%s", startDate, endDate))
+		tErr, errMsg := InitTradePosition(exchange, startDate, endDate)
+		if tErr != nil {
+			err = tErr
+			fmt.Println("InitTradePosition: 操作失败："+errMsg+tErr.Error())
+			utils.FileLog.Info(fmt.Sprintf("InitTradePosition: 操作失败：%s:%s", errMsg, tErr.Error()))
+			continue
 		}
-	}
 
+		fmt.Println("InitTradePosition:"+exchange+"已完成")
+		utils.FileLog.Info("InitTradePosition:"+exchange+"已完成")
+	}
 	return
 }