From fae2bc53d7baca6350ee457e623030ef9f2e2f37 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 24 Dec 2025 13:34:11 +0800
Subject: [PATCH] fix(okxNewPrice): 修正K线数据获取逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java | 8 ++++----
1 files changed, 4 insertions(+), 4 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 5d2b25e..85e6d6e 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java
@@ -340,7 +340,7 @@
List<Kline> kline15MinuteData = getKlineDataByInstIdAndBar(instId, "15m");
//stream流获取kline15MinuteData中的o数据的集合
List<BigDecimal> prices = kline15MinuteData.stream()
- .map(Kline::getO)
+ .map(Kline::getC)
.collect(Collectors.toList());
// 生成对应的高、低、收盘价数据
@@ -381,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