| | |
|---|
| | | */ |
|---|
| | | private void handleWebSocketMessage(String message) { |
|---|
| | | try { |
|---|
| | | if ("pong".equals(message)) { |
|---|
| | | log.debug("{}: 收到心跳响应"); |
|---|
| | | cancelPongTimeout(); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | JSONObject response = JSON.parseObject(message); |
|---|
| | | String event = response.getString("event"); |
|---|
| | | |
|---|
| | |
|---|
| | | List<BigDecimal> historicalPrices1M = kline1MinuteData.stream() |
|---|
| | | .map(Kline::getC) |
|---|
| | | .collect(Collectors.toList()); |
|---|
| | | log.info("生成100个1分钟价格数据点成功！"); |
|---|
| | | // 使用策略分析最新价格数据 |
|---|
| | | MacdMaStrategy.TradingOrder tradingOrderOpen1M = strategy.generateTradingOrder(historicalPrices1M,MacdMaStrategy.OperationType.open.name()); |
|---|
| | | if (tradingOrderOpen1M == null ){ |
|---|
| | |
|---|
| | | requestParam.put("bar", bar); |
|---|
| | | requestParam.put("limit", "200"); |
|---|
| | | String result = ExchangeLoginService.getInstance(ExchangeInfoEnum.OKX_UAT.name()).lineHistory(requestParam); |
|---|
| | | log.info("加载OKX-KLINE，{}", result); |
|---|
| | | |
|---|
| | | JSONObject json = JSON.parseObject(result); |
|---|
| | | String data = json.getString("data"); |
|---|
| | | |
|---|
| | |
|---|
| | | private void sendPing() { |
|---|
| | | try { |
|---|
| | | if (webSocketClient != null && webSocketClient.isOpen()) { |
|---|
| | | JSONObject ping = new JSONObject(); |
|---|
| | | ping.put("op", "ping"); |
|---|
| | | webSocketClient.send(ping.toJSONString()); |
|---|
| | | webSocketClient.send("ping"); |
|---|
| | | log.debug("发送ping请求"); |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
