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

跟SaveUikey关系不大，应该是max没有区分7/30的hash key造成写入es被统一对待了

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-14 18:18:13 +08:00
parent 8d3303119c
commit 4ae67cbcd6
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
candle.go
View File

@ -312,16 +312,15 @@ 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"
// refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result()
// core.RedisLocalCli.Expire(refName, extt)
refName := keyName + "|refer"
refRes, _ := core.RedisLocalCli.GetSet(refName, 1).Result()
core.RedisLocalCli.Expire(refName, extt)
// 为保证唯一性机制，防止SaveToSortSet 被重复执行
// 关掉唯一性验证，试试
// 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)
}