From 8d84a90a076676dfeb80b1882029895d28e9b238 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 07 May 2026 13:10:23 +0800
Subject: [PATCH] fix(okxWs): 修复OKX生产环境配置的调试模式设置
---
src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java | 19 ++-----------------
1 files changed, 2 insertions(+), 17 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 42f639f..ca59116 100644
--- a/src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/gateApi/GateKlineWebSocketClient.java
@@ -351,9 +351,9 @@
BigDecimal vol = new BigDecimal(data.getString("v"));
BigDecimal baseVol = new BigDecimal(data.getString("a"));
String name = data.getString("n");
- long tsSeconds = data.getLong("t");
+ long t = data.getLong("t");
boolean windowClosed = data.getBooleanValue("w");
- String time = DateUtil.TimeStampToDateTime(tsSeconds * 1000);
+ String time = DateUtil.TimeStampToDateTime(t);
System.out.println("========== Gate K线数据 ==========");
System.out.println("名称(n): " + name);
@@ -366,21 +366,6 @@
System.out.println("成交额(a): " + baseVol);
System.out.println("K线完结(w): " + windowClosed);
System.out.println("==================================");
-
- if (windowClosed) {
- MacdEmaStrategy strategy = new MacdEmaStrategy();
-
- List<Kline> kline1MinuteData = getKlineDataByInstIdAndBar(CoinEnums.HE_YUE.getCode(), "1m");
- List<BigDecimal> historicalPrices1M = kline1MinuteData.stream()
- .map(Kline::getC)
- .collect(Collectors.toList());
-
- MacdEmaStrategy.TradingOrder tradingOrderOpenOpen = strategy.generateTradingOrder(historicalPrices1M, MacdMaStrategy.OperationType.open.name());
- if (tradingOrderOpenOpen == null) {
- return;
- }
-
- }
} catch (Exception e) {
log.error("处理 K线频道推送数据失败", e);
}
--
Gitblit v1.9.1