From 71bc137f5a10f099230cbc0cfb1687ad5fe467fb Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Tue, 11 Aug 2020 11:27:16 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/member/entity/MemberEntity.java | 5 ++ src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java | 47 ++++++++++++++++++++++- src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java | 8 +++ src/main/java/com/xcong/excoin/modules/contract/service/ContractHoldOrderService.java | 4 ++ 4 files changed, 60 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java b/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java index 5edbdec..bdd2674 100644 --- a/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java +++ b/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java @@ -115,10 +115,16 @@ return contractHoldOrderService.findOrderDetailById(id); } - @ApiOperation(value = "全仓模式平仓") + @ApiOperation(value = "全仓模式 - 平仓") @PostMapping(value = "/closingOrder") public Result closingOrder(@RequestBody @Validated WholeCloseOrderDto wholeCloseOrderDto) { return null; } + @ApiOperation(value = "全仓模式 - 变更仓位类型") + @GetMapping(value = "/changePositionType") + public Result changePositionType() { + return contractHoldOrderService.changePositionType(); + } + } diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/ContractHoldOrderService.java b/src/main/java/com/xcong/excoin/modules/contract/service/ContractHoldOrderService.java index 2f71589..a9efce4 100644 --- a/src/main/java/com/xcong/excoin/modules/contract/service/ContractHoldOrderService.java +++ b/src/main/java/com/xcong/excoin/modules/contract/service/ContractHoldOrderService.java @@ -26,6 +26,8 @@ public Result cancelHoldOrder(Long id); + public Result cancelHoldOrder(WholeCloseOrderDto wholeCloseOrderDto); + public Result cancelHoldOrderBatch(SymbolDto symbolDto); public Result setTargetProfitOrLess(ProfitOrLessDto profitOrLessDto); @@ -44,4 +46,6 @@ public void calHoldOrderHoldFeeAmount(); + public Result changePositionType(); + } diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java index 2ea272f..96fc875 100644 --- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java +++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java @@ -313,11 +313,13 @@ MemberEntity memberEntity = LoginUserUtils.getAppLoginUser(); ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectHoldOrderByMemberIdAndId(memberEntity.getId(), id); if (holdOrderEntity == null) { - return Result.fail("订单不存在"); + // 订单不存在 + return Result.fail(MessageSourceUtils.getString("order_service_0027")); } if (ContractHoldOrderEntity.ORDER_CAN_CLOSING_N == holdOrderEntity.getIsCanClosing()) { - return Result.fail("订单暂不可平仓"); + // 该订单暂不能平仓 + return Result.fail(MessageSourceUtils.getString("order_service_0045")); } contractHoldOrderDao.updateHoldOrderIsCanClosingById(ContractHoldOrderEntity.ORDER_CAN_CLOSING_N, id); @@ -326,7 +328,31 @@ ids.add(id); producer.sendCloseTrade(JSONObject.toJSONString(ids)); - return Result.ok("平仓成功"); + // 平仓成功 + return Result.ok(MessageSourceUtils.getString("order_service_0044")); + } + + @Override + public Result cancelHoldOrder(WholeCloseOrderDto wholeCloseOrderDto) { + MemberEntity memberEntity = LoginUserUtils.getAppLoginUser(); + ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectHoldOrderByMemberIdAndId(memberEntity.getId(), wholeCloseOrderDto.getId()); + if (holdOrderEntity == null) { + // 订单不存在 + return Result.fail(MessageSourceUtils.getString("order_service_0027")); + } + + if (ContractHoldOrderEntity.ORDER_CAN_CLOSING_N == holdOrderEntity.getIsCanClosing()) { + // 该订单暂不能平仓 + return Result.fail(MessageSourceUtils.getString("order_service_0045")); + } + + if (wholeCloseOrderDto.getCount() > holdOrderEntity.getSymbolCntSale()) { + return Result.fail("可平张数不足"); + } + + holdOrderEntity.setSymbolCntSale(holdOrderEntity.getSymbolCntSale() - wholeCloseOrderDto.getCount()); + contractHoldOrderDao.updateById(holdOrderEntity); + return null; } @Override @@ -679,4 +705,19 @@ } producer.sendPriceOperate(JSONObject.toJSONString(model)); } + + @Override + public Result changePositionType() { + MemberEntity member = LoginUserUtils.getAppLoginUser(); + Integer positionType = member.getContractPositionType() == ContractEntrustOrderEntity.POSITION_TYPE_ADD ? ContractEntrustOrderEntity.POSITION_TYPE_ALL : ContractEntrustOrderEntity.POSITION_TYPE_ADD; + MemberEntity updateEntity = new MemberEntity(); + updateEntity.setContractPositionType(positionType); + updateEntity.setId(member.getId()); + int i = memberDao.updateById(updateEntity); + if (i > 0) { + LoginUserUtils.resetAppLoginUser(member); + return Result.ok(MessageSourceUtils.getString("member_service_0040")); + } + return Result.fail(MessageSourceUtils.getString("member_service_0041")); + } } diff --git a/src/main/java/com/xcong/excoin/modules/member/entity/MemberEntity.java b/src/main/java/com/xcong/excoin/modules/member/entity/MemberEntity.java index 1a81f6c..4e06b62 100644 --- a/src/main/java/com/xcong/excoin/modules/member/entity/MemberEntity.java +++ b/src/main/java/com/xcong/excoin/modules/member/entity/MemberEntity.java @@ -173,4 +173,9 @@ * 强平系数 */ private BigDecimal forceParam; + + /** + * 合约仓位类型 + */ + private Integer contractPositionType; } -- Gitblit v1.9.1