CPV配置

zainali5120

2020-09-28 40ddd61501370f68ec0eea0e0883a59eb301e952

 src/main/java/com/xcong/excoin/websocket/TradePlateSendWebSocket.java

@@ -95,9 +95,9 @@
            // 发送一次盘口
            CoinTraderFactory factory = SpringContextHolder.getBean(CoinTraderFactory.class);
            // 发送订阅消息
            String nekk = factory.getTrader(SymbolsConstats.ROC).sendTradePlateMessage();
            String nekk = factory.getTrader(SymbolsConstats.CPV).sendTradePlateMessage();
            SubResultModel subResultModel = new SubResultModel();
            subResultModel.setId("rocusdt");
            subResultModel.setId("cpvusdt");
            subResultModel.setSubbed(sub);
            synchronized (session) {
                try {
@@ -219,7 +219,7 @@
            String key = "KINE_{}_{}";
            // 币币k线数据
            //key = StrUtil.format(key, symbol, period);
            key = StrUtil.format(key, "ROC/USDT", period);
            key = StrUtil.format(key, "CPV/USDT", period);
            RedisUtils bean = SpringContextHolder.getBean(RedisUtils.class);
            Object o = bean.get(key);
            List<CandlestickModel> candlestickModels = new ArrayList<>();