diff --git a/candle.go b/candle.go index 4954c62..85d209c 100644 --- a/candle.go +++ b/candle.go @@ -343,14 +343,14 @@ func (cl *Candle) ToStruct(core *Core) (*Candle, error) { func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration, tsi int64) { refName := keyName + "|refer" - refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result() + // refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result() core.RedisLocalCli.Expire(refName, extt) // 为保证唯一性机制,防止SaveToSortSet 被重复执行, ps: 不需要唯一,此操作幂等在redis里 // founded, _ := core.findInSortSet(period, keyName, extt, tsi) - if len(refRes) != 0 { - logrus.Error("refName exist: ", refName) - return - } + // if len(refRes) != 0 { + // logrus.Error("refName exist: ", refName) + // return + // } core.SaveToSortSet(period, keyName, extt, tsi) }