From 87f7475be96627ef47148b26a7541c5f7848dc18 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 03 Jun 2020 18:18:53 +0800
Subject: [PATCH] modify contract wallet update
---
src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java | 33 ++++++++++++++-------------------
1 files changed, 14 insertions(+), 19 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java
index 367a0bd..cb215e9 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java
@@ -6,6 +6,7 @@
import com.xcong.excoin.modules.contract.entity.ContractEntrustOrderEntity;
import com.xcong.excoin.modules.contract.entity.ContractHoldOrderEntity;
import com.xcong.excoin.modules.contract.entity.ContractOrderEntity;
+import com.xcong.excoin.modules.contract.mapper.ContractEntrustOrderEntityMapper;
import com.xcong.excoin.modules.contract.mapper.ContractHoldOrderEntityMapper;
import com.xcong.excoin.modules.contract.service.ContractEntrustOrderService;
import com.xcong.excoin.modules.contract.service.ContractHoldOrderService;
@@ -147,8 +148,8 @@
System.out.println("执行操作");
// 止盈价
String symbol = order.getSymbol();
- // 本次需要退回的预付款
- BigDecimal prePrice = order.getPrePaymentAmount();
+ // 本次需要退回的保证金
+ BigDecimal prePrice = order.getBondAmount();
Long memberId = order.getMemberId();
MemberWalletContractEntity wallet = memberWalletContractService.findWalletContractByMemberIdAndSymbol(memberId, "USDT");
if (wallet != null) {
@@ -163,7 +164,7 @@
// 盈亏额度= (当前的币种的平仓价-下单时的建仓价)*购买的手数/规格*倍率
BigDecimal profitLossPrice = (closePrice
.subtract(order.getOpeningPrice()))
- .multiply(new BigDecimal(currentFlat + ""))
+ .multiply(new BigDecimal(currentFlat))
.multiply(symbolSku).setScale(8, BigDecimal.ROUND_DOWN);
MemberEntity memberEntity = memberService.getById(memberId);
@@ -486,7 +487,6 @@
* @param
*/
public void dealLimitBuyOrder(List<ContractEntrustOrderEntity> orderList) {
-
//List<CoinsCoinsOrder> orderList = orderMapper.selectOrderByBatchNo(batchno);
if (CollectionUtils.isNotEmpty(orderList)) {
ContractHoldOrderEntity contractHoldOrderEntity = null;
@@ -496,23 +496,21 @@
continue;
}
- contractHoldOrderEntity = new ContractHoldOrderEntity();
+ // 委托单bean转换为持仓单bean
+ contractHoldOrderEntity = ContractEntrustOrderEntityMapper.INSTANCE.entrustOrderToHoldOrder(coinsCoinsOrder);
+ contractHoldOrderEntity.setId(null);
Long memId = coinsCoinsOrder.getMemberId();
MemberEntity memberEntity = memberService.getById(memId);
BigDecimal entrustPrice = coinsCoinsOrder.getEntrustPrice();
int symbolCnt = coinsCoinsOrder.getSymbolCnt();
int type = coinsCoinsOrder.getEntrustType();
- //开仓价
- // Double openPrice = coinsCoinsOrder.getOpenPrice().doubleValue();
- //委托价
- // Double markPrice = coinsCoinsOrder.getMarkPrice();
+
if (type == 1) {
// 开多
contractHoldOrderEntity.setOpeningType(ContractHoldOrderEntity.OPENING_TYPE_MORE);
} else {
// 开空
contractHoldOrderEntity.setOpeningType(ContractHoldOrderEntity.OPENING_TYPE_LESS);
-
}
//持仓单赋值
@@ -534,10 +532,14 @@
contractHoldOrderEntity.setForceClosingPrice(forceSetPrice);
contractHoldOrderEntity.setLeverRatio(coinsCoinsOrder.getLeverRatio());
contractHoldOrderEntity.setOpeningPrice(entrustPrice);
+ contractHoldOrderEntity.setTradeType(ContractHoldOrderEntity.TRADE_TYPE_LIMIT);
contractHoldOrderService.save(contractHoldOrderEntity);
// 需要一个历史插入
ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(contractHoldOrderEntity);
+ contractOrderEntity.setEntrustOpeningPrice(coinsCoinsOrder.getEntrustPrice());
+ contractOrderEntity.setEntrustTime(coinsCoinsOrder.getCreateTime());
+ contractOrderEntity.setOpeningTime(new Date());
contractOrderEntity.setId(null);
contractOrderService.save(contractOrderEntity);
// 发送爆仓的队列
@@ -552,18 +554,11 @@
producer.sendPriceOperate(JSONObject.toJSONString(model));
}
// 扣除手续费
- //double totalBalance = wallet.getTotalBalance() - coinsCoinsOrder.getClosingPrice();
BigDecimal totalBalance = openFeePrice.negate();
-
- /** TradeSetting tradeSetting = tradeSettingCache.getTradeSetting();
-
- Double totalPayPrice = new BigDecimal(coinsCoinsOrder.getPrePrice()).add(new BigDecimal(coinsCoinsOrder.getClosingPrice())).add(new BigDecimal(coinsCoinsOrder.getClosingPrice()))
- .setScale(8, BigDecimal.ROUND_HALF_UP).doubleValue();
- totalBalance = totalBalance+(-totalPayPrice*(Double.valueOf(tradeSetting.getSpread())/10000));*/
-
+ contractEntrustOrderService.removeById(coinsCoinsOrder.getId());
memberWalletContractService.increaseWalletContractBalanceById(null, totalBalance, null, wallet.getId());
// TODO 531 待写
- calYj(memId, contractOrderEntity.getClosingFeeAmount(), contractOrderEntity, 1);
+ calYj(memId, openFeePrice, contractOrderEntity, 1);
}
}
}
--
Gitblit v1.9.1