| | |
| | | e.printStackTrace(); |
| | | } |
| | | closeExistingPositions(); |
| | | |
| | | state = StrategyState.STOPPED; |
| | | // 提交到 executor 末尾:单线程FIFO保证前面所有平仓/取消任务完成后才重置 |
| | | executor.submitTask(() -> { |
| | | try { Thread.sleep(3000); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } |
| | |
| | | |
| | | GridElement cancelGridElement = GridElement.findById(newEntryGrid.getUpId()); |
| | | if (cancelGridElement != null && cancelGridElement.isHasLongOrder()) { |
| | | String longOrderId = cancelGridElement.getLongOrderId(); |
| | | longEntryTraderIdParam(cancelGridElement, null, false); |
| | | executor.cancelConditionalOrder(cancelGridElement.getLongOrderId(), oid -> { |
| | | log.info("[Gate] 多仓仓位归零, 取消gridId:{}的多单", cancelGridElement.getId()); |
| | | executor.cancelConditionalOrder(longOrderId, oid -> { |
| | | log.info("[Gate] 多仓仓位归零, 取消gridId:{}的多单,{}", cancelGridElement.getId(),longOrderId); |
| | | }); |
| | | } |
| | | } |
| | |
| | | * 看是否有空仓挂单,有就取消 |
| | | */ |
| | | if (cancelGridElement != null && cancelGridElement.isHasShortOrder()) { |
| | | String shortOrderId = cancelGridElement.getShortOrderId(); |
| | | shortEntryTraderIdParam(cancelGridElement, null, false); |
| | | executor.cancelConditionalOrder(cancelGridElement.getShortOrderId(), oid -> { |
| | | log.info("[Gate] 空仓仓位归零, 取消gridId:{}的多单", cancelGridElement.getId()); |
| | | executor.cancelConditionalOrder(shortOrderId, oid -> { |
| | | log.info("[Gate] 空仓仓位归零, 取消gridId:{}的多单{}", cancelGridElement.getId(),shortOrderId); |
| | | }); |
| | | } |
| | | |