From 1278ee2bd43b401489b4377b0eee5259b3d5bbbb Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 13 May 2026 18:17:19 +0800
Subject: [PATCH] refactor(okxNewPrice): 账户配置
---
src/main/java/com/xcong/excoin/modules/okxApi/wsHandler/handler/OkxPositionsChannelHandler.java | 10 +++-------
1 files changed, 3 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxApi/wsHandler/handler/OkxPositionsChannelHandler.java b/src/main/java/com/xcong/excoin/modules/okxApi/wsHandler/handler/OkxPositionsChannelHandler.java
index 1f60705..bb681b6 100644
--- a/src/main/java/com/xcong/excoin/modules/okxApi/wsHandler/handler/OkxPositionsChannelHandler.java
+++ b/src/main/java/com/xcong/excoin/modules/okxApi/wsHandler/handler/OkxPositionsChannelHandler.java
@@ -38,7 +38,6 @@
args.add(arg);
msg.put("args", args);
ws.send(msg.toJSONString());
- log.info("[{}] 订阅成功, 合约:{}", OkxEnums.CHANNEL_POSITIONS, instId);
}
@Override
@@ -53,7 +52,6 @@
args.add(arg);
msg.put("args", args);
ws.send(msg.toJSONString());
- log.info("[{}] 取消订阅成功", OkxEnums.CHANNEL_POSITIONS);
}
@Override
@@ -80,13 +78,11 @@
BigDecimal size = new BigDecimal(pos.getString("pos"));
BigDecimal avgPx = pos.containsKey("avgPx") && pos.getString("avgPx") != null
? new BigDecimal(pos.getString("avgPx")) : BigDecimal.ZERO;
-
- log.info("[{}] 持仓更新, 方向:{}, 数量:{}, 均价:{}, 未实现盈亏:{}, 保证金:{}",
- OkxEnums.CHANNEL_POSITIONS, posSide, size, avgPx,
- pos.get("upl"), pos.get("imr"));
+ BigDecimal realizedPnl = pos.containsKey("realizedPnl") && pos.getString("realizedPnl") != null
+ ? new BigDecimal(pos.getString("realizedPnl")) : BigDecimal.ZERO;
if (gridTradeService != null) {
- gridTradeService.onPositionUpdate(posSide, size, avgPx);
+ gridTradeService.onPositionUpdate(posSide, size, avgPx, realizedPnl);
}
}
} catch (Exception e) {
--
Gitblit v1.9.1