Administrator
15 hours ago c4d7235172c0d4c451b3bd71d5520e15bf8fde66
refactor(symbols): 优化K线历史数据加载逻辑

- 移除了不必要的线程休眠逻辑
- 调整了日志输出内容,使用instId替换结果字符串
- 添加了数据内容的日志输出便于调试
- 统一了交易对ID的格式转换逻辑
1 files modified
9 ■■■■ changed files
src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java 9 ●●●● patch | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java
@@ -111,13 +111,7 @@
        synchronized (this) {
            //更新币币交易K线历史数据
            for (SymbolEnum symbol : SymbolEnum.values()) {
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    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;
@@ -126,9 +120,10 @@
                requestParam.put("bar",bar);
                requestParam.put("limit","300");
                String result = ExchangeLoginService.getInstance(ExchangeInfoEnum.OKX_UAT.name()).lineHistory(requestParam);
                log.info("加载OKX-KLINE,{}", result);
                log.info("加载OKX-KLINE,{}", instId);
                JSONObject json = JSON.parseObject(result);
                String data = json.getString("data");
                log.info("加载OKX-KLINE,{}", data);
                redisUtils.set("KINE_" + instId + "_" + time, data);
            }
        }