From bdbdd07ad9d3bcb82e9f15fbda005962d35cf948 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Fri, 19 Dec 2025 13:17:34 +0800
Subject: [PATCH] feat(okx): 切换OKX WebSocket客户端至实盘环境

---
 src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java |   28 +++++++++++++++++++++++++++-
 1 files changed, 27 insertions(+), 1 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..6b3b1d6 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
@@ -34,6 +34,7 @@
 
         //获取WangGeListEnum全部网格参数
         WangGeListEnum gridByPrice = WangGeListEnum.getGridByPrice(new BigDecimal(markPx));
+        log.info("获取的网格参数: {}", gridByPrice);
         if (gridByPrice == null){
             log.error("没有获取到网格参数......");
             return null;
@@ -72,7 +73,6 @@
                 return null;
             }
 
-            log.info("网格初始化成功");
             return queueAsc;
         } catch (NumberFormatException e) {
             log.error("解析价格参数失败", e);
@@ -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