phyer/siaga
1
0
Fork 0
Code Issues 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 16:16:40 +08:00
parent 41e90a2fc5
commit 96fe3abe92
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
modules/extent.go
View File

@ -314,6 +314,7 @@ func MakeMaX(cr *core.Core, cl *core.Candle, count int) (error, int) {
// fmt.Println("makeMax keyName: ma", count, keyName, " avgLast: ", avgLast, "ts: ", tsi, "ct: ", ct, "ots: ", ots, "candle: ", string(cjs)) // fmt.Println("makeMax keyName: ma", count, keyName, " avgLast: ", avgLast, "ts: ", tsi, "ct: ", ct, "ots: ", ots, "candle: ", string(cjs))
} }
tm, _ := core.Int64ToTime(tsi)
mx := core.MaX{ mx := core.MaX{
KeyName: keyName, KeyName: keyName,
InstID: cl.InstID, InstID: cl.InstID,
@ -322,7 +323,7 @@ func MakeMaX(cr *core.Core, cl *core.Candle, count int) (error, int) {
Count: count, Count: count,
Ts: tsi, Ts: tsi,
AvgVal: avgLast, AvgVal: avgLast,
Timestamp: cl.Timestamp, Timestamp: tm,
} }
// MaX的Data里包含三个有效信息：时间戳，平均值，计算平均值所采用的数列长度 // MaX的Data里包含三个有效信息：时间戳，平均值，计算平均值所采用的数列长度
dt := []interface{}{} dt := []interface{}{}