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 | 17 ++++++-----------
1 files changed, 6 insertions(+), 11 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 1627d61..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
@@ -1,8 +1,5 @@
package com.xcong.excoin.modules.okxNewPrice.okxWs.wanggeList;
-import com.xcong.excoin.modules.okxNewPrice.wangge.WangGeEnum;
-import com.xcong.excoin.modules.okxNewPrice.wangge.WangGeQueue;
-import com.xcong.excoin.modules.okxNewPrice.wangge.WangGeService;
import com.xcong.excoin.rabbit.pricequeue.AscBigDecimal;
import com.xcong.excoin.rabbit.pricequeue.DescBigDecimal;
import lombok.RequiredArgsConstructor;
@@ -31,8 +28,7 @@
*/
@Override
public PriorityBlockingQueue<AscBigDecimal> initWangGe(String markPx) {
- log.info("网格初始化中");
- PriorityBlockingQueue<AscBigDecimal> queueAsc = WangGeQueue.getQueueAsc();
+ PriorityBlockingQueue<AscBigDecimal> queueAsc = WangGeListQueue.getQueueAsc();
queueAsc.clear();
//获取WangGeListEnum全部网格参数
@@ -71,11 +67,10 @@
}
if (queueAsc.isEmpty()) {
- log.info("网格初始化失败");
+ log.error("网格初始化失败");
return null;
}
- log.info("网格初始化成功");
return queueAsc;
} catch (NumberFormatException e) {
log.error("解析价格参数失败", e);
@@ -95,7 +90,7 @@
*/
@Override
public PriorityBlockingQueue<DescBigDecimal> initKaiCang(BigDecimal jiaGe, PriorityBlockingQueue<AscBigDecimal> queueAsc) {
- PriorityBlockingQueue<DescBigDecimal> queueKaiCang = WangGeQueue.getKaiCang();
+ PriorityBlockingQueue<DescBigDecimal> queueKaiCang = WangGeListQueue.getKaiCang();
queueKaiCang.clear();
AscBigDecimal now = new AscBigDecimal(jiaGe.toString());
@@ -107,7 +102,7 @@
}
}
StringBuilder kaiCangStr = new StringBuilder();
- kaiCangStr.append("队列: [");
+ kaiCangStr.append("初始化下限队列: [");
boolean first = true;
for (DescBigDecimal item : queueKaiCang) {
if (!first) {
@@ -131,7 +126,7 @@
*/
@Override
public PriorityBlockingQueue<AscBigDecimal> initPingCang(BigDecimal jiaGe, PriorityBlockingQueue<AscBigDecimal> queueAsc) {
- PriorityBlockingQueue<AscBigDecimal> queuePingCang = WangGeQueue.getPingCang();
+ PriorityBlockingQueue<AscBigDecimal> queuePingCang = WangGeListQueue.getPingCang();
queuePingCang.clear();
AscBigDecimal now = new AscBigDecimal(jiaGe.toString());
@@ -143,7 +138,7 @@
}
StringBuilder pingCangStr = new StringBuilder();
- pingCangStr.append("平仓队列: [");
+ pingCangStr.append("初始化上限队列: [");
boolean first = true;
for (AscBigDecimal item : queuePingCang) {
if (!first) {
--
Gitblit v1.9.1