modify

Helius

2020-10-28 d0a348c1716c19a671d21563232ebcf596f607d0

modify

 src/main/java/com/xcong/excoin/rabbit/consumer/OrderSubmitConsumer.java

@@ -46,7 +46,7 @@
     */
    @RabbitListener(queues = RabbitMqConfig.QUEUE_ROC_ORDER_CANCEL)
    public void doCancel(String content) {
        log.info("#取消的订单---->{}#", content);
        //log.debug("#取消的订单---->{}#", content);
        orderCoinService.cancelEntrustWalletCoinOrderForMatch(content);
    }


 src/main/java/com/xcong/excoin/trade/CoinTrader.java

@@ -83,9 +83,7 @@
            }
        } else {
            list = sellLimitPriceQueue;
            logger.info("押入列表前:{}", sellTradePlate);
            sellTradePlate.add(exchangeOrder);
            logger.info("押入列表后:{}", sellTradePlate);
            if (ready) {
                sendTradePlateMessage(buyTradePlate, sellTradePlate);
            }
@@ -553,7 +551,6 @@
            tradePlateModel.setBuy(plate);
        }

        logger.info("卖盘信息:{}", sellTradePlate);
        if (sellTradePlate != null && sellTradePlate.getItems() != null) {
            plate = new ArrayList<>();
            LinkedList<TradePlateItem> items = sellTradePlate.getItems();
@@ -567,7 +564,6 @@
            }
            tradePlateModel.setSell(plate);
        }
        logger.info("卖盘信息:{}", sellTradePlate);

        // 盘口发生变化通知
        exchangeProducer.sendPlateMsg(JSON.toJSONString(tradePlateModel));