From 139de7fa16a29ddaf17cc261b273655d87c23105 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 03 Feb 2021 14:50:23 +0800
Subject: [PATCH] modify

---
 src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java |    4 ++--
 1 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java b/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
index 5eb283a..4f6fb95 100644
--- a/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
+++ b/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
@@ -287,7 +287,6 @@
         }
     }
 
-    @Transactional(rollbackFor = Exception.class)
     public void wholeBomb() {
         Map<String, WholePriceDataModel> dataModelMap = WholeDataQueue.MAP;
         if (CollUtil.isEmpty(dataModelMap)) {
@@ -339,7 +338,8 @@
                     continue;
                 }
 
-                synchronized (this) {
+                synchronized(this) {
+                    log.info("爆仓啥的:{}", entry.getKey());
                     if (entry.getKey() != null) {
                         dataModelMap.remove(entry.getKey());
                         wholePriceData.setEquity(wholePriceData.getBalance().add(totalProfitOrLoss));

--
Gitblit v1.9.1