From ae694f58d6d15f4ed79c606d918c4bc2679bd37c Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Tue, 14 Jan 2025 00:00:43 +0800 Subject: [PATCH] =?UTF-8?q?SaveUniKey=20=E5=85=B3=E6=8E=89=E5=94=AF?= =?UTF-8?q?=E4=B8=80=E6=80=A7=E9=AA=8C=E8=AF=81=E8=AF=95=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- candle.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/candle.go b/candle.go index 36dc3f9..ce03797 100644 --- a/candle.go +++ b/candle.go @@ -312,9 +312,9 @@ func (cl *Candle) ToStruct(core *Core) (*Candle, error) { // 保证同一个 period, keyName ，在一个周期里，SaveToSortSet只会被执行一次 func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration, tsi int64) { - refName := keyName + "|refer" + // refName := keyName + "|refer" // refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result() - core.RedisLocalCli.Expire(refName, extt) + // core.RedisLocalCli.Expire(refName, extt) // 为保证唯一性机制，防止SaveToSortSet 被重复执行 // 关掉唯一性验证，试试 // if len(refRes) != 0 { @@ -335,9 +335,9 @@ func (core *Core) SaveToSortSet(period string, keyName string, extt time.Duratio } rs, err := core.RedisLocalCli.ZAdd(setName, z).Result() if err != nil { - logrus.Error("err of ma7|ma30 add to redis:", err) + logrus.Warn("err of ma7|ma30 add to redis:", err) } else { - logrus.Info("sortedSet added to redis:", rs, keyName) + logrus.Warn("sortedSet added to redis:", rs, keyName) } } @@ -485,7 +485,7 @@ func (cl *Candle) SetToKey(core *Core) ([]interface{}, error) { logrus.Error("err of PeriodToMinutes:", err) } // expf := float64(exp) * 60 - expf := utils.Sqrt(float64(exp)) * 100 + expf := float64(exp) * 300 extt := time.Duration(expf) * time.Minute curVolstr, _ := data[5].(string) curVol, err := strconv.ParseFloat(curVolstr, 64)