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

add lastUpdate to candle and max

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-18 19:25:42 +08:00
parent e10569b0c0
commit fe376c6be8
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
maX.go
View File

@ -48,6 +48,7 @@ func (mx MaX) SetToKey(cr *Core) ([]interface{}, error) {
} }
keyName := "ma" + cstr + "|candle" + mx.Period + "|" + mx.InstID + "|ts:" + tss keyName := "ma" + cstr + "|candle" + mx.Period + "|" + mx.InstID + "|ts:" + tss
//过期时间：根号(当前candle的周期/1分钟)*10000 //过期时间：根号(当前candle的周期/1分钟)*10000
dj, err := json.Marshal(mx) dj, err := json.Marshal(mx)
if err != nil { if err != nil {
fmt.Println("maX SetToKey json marshal err: ", err) fmt.Println("maX SetToKey json marshal err: ", err)
@ -102,6 +103,7 @@ func (mx *MaX) PushToWriteLogChan(cr *Core) error {
mx0.Ts = mx.Ts mx0.Ts = mx.Ts
mx0.AvgVal = mx.AvgVal mx0.AvgVal = mx.AvgVal
mx0.LastUpdate = mx.LastUpdate mx0.LastUpdate = mx.LastUpdate
mx0.Timestamp = mx.Timestamp
hs := HashString(did) hs := HashString(did)
md, _ := json.Marshal(mx0) md, _ := json.Marshal(mx0)
mx = &mx0 mx = &mx0