Revert "revert to 73b8d92f95b163435a94b2aaec49ee9a0c12030c"

This reverts commit 7a643dd524bbd34bd2f752aef2b68ec6dbb84482.
This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-14 21:40:06 +08:00
parent 7a643dd524
commit 48bdc792d7
2 changed files with 2 additions and 2 deletions

2
go.mod
View File

@ -6,7 +6,7 @@ go 1.21
require ( require (
github.com/go-redis/redis v6.15.9+incompatible github.com/go-redis/redis v6.15.9+incompatible
github.com/phyer/core v0.1.99 github.com/phyer/core v0.1.100
github.com/sirupsen/logrus v1.9.3 github.com/sirupsen/logrus v1.9.3
) )

View File

@ -276,7 +276,7 @@ func GetRangeCandleSortedSet(cr *core.Core, setName string, count int, from time
cli.LTrim(setName, 0, oti) cli.LTrim(setName, 0, oti)
cunt, _ := cli.ZRemRangeByScore(setName, "0", strconv.FormatInt(oti, 10)).Result() cunt, _ := cli.ZRemRangeByScore(setName, "0", strconv.FormatInt(oti, 10)).Result()
if cunt > 0 { if cunt > 0 {
logrus.Warning("移出过期的引用数量:", setName, count, "ZRemRangeByScore ", setName, 0, strconv.FormatInt(oti, 10)) logrus.Warning("移出过期的引用数量:setName: ", setName, " cunt: ", cunt, " , ZRemRangeByScore ", setName, 0, strconv.FormatInt(oti, 10))
} }
logrus.Info("ZRevRangeByScore ", setName, opt) logrus.Info("ZRevRangeByScore ", setName, opt)
ary, err = cli.ZRevRangeByScore(setName, opt).Result() ary, err = cli.ZRevRangeByScore(setName, opt).Result()