Helius
2021-02-03 139de7fa16a29ddaf17cc261b273655d87c23105
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));