| | |
| | | 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("totalEq"), acct.get("upl"), acct.get("imr")); |
| | | |
| | | JSONArray details = acct.getJSONArray("details"); |
| | | if (details != null) { |
| | | for (int j = 0; j < details.size(); j++) { |
| | | JSONObject detail = details.getJSONObject(j); |
| | | log.info("[{}] 币种:{}, 可用余额:{}, 现金余额:{}, 权益:{}", |
| | | CHANNEL_NAME, |
| | | detail.get("ccy"), detail.get("availBal"), |
| | | detail.get("cashBal"), detail.get("eq")); |
| | | } |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("[{}] 处理数据失败", CHANNEL_NAME, e); |
| | | } |