| | |
| | | args.add(arg); |
| | | msg.put("args", args); |
| | | ws.send(msg.toJSONString()); |
| | | log.info("[{}] 订阅成功", CHANNEL_NAME); |
| | | } |
| | | |
| | | @Override |
| | |
| | | args.add(arg); |
| | | msg.put("args", args); |
| | | ws.send(msg.toJSONString()); |
| | | log.info("[{}] 取消订阅成功", CHANNEL_NAME); |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | for (int i = 0; i < dataArray.size(); i++) { |
| | | JSONObject acct = dataArray.getJSONObject(i); |
| | | log.info("[{}] 账户更新, 可用余额:{}, 现金余额:{}, 权益:{}, 未实现盈亏:{}, 保证金:{}", |
| | | CHANNEL_NAME, |
| | | acct.get("availBal"), acct.get("cashBal"), |
| | | acct.get("eq"), acct.get("upl"), acct.get("imr")); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("[{}] 处理数据失败", CHANNEL_NAME, e); |
| | | } |