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

http://gitea.zjmod.xyz/phyer/core/issues/1#issuecomment-1

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-19 22:15:49 +08:00
parent 90afe9b6d3
commit 97db2d80c8
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
candle.go
View File

@ -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) { 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 被重复执行, ps: 不需要唯一，此操作幂等在redis里 // 为保证唯一性机制，防止SaveToSortSet 被重复执行, ps: 不需要唯一，此操作幂等在redis里
// founded, _ := core.findInSortSet(period, keyName, extt, tsi) // founded, _ := core.findInSortSet(period, keyName, extt, tsi)
if len(refRes) != 0 { // if len(refRes) != 0 {
logrus.Error("refName exist: ", refName) // logrus.Error("refName exist: ", refName)
return // return
} // }
core.SaveToSortSet(period, keyName, extt, tsi) core.SaveToSortSet(period, keyName, extt, tsi)
} }