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

上个bug貌似已经解决

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-26 23:00:54 +08:00
parent 4a89e440dc
commit 32abafb9e6
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
candle.go
View File

@ -183,14 +183,14 @@ func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura
logrus.Info("saveCandles leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data)) logrus.Info("saveCandles leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data))
for k, v := range rsp.Data { for k, v := range rsp.Data {
tmi := ToInt64(v[0]) tmi := ToInt64(v[0])
last := ToInt64(v[4]) last := ToFloat64(v[4])
ty := reflect.TypeOf(v[4]).Name() // ty := reflect.TypeOf(v[4]).Name()
v4It, err := strconv.ParseInt(v[4].(string), 10, 64) // v4It, err := strconv.ParseInt(v[4].(string), 10, 64)
if err != nil { // if err != nil {
logrus.Info("saveCandles last is 0 is err: ", err, "v4It: ", v4It, "v[4]: ", v[4], "v[4] type: ", ty, "leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data), " data:", rsp.Data) // logrus.Info("saveCandles last is 0 is err: ", err, "v4It: ", v4It, "v[4]: ", v[4], "v[4] type: ", ty, "leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data), " data:", rsp.Data)
} // }
if last == 0 { if last == 0 {
logrus.Info("saveCandles last is 0: ", "v[4]: ", v[4], "v[4] type: ", ty, " v4It: ", v4It, "leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data), " data:", rsp.Data) // logrus.Info("saveCandles last is 0: ", "v[4]: ", v[4], "v[4] type: ", ty, " v4It: ", v4It, "leng: ", leng, " instId: ", instId, " period: ", period, " length of rsp.Data: ", len(rsp.Data), " data:", rsp.Data)
continue continue
} }
ts, _ := Int64ToTime(tmi) ts, _ := Int64ToTime(tmi)