phyer/core
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

SaveUniKey 关掉唯一性验证试试

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-13 23:29:41 +08:00
parent 6f60e7ed5c
commit edef3e6a3e
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
candle.go
View File

@ -313,13 +313,14 @@ func (cl *Candle) ToStruct(core *Core) (*Candle, error) {
func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration, tsi int64) { 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() // refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result()
core.RedisLocalCli.Expire(refName, extt) core.RedisLocalCli.Expire(refName, extt)
// 为保证唯一性机制，防止SaveToSortSet 被重复执行 // 为保证唯一性机制，防止SaveToSortSet 被重复执行
if len(refRes) != 0 { // 关掉唯一性验证，试试
logrus.Error("refName exist: ", refName) // if len(refRes) != 0 {
return // logrus.Error("refName exist: ", refName)
} // return
// }
core.SaveToSortSet(period, keyName, extt, tsi) core.SaveToSortSet(period, keyName, extt, tsi)
} }