From be6979a915b64b831526baf9052726b5bb5cf152 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 02 Jun 2020 21:32:22 +0800
Subject: [PATCH] modify rabbit something

---
 src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java |   30 ++++++++++++++++--------------
 1 files changed, 16 insertions(+), 14 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java b/src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java
index f8d0554..a2e194c 100644
--- a/src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java
@@ -254,6 +254,7 @@
 				detail.setDealPrice(price.setScale(4, BigDecimal.ROUND_DOWN));
 				detail.setDealAmount(totalPayPrice.setScale(4, BigDecimal.ROUND_DOWN));
 				detail.setFeeAmount(closingPrice.setScale(4, BigDecimal.ROUND_DOWN));
+				detail.setOrderStatus(OrderCoinsDealEntity.ORDERSTATUS_DONE);
 				orderCoinDealDao.insert(detail);
 				
 				if(OrderCoinsEntity.ORDERTYPE_BUY.equals(type)) {
@@ -327,6 +328,21 @@
 					
 					String symbol = orderCoinsEntity.getSymbol();
 					
+					OrderCoinsDealEntity detail = new OrderCoinsDealEntity();
+					detail.setMemberId(memberId);
+					detail.setOrderId(orderCoinsEntity.getId());
+					detail.setOrderNo(generateSimpleSerialno(memberId.toString()));
+					detail.setOrderType(orderCoinsEntity.getOrderType());
+					detail.setTradeType(orderCoinsEntity.getTradeType());
+					detail.setSymbol(symbol);
+					detail.setOrderStatus(OrderCoinsDealEntity.ORDERSTATUS_CANCEL);
+					detail.setSymbolCnt(orderCoinsEntity.getEntrustCnt());
+					detail.setEntrustPrice(orderCoinsEntity.getEntrustPrice().setScale(4, BigDecimal.ROUND_DOWN));
+					detail.setDealPrice(orderCoinsEntity.getDealPrice().setScale(4, BigDecimal.ROUND_DOWN));
+					detail.setDealAmount(orderCoinsEntity.getDealAmount().setScale(4, BigDecimal.ROUND_DOWN));
+					detail.setFeeAmount(orderCoinsEntity.getFeeAmount().setScale(4, BigDecimal.ROUND_DOWN));
+					orderCoinDealDao.insert(detail);
+					
 					if(OrderCoinsEntity.ORDERTYPE_BUY.equals(orderCoinsEntity.getOrderType())) {
 						//如果是限价买入,撤单将USDT账户冻结金额返回
 						String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();
@@ -372,20 +388,6 @@
 							return Result.ok(MessageSourceUtils.getString("order_service_0013"));
 						}
 					}
-					OrderCoinsDealEntity detail = new OrderCoinsDealEntity();
-					detail.setMemberId(memberId);
-					detail.setOrderId(orderCoinsEntity.getId());
-					detail.setOrderNo(generateSimpleSerialno(memberId.toString()));
-					detail.setOrderType(orderCoinsEntity.getOrderType());
-					detail.setTradeType(orderCoinsEntity.getTradeType());
-					detail.setSymbol(symbol);
-					detail.setOrderStatus(OrderCoinsDealEntity.ORDERSTATUS_CANCEL);
-					detail.setSymbolCnt(orderCoinsEntity.getEntrustCnt());
-					detail.setEntrustPrice(orderCoinsEntity.getEntrustPrice().setScale(4, BigDecimal.ROUND_DOWN));
-					detail.setDealPrice(orderCoinsEntity.getDealPrice().setScale(4, BigDecimal.ROUND_DOWN));
-					detail.setDealAmount(orderCoinsEntity.getDealAmount().setScale(4, BigDecimal.ROUND_DOWN));
-					detail.setFeeAmount(orderCoinsEntity.getFeeAmount().setScale(4, BigDecimal.ROUND_DOWN));
-					orderCoinDealDao.insert(detail);
 				}
 		return Result.fail(MessageSourceUtils.getString("order_service_0043"));
 	}

--
Gitblit v1.9.1