From 9eed388bf3c07dc0ea24fb0637b4964c8e387437 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 22 Dec 2025 16:45:43 +0800
Subject: [PATCH] fix(symbols): 修复K线数据获取逻辑

---
 src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java |   50 ++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 44 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java b/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java
index 586fa07..d5a5771 100644
--- a/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java
+++ b/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java
@@ -53,6 +53,44 @@
         }
     }
 
+    public static String convertToCoinKlineKey(String symbol) {
+        switch (symbol) {
+            case "BTC/USDT":
+                return "BTC-USDT";
+            case "ETH/USDT":
+                return "ETH-USDT";
+            case "XRP/USDT":
+                return "XRP-USDT";
+            case "LTC/USDT":
+                return "LTC-USDT";
+            case "BCH/USDT":
+                return "BCH-USDT";
+            case "ETC/USDT":
+                return "ETC-USDT";
+            default:
+                return null;
+        }
+    }
+
+    public static String convertToKlineKey(String symbol) {
+        switch (symbol) {
+            case "BTC/USDT":
+                return "BTC-USDT-SWAP";
+            case "ETH/USDT":
+                return "ETH-USDT-SWAP";
+            case "XRP/USDT":
+                return "XRP-USDT-SWAP";
+            case "LTC/USDT":
+                return "LTC-USDT-SWAP";
+            case "BCH/USDT":
+                return "BCH-USDT-SWAP";
+            case "ETC/USDT":
+                return "ETC-USDT-SWAP";
+            default:
+                return null;
+        }
+    }
+
 
 
     public static String convertToOpenKey(String symbol) {
@@ -79,17 +117,17 @@
     public static String convertToVolumeKey(String symbol) {
         switch (symbol) {
             case "BTC/USDT":
-                return "volume:BTC_NEW_PRICE";
+                return "volume:PRICE_BTCUSDTSWAP";
             case "ETH/USDT":
-                return "volume:ETH_NEW_PRICE";
+                return "volume:PRICE_ETHUSDTSWAP";
             case "XRP/USDT":
-                return "volume:XRP_NEW_PRICE";
+                return "volume:PRICE_XRPUSDTSWAP";
             case "LTC/USDT":
-                return "volume:LTC_NEW_PRICE";
+                return "volume:PRICE_LTCUSDTSWAP";
             case "BCH/USDT":
-                return "volume:BCH_NEW_PRICE";
+                return "volume:PRICE_BCHUSDTSWAP";
             case "ETC/USDT":
-                return "volume:ETC_NEW_PRICE";
+                return "volume:PRICE_ETCUSDTSWAP";
             default:
                 return null;
         }

--
Gitblit v1.9.1