From 91c4a7a84f91518604a12cff816ff3f4e670477b Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 07 May 2026 17:30:51 +0800
Subject: [PATCH] refactor(gateApi): 简化 K线回调方法参数
---
src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java | 10 ++++------
1 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java b/src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java
index 8d2f655..e9636de 100644
--- a/src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java
@@ -58,7 +58,7 @@
private static final String FUTURES_PING = "futures.ping";
private static final String FUTURES_PONG = "futures.pong";
private static final String GATE_INTERVAL = "1m";
- private static final String GATE_CONTRACT = "XAU_USDT";
+ private static final String GATE_CONTRACT = "XAUT_USDT";
private GateGridTradeService gridTradeService;
@@ -74,14 +74,12 @@
public GateKlineWebSocketClient(CaoZuoService caoZuoService,
GateWebSocketClientManager clientManager,
- WangGeListService wangGeListService
+ WangGeListService wangGeListService,
+ GateGridTradeService gridTradeService
) {
this.caoZuoService = caoZuoService;
this.clientManager = clientManager;
this.wangGeListService = wangGeListService;
- }
-
- public void setGridTradeService(GateGridTradeService gridTradeService) {
this.gridTradeService = gridTradeService;
}
@@ -374,7 +372,7 @@
log.info("==================================");
if (gridTradeService != null) {
- gridTradeService.onKline(closePx, windowClosed);
+ gridTradeService.onKline(closePx);
}
} catch (Exception e) {
log.error("处理 K线频道推送数据失败", e);
--
Gitblit v1.9.1