From a1b05c46a7141a4c217569b89029a3d0b63dc741 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Fri, 29 Jan 2021 14:51:12 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java | 36 +-----------------------------------
1 files changed, 1 insertions(+), 35 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java b/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
index de3abb7..ddc8c7d 100644
--- a/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
+++ b/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
@@ -112,44 +112,10 @@
@Override
public void run() {
log.info("全仓操作价格");
- ContractHoldOrderDao contractHoldOrderDao = SpringContextHolder.getBean(ContractHoldOrderDao.class);
- ContractEntrustOrderDao contractEntrustOrderDao = SpringContextHolder.getBean(ContractEntrustOrderDao.class);
- RedisUtils redisUtils = SpringContextHolder.getBean(RedisUtils.class);
- MemberWalletContractDao memberWalletContractDao = SpringContextHolder.getBean(MemberWalletContractDao.class);
-
- List<ContractHoldOrderEntity> holdOrders = contractHoldOrderDao.selectHoldOrderListByMemberId(memberId);
- if (CollUtil.isEmpty(holdOrders)) {
- return;
- }
- MemberWalletContractEntity wallet = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberId, CoinTypeEnum.USDT.name());
-
- WholePriceDataModel wholePriceData = new WholePriceDataModel();
- List<HoldOrderDataModel> holdOrderDataModels = ContractHoldOrderEntityMapper.INSTANCE.entitiesToDataModels(holdOrders);
- wholePriceData.setList(holdOrderDataModels);
-
- BigDecimal totalHoldBond = BigDecimal.ZERO;
- for (ContractHoldOrderEntity holdOrder : holdOrders) {
- totalHoldBond = totalHoldBond.add(holdOrder.getHoldBond() == null ? BigDecimal.ZERO : holdOrder.getHoldBond());
- }
-
- wholePriceData.setHoldBond(totalHoldBond);
-
- List<ContractEntrustOrderEntity> entrustOrder = contractEntrustOrderDao.selectEntrustOrderListByMemberId(wholePriceData.getMemberId());
- BigDecimal totalAmount = BigDecimal.ZERO;
- if (CollUtil.isNotEmpty(entrustOrder)) {
- for (ContractEntrustOrderEntity contractEntrustOrderEntity : entrustOrder) {
- totalAmount.add(contractEntrustOrderEntity.getEntrustAmount());
- }
- }
-
- wholePriceData.setBalance(wallet.getTotalBalance().subtract(totalAmount));
- wholePriceData.setMemberId(memberId);
OrderProducer orderProducer = SpringContextHolder.getBean(OrderProducer.class);
-
- orderProducer.sendWholePrice(JSONObject.toJSONString(wholePriceData));
+ orderProducer.sendWholePrice(memberId.toString());
}
});
-
}
}
--
Gitblit v1.9.1