From d78a2d27fc6214a86f84ae0353326ac304965c9b Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 19 Aug 2020 16:10:42 +0800
Subject: [PATCH] modify

---
 src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java |   18 +++++++++++++++---
 1 files changed, 15 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
index 726f020..ac0d1ef 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
@@ -89,10 +89,14 @@
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void cancelHoldOrder(List<Long> ids) {
+        log.info("--------");
         if (CollUtil.isNotEmpty(ids)) {
+            log.info("=========:{}", ids.size());
             try {
                 if (ids.size() == 1) {
                     ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(ids.get(0));
+
+                    log.info(">>>>>>>>>>>>>{}", holdOrderEntity.getPositionType());
                     // 判断仓位类型是否逐仓
                     if (holdOrderEntity.getPositionType() == ContractEntrustOrderEntity.POSITION_TYPE_ADD) {
                         // 逐仓平仓
@@ -254,6 +258,7 @@
      * 全仓模式平仓逻辑
      */
     public void closingWholeOrder(ContractHoldOrderEntity holdOrderEntity) {
+        log.info("进入全仓模式--平仓");
         String symbol = holdOrderEntity.getSymbol();
         // 获取最新价
         BigDecimal newPrice = new BigDecimal(redisUtils.getString(CoinTypeConvert.convertToKey(symbol)));
@@ -262,6 +267,7 @@
 
         MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(holdOrderEntity.getMemberId(), CoinTypeEnum.USDT.name());
         if (walletContract != null) {
+            log.info("--->逻辑");
             BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(symbol);
             // 盈亏
             BigDecimal profitOrLoss = BigDecimal.ZERO;
@@ -296,13 +302,15 @@
                     profitOrLoss = profitOrLoss.multiply(BigDecimal.ONE.add(tradeSettingEntity.getProfitParam()));
                 }
             }
+            log.info("profitOrLoss:{}", profitOrLoss);
 
             // 保证金
             BigDecimal bondAmount = CalculateUtil.getBondAmount(holdOrderEntity.getOpeningPrice(), lotNumber, closeCnt, holdOrderEntity.getLeverRatio());
 
+            log.info("bondAmount:{}", bondAmount);
             // 平仓手续费
             BigDecimal fee = holdOrderEntity.getOpeningFeeAmount().divide(BigDecimal.valueOf(holdOrderEntity.getSymbolCnt()), 8, BigDecimal.ROUND_DOWN).multiply(BigDecimal.valueOf(closeCnt));
-
+            log.info("fee:{}", fee);
             ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(holdOrderEntity);
             contractOrderEntity.setId(null);
             contractOrderEntity.setClosingPrice(newPrice);
@@ -314,8 +322,12 @@
             contractOrderEntity.setClosingFeeAmount(fee);
             contractOrderDao.insert(contractOrderEntity);
 
-            holdOrderEntity.setSymbolCntSale(holdOrderEntity.getSymbolCntSale() - closeCnt);
-            contractHoldOrderDao.updateById(holdOrderEntity);
+            if (holdOrderEntity.getSymbolCntSale() - closeCnt != 0) {
+                holdOrderEntity.setSymbolCntSale(holdOrderEntity.getSymbolCntSale() - closeCnt);
+                contractHoldOrderDao.updateById(holdOrderEntity);
+            } else {
+                contractHoldOrderDao.deleteById(holdOrderEntity.getId());
+            }
 
             BigDecimal changeAmount = profitOrLoss.add(bondAmount).subtract(fee);
 

--
Gitblit v1.9.1