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 16:45:18 +08:00
parent 2ec9627fe6
commit e10569b0c0
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
candle.go
View File

@ -457,9 +457,12 @@ func (cl *Candle) SetToKey(core *Core) ([]interface{}, error) {
data := cl.Data data := cl.Data
tsi, err := strconv.ParseInt(data[0].(string), 10, 64) tsi, err := strconv.ParseInt(data[0].(string), 10, 64)
tss := strconv.FormatInt(tsi, 10) tss := strconv.FormatInt(tsi, 10)
tm, _ := Int64ToTime(tsi)
keyName := "candle" + cl.Period + "|" + cl.InstID + "|ts:" + tss keyName := "candle" + cl.Period + "|" + cl.InstID + "|ts:" + tss
//过期时间：根号(当前candle的周期/1分钟)*10000 //过期时间：根号(当前candle的周期/1分钟)*10000
cl.LastUpdate = time.Now() cl.LastUpdate = time.Now()
cl.Timestamp = tm
dt, err := json.Marshal(cl) dt, err := json.Marshal(cl)
if err != nil { if err != nil {
fmt.Println("candle Save to String err:", err) fmt.Println("candle Save to String err:", err)