From 96fe3abe92480c1ab0d14dffca0e5e37711db15d Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Wed, 18 Dec 2024 16:16:40 +0800 Subject: [PATCH] add lastUpdate to candle and maX --- modules/extent.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/modules/extent.go b/modules/extent.go index 0c4d5c3..1af8542 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -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)) } + tm, _ := core.Int64ToTime(tsi) mx := core.MaX{ KeyName: keyName, InstID: cl.InstID, @@ -322,7 +323,7 @@ func MakeMaX(cr *core.Core, cl *core.Candle, count int) (error, int) { Count: count, Ts: tsi, AvgVal: avgLast, - Timestamp: cl.Timestamp, + Timestamp: tm, } // MaX的Data里包含三个有效信息:时间戳,平均值,计算平均值所采用的数列长度 dt := []interface{}{}