From 42fd88de38a221d6b1ea00a8560a43abab7f2369 Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Wed, 18 Dec 2024 16:34:43 +0800 Subject: [PATCH] add lastUpdate to candle and maX --- modules/extent.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/modules/extent.go b/modules/extent.go index 59bd4b7..a9be716 100644 --- a/modules/extent.go +++ b/modules/extent.go @@ -379,6 +379,7 @@ func MakeSoftCandles(cr *core.Core, mcd *MyCandle) { json.Unmarshal(bt, &cd0) tmi := ToInt64(cd0.Data[0]) + ts, _ := core.Int64ToTime(tmi) tm := time.UnixMilli(tmi) if tm.Unix() > 10*time.Now().Unix() { continue @@ -396,10 +397,11 @@ func MakeSoftCandles(cr *core.Core, mcd *MyCandle) { } otmi := otm.UnixMilli() cd1 := core.Candle{ - InstID: cd0.InstID, // string `json:"instId", string` - Period: cs.Seg, // `json:"period", string` - Data: cd0.Data, // `json:"data"` - From: "soft|" + os.Getenv("HOSTNAME"), // string `json:"from"` + InstID: cd0.InstID, // string `json:"instId", string` + Period: cs.Seg, // `json:"period", string` + Data: cd0.Data, // `json:"data"` + From: "soft|" + os.Getenv("HOSTNAME"), // string `json:"from"` + Timestamp: ts, } // cd0是从tickerInfo创建的1m Candle克隆来的, Data里只有Data[4]被赋值，是last，其他都是"-1" // TODO 填充其余几个未赋值的字段，除了成交量和成交美元数以外，并存入redis待用