| | |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | List<Kline> kline15MinuteData = getKlineDataByInstIdAndBar(instId, "15m"); |
|---|
| | | List<BigDecimal> historicalPrices15M = kline15MinuteData.stream() |
|---|
| | | .map(Kline::getC) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | // 使用策略分析最新价格数据 |
|---|
| | | MacdMaStrategy.TradingOrder tradingOrderOpen15M = strategy.generateTradingOrder(historicalPrices15M,MacdMaStrategy.OperationType.open.name()); |
|---|
| | | if (tradingOrderOpen15M == null ){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // List<Kline> kline15MinuteData = getKlineDataByInstIdAndBar(instId, "15m"); |
|---|
| | | // List<BigDecimal> historicalPrices15M = kline15MinuteData.stream() |
|---|
| | | // .map(Kline::getC) |
|---|
| | | // .collect(Collectors.toList()); |
|---|
| | | // // 使用策略分析最新价格数据 |
|---|
| | | // MacdMaStrategy.TradingOrder tradingOrderOpen15M = strategy.generateTradingOrder(historicalPrices15M,MacdMaStrategy.OperationType.open.name()); |
|---|
| | | // if (tradingOrderOpen15M == null ){ |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // if (!tradingOrderOpen1M.getPosSide().equals(tradingOrderOpen15M.getPosSide())){ |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | |
|---|
| | | if (!tradingOrderOpen1M.getPosSide().equals(tradingOrderOpen15M.getPosSide())){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | log.info("1分钟和15分钟K线方向一致，开始执行交易操作！"); |
|---|
| | | // log.info("1分钟和15分钟K线方向一致，开始执行交易操作！"); |
|---|
| | | |
|---|
| | | |
|---|
| | | Collection<OkxQuantWebSocketClient> allClients = clientManager.getAllClients(); |
|---|
