modify

Helius

2021-02-03 0002f4d59b5a40457258291ef95b6bddd7fc2153

 src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java

@@ -288,7 +288,7 @@
    }

    @Transactional(rollbackFor = Exception.class)
    public void wholeBomb() {
    public synchronized void wholeBomb() {
        Map<String, WholePriceDataModel> dataModelMap = WholeDataQueue.MAP;
        if (CollUtil.isEmpty(dataModelMap)) {
            return;
@@ -339,7 +339,6 @@
                    continue;
                }

                synchronized (this) {
                    log.info("爆仓啥的:{}", entry.getKey());
                    if (entry.getKey() != null) {
                        dataModelMap.remove(entry.getKey());
@@ -349,7 +348,6 @@
                        wholePriceData.setPrices(prices);
                        contractHoldOrderDao.updateMemberAllHoldOrderClosingStatus(wholePriceData.getMemberId());
                        orderProducer.sendWholeBomb(JSONObject.toJSONString(wholePriceData));
                    }
                }
            }
        }