From 192f9bec8f7fb77ed5d676ab72c8c663bd94c039 Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Mon, 13 Jan 2025 13:42:55 +0800 Subject: [PATCH] test --- modules/extent.go | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/modules/extent.go b/modules/extent.go index 061b227..2cc4a27 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -4,11 +4,12 @@ import ( "encoding/json" "errors" "fmt" - "github.com/phyer/core" "os" "strconv" "strings" + "github.com/phyer/core" + // "sync" "time" // @@ -257,12 +258,13 @@ func GetRangeCandleSortedSet(cr *core.Core, setName string, count int, from time 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) go func() { - // parts := strings.Split(setName, "|") - // instId := parts[1] - // // 定义正则表达式，匹配 maX 或 candle 后面的内容直到第一个竖线 - // period, _ := extractString(setName) - // InvokeCandle(cr, instId, period, fromt, sti) + parts := strings.Split(setName, "|") + instId := parts[1] + // 定义正则表达式，匹配 maX 或 candle 后面的内容直到第一个竖线 + period, _ := extractString(setName) + InvokeCandle(cr, instId, period, fromt, sti) }() + return &cdl, err } for _, str := range keyAry { if str == nil {