| | |
| | | private final String contract; |
| | | private final String marginMode; |
| | | private final String accountName; |
| | | private final String instIdCode; |
| | | private final Long instIdCode; |
| | | |
| | | private volatile WebSocketClient wsClient; |
| | | |
| | | private final ExecutorService executor; |
| | | |
| | | public OkxTradeExecutor(String contract, String marginMode, String accountName, String instIdCode) { |
| | | public OkxTradeExecutor(String contract, String marginMode, String accountName, Long instIdCode) { |
| | | this.contract = contract; |
| | | this.marginMode = marginMode; |
| | | this.accountName = accountName; |
| | |
| | | |
| | | String connId = OkxWsUtil.getOrderNum("order"); |
| | | JSONObject msg = OkxWsUtil.buildJsonObject(connId, "order", argsArray); |
| | | String msgStr = msg.toJSONString(); |
| | | log.info("[TradeExec] 发送下单: {}", msgStr); |
| | | wsClient.send(msgStr); |
| | | log.info("[TradeExec] 下单已发送: side={}, sz={}, instId={}", param.getSide(), param.getSz(), param.getInstId()); |
| | | wsClient.send(msg.toJSONString()); |
| | | } |
| | | |
| | | private void sendBatchOrders(List<TradeRequestParam> params) { |