Administrator
2025-12-17 84d454b0d772cd59d32d08f5a1db1ac8ef24eed3
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());
@@ -107,7 +104,7 @@
            }
        }
        StringBuilder kaiCangStr = new StringBuilder();
        kaiCangStr.append("队列: [");
        kaiCangStr.append("初始化下限队列: [");
        boolean first = true;
        for (DescBigDecimal item : queueKaiCang) {
            if (!first) {
@@ -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());
@@ -143,7 +140,7 @@
        }
        StringBuilder pingCangStr = new StringBuilder();
        pingCangStr.append("平仓队列: [");
        pingCangStr.append("初始化上限队列: [");
        boolean first = true;
        for (AscBigDecimal item : queuePingCang) {
            if (!first) {