修复冻结问题

zainali5120

2020-10-08 0f25ef5fe5076be73cf7d40b2f0f9c3f7293eadb

 src/main/java/com/xcong/excoin/modules/exchange/service/impl/HandleKlineServiceImpl.java

@@ -39,10 +39,14 @@
        CoinProcessor processor = processorFactory.getProcessor(symbol);
        Map<String, Candlestick> currentKlineMap = processor.getCurrentKlineMap();
        Collection<Candlestick> values = currentKlineMap.values();
        BigDecimal newPrice = trades.get(trades.size()-1).getPrice();
        BigDecimal newPrice =null;
        for (Candlestick candlestick : values) {
            for (ExchangeTrade exchangeTrade : trades) {
                if(exchangeTrade==null){
                    continue;
                }
                processor.processTrade(candlestick, exchangeTrade);
                newPrice=exchangeTrade.getPrice();
            }
        }

@@ -51,6 +55,9 @@
        key = StrUtil.format(key, symbolUsdt);
        redisUtils.set(key,currentKlineMap);
        // 更新最新价
        redisUtils.set(CoinTypeConvert.convertToKey(symbolUsdt), newPrice);
        if(newPrice!=null){
            redisUtils.set(CoinTypeConvert.convertToKey(symbolUsdt), newPrice);
        }

    }
}