修改广期所命名

services/task.go

@@ -171,18 +171,19 @@ func RefreshChangesVisitorsCovid(cont context.Context) (err error) {
 
 func Task123() {
 	fmt.Println("start")
-	//n := 193
-	//for i := n; i >= 0; i-- {
-	//	date := time.Now().AddDate(0, 0, -i)
-	//	if date.Weekday() == time.Saturday || date.Weekday() == time.Sunday {
-	//		continue
-	//	}
-	//	fmt.Println("date:", date.Format(utils.FormatDate))
-	//	CrawlerFromGuangzhouWbillWeeklyQuotes(date)
-	//	rn := utils.RangeRand(3, 15)
-	//	fmt.Println("i:"+strconv.Itoa(i)+" date:", date.Format(utils.FormatDate)+";sleep:", strconv.Itoa(int(rn)))
-	//	time.Sleep(time.Duration(rn) * time.Second)
-	//}
+	n := 60
+	//日成交持仓排名
+	for i := n; i >= 0; i-- {
+		date := time.Now().AddDate(0, 0, -i)
+		if date.Weekday() == time.Saturday || date.Weekday() == time.Sunday {
+			continue
+		}
+		fmt.Println("date:", date.Format(utils.FormatDate))
+		CrawlerFromGuangzhouDealPosiQuotes(date)
+		rn := utils.RangeRand(3, 15)
+		fmt.Println("i:"+strconv.Itoa(i)+" date:", date.Format(utils.FormatDate)+";sleep:", strconv.Itoa(int(rn)))
+		time.Sleep(time.Duration(rn) * time.Second)
+	}
 	CrawlerFromGuangzhouIndexMinAndMaxDate()
 	fmt.Println("end")
 }

services/trade_guangzhou.go

@@ -452,14 +452,14 @@ func CrawlerFromGuangzhouDealPosiQuotes(date time.Time) {
 					var indexName string
 					switch pv {
 					case 1:
-						indexName = v.Abbr + "成交量"
-						indexCode = indexCode + "deal"
+						indexName = v.Abbr + "_" + cv.Contract + "_" + "成交量"
+						indexCode = indexCode + cv.Contract + "deal"
 					case 2:
-						indexName = v.Abbr + "持买单量"
-						indexCode = indexCode + "buy"
+						indexName = v.Abbr + "_" + cv.Contract + "_" + "持买单量"
+						indexCode = indexCode + cv.Contract + "buy"
 					case 3:
-						indexName = v.Abbr + "持卖单量"
-						indexCode = indexCode + "sold"
+						indexName = v.Abbr + "_" + cv.Contract + "_" + "持卖单量"
+						indexCode = indexCode + cv.Contract + "sold"
 					}
 
 					var indexId int