1

zj

13 hours ago b28a97e1bf66e3279e78f31ce58122427787ceec

 trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/KlineServiceImpl.java

@@ -218,7 +218,9 @@
                long latestSameLineKlineTs = latestSameLineKline.getTs();
                klineOneTop5 = klineOneTop5.stream().filter(r -> r.getTs() > latestSameLineKlineTs).collect(Collectors.toList());
            }

            if (klineOneTop5.isEmpty()) {
                return null;
            }

            Double high = null;
            Double low = null;
@@ -676,8 +678,13 @@
            if (latestKilne != null && latestKilne.getTs() >= realtime.getTs()) {
                return null;
            }
            long lastKlineTs = latestKilne.getTs();
            realTimeList = realTimeList.stream().filter(r -> r.getTs() > lastKlineTs).collect(Collectors.toList());
            if (latestKilne != null) {
                long lastKlineTs = latestKilne.getTs();
                realTimeList = realTimeList.stream().filter(r -> r.getTs() > lastKlineTs).collect(Collectors.toList());
            }
            if (realTimeList.isEmpty()) {
                return null;
            }
            Double high = null;
            Double low = null;
            for (Realtime realTime : realTimeList) {