大连获取近半年数据

services/commodity_trade_dalian.go

@@ -810,8 +810,16 @@ type SearchContractId struct {
 	ContractId string `description:"商品类型"`
 }
 
+func SyncRankingFromDalianDo() {
+
+	for i := 6; i >= 0; i-- {
+		//fmt.Println(i)
+		SyncRankingFromDalian2(i)
+	}
+}
+
 //郑州商品交易所持单排名
-func SyncRankingFromDalian2() {
+func SyncRankingFromDalian2(dayNum int) {
 	fmt.Println("start")
 	searchList := []SearchList{
 		SearchList{VarietyName: "豆一", CarietyCode: "a", List: []SearchContractId{SearchContractId{ContractId: "a2111"}, {ContractId: "a2201"}, {ContractId: "a2203"}}},
@@ -837,7 +845,7 @@ func SyncRankingFromDalian2() {
 		SearchList{VarietyName: "液化石油气", CarietyCode: "pg", List: []SearchContractId{SearchContractId{ContractId: "pg2111"}, {ContractId: "pg2112"}, {ContractId: "pg2201"}, {ContractId: "pg2202"}}},
 	}
 	//定义爬取时间
-	endDate := time.Now().AddDate(0, 0, -1).Format(utils.FormatDateTime)
+	endDate := time.Now().AddDate(0, 0, -dayNum).Format(utils.FormatDateTime)
 	//endDate := time.Now().Format(utils.FormatDateTime)
 	timeDate := utils.StrTimeToTime(endDate)
 	currDate := timeDate.Format(utils.FormatDateUnSpace)