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

test

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2025-01-13 23:04:02 +08:00
parent db66ceaf7b
commit 6f60e7ed5c
1 changed files with 2 additions and 2 deletions

4
core.go

@ -104,9 +104,9 @@ func (rst *RestQueue) Save(cr *Core) {
logrus.Info("restLink: ", link) logrus.Info("restLink: ", link)
rsp, err := cr.v5PublicInvoke(link) rsp, err := cr.v5PublicInvoke(link)
if err != nil { if err != nil {
logrus.Info("cr.v5PublicInvoke err:", err, " count: ", len(rsp.Data), " instId: ", rst.InstId, " period: ", rst.Bar, " after:", afterSec) logrus.Warn("cr.v5PublicInvoke err:", err, " count: ", len(rsp.Data), " instId: ", rst.InstId, " period: ", rst.Bar, " after:", afterSec)
} else { } else {
logrus.Info("cr.v5PublicInvoke result count:", len(rsp.Data), " instId: ", rst.InstId, " period: ", rst.Bar, " after:", afterSec, " rsp: ", rsp) logrus.Warn("cr.v5PublicInvoke result count:", len(rsp.Data), " instId: ", rst.InstId, " period: ", rst.Bar, " after:", afterSec, " rsp: ", rsp)
} }
cr.SaveCandle(rst.InstId, rst.Bar, rsp, rst.Duration, rst.WithWs) cr.SaveCandle(rst.InstId, rst.Bar, rsp, rst.Duration, rst.WithWs)
} }