From 49b96dc04a24b93185c09de4b61d9539a5e77990 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 29 Oct 2020 10:51:42 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java | 34 ++++++++++++++++++++++++++++------
1 files changed, 28 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java b/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
index 23168f6..a32cd9f 100644
--- a/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
+++ b/src/main/java/com/xcong/excoin/rabbit/pricequeue/WebsocketPriceService.java
@@ -77,16 +77,25 @@
}
- private void addExecType(OrderModel model) {
+ private boolean addExecType(OrderModel model) {
List<Object> orderTypes = redisUtils.lGet(AppContants.RABBIT_TYPE + model.getOrderId(), 0 , -1);
+// if (CollUtil.isNotEmpty(orderTypes)) {
+// orderTypes.add(model.getType());
+// } else {
+// orderTypes = new ArrayList<>();
+// orderTypes.add(model.getType());
+// }
+
if (CollUtil.isNotEmpty(orderTypes)) {
- orderTypes.add(model.getType());
- } else {
- orderTypes = new ArrayList<>();
- orderTypes.add(model.getType());
+ log.info("存在止盈/止损/爆仓:{} -- {}",model, orderTypes);
+ return false;
}
+ orderTypes = new ArrayList<>();
+ orderTypes.add(model.getType());
redisUtils.lSet(AppContants.RABBIT_TYPE + model.getOrderId(), orderTypes, 10);
+ redisUtils.lSet(AppContants.MEMBER_TYPE + model.getMemberId(), orderTypes, 5);
+ return true;
}
// 处理消息 正序的 包括
@@ -122,7 +131,10 @@
2、全仓: 止盈价/止损价 设置的与委托平仓价相同，需优先处理止盈/止损
解决: 将订单ID作为Key, 该订单执行的队列类型集合作为value, 用于在执行爆仓、委托平仓时，是否存在止盈/止损，若存在则不执行该爆仓和委托平仓
*/
- addExecType(model);
+ boolean b = addExecType(model);
+ if (!b) {
+ continue;
+ }
// 止损平空
List<OrderModel> kkzsList = new ArrayList<OrderModel>();
@@ -204,6 +216,16 @@
// 2：开多6:爆仓平多
// 10：止盈平空11：止损平多
for (OrderModel model : orderModelList) {
+ /*
+ 问题: 1、逐仓: 当行情大时，若设置的止损点与爆仓过于接近，则可能会出现直接爆仓，而不止损的情况
+ 2、全仓: 止盈价/止损价 设置的与委托平仓价相同，需优先处理止盈/止损
+ 解决: 将订单ID作为Key, 该订单执行的队列类型集合作为value, 用于在执行爆仓、委托平仓时，是否存在止盈/止损，若存在则不执行该爆仓和委托平仓
+ */
+ boolean b = addExecType(model);
+ if (!b) {
+ continue;
+ }
+
// 开空止盈
List<OrderModel> kkzyList = new ArrayList<OrderModel>();
// 开多止损
--
Gitblit v1.9.1