From 6ee948c0a97f2d92814af3cce5d794e7b9d6989b Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 16 Dec 2025 15:58:48 +0800
Subject: [PATCH] feat(okx): 更新网格交易参数并修复初始化逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListEnum.java | 8 ++++----
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListServiceImpl.java | 9 +++------
2 files changed, 7 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListEnum.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListEnum.java
index 06d6cf7..71460a0 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListEnum.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/wanggeList/WangGeListEnum.java
@@ -11,9 +11,9 @@
*/
@Getter
public enum WangGeListEnum {
- UP("上层做空", "2", "3000", "3200", "10", "short", "3214"),
- CENTER("中间指定一个方向", "2", "3000", "2700", "5", "long", "2986"),
- DOWN("下层做多", "2", "2500", "2700", "10", "long", "2586");
+ UP("上层做空", "2", "2950", "2980", "4", "short", "2980"),
+ CENTER("中间指定一个方向", "2", "2950", "2920", "4", "long", "2920"),
+ DOWN("下层做多", "2", "2920", "2890", "4", "long", "2890");
private String name;
private String xiaoshu_weishu;
@@ -30,7 +30,7 @@
this.jiage_xiaxian = jiage_xiaxian;
this.jian_ju = jian_ju;
this.fang_xiang = fang_xiang;
- this.fang_xiang = zhi_sun_dian;
+ this.zhi_sun_dian = zhi_sun_dian;
}
/**
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..912629a 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;
@@ -32,7 +29,7 @@
@Override
public PriorityBlockingQueue<AscBigDecimal> initWangGe(String markPx) {
log.info("网格初始化中");
- PriorityBlockingQueue<AscBigDecimal> queueAsc = WangGeQueue.getQueueAsc();
+ PriorityBlockingQueue<AscBigDecimal> queueAsc = WangGeListQueue.getQueueAsc();
queueAsc.clear();
//获取WangGeListEnum全部网格参数
@@ -95,7 +92,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());
@@ -131,7 +128,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());
--
Gitblit v1.9.1