diff --git a/protocol/model_trade.go b/protocol/model_trade.go index 0b4954e..2babcf7 100644 --- a/protocol/model_trade.go +++ b/protocol/model_trade.go @@ -183,6 +183,7 @@ func (this Trades) Kline(t time.Time, last Price) *Kline { // kline1 生成一分钟k线,一天 func (this Trades) klinesForDay(date time.Time) Klines { + _929 := 569 //9:29 的分钟,为了兼容性强,把9:25算9:29 _930 := 570 //9:30 的分钟 _1130 := 690 //11:30 的分钟 _1300 := 780 //13:00 的分钟 @@ -190,7 +191,7 @@ func (this Trades) klinesForDay(date time.Time) Klines { keys := []int(nil) //早上 m := map[int]Trades{} - for i := 1; i <= 120; i++ { + for i := 0; i <= 120; i++ { keys = append(keys, _930+i) m[_930+i] = []*Trade{} } @@ -210,7 +211,7 @@ func (this Trades) klinesForDay(date time.Time) Klines { //分组,按 for _, v := range this { ms := minutes(v.Time) - t := conv.Select(ms <= _930, _930, ms) + t := conv.Select(ms < _929, _929, ms) t++ t = conv.Select(t > _1130 && t <= _1300, _1130, t) t = conv.Select(t > _1500, _1500, t)