| | |
| | | log.info("生成100个15分钟价格数据点成功!"); |
| | | // 使用策略分析最新价格数据 |
| | | MacdMaStrategy.TradingOrder tradingOrderOpen = strategy.generateTradingOrder(historicalPrices,MacdMaStrategy.OperationType.open.name()); |
| | | MacdMaStrategy.TradingOrder tradingOrderClose = strategy.generateTradingOrder(historicalPrices,MacdMaStrategy.OperationType.close.name()); |
| | | if (tradingOrderOpen == null && tradingOrderClose == null){ |
| | | if (tradingOrderOpen == null ){ |
| | | return; |
| | | } |
| | | Collection<OkxQuantWebSocketClient> allClients = clientManager.getAllClients(); |
| | |
| | | tradeRequestParam.setSz(sz); |
| | | TradeOrderWs.orderEvent(client.getWebSocketClient(), tradeRequestParam); |
| | | } |
| | | if (ObjectUtil.isNotEmpty(tradingOrderClose)){ |
| | | // 根据信号执行交易操作 |
| | | TradeRequestParam tradeRequestParam = new TradeRequestParam(); |
| | | |
| | | String posSide = tradingOrderClose.getPosSide(); |
| | | tradeRequestParam.setPosSide(posSide); |
| | | String currentPrice = String.valueOf(closePx); |
| | | tradeRequestParam = caoZuoService.caoZuoZhiSunEvent(accountName, currentPrice, posSide); |
| | | |
| | | TradeOrderWs.orderEvent(client.getWebSocketClient(), tradeRequestParam); |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |