From 4097ef07c0b62e4b2120d5296d3d86b9bfbd487e Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 23 Sep 2026 11:48:47 +0800
Subject: [PATCH] feat(stations): 添加止盈触发对向加仓功能
---
src/main/java/com/xcong/excoin/modules/station/service/impl/StationServiceImpl.java | 39 ++++++++++++++++++++++++++++++++++++++-
1 files changed, 38 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/station/service/impl/StationServiceImpl.java b/src/main/java/com/xcong/excoin/modules/station/service/impl/StationServiceImpl.java
index 8bc76bd..0623e2e 100644
--- a/src/main/java/com/xcong/excoin/modules/station/service/impl/StationServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/station/service/impl/StationServiceImpl.java
@@ -67,6 +67,38 @@
cmdProducer.sendCommand(apiKeyMd5, "UPDATE_CONFIG", JSON.toJSONString(params));
}
+ // ==================== 手动控制指令 ====================
+
+ @Override
+ public void cancelLongTpSl(String apiKeyMd5) {
+ cmdProducer.sendCommand(apiKeyMd5, "CANCEL_LONG_TP_SL");
+ }
+
+ @Override
+ public void cancelShortTpSl(String apiKeyMd5) {
+ cmdProducer.sendCommand(apiKeyMd5, "CANCEL_SHORT_TP_SL");
+ }
+
+ @Override
+ public void rebuildLongTpSl(String apiKeyMd5) {
+ cmdProducer.sendCommand(apiKeyMd5, "REBUILD_LONG_TP_SL");
+ }
+
+ @Override
+ public void rebuildShortTpSl(String apiKeyMd5) {
+ cmdProducer.sendCommand(apiKeyMd5, "REBUILD_SHORT_TP_SL");
+ }
+
+ @Override
+ public void closeLong(String apiKeyMd5) {
+ cmdProducer.sendCommand(apiKeyMd5, "CLOSE_LONG");
+ }
+
+ @Override
+ public void closeShort(String apiKeyMd5) {
+ cmdProducer.sendCommand(apiKeyMd5, "CLOSE_SHORT");
+ }
+
// ==================== 别名 ====================
@Override
@@ -209,8 +241,13 @@
if (params.containsKey("addPositionQuantity")) status.setAddPositionQuantity(intVal(params.get("addPositionQuantity")));
if (params.containsKey("maxPositionPerSide")) status.setMaxPositionPerSide(intVal(params.get("maxPositionPerSide")));
if (params.containsKey("addPositionStartThreshold")) status.setAddPositionStartThreshold(intVal(params.get("addPositionStartThreshold")));
- if (params.containsKey("placeExcessTakeProfit")) status.setPlaceExcessTakeProfit(boolVal(params.get("placeExcessTakeProfit")));
+ if (params.containsKey("placeExcessTakeProfit")) status.setPlaceExcessTakeProfit(str(params.get("placeExcessTakeProfit")));
if (params.containsKey("priceDriveEnabled")) status.setPriceDriveEnabled(boolVal(params.get("priceDriveEnabled")));
+ if (params.containsKey("dualStopLossEnabled")) status.setDualStopLossEnabled(boolVal(params.get("dualStopLossEnabled")));
+ if (params.containsKey("longStopLossPrice")) status.setLongStopLossPrice(str(params.get("longStopLossPrice")));
+ if (params.containsKey("shortStopLossPrice")) status.setShortStopLossPrice(str(params.get("shortStopLossPrice")));
+ if (params.containsKey("tpTriggerOppositeAddEnabled")) status.setTpTriggerOppositeAddEnabled(boolVal(params.get("tpTriggerOppositeAddEnabled")));
+ if (params.containsKey("tpTriggerOppositeAddQuantity")) status.setTpTriggerOppositeAddQuantity(intVal(params.get("tpTriggerOppositeAddQuantity")));
if (params.containsKey("rounds")) status.setTotalRounds(intVal(params.get("rounds")));
if (params.containsKey("principal")) status.setPrincipal(str(params.get("principal")));
}
--
Gitblit v1.9.1