modify

Helius

2020-08-25 2ddf12b246017ef1092b13fa6eb36c7476fbeda2

 src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java

@@ -617,6 +617,7 @@
        ContractHoldOrderEntity wholeHoldOrder = contractHoldOrderDao.selectWholeHoldOrderByOrderType(entrustOrder.getMemberId(), entrustOrder.getEntrustType());
        // 判断持仓是否存在，若不存在则创建新的持仓订单
        if (wholeHoldOrder == null) {
            log.info("持仓不存在");
            ContractHoldOrderEntity holdOrderEntity = ContractEntrustOrderEntityMapper.INSTANCE.entrustOrderToHoldOrder(entrustOrder);

            int type = entrustOrder.getEntrustType();
@@ -646,7 +647,7 @@

            if (isSuccess) {
                contractEntrustOrderService.removeById(entrustOrder.getId());
                memberWalletContractService.increaseWalletContractBalanceById(null, entrustOrder.getBondAmount().add(openFeePrice).negate(), entrustOrder.getBondAmount().negate(), wallet.getId());
                memberWalletContractService.increaseWalletContractBalanceById(null, openFeePrice.negate(), entrustOrder.getBondAmount().negate(), wallet.getId());

                // 发送强平价
                ThreadPoolUtils.sendWholeForceClosingPrice(entrustOrder.getSymbol(), member);
@@ -658,6 +659,7 @@
            return;
        }

        log.info("持仓存在");
        ContractOrderEntity contractOrderEntity = ContractHoldOrderEntityMapper.INSTANCE.holdOrderToOrder(wholeHoldOrder);
        contractOrderEntity.setBondAmount(entrustOrder.getBondAmount().add(openFeePrice));
        contractOrderEntity.setOpeningPrice(entrustOrder.getEntrustPrice());
@@ -670,23 +672,23 @@
        BigDecimal totalPrice = entrustOrder.getEntrustPrice().multiply(BigDecimal.valueOf(entrustOrder.getSymbolCnt()));
        BigDecimal newOpenPrice = totalPrice.add(wholeHoldOrder.getOpeningPrice().multiply(BigDecimal.valueOf(wholeHoldOrder.getSymbolCnt()))).divide(BigDecimal.valueOf(entrustOrder.getSymbolCnt() + wholeHoldOrder.getSymbolCntSale()), 8, BigDecimal.ROUND_DOWN);
        // 保证金
        BigDecimal bondAmount = CalculateUtil.getBondAmount(newOpenPrice, entrustOrder.getSymbolSku(), entrustOrder.getSymbolCnt() + wholeHoldOrder.getSymbolCntSale(), entrustOrder.getLeverRatio());
        BigDecimal bondAmount = entrustOrder.getBondAmount();
        // 手续费
        BigDecimal fee = openFeePrice.add(wholeHoldOrder.getOpeningFeeAmount());
        BigDecimal fee = CalculateUtil.getOpenFeePrice(entrustOrder.getEntrustPrice(), entrustOrder.getSymbolSku(), entrustOrder.getSymbolCnt(), tradeSettingEntity.getFeeRatio());
        // 预付款
        BigDecimal prePaymentAmount = bondAmount.add(fee).add(fee);
        BigDecimal prePaymentAmount = wholeHoldOrder.getPrePaymentAmount().add(entrustOrder.getEntrustAmount());

        wholeHoldOrder.setSymbolCnt(wholeHoldOrder.getSymbolCnt() + entrustOrder.getSymbolCnt());
        wholeHoldOrder.setSymbolCntSale(wholeHoldOrder.getSymbolCntSale() + entrustOrder.getSymbolCnt());
        wholeHoldOrder.setOpeningFeeAmount(wholeHoldOrder.getOpeningFeeAmount().add(openFeePrice));
        wholeHoldOrder.setOpeningFeeAmount(wholeHoldOrder.getOpeningFeeAmount().add(fee));
        wholeHoldOrder.setOpeningPrice(newOpenPrice);
        wholeHoldOrder.setBondAmount(bondAmount);
        wholeHoldOrder.setBondAmount(wholeHoldOrder.getBondAmount().add(bondAmount));
        wholeHoldOrder.setPrePaymentAmount(prePaymentAmount);
        wholeHoldOrder.setOperateNo(wholeHoldOrder.getOperateNo() + 1);
        contractHoldOrderService.save(wholeHoldOrder);
        contractHoldOrderService.updateById(wholeHoldOrder);

        contractEntrustOrderService.removeById(entrustOrder.getId());
        memberWalletContractService.increaseWalletContractBalanceById(null, entrustOrder.getBondAmount().add(openFeePrice).negate(), entrustOrder.getBondAmount().negate(), wallet.getId());
        memberWalletContractService.increaseWalletContractBalanceById(null, openFeePrice.negate(), entrustOrder.getBondAmount().negate(), wallet.getId());

        // 发送强平价
        ThreadPoolUtils.sendWholeForceClosingPrice(entrustOrder.getSymbol(), member);