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