From 6dcaa1d6d256cd7de744a04b2576111c1a7902c7 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Fri, 12 Dec 2025 15:40:41 +0800
Subject: [PATCH] refactor(utils): 更新币种成交量键值映射规则

---
 src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java |   55 +++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 51 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java b/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java
index d9babcb..b60c94e 100644
--- a/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java
+++ b/src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java
@@ -18,13 +18,20 @@
                 return "LTC/USDT";
             case "bchusdt":
                 return "BCH/USDT";
-            case "eosusdt":
-                return "EOS/USDT";
             case "etcusdt":
                 return "ETC/USDT";
             default:
                 return null;
         }
+    }
+
+    public static String okxConvert(String symbol) {
+        //将xxx-USDT转换成xxx/USDT
+        if (symbol.contains("-")) {
+            symbol = symbol.replace("-", "/");
+        }
+
+        return symbol;
     }
 
     public static String convertToKey(String symbol) {
@@ -39,8 +46,6 @@
                 return "LTC_NEW_PRICE";
             case "BCH/USDT":
                 return "BCH_NEW_PRICE";
-            case "EOS/USDT":
-                return "EOS_NEW_PRICE";
             case "ETC/USDT":
                 return "ETC_NEW_PRICE";
             default:
@@ -48,6 +53,48 @@
         }
     }
 
+
+
+    public static String convertToOpenKey(String symbol) {
+        switch (symbol) {
+            case "BTC/USDT":
+                return "open:BTC_NEW_PRICE";
+            case "ETH/USDT":
+                return "open:ETH_NEW_PRICE";
+            case "XRP/USDT":
+                return "open:XRP_NEW_PRICE";
+            case "LTC/USDT":
+                return "open:LTC_NEW_PRICE";
+            case "BCH/USDT":
+                return "open:BCH_NEW_PRICE";
+            case "ETC/USDT":
+                return "open:ETC_NEW_PRICE";
+            default:
+                return null;
+        }
+    }
+
+
+
+    public static String convertToVolumeKey(String symbol) {
+        switch (symbol) {
+            case "BTC/USDT":
+                return "volume:PRICE_BTCUSDTSWAP";
+            case "ETH/USDT":
+                return "volume:PRICE_ETHUSDTSWAP";
+            case "XRP/USDT":
+                return "volume:PRICE_XRPUSDTSWAP";
+            case "LTC/USDT":
+                return "volume:PRICE_LTCUSDTSWAP";
+            case "BCH/USDT":
+                return "volume:PRICE_BCHUSDTSWAP";
+            case "ETC/USDT":
+                return "volume:PRICE_ETCUSDTSWAP";
+            default:
+                return null;
+        }
+    }
+
     public static String convertContractTypeToCoin(String symbol) {
         if (symbol.indexOf("/") > 0) {
             return symbol.substring(0, symbol.indexOf("/"));

--
Gitblit v1.9.1