phyer/core
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

上个bug貌似已经解决

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-26 15:58:55 +08:00
parent 7e8bd06b95
commit 72f325986e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
candle.go
View File

@ -179,7 +179,7 @@ func IsModOf(curInt int64, duration time.Duration) bool {
func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura time.Duration, withWs bool) {
leng := len(rsp.Data)
// fmt.Println("saveCandle leng: ", leng, " instId: ", instId, " period: ", period)
logrus.Info("saveCandle leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data))
logrus.Info("saveCandles leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data))
for k, v := range rsp.Data {
tmi := ToInt64(v[0])
last := ToInt64(v[4])
@ -206,6 +206,7 @@ func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura
}
// 如果candle都不需要存到redis，那么AddToGeneralCandleChnl也没有意义
saveCandle := os.Getenv("TEXUS_SAVECANDLE")
logrus.Info("saveCandles datas: k,v: ", k, v)
if saveCandle == "true" {
go func(k int) {
time.Sleep(time.Duration(k*40) * time.Millisecond)