From a3b1a527e7128fc0eb724dec7cb344763c75406b Mon Sep 17 00:00:00 2001
From: zhangkun <zhangkun>
Date: Tue, 3 Dec 2024 22:22:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3v5api=E8=BF=94=E5=9B=9E?=
=?UTF-8?q?=E6=8A=A5=E9=94=99=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
core/candle.go | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/candle.go b/core/candle.go
index 68f0192..37bc8b1 100644
--- a/core/candle.go
+++ b/core/candle.go
@@ -267,9 +267,9 @@ func (mx *MaX) SetToKey() ([]interface{}, error) {
// 保证同一个 period, keyName ，在一个周期里，SaveToSortSet只会被执行一次
func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration, tsi int64, cl *Candle) {
refName := keyName + "|refer"
- refRes, _ := core.RedisCli.GetSet(refName, 1).Result()
+ refRes, err := core.RedisCli.GetSet(refName, 1).Result()
core.RedisCli.Expire(refName, extt)
- if len(refRes) != 0 {
+ if len(refRes) != 0 || err != nil {
return
}
cl.ToStruct(core)
@@ -278,7 +278,7 @@ func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration,
Content: cd,
Tag: "sardine.log.candle." + cl.Period,
}
- err := wg.Process(core)
+ err = wg.Process(core)
if err != nil {
fmt.Println("writeLog err:", err)
}