From 381b104913b1f2874aade5e16db7f3f49003b70c Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Fri, 26 Dec 2025 10:05:22 +0800
Subject: [PATCH] refactor(symbols): 简化K线数据存储逻辑
---
src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java | 8 +++-----
1 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java b/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java
index 7c8b91d..a7b0c27 100644
--- a/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java
@@ -117,8 +117,9 @@
e.printStackTrace();
}
String[] symbols = symbol.getValue().toLowerCase().split("/");
-
+ log.info("加载OKX-KLINE，{}", symbols[0] +"-"+ symbols[1]);
String instId = symbols[0] +"-"+ symbols[1];
+ instId = instId.toUpperCase() ;
String bar = time;
LinkedHashMap<String, Object> requestParam = new LinkedHashMap<>();
requestParam.put("instId",instId);
@@ -128,10 +129,7 @@
log.info("加载OKX-KLINE，{}", result);
JSONObject json = JSON.parseObject(result);
String data = json.getString("data");
- List<String[]> klinesList = JSON.parseArray(data, String[].class);
- if (klinesList != null) {
- redisUtils.set("KINE_" + instId + "_" + time, klinesList);
- }
+ redisUtils.set("KINE_" + instId + "_" + time, data);
}
}
}
--
Gitblit v1.9.1