From 1d32c206cc2c5815d43f03f17491bf933c5586d5 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 27 Aug 2020 17:57:22 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java | 38 +++++++++++++++++++++----------------- 1 files changed, 21 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java index acf60a0..30c5e5c 100644 --- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java @@ -180,7 +180,7 @@ MemberWalletContractEntity walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberEntity.getId(), CoinTypeConvert.convertContractTypeToCoin(submitEntrustDto.getSymbol())); - ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectWholeHoldOrderByOrderType(memberEntity.getId(), submitEntrustDto.getEntrustType()); + ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectWholeHoldOrderByOrderType(memberEntity.getId(), submitEntrustDto.getEntrustType(), submitEntrustDto.getSymbol()); BigDecimal bondAmount; BigDecimal openFeePrice; @@ -268,6 +268,10 @@ ContractOrderEntity orderEntity = ContractEntrustOrderEntityMapper.INSTANCE.entrustOrderToOrder(entrustOrderEntity); orderEntity.setTradeType(ContractOrderEntity.TRADE_TYPE_MARK_PRICE); orderEntity.setOrderStatus(ContractOrderEntity.ORDER_STATUS_CANCEL); + + if (entrustOrderEntity.getEntrustType() == ContractEntrustOrderEntity.ENTRUST_TYPE_CLOSE_LESS || entrustOrderEntity.getEntrustType() == ContractEntrustOrderEntity.ENTRUST_TYPE_CLOSE_MORE) { + orderEntity.setClosingType(entrustOrderEntity.getEntrustType()); + } int i = contractOrderDao.insert(orderEntity); contractEntrustOrderDao.deleteById(entrustOrderEntity.getId()); @@ -315,22 +319,22 @@ int closeType; if (holdOrderEntity.getOpeningType() == ContractHoldOrderEntity.OPENING_TYPE_MORE) { // 开多, 若委托价低于当前价则立即成交 -// if (submitCloseEntrustDto.getEntrustPrice().compareTo(newPrice) <= 0) { -// WholeCloseOrderDto wholeCloseOrderDto = new WholeCloseOrderDto(); -// wholeCloseOrderDto.setCount(submitCloseEntrustDto.getSymbolCnt()); -// wholeCloseOrderDto.setId(submitCloseEntrustDto.getId()); -// return contractHoldOrderService.cancelHoldOrder(wholeCloseOrderDto); -// } + if (submitCloseEntrustDto.getEntrustPrice().compareTo(newPrice) <= 0) { + WholeCloseOrderDto wholeCloseOrderDto = new WholeCloseOrderDto(); + wholeCloseOrderDto.setCount(submitCloseEntrustDto.getSymbolCnt()); + wholeCloseOrderDto.setId(submitCloseEntrustDto.getId()); + return contractHoldOrderService.cancelHoldOrder(wholeCloseOrderDto); + } closeType = ContractOrderEntity.ORDER_TYPE_CLOSE_MORE; } else { // 开空, 若委托价高于当前价则立即成交 -// if (submitCloseEntrustDto.getEntrustPrice().compareTo(newPrice) >= 0) { -// WholeCloseOrderDto wholeCloseOrderDto = new WholeCloseOrderDto(); -// wholeCloseOrderDto.setCount(submitCloseEntrustDto.getSymbolCnt()); -// wholeCloseOrderDto.setId(submitCloseEntrustDto.getId()); -// return contractHoldOrderService.cancelHoldOrder(wholeCloseOrderDto); -// } + if (submitCloseEntrustDto.getEntrustPrice().compareTo(newPrice) >= 0) { + WholeCloseOrderDto wholeCloseOrderDto = new WholeCloseOrderDto(); + wholeCloseOrderDto.setCount(submitCloseEntrustDto.getSymbolCnt()); + wholeCloseOrderDto.setId(submitCloseEntrustDto.getId()); + return contractHoldOrderService.cancelHoldOrder(wholeCloseOrderDto); + } closeType = ContractOrderEntity.ORDER_TYPE_CLOSE_LESS; } @@ -351,21 +355,21 @@ entrustOrder.setLeverRatio(holdOrderEntity.getLeverRatio()); entrustOrder.setSymbolSku(holdOrderEntity.getSymbolSku()); entrustOrder.setEntrustType(closeType); - entrustOrder.setSymbolCnt(holdOrderEntity.getSymbolCnt()); + entrustOrder.setSymbolCnt(submitCloseEntrustDto.getSymbolCnt()); entrustOrder.setSymbol(holdOrderEntity.getSymbol()); int i = contractEntrustOrderDao.insert(entrustOrder); - memberWalletContractDao.increaseWalletContractBalanceById(null, null, bondAmount, walletContract.getId()); +// memberWalletContractDao.increaseWalletContractBalanceById(null, null, bondAmount, walletContract.getId()); if (i > 0) { // 发送委托消息 if (holdOrderEntity.getOpeningType() == ContractEntrustOrderEntity.ENTRUST_TYPE_OPEN_MORE) { - OrderModel model = new OrderModel(holdOrderEntity.getId(), RabbitPriceTypeEnum.ENTRUST_CLOSE_MORE.getValue(), submitCloseEntrustDto.getEntrustPrice().setScale(8, RoundingMode.HALF_UP).toPlainString(), holdOrderEntity.getSymbol()); + OrderModel model = new OrderModel(entrustOrder.getId(), RabbitPriceTypeEnum.ENTRUST_CLOSE_MORE.getValue(), submitCloseEntrustDto.getEntrustPrice().setScale(8, RoundingMode.HALF_UP).toPlainString(), holdOrderEntity.getSymbol()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } else { - OrderModel model = new OrderModel(holdOrderEntity.getId(), RabbitPriceTypeEnum.ENTRUST_CLOSE_LESS.getValue(), submitCloseEntrustDto.getEntrustPrice().setScale(8, RoundingMode.HALF_UP).toPlainString(), holdOrderEntity.getSymbol()); + OrderModel model = new OrderModel(entrustOrder.getId(), RabbitPriceTypeEnum.ENTRUST_CLOSE_LESS.getValue(), submitCloseEntrustDto.getEntrustPrice().setScale(8, RoundingMode.HALF_UP).toPlainString(), holdOrderEntity.getSymbol()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } } -- Gitblit v1.9.1