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

解决v5api返回报错问题

Browse Source
This commit is contained in:
zhangkun 2024-12-03 22:22:22 +08:00
parent 6cb56dab4f
commit a3b1a527e7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/candle.go
View File

@ -267,9 +267,9 @@ func (mx *MaX) SetToKey() ([]interface{}, error) {
// 保证同一个 period, keyName ，在一个周期里，SaveToSortSet只会被执行一次 // 保证同一个 period, keyName ，在一个周期里，SaveToSortSet只会被执行一次
func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration, tsi int64, cl *Candle) { func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration, tsi int64, cl *Candle) {
refName := keyName + "|refer" refName := keyName + "|refer"
refRes, _ := core.RedisCli.GetSet(refName, 1).Result() refRes, err := core.RedisCli.GetSet(refName, 1).Result()
core.RedisCli.Expire(refName, extt) core.RedisCli.Expire(refName, extt)
if len(refRes) != 0 { if len(refRes) != 0 || err != nil {
return return
} }
cl.ToStruct(core) cl.ToStruct(core)
@ -278,7 +278,7 @@ func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration,
Content: cd, Content: cd,
Tag: "sardine.log.candle." + cl.Period, Tag: "sardine.log.candle." + cl.Period,
} }
err := wg.Process(core) err = wg.Process(core)
if err != nil { if err != nil {
fmt.Println("writeLog err:", err) fmt.Println("writeLog err:", err)
} }