| | |
| | | log.warn("下单{}参数缺失,取消发送",tradeRequestParams); |
| | | return; |
| | | } |
| | | |
| | | JSONArray argsArray = new JSONArray(); |
| | | JSONObject args = new JSONObject(); |
| | | for (TradeRequestParam tradeRequestParam : tradeRequestParams){ |
| | | String accountName = tradeRequestParam.getAccountName(); |
| | | String markPx = tradeRequestParam.getMarkPx(); |
| | |
| | | * 平空:买入平空(side 填写 buy; posSide 填写 short ) 需要检验仓位通道是否准备就绪 |
| | | */ |
| | | |
| | | try { |
| | | JSONArray argsArray = new JSONArray(); |
| | | JSONObject args = new JSONObject(); |
| | | args.put("instId", instId); |
| | | args.put("tdMode", tdMode); |
| | | args.put("clOrdId", clOrdId); |
| | |
| | | args.put("sz", sz); |
| | | args.put("px", markPx); |
| | | argsArray.add(args); |
| | | } |
| | | |
| | | String connId = WsParamBuild.getOrderNum(ORDERWS_CHANNEL); |
| | | JSONObject jsonObject = WsParamBuild.buildJsonObject(connId, ORDERWS_CHANNEL, argsArray); |
| | | webSocketClient.send(jsonObject.toJSONString()); |
| | | log.info("发送下单频道:{},数量:{}", side, sz); |
| | | |
| | | } catch (Exception e) { |
| | | log.error("下单构建失败", e); |
| | | } |
| | | } |
| | | log.info("发送止盈止损下单频道:{}",argsArray); |
| | | } |
| | | |
| | | |