From 269e8765fabd893d47a1ce276304256650c8e99e Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 16 Dec 2025 18:08:03 +0800
Subject: [PATCH] fix(okxWs): 调整账户持仓为空时的处理逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListService.java | 41 +++++++++++++++++++++++++++++++++++++++++
1 files changed, 41 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListService.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListService.java
new file mode 100644
index 0000000..b8b304a
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListService.java
@@ -0,0 +1,41 @@
+package com.xcong.excoin.modules.okxNewPrice.okxWs.wanggeList;
+
+import com.xcong.excoin.rabbit.pricequeue.AscBigDecimal;
+import com.xcong.excoin.rabbit.pricequeue.DescBigDecimal;
+
+import java.math.BigDecimal;
+import java.util.concurrent.PriorityBlockingQueue;
+
+/**
+ * 网格交易服务接口
+ * 定义了网格交易的核心操作方法，包括初始化网格、开仓和平仓等操作
+ * @author Administrator
+ */
+public interface WangGeListService {
+
+ /**
+ * 初始化网格交易
+ * 创建并初始化用于网格交易的价格队列，按照价格升序排列
+ * @return 初始化结果信息，返回按价格升序排列的阻塞队列
+ */
+ PriorityBlockingQueue<AscBigDecimal> initWangGe(String markPx);
+
+ /**
+ * 初始化开仓操作
+ * 根据指定价格初始化开仓队列，将开仓价格点加入到价格队列中
+ * @param jiaGe 开仓价格
+ * @param queueAsc 价格队列，用于存储按升序排列的价格点
+ */
+ PriorityBlockingQueue<DescBigDecimal> initKaiCang(BigDecimal jiaGe, PriorityBlockingQueue<AscBigDecimal> queueAsc);
+
+ /**
+ * 初始化平仓操作
+ * 根据指定价格初始化平仓队列，将平仓价格点加入到价格队列中
+ * @param jiaGe 开仓价格
+ * @param queueAsc 价格队列，用于存储按升序排列的价格点
+ */
+ PriorityBlockingQueue<AscBigDecimal> initPingCang(BigDecimal jiaGe, PriorityBlockingQueue<AscBigDecimal> queueAsc);
+
+
+}
+
--
Gitblit v1.9.1