From d23645e976981bc9b670eea1d469fe8a36be309c Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Wed, 17 Apr 2024 17:19:53 +0800 Subject: [PATCH] 55测试环境 --- src/main/java/com/xcong/excoin/rabbit/pricequeue/OrderOperatePriceService.java | 9 ++++++--- 1 files changed, 6 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/xcong/excoin/rabbit/pricequeue/OrderOperatePriceService.java b/src/main/java/com/xcong/excoin/rabbit/pricequeue/OrderOperatePriceService.java index 503b23e..120acf3 100644 --- a/src/main/java/com/xcong/excoin/rabbit/pricequeue/OrderOperatePriceService.java +++ b/src/main/java/com/xcong/excoin/rabbit/pricequeue/OrderOperatePriceService.java @@ -152,6 +152,7 @@ */ public static void wholePriceDataOperation(Long memberId) { Map<String, WholePriceDataModel> dataModelMap = WholeDataQueue.MAP; + log.info("操作前:{}", dataModelMap); RedisUtils redisUtils = SpringContextHolder.getBean(RedisUtils.class); ContractHoldOrderDao contractHoldOrderDao = SpringContextHolder.getBean(ContractHoldOrderDao.class); @@ -160,8 +161,10 @@ MemberWalletContractDao memberWalletContractDao = SpringContextHolder.getBean(MemberWalletContractDao.class); List<ContractHoldOrderEntity> holdOrders = contractHoldOrderDao.selectHoldOrderListByMemberId(memberId); + log.info("持仓数量:{}", holdOrders.size()); if (CollUtil.isEmpty(holdOrders)) { if (dataModelMap.get(memberId.toString()) != null) { + log.info("平仓后执行"); dataModelMap.remove(memberId.toString()); redisUtils.set(AppContants.WHOLE_BOMB_MAP, JSONObject.toJSONString(dataModelMap)); @@ -182,11 +185,11 @@ wholePriceData.setHoldBond(totalHoldBond); - List<ContractEntrustOrderEntity> entrustOrder = contractEntrustOrderDao.selectEntrustOrderListByMemberId(wholePriceData.getMemberId()); + List<ContractEntrustOrderEntity> entrustOrder = contractEntrustOrderDao.selectEntrustOrderListByMemberId(memberId); BigDecimal totalAmount = BigDecimal.ZERO; if (CollUtil.isNotEmpty(entrustOrder)) { for (ContractEntrustOrderEntity contractEntrustOrderEntity : entrustOrder) { - totalAmount.add(contractEntrustOrderEntity.getEntrustAmount()); + totalAmount = totalAmount.add(contractEntrustOrderEntity.getEntrustAmount()); } } @@ -194,8 +197,8 @@ wholePriceData.setMemberId(memberId); dataModelMap.put(wholePriceData.getMemberId().toString(), wholePriceData); - redisUtils.set(AppContants.WHOLE_BOMB_MAP, JSONObject.toJSONString(dataModelMap)); + log.info("dataModelMap为:{}", dataModelMap); } } -- Gitblit v1.9.1