modify

Helius

2021-06-15 2e3db6b70d8441f11fbbd60999ab8fe8cc167fa0

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

@@ -79,6 +79,7 @@
    public void onMessage(String message, Session session) {
        // 盘口订阅方法 {sub: 'market.btcusdt.depth.10,id: symbol}
        JSONObject jsonObject = JSON.parseObject(message);
        log.info("订阅参数:{}", jsonObject);
        // 盘口的判断
        if (jsonObject.containsKey("sub") && jsonObject.get("sub").toString().contains("depth")) {

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