xiaoyong931011
2021-03-03 8bf1fd2444ee53fb16d4e7d565a22bafbd5e1107
src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
@@ -338,9 +338,11 @@
                    continue;
                }
                log.info("过来过来");
                synchronized(this) {
                    log.info("爆仓啥的:{}", entry.getKey());
                    if (entry.getKey() != null) {
                    boolean b = redisUtils.setNotExist(AppContants.WHOLE_BOMB_PREFIX + entry.getKey(), 1, 5);
                    if (b) {
                        dataModelMap.remove(entry.getKey());
                        wholePriceData.setEquity(wholePriceData.getBalance().add(totalProfitOrLoss));
                        redisUtils.set(AppContants.WHOLE_BOMB_MAP, JSONObject.toJSONString(dataModelMap));