排查2D周期sortedSet周期间隔不统一的问题
This commit is contained in:
parent
c58cffe56e
commit
ffc18606c4
@ -188,17 +188,19 @@ func (core *Core) SaveCandle(instId string, period string, rsp *CandleData, dura
|
|||||||
for k, v := range segments {
|
for k, v := range segments {
|
||||||
logrus.Warn("fetch segments:", k, v)
|
logrus.Warn("fetch segments:", k, v)
|
||||||
cs := CandleSegment{}
|
cs := CandleSegment{}
|
||||||
sv, _ := json.Marshal(v)
|
|
||||||
json.Unmarshal(sv, &cs)
|
|
||||||
logrus.Warn("fetch segments2:", cs)
|
|
||||||
if !cs.Enabled {
|
if !cs.Enabled {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
sv, _ := json.Marshal(v)
|
||||||
|
json.Unmarshal(sv, &cs)
|
||||||
|
logrus.Warn("fetch segments2:", cs)
|
||||||
|
|
||||||
if cs.Seg == period {
|
if cs.Seg == period {
|
||||||
curSegStartTime = cs.StartTime
|
curSegStartTime = cs.StartTime
|
||||||
}
|
}
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
logrus.Warn("curSegStartTime:", curSegStartTime)
|
||||||
curTm, _ := time.ParseInLocation("2006-01-02 15:04.000", curSegStartTime, time.Local)
|
curTm, _ := time.ParseInLocation("2006-01-02 15:04.000", curSegStartTime, time.Local)
|
||||||
curTmi := curTm.UnixMilli()
|
curTmi := curTm.UnixMilli()
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user