| | |
|---|
| | | private final AtomicBoolean isConnecting = new AtomicBoolean(false); |
|---|
| | | private final AtomicBoolean isInitialized = new AtomicBoolean(false); |
|---|
| | | |
|---|
| | | private static final String CHANNEL = "candle15m"; |
|---|
| | | private static final String CHANNEL = "candle5m"; |
|---|
| | | // private static final String CHANNEL = "candle15m"; |
|---|
| | | |
|---|
| | | // 心跳超时时间(秒)，小于30秒 |
|---|
| | | private static final int HEARTBEAT_TIMEOUT = 10; |
|---|
| | |
|---|
| | | List<Kline> kline15MinuteData = getKlineDataByInstIdAndBar(instId, "15m"); |
|---|
| | | //stream流获取kline15MinuteData中的o数据的集合 |
|---|
| | | List<BigDecimal> prices = kline15MinuteData.stream() |
|---|
| | | .map(Kline::getO) |
|---|
| | | .map(Kline::getC) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | |
|---|
| | | // 生成对应的高、低、收盘价数据 |
|---|
| | |
|---|
| | | List<BigDecimal> low = kline15MinuteData.stream() |
|---|
| | | .map(Kline::getL) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | List<BigDecimal> close = kline15MinuteData.stream() |
|---|
| | | .map(Kline::getC) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | List<BigDecimal> close = prices; |
|---|
| | | |
|---|
| | | // 生成成交量数据 |
|---|
| | | List<BigDecimal> volume = kline15MinuteData.stream() |
|---|
| | |
|---|
| | | // 确定市场方向 |
|---|
| | | TradingStrategy.Direction direction = tradingStrategy.getDirection(prices, high, low, close, currentPrice); |
|---|
| | | System.out.println("市场方向（15分钟）: " + direction); |
|---|
| | | if (direction == TradingStrategy.Direction.RANGING){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // if (direction == TradingStrategy.Direction.RANGING){ |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 获取当前网格信息 |
|---|
