package com.xcong.excoin.modules.okxApi;
import com.xcong.excoin.modules.okxApi.wsHandler.handler.MarkPriceOkxChannelHandler;
import com.xcong.excoin.modules.okxApi.wsHandler.handler.OrdersOkxChannelHandler;
import com.xcong.excoin.modules.okxApi.wsHandler.handler.PositionsOkxChannelHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import java.math.BigDecimal;
/**
* OKX 盈利回收策略 — 唯一入口，所有参数集中在此。
*
*
* ┌─────────────────────────────────────────────────────────────────┐
* │ 🔧 全部参数在此修改 │
* ├──────────────────┬──────────────────────────────────────────────┤
* │ 参数名 │ 值 │ 说明 │
* ├──────────────────┼──────────────────────────────────────┼────────┤
* │ apiKey │ ac76252d-... │ API密钥 │
* │ apiSecret │ A8168543... │ 签名密钥│
* │ passphrase │ Aa12345678@ │ 口令密码│
* ├──────────────────┼──────────────────────────────────────┼────────┤
* │ contract │ BTC-USDT-SWAP │ 交易合约│
* │ leverage │ 50 │ 杠杆倍数│
* │ baseQuantity │ 10 │ 底仓张数│
* ├──────────────────┼──────────────────────────────────────┼────────┤
* │ profitTriggerRatio│ 0.5 │ 触发ROI │
* │ reinvestRatio │ 0.5 │ 补仓比例│
* ├──────────────────┼──────────────────────────────────────┼────────┤
* │ maxPositionMult │ 10 (= base×10 = 100张上限) │ 风控1 │
* │ maxLoss │ 15 USDT │ 风控2 │
* │ equityRestartRatio│ 0.05 (= 5%) │ 风控3 │
* ├──────────────────┼──────────────────────────────────────┼────────┤
* │ contractMult │ 0.01 (BTC 每张0.01个币) │ 合约乘数│
* │ priceScale │ 2 (价格精度0.01) │ 价格精度│
* │ pnlPriceMode │ LAST_PRICE │ 盈亏计价│
* │ isProduction │ false (false=模拟盘) │ 交易环境│
* └──────────────────┴──────────────────────────────────────────────┘
*
*
* 策略核心公式
*
* - 保证金 = 张数 × 合约乘数 × 开仓均价 / 杠杆
* - ROI = 未实现盈亏 / 该方向保证金
* - 触发条件：ROI ≥ profitTriggerRatio
* - 平仓：floor(盈利仓位张数 / 2)
* - 补仓保证金 B = 已实现利润 × reinvestRatio
* - 单张保证金 = 合约乘数 × 开仓均价 / 杠杆
* - 补仓张数 = max(baseQuantity, floor(B / 单张保证金))
*
*
* 仓位演化示例 (BTC-USDT-SWAP, 50x, base10)
*
* 初始: LONG=10 SHORT=10
* 多盈: LONG=5 SHORT=12
* 多盈: LONG=3 SHORT=15
* 多盈: LONG=2 SHORT=18
* → 权益达+5% → 全平重置 → LONG=10 SHORT=10
*
*
* @author Administrator
*/
@Slf4j
@Component
public class OkxWebSocketClientManager {
// ╔══════════════════════════════════════════════════════════════╗
// ║ 🔐 OKX API 认证信息 ║
// ╚══════════════════════════════════════════════════════════════╝
private static final String OKX_API_KEY = "ac76252d-e717-4459-a6f9-80512aed5ea0";
private static final String OKX_API_SECRET = "A8168543EF4F08A6DBFE27AB23956898";
private static final String OKX_PASSPHRASE = "Aa12345678@";
// ╔══════════════════════════════════════════════════════════════╗
// ║ 📊 交易标的参数 ║
// ╚══════════════════════════════════════════════════════════════╝
private static final String CONTRACT = "BTC-USDT-SWAP"; // 合约名称
private static final String LEVERAGE = "50"; // 杠杆倍数
private static final String MARGIN_MODE = "cross"; // 全仓 cross / 逐仓 isolated
private static final String POSITION_MODE = "long_short_mode"; // 双向持仓
// ╔══════════════════════════════════════════════════════════════╗
// ║ 🎯 策略核心参数 ║
// ╚══════════════════════════════════════════════════════════════╝
/** 基础仓位张数 — 初始化时多空各开此张数，也是最小开仓单位 */
private static final String BASE_QUANTITY = "10";
/** 盈利触发比例 — ROI=未实现盈亏/保证金 达到此值时触发平仓 */
private static final BigDecimal PROFIT_TRIGGER_RATIO = new BigDecimal("0.5"); // 50%
/** 再投资比例 — 已实现利润中用于补反向仓的比例 */
private static final BigDecimal REINVEST_RATIO = new BigDecimal("0.5"); // 50%
// ╔══════════════════════════════════════════════════════════════╗
// ║ 🛡 风控参数 ║
// ╚══════════════════════════════════════════════════════════════╝
/** 风控1: 反向仓位倍数上限 — 反向最大持仓 = baseQuantity × 此值 (10×10=100张) */
private static final int MAX_POSITION_MULTIPLIER = 10;
/** 风控2: 最大亏损阈值(USDT) — 全局盈亏≤-此值时停止策略 */
private static final BigDecimal MAX_LOSS = new BigDecimal("15");
/** 风控3: 权益重置比例 — 账户权益 ≥ 初始权益 × (1+此值) 时全平重新双开 */
private static final BigDecimal EQUITY_RESTART_RATIO = new BigDecimal("0.05"); // 5%
// ╔══════════════════════════════════════════════════════════════╗
// ║ ⚙ 技术与环境参数 ║
// ╚══════════════════════════════════════════════════════════════╝
/** 合约乘数 — BTC-USDT-SWAP 每张=0.01 BTC */
private static final BigDecimal CONTRACT_MULTIPLIER = new BigDecimal("0.01");
/** 价格精度 — OKX 价格小数位数 (BTC=2, ETH=2) */
private static final int PRICE_SCALE = 2;
/** 盈亏计价模式 — LAST_PRICE(最新价) / MARK_PRICE(标记价) */
private static final OkxConfig.PnLPriceMode PNL_PRICE_MODE = OkxConfig.PnLPriceMode.LAST_PRICE;
/** false=模拟盘 (wspap.okx.com) / true=实盘 (ws.okx.com) */
private static final boolean IS_PRODUCTION = false;
// ==================== 以下为启动代码，通常无需修改 ====================
private OkxKlineWebSocketClient wsClient;
private OkxProfitRecycleStrategy strategy;
private OkxConfig config;
@PostConstruct
public void init() {
log.info("[OKX] 正在初始化盈利回收策略...");
try {
config = OkxConfig.builder()
.apiKey(OKX_API_KEY)
.apiSecret(OKX_API_SECRET)
.passphrase(OKX_PASSPHRASE)
.contract(CONTRACT)
.leverage(LEVERAGE)
.marginMode(MARGIN_MODE)
.positionMode(POSITION_MODE)
.baseQuantity(BASE_QUANTITY)
.maxLoss(MAX_LOSS)
.priceScale(PRICE_SCALE)
.contractMultiplier(CONTRACT_MULTIPLIER)
.unrealizedPnlPriceMode(PNL_PRICE_MODE)
.isProduction(IS_PRODUCTION)
.profitTriggerRatio(PROFIT_TRIGGER_RATIO)
.reinvestRatio(REINVEST_RATIO)
.maxPositionMultiplier(MAX_POSITION_MULTIPLIER)
.equityRestartRatio(EQUITY_RESTART_RATIO)
.build();
strategy = new OkxProfitRecycleStrategy(config);
strategy.init();
wsClient = new OkxKlineWebSocketClient(config);
wsClient.addPublicHandler(new MarkPriceOkxChannelHandler(config.getContract(), strategy));
wsClient.addPrivateHandler(new PositionsOkxChannelHandler(config, strategy));
wsClient.addPrivateHandler(new OrdersOkxChannelHandler(config, strategy));
strategy.setWsClient(wsClient);
wsClient.init();
log.info("[OKX] WS已连接 | 合约: {} | 杠杆: {}x | 基础张数: {} | "
+ "触发ROI: {}% | 补仓比例: {}% | 仓位上限: {}x | 重置阈值: {}%",
CONTRACT, LEVERAGE, BASE_QUANTITY,
PROFIT_TRIGGER_RATIO.multiply(new BigDecimal("100")),
REINVEST_RATIO.multiply(new BigDecimal("100")),
MAX_POSITION_MULTIPLIER,
EQUITY_RESTART_RATIO.multiply(new BigDecimal("100")));
strategy.startStrategy();
} catch (Exception e) {
log.error("[OKX] 初始化失败", e);
}
}
@PreDestroy
public void destroy() {
log.info("[OKX] 正在销毁...");
if (strategy != null) strategy.stopStrategy();
if (wsClient != null) wsClient.destroy();
log.info("[OKX] 销毁完成");
}
public OkxKlineWebSocketClient getKlineWebSocketClient() { return wsClient; }
public OkxProfitRecycleStrategy getStrategy() { return strategy; }
public IOkxStrategy getActiveStrategy() { return strategy; }
}