blame | history | patch | commit | commitdiff | ignore whitespace
Administrator
7 days ago e0000fb876b0dd6261122314e6b84040e64d337d 
 src/main/java/com/xcong/excoin/modules/gateApi/GateWebSocketClientManager.java


@@ -2,10 +2,8 @@




import com.xcong.excoin.modules.gateApi.wsHandler.handler.AutoOrdersChannelHandler;


import com.xcong.excoin.modules.gateApi.wsHandler.handler.CandlestickChannelHandler;


import com.xcong.excoin.modules.gateApi.wsHandler.handler.OrdersChannelHandler;


import com.xcong.excoin.modules.gateApi.wsHandler.handler.PositionClosesChannelHandler;


import com.xcong.excoin.modules.gateApi.wsHandler.handler.PositionsChannelHandler;


import com.xcong.excoin.modules.gateApi.wsHandler.handler.UserTradesChannelHandler;


import lombok.extern.slf4j.Slf4j;


import org.springframework.stereotype.Component;




@@ -58,58 +56,25 @@


        log.info("[管理器] 开始初始化...");




        try {


            //测试盘


//            config = GateConfig.builder()


//                    .apiKey("d90ca272391992b8e74f8f92cedb21ec")


//                    .apiSecret("1861e4f52de4bb53369ea3208d9ede38ece4777368030f96c77d27934c46c274")


//                    .contract("ETH_USDT")


//                    .leverage("100")


//                    .marginMode("CROSS")


//                    .positionMode("dual")


//                    .gridRate(new BigDecimal("0.002"))


//                    .overallTp(new BigDecimal("5"))


//                    .maxLoss(new BigDecimal("15"))


//                    .quantity("1")


//                    .priceScale(1)


//                    .contractMultiplier(new BigDecimal("0.01"))


//                    .unrealizedPnlPriceMode(GateConfig.PnLPriceMode.LAST_PRICE)


//                    .isProduction(false)


//                    .reopenMaxRetries(3)


//                    .build();


//            //实盘


//            config = GateConfig.builder()


//                    .apiKey("a2338398e00b7935104520e16be96918")


//                    .apiSecret("9111d897f2346d5217619f2da76536632715fef4d7eb304c6c61e869a2a74e98")


//                    .contract("ETH_USDT")


//                    .leverage("100")


//                    .marginMode("CROSS")


//                    .positionMode("dual")


//                    .gridRate(new BigDecimal("0.005"))


//                    .overallTp(new BigDecimal("100"))


//                    .maxLoss(new BigDecimal("15"))


//                    .quantity("5")


//                    .priceScale(2)


//                    .contractMultiplier(new BigDecimal("0.01"))


//                    .unrealizedPnlPriceMode(GateConfig.PnLPriceMode.LAST_PRICE)


//                    .isProduction(true)


//                    .reopenMaxRetries(3)


//                    .build();


            //实盘


            config = GateConfig.builder()


                    .apiKey("d90ca272391992b8e74f8f92cedb21ec")


                    .apiSecret("1861e4f52de4bb53369ea3208d9ede38ece4777368030f96c77d27934c46c274")


                    .apiKey("8a995c9662bbdfb0b2577f5f56cf4210")


                    .apiSecret("4aaf5e7c97cf3bd14450c6703d4dc2af8647dee4c0a72272fa04280e83545d96")


                    .contract("ETH_USDT")


                    .leverage("100")


                    .marginMode("CROSS")


                    .positionMode("dual")


                    .gridRate(new BigDecimal("0.005"))


                    .overallTp(new BigDecimal("100"))


                    .gridRate(new BigDecimal("0.004"))


                    .expectedProfit(new BigDecimal("25"))


                    .maxLoss(new BigDecimal("15"))


                    .quantity("5")


                    .priceScale(1)


                    .baseQuantity("39")


                    .quantity("13")


                    .restartGridSpan(2)


                    .maxPositionSize(2)


                    .priceScale(2)


                    .contractMultiplier(new BigDecimal("0.01"))


                    .unrealizedPnlPriceMode(GateConfig.PnLPriceMode.LAST_PRICE)


                    .isProduction(false)


                    .isProduction(true)


                    .reopenMaxRetries(3)


                    .build();




@@ -117,21 +82,18 @@


            gridTradeService = new GateGridTradeService(config);


            gridTradeService.init();




            // 2. 创建 WS 客户端并注册 3 个频道处理器


            // 2. 创建 WS 客户端并注册频道处理器


            wsClient = new GateKlineWebSocketClient(config.getWsUrl());


            wsClient.addChannelHandler(new CandlestickChannelHandler(config.getContract(), gridTradeService));


            wsClient.addChannelHandler(new PositionsChannelHandler(


                    config.getApiKey(), config.getApiSecret(), config.getContract(), gridTradeService));


            wsClient.addChannelHandler(new PositionClosesChannelHandler(


                    config.getApiKey(), config.getApiSecret(), config.getContract(), gridTradeService));


            wsClient.addChannelHandler(new OrdersChannelHandler(


                    config.getApiKey(), config.getApiSecret(), config.getContract(), gridTradeService));


            wsClient.addChannelHandler(new UserTradesChannelHandler(


                    config.getApiKey(), config.getApiSecret(), config.getContract(), gridTradeService));


            wsClient.addChannelHandler(new AutoOrdersChannelHandler(


                    config.getApiKey(), config.getApiSecret(), config.getContract(), gridTradeService));


            gridTradeService.setWsClient(wsClient);


            wsClient.init();


            log.info("[管理器] WS已连接, 已注册 6 个频道处理器");


            log.info("[管理器] WS已连接, 已注册 4 个频道处理器");




            // 3. 激活策略，等待首根 K 线触发基底双开


            gridTradeService.startGrid();