refactor(utils): 更新币种成交量键值映射规则

Administrator

2 days ago 6dcaa1d6d256cd7de744a04b2576111c1a7902c7

refactor(utils): 更新币种成交量键值映射规则

- 修改 BTC/USDT 成交量键值为 volume:PRICE_BTCUSDTSWAP
- 修改 ETH/USDT 成交量键值为 volume:PRICE_ETHUSDTSWAP
- 修改 XRP/USDT 成交量键值为 volume:PRICE_XRPUSDTSWAP
- 修改 LTC/USDT 成交量键值为 volume:PRICE_LTCUSDTSWAP
- 修改 BCH/USDT 成交量键值为 volume:PRICE_BCHUSDTSWAP
- 修改 ETC/USDT 成交量键值为 volume:PRICE_ETCUSDTSWAP
- 移除重复的成交量键值设置逻辑

 src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java

@@ -327,11 +327,6 @@
                            String redisKey = "volume:" + buildRedisKey(instId);
                            redisUtils.set(redisKey, oiUsd);

                            String symbol = CoinTypeConvert.okxConvert(instId);
                            if (symbol != null) {
                                redisUtils.set(CoinTypeConvert.convertToVolumeKey(symbol), oiUsd);
                            }

                            log.debug("更新持仓量: {} = {}, 时间: {}", redisKey, oiUsd, ts);
                        } catch (Exception innerEx) {
                            log.warn("处理单条价格数据失败", innerEx);

 src/main/java/com/xcong/excoin/utils/CoinTypeConvert.java

@@ -79,17 +79,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;
        }