| | |
| | | * @param onFailure 失败回调 |
| | | */ |
| | | public void openLong(String quantity, Consumer<String> onSuccess, Runnable onFailure) { |
| | | submitOrder("buy", "long", quantity, "market", null, false, "tGridLong", onSuccess, onFailure); |
| | | submitOrder("buy", "long", quantity, "market", null, false, null, onSuccess, onFailure); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param onFailure 失败回调 |
| | | */ |
| | | public void openShort(String quantity, Consumer<String> onSuccess, Runnable onFailure) { |
| | | submitOrder("sell", "short", quantity, "market", null, false, "tGridShort", onSuccess, onFailure); |
| | | submitOrder("sell", "short", quantity, "market", null, false, null, onSuccess, onFailure); |
| | | } |
| | | |
| | | /** |
| | |
| | | } |
| | | |
| | | /** |
| | | * 异步取消所有未完成的 algo 订单。 |
| | | * 异步取消所有未完成的 algo 订单(best-effort,失败仅警告)。 |
| | | */ |
| | | public void cancelAllAlgoOrders() { |
| | | executor.execute(() -> { |
| | |
| | | okxAccount.baseUrl, "/api/v5/trade/cancel-algos", body, HttpMethod.POST, okxAccount.isSimluate()); |
| | | log.info("[OkxExec] 已尝试清除条件单, resp:{}", resp); |
| | | } catch (Exception e) { |
| | | log.error("[OkxExec] 清除条件单失败", e); |
| | | log.warn("[OkxExec] 清除条件单失败(若无挂单可忽略), msg:{}", e.getMessage()); |
| | | } |
| | | }); |
| | | } |