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

排查 max 制作数量不够，声称不及时的问题

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-24 10:50:33 +08:00
parent 8888c52d1b
commit b0a4ffcb57
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
modules/extent.go
View File

@ -156,7 +156,9 @@ func LoopMakeMaX(cr *core.Core) {
// sz := utils.ShaiziInt(1500) + 500 // sz := utils.ShaiziInt(1500) + 500
time.Sleep(time.Duration(1500) * time.Millisecond) time.Sleep(time.Duration(1500) * time.Millisecond)
err, ct := MakeMaX(cr, cad, 7) err, ct := MakeMaX(cr, cad, 7)
logrus.Warn(GetFuncName(), " ma7 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period) if err != nil {
logrus.Warn(GetFuncName(), " ma7 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period)
}
//TODO 这个思路不错，单行不通，远程redis禁不住这么频繁的请求 //TODO 这个思路不错，单行不通，远程redis禁不住这么频繁的请求
// cd.InvokeRestQFromRemote(cr, ct) // cd.InvokeRestQFromRemote(cr, ct)
}(cd) }(cd)
@ -165,7 +167,9 @@ func LoopMakeMaX(cr *core.Core) {
// sz := utils.ShaiziInt(2000) + 500 // sz := utils.ShaiziInt(2000) + 500
time.Sleep(time.Duration(1600) * time.Millisecond) time.Sleep(time.Duration(1600) * time.Millisecond)
err, ct := MakeMaX(cr, cad, 30) err, ct := MakeMaX(cr, cad, 30)
logrus.Warn(GetFuncName(), " ma30 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period) if err != nil {
logrus.Warn(GetFuncName(), " ma30 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period)
}
// cd.InvokeRestQFromRemote(cr, ct) // cd.InvokeRestQFromRemote(cr, ct)
}(cd) }(cd)
go func(cad *core.Candle) { go func(cad *core.Candle) {