From 3129b41924bf541e5157ee30ceaf70ee5496f30e Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Wed, 19 Aug 2020 17:08:34 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java | 3 ++- src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java | 8 +++++--- src/main/java/com/xcong/excoin/utils/CalculateUtil.java | 2 +- 3 files changed, 8 insertions(+), 5 deletions(-) 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 cc77bc4..d29143d 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 @@ -556,6 +556,7 @@ return Result.fail("可平张数不足"); } + log.info("--->{},{}", holdOrderEntity.getSymbolCntSale(), wholeCloseOrderDto.getCount()); // 判断当前持仓张数是否等于平仓张数,若等于则直接更新该订单为不可平状态,否则更新可平张数 if (wholeCloseOrderDto.getCount() == holdOrderEntity.getSymbolCntSale()) { contractHoldOrderDao.updateHoldOrderIsCanClosingById(ContractHoldOrderEntity.ORDER_CAN_CLOSING_N, wholeCloseOrderDto.getId()); @@ -571,7 +572,7 @@ // 发送平仓消息 List<Long> ids = new ArrayList<>(); ids.add(wholeCloseOrderDto.getId()); - producer.sendCloseTrade(JSONObject.toJSONString(ids)); +// producer.sendCloseTrade(JSONObject.toJSONString(ids)); // 平仓成功 return Result.ok(MessageSourceUtils.getString("order_service_0044")); diff --git a/src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java b/src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java index 25638d8..6b78a59 100644 --- a/src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java +++ b/src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java @@ -59,9 +59,11 @@ // 爆仓价 BigDecimal forceSetPrice = order.getForceClosingPrice(); if (forceSetPrice != null) { - OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_MORE_BOMB.getValue(), forceSetPrice.toPlainString(), - order.getSymbol(), order.getOperateNo()); - producer.sendPriceOperate(JSONObject.toJSONString(model)); + if (forceSetPrice.compareTo(BigDecimal.ZERO) >= 0) { + OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_MORE_BOMB.getValue(), forceSetPrice.toPlainString(), + order.getSymbol(), order.getOperateNo()); + producer.sendPriceOperate(JSONObject.toJSONString(model)); + } } // 止损 BigDecimal stopLossPrice = order.getStopLossPrice(); diff --git a/src/main/java/com/xcong/excoin/utils/CalculateUtil.java b/src/main/java/com/xcong/excoin/utils/CalculateUtil.java index 841beee..5b4a8cd 100644 --- a/src/main/java/com/xcong/excoin/utils/CalculateUtil.java +++ b/src/main/java/com/xcong/excoin/utils/CalculateUtil.java @@ -146,7 +146,7 @@ holdOrderDao.updateById(updateHoldOrder); if (forceSetPrice.compareTo(BigDecimal.ZERO) >= 0) { - sendOrderBombMsg(updateHoldOrder.getId(), updateHoldOrder.getOpeningType(), forceSetPrice, updateHoldOrder.getSymbol(), updateHoldOrder.getOperateNo()); +// sendOrderBombMsg(updateHoldOrder.getId(), updateHoldOrder.getOpeningType(), forceSetPrice, updateHoldOrder.getSymbol(), updateHoldOrder.getOperateNo()); } } } else { -- Gitblit v1.9.1