From d5416fa89d656f66779b722edd6710f6272a356c Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 23 Dec 2025 17:11:53 +0800
Subject: [PATCH] refactor(okxNewPrice): 优化K线数据处理逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java | 13 ++++++-------
1 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java
index 424fc76..347845a 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java
@@ -57,7 +57,8 @@
private final AtomicBoolean isConnecting = new AtomicBoolean(false);
private final AtomicBoolean isInitialized = new AtomicBoolean(false);
- private static final String CHANNEL = "candle15m";
+ private static final String CHANNEL = "candle5m";
+// private static final String CHANNEL = "candle15m";
// 心跳超时时间(秒)，小于30秒
private static final int HEARTBEAT_TIMEOUT = 10;
@@ -349,9 +350,7 @@
List<BigDecimal> low = kline15MinuteData.stream()
.map(Kline::getL)
.collect(Collectors.toList());
- List<BigDecimal> close = kline15MinuteData.stream()
- .map(Kline::getC)
- .collect(Collectors.toList());
+ List<BigDecimal> close = prices;
// 生成成交量数据
List<BigDecimal> volume = kline15MinuteData.stream()
@@ -382,9 +381,9 @@
// 确定市场方向
TradingStrategy.Direction direction = tradingStrategy.getDirection(prices, high, low, close, currentPrice);
System.out.println("市场方向（15分钟）: " + direction);
- if (direction == TradingStrategy.Direction.RANGING){
- return;
- }
+// if (direction == TradingStrategy.Direction.RANGING){
+// return;
+// }
/**
* 获取当前网格信息
--
Gitblit v1.9.1