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

尝试在报错时补齐缺少的candle序列

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-13 13:28:36 +08:00
parent 99cc913214
commit 3ecc4d5b8e
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
modules/extent.go
View File

@ -256,15 +256,15 @@ func GetRangeCandleSortedSet(cr *core.Core, setName string, count int, from time
if err != nil || len(keyAry) == 0 {
logrus.Warning("no record with cmd: ZRevRangeByScore ", "setName: ", setName, " from: ", froms, " sts: ", sts, " err:", err.Error())
logrus.Warning("zrev lens of ary: lens: ", len(ary), "GetRangeSortedSet ZRevRangeByScore:", "setName:", setName, " opt.Max:", opt.Max, " opt.Min:", opt.Min)
parts := strings.Split(setName, "|")
instId := parts[1]
// 定义正则表达式，匹配 maX 或 candle 后面的内容直到第一个竖线
period, err := extractString(setName)
if err != nil {
return &cdl, err
}
err = InvokeCandle(cr, instId, period, fromt, sti)
return &cdl, err
// parts := strings.Split(setName, "|")
// instId := parts[1]
// // 定义正则表达式，匹配 maX 或 candle 后面的内容直到第一个竖线
// period, err := extractString(setName)
// if err != nil {
// return &cdl, err
// }
// err = InvokeCandle(cr, instId, period, fromt, sti)
// return &cdl, err
}
for _, str := range keyAry {
if str == nil {