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

tracebug of insertPlate

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-15 01:19:32 +08:00
parent 86d275c85b
commit 534733249a
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
modules/candle.go
View File

@ -225,4 +225,4 @@ func (mcd MyCandle) GetSetCandleInfo(cr *core.Core, newPeriod string, ts int64)
return cd.Data return cd.Data
} }
} }
} }v0.1.102-0.20250114162456-b9d1cb390c17

12
modules/extent.go
View File

@ -288,12 +288,12 @@ func GetRangeCandleSortedSet(cr *core.Core, setName string, count int, from time
if err != nil || len(keyAry) == 0 { if err != nil || len(keyAry) == 0 {
logrus.Warning("no record with cmd: ZRevRangeByScore ", "setName: ", setName, " from: ", froms, " sts: ", sts, " err:", err.Error()) 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) logrus.Warning("zrev lens of ary: lens: ", len(ary), "GetRangeSortedSet ZRevRangeByScore:", "setName:", setName, " opt.Max:", opt.Max, " opt.Min:", opt.Min)
go func() { // go func() {
parts := strings.Split(setName, "|") // parts := strings.Split(setName, "|")
instId := parts[1] // instId := parts[1]
period, _ := extractString(setName) // period, _ := extractString(setName)
InvokeCandle(cr, instId, period, fromt, sti) // InvokeCandle(cr, instId, period, fromt, sti)
}() // }()
return &cdl, err return &cdl, err
} }
for _, str := range keyAry { for _, str := range keyAry {