From 815aa1f65c9430fe23256fb6a9ee0a131274fc0a Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 17 Dec 2025 12:03:45 +0800
Subject: [PATCH] feat(okxWs): 添加队列初始化日志记录功能
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java | 26 ++++++++++++++++++++++++++
1 files changed, 26 insertions(+), 0 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 6de3a10..50bbccb 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
@@ -103,6 +103,19 @@
queueKaiCang.add(kaiCangJia);
}
}
+ StringBuilder kaiCangStr = new StringBuilder();
+ kaiCangStr.append("初始化下限队列: [");
+ boolean first = true;
+ for (DescBigDecimal item : queueKaiCang) {
+ if (!first) {
+ kaiCangStr.append(", ");
+ }
+ kaiCangStr.append(item.getValue());
+ first = false;
+ }
+ kaiCangStr.append("]");
+ log.info(kaiCangStr.toString());
+
return queueKaiCang;
}
@@ -126,6 +139,19 @@
}
}
+ StringBuilder pingCangStr = new StringBuilder();
+ pingCangStr.append("初始化上限队列: [");
+ boolean first = true;
+ for (AscBigDecimal item : queuePingCang) {
+ if (!first) {
+ pingCangStr.append(", ");
+ }
+ pingCangStr.append(item.getValue());
+ first = false;
+ }
+ pingCangStr.append("]");
+ log.info(pingCangStr.toString());
+
return queuePingCang;
}
--
Gitblit v1.9.1