From 237d0b600b55ecbf3d4f241568862ae7b498e983 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Mon, 31 Aug 2020 18:51:12 +0800 Subject: [PATCH] modify entrsut open order when more/less/bomb/entrustClose --- src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java | 20 ++++++++++---------- 1 files changed, 10 insertions(+), 10 deletions(-) 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 94d6e76..f184fea 100644 --- a/src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java +++ b/src/main/java/com/xcong/excoin/rabbit/init/OrderProducerInit.java @@ -69,7 +69,7 @@ if (forceSetPrice != null) { if (forceSetPrice.compareTo(BigDecimal.ZERO) >= 0) { OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_MORE_BOMB.getValue(), forceSetPrice.toPlainString(), - order.getSymbol(), order.getOperateNo()); + order.getSymbol(), order.getOperateNo(), order.getMemberId()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } } @@ -79,7 +79,7 @@ if (stopLossPrice != null && stopLossPrice.compareTo(BigDecimal.ZERO) > 0) { OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_MORE_STOP_LESS.getValue(), stopLossPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } // 止盈 @@ -87,7 +87,7 @@ if (stopProfitPrice != null && stopProfitPrice.compareTo(BigDecimal.ZERO) > 0) { OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_MORE_STOP_PROFIT.getValue(), stopProfitPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } @@ -99,7 +99,7 @@ if (forceSetPrice != null) { if (forceSetPrice.compareTo(BigDecimal.ZERO) >= 0) { OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_LESS_BOMB.getValue(), forceSetPrice.toPlainString(), - order.getSymbol(), order.getOperateNo()); + order.getSymbol(), order.getOperateNo(), order.getMemberId()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } } @@ -109,7 +109,7 @@ if (stopLossPrice != null && stopLossPrice.compareTo(BigDecimal.ZERO) > 0) { OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_LESS_STOP_LESS.getValue(), stopLossPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } // 止盈 @@ -117,7 +117,7 @@ if (stopProfitPrice != null && stopProfitPrice.compareTo(BigDecimal.ZERO) > 0) { OrderModel model = new OrderModel(order.getId(), RabbitPriceTypeEnum.CLOSE_LESS_STOP_PROFIT.getValue(), stopProfitPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); producer.sendPriceOperate(JSONObject.toJSONString(model)); } } @@ -151,20 +151,20 @@ // 开多委托 model = new OrderModel(order.getId(), RabbitPriceTypeEnum.ENTRUST_OPEN_MORE.getValue(), entrustPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); } else if (ContractEntrustOrderEntity.ENTRUST_TYPE_OPEN_LESS == entrustType){ model = new OrderModel(order.getId(), RabbitPriceTypeEnum.ENTRUST_OPEN_LESS.getValue(), entrustPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); } else if (ContractEntrustOrderEntity.ENTRUST_TYPE_CLOSE_MORE == entrustType) { model = new OrderModel(order.getId(), RabbitPriceTypeEnum.ENTRUST_CLOSE_MORE.getValue(), entrustPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); } else { model = new OrderModel(order.getId(), RabbitPriceTypeEnum.ENTRUST_CLOSE_LESS.getValue(), entrustPrice.setScale(8, RoundingMode.HALF_UP).toPlainString(), - order.getSymbol()); + order.getSymbol(), order.getMemberId()); } producer.sendPriceOperate(JSONObject.toJSONString(model)); } -- Gitblit v1.9.1