| | |
| | | BigDecimal totalPnl = cumulativePnl.add(unrealizedPnl); |
| | | log.info("[Gate] 已实现:{}, 未实现:{}, 合计:{}", |
| | | cumulativePnl, unrealizedPnl, totalPnl); |
| | | |
| | | startGrid(); |
| | | return; |
| | | } |
| | | |
| | |
| | | BigDecimal totalPnl = cumulativePnl.add(unrealizedPnl); |
| | | log.info("[Gate] 已实现:{}, 未实现:{}, 合计:{}", |
| | | cumulativePnl, unrealizedPnl, totalPnl); |
| | | |
| | | if (totalPnl.compareTo(config.getOverallTp()) >= 0) { |
| | | log.info("[Gate] 已达止盈目标(合计{})→已停止, 已实现:{}, 未实现:{}", |
| | | totalPnl, cumulativePnl, unrealizedPnl); |
| | | state = StrategyState.STOPPED; |
| | | } else if (totalPnl.compareTo(config.getMaxLoss().negate()) <= 0) { |
| | | if(totalPnl.compareTo(config.getMaxLoss().negate()) <= 0) { |
| | | String logMessage = StrUtil.format("[Gate] 已达亏损风险值(合计{}), 已实现:{}, 未实现:{}", |
| | | totalPnl, cumulativePnl, unrealizedPnl); |
| | | log.info(logMessage); |
| | | |
| | | |
| | | DingTalkUtils.getDefault().sendActionCard("风险提醒", logMessage, config.getApiKey(), ""); |
| | | // state = StrategyState.STOPPED; |
| | | } |
| | | } |
| | | |
| | |
| | | unrealisedPnl, available, totalEquity, target); |
| | | if (totalEquity.compareTo(target) > 0) { |
| | | log.info("[Gate] 盈亏达标({}>{}),重置策略", totalEquity, target); |
| | | state = StrategyState.STOPPED; |
| | | closeExistingPositions(); |
| | | futuresApi.cancelPriceTriggeredOrderList(SETTLE, config.getContract()); |
| | | startGrid(); |
| | |
| | | } |
| | | |
| | | private void handlePositionZeroAndReset(String direction) { |
| | | state = StrategyState.STOPPED; |
| | | try { |
| | | futuresApi.cancelPriceTriggeredOrderList(SETTLE, config.getContract()); |
| | | } catch (Exception e) { |