| | |
|---|
| | | |
|---|
| | | log.info("[Gate] 重置策略，开始第{}轮...", currentRound); |
|---|
| | | state = StrategyState.STOPPED; |
|---|
| | | // 关键修复：取消+平仓+延时+重启必须整体放进 executor 队列末尾，让上一轮排队的 |
|---|
| | | // 挂单任务先执行完（挂到交易所），随后的 cancel 才能取消到它们。若 cancel 仍留在 |
|---|
| | | // WS 线程同步执行，会早于上一轮挂单任务，取消不到"尚未挂出"的单（竞态）。 |
|---|
| | | executor.submitTask(() -> { |
|---|
| | | try { |
|---|
| | | futuresApi.cancelPriceTriggeredOrderList(SETTLE, config.getContract()); |
|---|
| | | } catch (ApiException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | closeExistingPositions(); |
|---|
| | | // 提交到 executor 末尾：单线程FIFO保证前面所有平仓/取消任务完成后才重置 |
|---|
| | | executor.submitTask(() -> { |
|---|
| | | try { Thread.sleep(3000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } |
|---|
| | | // 注意：startGrid() 会将 currentRound 归零，这里需要保留 |
|---|
| | | int savedRound = currentRound; |
|---|
