modify

Helius

2021-02-03 37ba1289309bbfb00617ab6be9662fe46ea3894c

modify

 src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java

@@ -491,6 +491,7 @@
                ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(holdOrderDataModel.getId());
                if (holdOrderEntity == null) {
                    log.info("持仓不存在:{}", holdOrderDataModel.getId());
                    redisUtils.del(AppContants.WHOLE_BOMB_PREFIX + wholePriceData.getMemberId());
                    continue;
                }

@@ -530,6 +531,8 @@
            }

            memberWalletContractDao.increaseWalletContractBalanceById(wallet.getAvailableBalance().negate(), wallet.getTotalBalance().subtract(totalAmount).negate(), null, wallet.getId());

            redisUtils.del(AppContants.WHOLE_BOMB_PREFIX + wholePriceData.getMemberId());
        } else {
            log.info("参数有误:{}", memberEntity.getId());
        }

 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));