blame | history | patch | commit | commitdiff | ignore whitespace
Administrator
2025-12-29 9b0494e23f7873418752c6c69874b59af58c0397 
 src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java


@@ -4,20 +4,18 @@


import com.alibaba.fastjson.JSONObject;


import com.xcong.excoin.modules.okxNewPrice.celue.CaoZuoService;


import com.xcong.excoin.modules.okxNewPrice.okxWs.*;


import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.CoinEnums;


import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.ExchangeInfoEnum;


import com.xcong.excoin.modules.okxNewPrice.okxWs.param.TradeRequestParam;


import com.xcong.excoin.modules.okxNewPrice.utils.SSLConfig;


import com.xcong.excoin.modules.okxNewPrice.wangge.WangGeService;


import com.xcong.excoin.utils.RedisUtils;


import lombok.extern.slf4j.Slf4j;


import org.java_websocket.client.WebSocketClient;


import org.java_websocket.handshake.ServerHandshake;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;


import org.springframework.stereotype.Component;




import javax.annotation.PostConstruct;


import javax.annotation.PreDestroy;


import java.math.BigDecimal;


import java.net.URI;


import java.net.URISyntaxException;


import java.util.concurrent.*;


@@ -34,6 +32,7 @@


public class OkxQuantWebSocketClient {


    private final RedisUtils redisUtils;


    private final ExchangeInfoEnum account;


    private final CaoZuoService caoZuoService;




    private WebSocketClient webSocketClient;


    private ScheduledExecutorService heartbeatExecutor;


@@ -61,8 +60,10 @@


    }


    


    public OkxQuantWebSocketClient(ExchangeInfoEnum account,


                                   CaoZuoService caoZuoService,


                                   RedisUtils redisUtils) {


        this.account = account;


        this.caoZuoService = caoZuoService;


        this.redisUtils = redisUtils;


    }




@@ -382,12 +383,9 @@


        // 注意：当前实现中，OrderInfoWs等类使用静态Map存储数据


        // 这会导致多账号之间的数据冲突。需要进一步修改这些类的设计，让数据存储与特定账号关联


        if (OrderInfoWs.ORDERINFOWS_CHANNEL.equals(channel)) {


            TradeRequestParam tradeRequestParam = OrderInfoWs.handleEvent(response, redisUtils, account.name());


            TradeOrderWs.orderZhiYingEvent(webSocketClient, tradeRequestParam);


            OrderInfoWs.handleEvent(response, redisUtils, account.name());


        }else if (AccountWs.ACCOUNTWS_CHANNEL.equals(channel)) {


            AccountWs.handleEvent(response, account.name());


//            String side = caoZuoService.caoZuo(account.name());


//            TradeOrderWs.orderEvent(webSocketClient, side, account.name());


        } else if (PositionsWs.POSITIONSWS_CHANNEL.equals(channel)) {


            PositionsWs.handleEvent(response, account.name());


        } else if (BalanceAndPositionWs.CHANNEL_NAME.equals(channel)) {