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-25 16:33:20 +08:00
parent b72d8a69e4
commit c090a76c70
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
candle.go
View File

@ -5,7 +5,7 @@ import (
"encoding/hex" "encoding/hex"
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" // "fmt"
"math/rand" "math/rand"
"os" "os"
"strconv" "strconv"
@ -178,7 +178,7 @@ 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)
fmt.Println("saveCandle leng: ", leng, " instId: ", instId, " period: ", period) // fmt.Println("saveCandle leng: ", leng, " instId: ", instId, " period: ", period)
for _, v := range rsp.Data { for _, v := range rsp.Data {
tmi := ToInt64(v[0]) tmi := ToInt64(v[0])
last := ToInt64(v[4]) last := ToInt64(v[4])
@ -495,7 +495,6 @@ func (cl *Candle) SetToKey(core *Core) ([]interface{}, error) {
} }
redisCli := core.RedisLocalCli redisCli := core.RedisLocalCli
// tm := time.UnixMilli(tsi).Format("2006-01-02 15:04") // tm := time.UnixMilli(tsi).Format("2006-01-02 15:04")
fmt.Println()
logrus.Info("setToKey:", keyName, "ts: ", "price: ", curPrice, "from:", cl.From) logrus.Info("setToKey:", keyName, "ts: ", "price: ", curPrice, "from:", cl.From)
redisCli.Set(keyName, dt, extt).Result() redisCli.Set(keyName, dt, extt).Result()
core.SaveUniKey(cl.Period, keyName, extt, tsi) core.SaveUniKey(cl.Period, keyName, extt, tsi)