| | |
|---|
| | | public void handleTradeExchange(String content) { |
|---|
| | | // log.info("#处理订单---->{}#", content); |
|---|
| | | List<ExchangeTrade> exchangeTrades = JSONObject.parseArray(content, ExchangeTrade.class); |
|---|
| | | if(CollectionUtils.isEmpty(exchangeTrades)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // 去掉空的 暂时这样 |
|---|
| | | Iterator<ExchangeTrade> iterator = exchangeTrades.iterator(); |
|---|
| | | while (iterator.hasNext()){ |
|---|
| | |
|---|
| | | } |
|---|
| | | // 先处理处理用户订单 |
|---|
| | | orderCoinService.handleOrder(exchangeTrades); |
|---|
| | | try{ |
|---|
| | | // 处理K线 并更新最新价 |
|---|
| | | handleKlineService.handleExchangeOrderToKline(exchangeTrades); |
|---|
| | | // 推送最新K线 |
|---|
| | |
|---|
| | | tradePlateSendWebSocket.sendMessageKline(symbolUsdt,key1,JSONObject.toJSONString(newCandlestick),null); |
|---|
| | | } |
|---|
| | | |
|---|
| | | }catch (Exception e){ |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
