From 8f5d1b8bafd09fb9de73fa30206124f2c2caae92 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Mon, 01 Feb 2021 15:49:00 +0800
Subject: [PATCH] modify

---
 src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java |    3 +++
 src/main/java/com/xcong/excoin/rabbit/consumer/WebsocketPriceConsumer.java               |    2 +-
 2 files changed, 4 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
index 9598533..edba4e0 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
@@ -488,6 +488,7 @@
             for (HoldOrderDataModel holdOrderDataModel : list) {
                 ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(holdOrderDataModel.getId());
                 if (holdOrderEntity == null) {
+                    log.info("持仓不存在:{}", holdOrderDataModel.getId());
                     continue;
                 }
 
@@ -527,6 +528,8 @@
             }
 
             memberWalletContractDao.increaseWalletContractBalanceById(wallet.getAvailableBalance().negate(), wallet.getTotalBalance().subtract(totalAmount).negate(), null, wallet.getId());
+        } else {
+            log.info("参数有误:{}", memberEntity.getId());
         }
     }
 
diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/WebsocketPriceConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/WebsocketPriceConsumer.java
index 1514f79..12a9257 100644
--- a/src/main/java/com/xcong/excoin/rabbit/consumer/WebsocketPriceConsumer.java
+++ b/src/main/java/com/xcong/excoin/rabbit/consumer/WebsocketPriceConsumer.java
@@ -171,7 +171,7 @@
     public void onMessageWholeBomb(Message message, Channel channel) {
         String content = new String(message.getBody());
         WholePriceDataModel wholePriceDataModel = JSONArray.parseObject(content, WholePriceDataModel.class);
-        log.info("==message-price-consumer==我收到消息了全仓爆仓: {}", wholePriceDataModel.getMemberId());
+        log.info("==message-price-consumer==我收到消息了全仓爆仓: {}", wholePriceDataModel);
         orderService.wholeBombOrder(wholePriceDataModel);
     }
 }

--
Gitblit v1.9.1