| | |
| | | private static final String CHANNEL_NAME = "positions"; |
| | | |
| | | private final String instId; |
| | | private final String instFamily; |
| | | private final OkxGridTradeService gridTradeService; |
| | | |
| | | public OkxPositionsChannelHandler(String instId, OkxGridTradeService gridTradeService) { |
| | | this.instId = instId; |
| | | this.instFamily = instId.contains("-") ? instId.substring(0, instId.lastIndexOf("-")) : instId; |
| | | this.gridTradeService = gridTradeService; |
| | | } |
| | | |
| | |
| | | JSONObject arg = new JSONObject(); |
| | | arg.put("channel", CHANNEL_NAME); |
| | | arg.put("instType", "SWAP"); |
| | | arg.put("instFamily", instFamily); |
| | | msg.put("op", "subscribe"); |
| | | JSONArray args = new JSONArray(); |
| | | args.add(arg); |
| | | msg.put("args", args); |
| | | ws.send(msg.toJSONString()); |
| | | log.info("[OKX-WS] {} 订阅成功, instFamily:{}", CHANNEL_NAME, instFamily); |
| | | log.info("[OKX-WS] {} 订阅成功", CHANNEL_NAME); |
| | | } |
| | | |
| | | @Override |
| | |
| | | JSONObject arg = new JSONObject(); |
| | | arg.put("channel", CHANNEL_NAME); |
| | | arg.put("instType", "SWAP"); |
| | | arg.put("instFamily", instFamily); |
| | | msg.put("op", "unsubscribe"); |
| | | JSONArray args = new JSONArray(); |
| | | args.add(arg); |