Administrator
2025-12-29 6171302110421222f6bb14293b5499759a967dad
refactor(okxNewPrice): 简化交易订单生成逻辑

- 移除不必要的 tradingOrderClose 变量声明
- 简化交易订单判断条件,只保留 tradingOrderOpen 判断
- 移除与 tradingOrderClose 相关的交易执行代码
- 优化代码结构以提高可读性
1 files modified
15 ■■■■■ changed files
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java 15 ●●●●● patch | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxKlineWebSocketClient.java
@@ -346,8 +346,7 @@
                    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();
@@ -378,18 +377,6 @@
                                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);
                            }
                        }
                    }
                }