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 16:39:33 +08:00
parent 4c689e9adf
commit 86d63a3318
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
modules/extent.go
View File

@ -218,6 +218,7 @@ func InvokeCandle(cr *core.Core, candleName string, period string, from int64, t
restQ := core.RestQueue{ restQ := core.RestQueue{
InstId: candleName, InstId: candleName,
Bar: period, Bar: period,
WithWs: false,
Limit: strconv.Itoa(candleCount), // 动态计算limit Limit: strconv.Itoa(candleCount), // 动态计算limit
After: from, After: from,
} }
@ -290,7 +291,6 @@ func GetRangeCandleSortedSet(cr *core.Core, setName string, count int, from time
go func() { go func() {
parts := strings.Split(setName, "|") parts := strings.Split(setName, "|")
instId := parts[1] instId := parts[1]
// 定义正则表达式，匹配 maX 或 candle 后面的内容直到第一个竖线
period, _ := extractString(setName) period, _ := extractString(setName)
InvokeCandle(cr, instId, period, fromt, sti) InvokeCandle(cr, instId, period, fromt, sti)
}() }()