From 7e213a5e5a233ba19eaa148cc65c9f3cfa96986e Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 09 Dec 2025 14:45:57 +0800
Subject: [PATCH] feat(okx): 优化持仓策略与交易逻辑
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java
index 1153973..88236c8 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/PositionsWs.java
@@ -106,8 +106,9 @@
String mgnRatio = safeGetString(posData, "mgnRatio");
String markPx = safeGetString(posData, "markPx");
String bePx = safeGetString(posData, "bePx");
+ String realizedPnl = safeGetString(posData, "realizedPnl");
- boolean setResult = saveToRedis(redisUtils, avgPx, pos, upl, imr, mgnRatio, markPx, bePx);
+ boolean setResult = saveToRedis(redisUtils, avgPx, pos, upl, imr, mgnRatio, markPx, bePx,realizedPnl);
if (setResult) {
calculateAndSaveBuyCount(redisUtils);
@@ -121,14 +122,15 @@
private static boolean saveToRedis(RedisUtils redisUtils,
String avgPx, String pos, String upl,
- String imr, String mgnRatio, String markPx, String bePx) {
+ String imr, String mgnRatio, String markPx, String bePx, String realizedPnl) {
return redisUtils.set(REDIS_KEY_PREFIX + ":avgPx", avgPx, 0)
&& redisUtils.set(REDIS_KEY_PREFIX + ":pos", pos, 0)
&& redisUtils.set(REDIS_KEY_PREFIX + ":upl", upl, 0)
&& redisUtils.set(REDIS_KEY_PREFIX + ":imr", imr, 0)
&& redisUtils.set(REDIS_KEY_PREFIX + ":mgnRatio", mgnRatio, 0)
&& redisUtils.set(REDIS_KEY_PREFIX + ":markPx", markPx, 0)
- && redisUtils.set(REDIS_KEY_PREFIX + ":bePx", bePx, 0);
+ && redisUtils.set(REDIS_KEY_PREFIX + ":bePx", bePx, 0)
+ && redisUtils.set(REDIS_KEY_PREFIX + ":realizedPnl", realizedPnl, 0);
}
private static void calculateAndSaveBuyCount(RedisUtils redisUtils) {
--
Gitblit v1.9.1