| | |
| | | String connId = MallUtils.getOrderNum(ACCOUNTWS_CHANNEL); |
| | | JSONObject jsonObject = WsParamBuild.buildJsonObject(connId, option, argsArray); |
| | | webSocketClient.send(jsonObject.toJSONString()); |
| | | log.info("发送账户频道:{}", option); |
| | | // log.info("发送账户频道:{}", option); |
| | | } catch (Exception e) { |
| | | log.error("订阅账户频道构建失败", e); |
| | | } |
| | | } |
| | | |
| | | public static void initEvent(JSONObject response) { |
| | | // log.info("订阅成功: {}", response.getJSONObject("arg")); |
| | | JSONObject arg = response.getJSONObject("arg"); |
| | | initParam(arg); |
| | | } |
| | | |
| | | /** |
| | |
| | | public static void handleEvent(JSONObject response) { |
| | | |
| | | |
| | | log.info("开始执行AccountWs......{}",ACCOUNTWS_CHANNEL); |
| | | // log.info("开始执行AccountWs......{}",ACCOUNTWS_CHANNEL); |
| | | try { |
| | | JSONArray dataArray = response.getJSONArray("data"); |
| | | if (dataArray == null || dataArray.isEmpty()) { |
| | |
| | | |
| | | for (int j = 0; j < detailsArray.size(); j++) { |
| | | JSONObject detail = detailsArray.getJSONObject(j); |
| | | log.info("账户详情: {}", JSONUtil.formatJsonStr(String.valueOf(detail))); |
| | | //需要获取的参数 |
| | | String ccyKey = "ccy"; |
| | | String availBalKey = "availBal"; |
| | | String cashBalKey = "cashBal"; |
| | | String eqKey = "eq"; |
| | | String imrKey = "imr"; |
| | | |
| | | String ccy = WsMapBuild.parseStringSafe( detail.getString(ccyKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, ccyKey, ccy); |
| | | |
| | | String availBal = WsMapBuild.parseStringSafe(detail.getString(availBalKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, availBalKey, availBal); |
| | | |
| | | String cashBal = WsMapBuild.parseStringSafe(detail.getString(cashBalKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, cashBalKey, cashBal); |
| | | |
| | | String eq = WsMapBuild.parseStringSafe(detail.getString(eqKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, eqKey, eq); |
| | | |
| | | String imr = WsMapBuild.parseStringSafe(detail.getString(imrKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, imrKey, imr); |
| | | |
| | | BigDecimal cashBalDecimal = WsMapBuild.parseBigDecimalSafe(cashBal); |
| | | if (cashBalDecimal.compareTo(BigDecimal.ZERO) == 0) { |
| | | log.warn("账户频道无效的账户余额数据,跳过处理"); |
| | | continue; |
| | | } |
| | | |
| | | // 根据可用余额计算下单总保证金 |
| | | String total_order_usdtpecent = InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.TOTAL_ORDER_USDTPECENT.name()); |
| | | BigDecimal total_order_usdt_factor = WsMapBuild.parseBigDecimalSafe(total_order_usdtpecent); |
| | | BigDecimal totalOrderUsdt = cashBalDecimal.multiply(total_order_usdt_factor).setScale(2, RoundingMode.DOWN); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, CoinEnums.TOTAL_ORDER_USDT.name(), String.valueOf(totalOrderUsdt)); |
| | | |
| | | log.info( |
| | | "账户详情-币种: {}, 可用余额: {}, 现金余额: {}, 余额: {}, 占用保证金: {}, 下单总保证金: {}", |
| | | ccy, availBal, cashBal, eq, imr, totalOrderUsdt |
| | | ); |
| | | initParam(detail); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, CoinEnums.READY_STATE.name(), CoinEnums.READY_STATE_YES.getCode()); |
| | | } |
| | | } catch (Exception innerEx) { |
| | | log.warn("处理账户频道数据失败", innerEx); |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | public static final String ccyKey = "ccy"; |
| | | public static final String availBalKey = "availBal"; |
| | | public static final String cashBalKey = "cashBal"; |
| | | public static final String eqKey = "eq"; |
| | | public static final String uplKey = "upl"; |
| | | private static void initParam(JSONObject detail) { |
| | | |
| | | String ccy = WsMapBuild.parseStringSafe( detail.getString(ccyKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, ccyKey, ccy); |
| | | |
| | | String availBal = WsMapBuild.parseStringSafe(detail.getString(availBalKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, availBalKey, availBal); |
| | | |
| | | String cashBal = WsMapBuild.parseStringSafe(detail.getString(cashBalKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, cashBalKey, cashBal); |
| | | |
| | | String eq = WsMapBuild.parseStringSafe(detail.getString(eqKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, eqKey, eq); |
| | | |
| | | String upl = WsMapBuild.parseStringSafe(detail.getString(uplKey)); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, uplKey, upl); |
| | | |
| | | BigDecimal cashBalDecimal = WsMapBuild.parseBigDecimalSafe(cashBal); |
| | | // 根据可用余额计算下单总保证金 |
| | | String total_order_usdtpecent = InstrumentsWs.INSTRUMENTSWSMAP.get(CoinEnums.TOTAL_ORDER_USDTPECENT.name()); |
| | | BigDecimal total_order_usdt_factor = WsMapBuild.parseBigDecimalSafe(total_order_usdtpecent); |
| | | BigDecimal totalOrderUsdt = cashBalDecimal.multiply(total_order_usdt_factor).setScale(2, RoundingMode.DOWN); |
| | | WsMapBuild.saveStringToMap(ACCOUNTWSMAP, CoinEnums.TOTAL_ORDER_USDT.name(), String.valueOf(totalOrderUsdt)); |
| | | |
| | | // log.info( |
| | | // "账户详情-币种: {}, 可用余额: {}, 现金余额: {}, 余额: {}, 全仓未实现盈亏: {}, 下单总保证金: {}", |
| | | // ccy, availBal, cashBal, eq, upl, totalOrderUsdt |
| | | // ); |
| | | } |
| | | } |
| | | |