From e9f583d2001eddac955a830405519fdfbabc059c Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 30 Sep 2026 16:42:16 +0800
Subject: [PATCH] feat(gateApi): 添加基础仓位止盈网格功能
---
src/main/java/com/xcong/excoin/modules/station/service/impl/StationServiceImpl.java | 72 +++++++++++++++++++++++++++++++++++
1 files changed, 71 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 86a8b68..9cba72e 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
@@ -2,6 +2,7 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xcong.excoin.modules.station.dao.StrategyEventLogDao;
import com.xcong.excoin.modules.station.dao.StrategyStatusDao;
@@ -64,6 +65,68 @@
persistConfig(apiKeyMd5, params);
// 2. 发送 MQ 命令，通知 JAR（需手动点击「启动」才生效）
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
+ public void saveAlias(String apiKeyMd5, String alias) {
+ String cleaned = alias == null ? "" : alias.trim();
+ String value = cleaned.isEmpty() ? null : cleaned;
+
+ StrategyStatus existing = strategyStatusDao.selectByApiKeyMd5(apiKeyMd5);
+ if (existing != null) {
+ // 用 UpdateWrapper 显式 set，支持把别名更新为 null（清除）
+ LambdaUpdateWrapper<StrategyStatus> wrapper = new LambdaUpdateWrapper<>();
+ wrapper.eq(StrategyStatus::getApiKeyMd5, apiKeyMd5)
+ .set(StrategyStatus::getAliasName, value);
+ strategyStatusDao.update(null, wrapper);
+ } else if (value != null) {
+ // 实例尚无状态记录（未启动过），仅创建一条只含别名的记录
+ StrategyStatus status = new StrategyStatus();
+ status.setApiKeyMd5(apiKeyMd5);
+ status.setAliasName(value);
+ status.setCreateTime(new Date());
+ strategyStatusDao.insert(status);
+ }
+ }
+
+ @Override
+ public String getAlias(String apiKeyMd5) {
+ StrategyStatus status = strategyStatusDao.selectByApiKeyMd5(apiKeyMd5);
+ return status == null ? null : status.getAliasName();
}
// ==================== 事件落库 ====================
@@ -178,8 +241,15 @@
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("baseTakeProfitPerGrid")) status.setBaseTakeProfitPerGrid(str(params.get("baseTakeProfitPerGrid")));
+ if (params.containsKey("baseTakeProfitGridCount")) status.setBaseTakeProfitGridCount(intVal(params.get("baseTakeProfitGridCount")));
if (params.containsKey("rounds")) status.setTotalRounds(intVal(params.get("rounds")));
if (params.containsKey("principal")) status.setPrincipal(str(params.get("principal")));
}
--
Gitblit v1.9.1