上个bug貌似已经解决

candle.go

@@ -203,6 +203,7 @@ func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura
 		arys := []string{ALLCANDLES_PUBLISH}
 		if withWs {
 			arys = append(arys, ALLCANDLES_INNER_PUBLISH)
+			time.Sleep(time.Duration(k*40) * time.Millisecond)
 		}
 		// 如果candle都不需要存到redis，那么AddToGeneralCandleChnl也没有意义
 		saveCandle := os.Getenv("TEXUS_SAVECANDLE")

core.go

@@ -91,7 +91,7 @@ func (rst *RestQueue) Save(cr *Core) {
 	}
 	isHistory := false
 	ct, _ := cr.PeriodToMinutes(rst.Bar)
-	if rst.After/ct > 30 {
+	if rst.After/ct > 10 {
 		isHistory = true
 	}
 	prfix := ""