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

candle ad timestap

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-18 11:29:26 +08:00
parent 1f703ce25c
commit 06a3db9d19
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
candle.go
View File

@ -178,12 +178,17 @@ func IsModOf(curInt int64, duration time.Duration) bool {
func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura time.Duration, withWs bool) { func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura time.Duration, withWs bool) {
leng := len(rsp.Data) leng := len(rsp.Data)
for _, v := range rsp.Data { for _, v := range rsp.Data {
candle := Candle{ candle := Candle{
InstID: instId, InstID: instId,
Period: period, Period: period,
Data: v, Data: v,
From: "rest", From: "rest",
} }
data := candle.Data
tsi, _ := strconv.ParseInt(data[0].(string), 10, 64)
tm, _ := Int64ToTime(tsi)
candle.Timestamp = tm
//存到elasticSearch //存到elasticSearch
candle.PushToWriteLogChan(core) candle.PushToWriteLogChan(core)
//保存rest得到的candle //保存rest得到的candle