| | |
|---|
| | | |
|---|
| | | import com.xcong.excoin.modules.okxNewPrice.gridWs.OkxAlgoOrdersChannelHandler; |
|---|
| | | import com.xcong.excoin.modules.okxNewPrice.gridWs.OkxKlineChannelHandler; |
|---|
| | | import com.xcong.excoin.modules.okxNewPrice.gridWs.OkxOrdersChannelHandler; |
|---|
| | | import com.xcong.excoin.modules.okxNewPrice.gridWs.OkxPositionsChannelHandler; |
|---|
| | | import com.xcong.excoin.modules.okxNewPrice.okxpi.config.OKXAccount; |
|---|
| | | import com.xcong.excoin.modules.okxNewPrice.okxpi.config.enums.DefaultUrls; |
|---|
| | |
|---|
| | | .instId("BTC-USDT-SWAP") |
|---|
| | | .leverage("100") |
|---|
| | | .tdMode("cross") |
|---|
| | | .gridRate(new BigDecimal("0.0025")) |
|---|
| | | .expectedProfit(new BigDecimal("2")) |
|---|
| | | .maxLoss(new BigDecimal("15")) |
|---|
| | | .gridRate(new BigDecimal("0.001")) |
|---|
| | | .expectedProfit(new BigDecimal("20")) |
|---|
| | | .maxLoss(new BigDecimal("30")) |
|---|
| | | .quantity("1") |
|---|
| | | .baseQuantity("10") |
|---|
| | | .priceScale(2) |
|---|
| | | .ctVal(new BigDecimal("0.1")) |
|---|
| | | .ctVal(new BigDecimal("0.01")) |
|---|
| | | .isSimulate(!primaryAccount.isAccountType()) |
|---|
| | | .gridQueueSize(300) |
|---|
| | | .marginRatioLimit(new BigDecimal("0.2")) |
|---|
| | |
|---|
| | | gridTradeService.init(); |
|---|
| | | |
|---|
| | | // 4. 创建 WS 客户端并注册频道处理器 |
|---|
| | | // 公共 WS：candle1m（K线数据） |
|---|
| | | // 业务 WS（/v5/business）：candle1m |
|---|
| | | gridWsClientPublic = new OkxGridWsClient(primaryAccount, true); |
|---|
| | | gridWsClientPublic.addChannelHandler(new OkxKlineChannelHandler(okxConfig.getInstId(), gridTradeService)); |
|---|
| | | gridWsClientPublic.init(); |
|---|
| | | |
|---|
| | | // 私有 WS：positions + orders-algo（持仓 + 条件单） |
|---|
| | | // 私有 WS（/v5/private）：positions + orders（algo触发后订单fill带algoId可匹配） |
|---|
| | | gridWsClientPrivate = new OkxGridWsClient(primaryAccount, false); |
|---|
| | | gridWsClientPrivate.addChannelHandler(new OkxPositionsChannelHandler(okxConfig.getInstId(), gridTradeService)); |
|---|
| | | gridWsClientPrivate.addChannelHandler(new OkxAlgoOrdersChannelHandler(okxConfig.getInstId(), gridTradeService)); |
|---|
| | | gridWsClientPrivate.addChannelHandler(new OkxOrdersChannelHandler(okxConfig.getInstId(), gridTradeService)); |
|---|
| | | gridWsClientPrivate.init(); |
|---|
| | | |
|---|
| | | log.info("[OKX-Manager] WS已连接, 公共: candle1m, 私有: positions/orders-algo"); |
|---|
| | | log.info("[OKX-Manager] WS已连接, business: candle1m, private: positions/orders"); |
|---|
| | | |
|---|
| | | // 5. 激活策略，等待首根 K 线触发基底双开 |
|---|
| | | gridTradeService.startGrid(); |
|---|
