From c8b80dc38d75e89aa44574659b154ddea2e8fce5 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 07 Jan 2026 14:16:32 +0800
Subject: [PATCH] refactor(okx): 重构WebSocket客户端实现止盈止损逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java | 9 +--------
1 files changed, 1 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java
index a199dd4..17a74be 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java
@@ -28,26 +28,20 @@
*/
@Override
public PriorityBlockingQueue<AscBigDecimal> initWangGe(String markPx) {
- log.info("网格初始化中");
PriorityBlockingQueue<AscBigDecimal> queueAsc = WangGeListQueue.getQueueAsc();
queueAsc.clear();
//获取WangGeListEnum全部网格参数
WangGeListEnum gridByPrice = WangGeListEnum.getGridByPrice(new BigDecimal(markPx));
- log.info("获取的网格参数: {}", gridByPrice);
if (gridByPrice == null){
log.error("没有获取到网格参数......");
return null;
}
String shangxianValue = gridByPrice.getJiage_shangxian();
- log.info("价格上限: {}", shangxianValue);
String xiaxianValue = gridByPrice.getJiage_xiaxian();
- log.info("价格下限: {}", xiaxianValue);
String jianjuValue = gridByPrice.getJian_ju();
- log.info("价格间隔: {}", jianjuValue);
String weishuValueStr = gridByPrice.getXiaoshu_weishu();
- log.info("价格位数: {}", weishuValueStr);
try {
BigDecimal shangxian = new BigDecimal(shangxianValue);
@@ -73,11 +67,10 @@
}
if (queueAsc.isEmpty()) {
- log.info("网格初始化失败");
+ log.error("网格初始化失败");
return null;
}
- log.info("网格初始化成功");
return queueAsc;
} catch (NumberFormatException e) {
log.error("解析价格参数失败", e);
--
Gitblit v1.9.1