feat(okx): 更新网格交易参数并修复初始化逻辑

Administrator

2025-12-16 6ee948c0a97f2d92814af3cce5d794e7b9d6989b

feat(okx): 更新网格交易参数并修复初始化逻辑

- 修改 WangGeListEnum 中的网格价格和间距配置
- 修复 WangGeListServiceImpl 中队列初始化引用错误
- 移除对旧版 WangGe 类的依赖导入
- 统一使用 WangGeListQueue 进行队列管理

 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;
    }

    /**

 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());