| | |
|---|
| | | args.put("channel", POSITIONSWS_CHANNEL); |
|---|
| | | args.put("instType", CoinEnums.INSTTYPE_SWAP.getCode()); |
|---|
| | | args.put("instId", CoinEnums.HE_YUE.getCode()); |
|---|
| | | JSONObject updateInterval = new JSONObject(); |
|---|
| | | updateInterval.put("updateInterval",CoinEnums.UPDATEINTERVAL.getCode()); |
|---|
| | | args.put("extraParams", updateInterval); |
|---|
| | | argsArray.add(args); |
|---|
| | | |
|---|
| | | String connId = MallUtils.getOrderNum(POSITIONSWS_CHANNEL); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static void handleEvent(JSONObject response, RedisUtils redisUtils) { |
|---|
| | | |
|---|
| | | |
|---|
| | | log.info("开始执行PositionsWs......"); |
|---|
| | | try { |
|---|
| | | JSONArray dataArray = response.getJSONArray("data"); |
|---|
| | | if (dataArray == null || dataArray.isEmpty()) { |
|---|
