From 31e6203a5bb778ad9d1c599171606c89c8edd3a3 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 21 May 2026 15:59:47 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/AdjustmentValueServiceImpl.java | 14 ++++++++------
1 files changed, 8 insertions(+), 6 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/AdjustmentValueServiceImpl.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/AdjustmentValueServiceImpl.java
index 9f6f207..c02ec1b 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/AdjustmentValueServiceImpl.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/AdjustmentValueServiceImpl.java
@@ -50,15 +50,17 @@
} else {
AdjustmentValueCache.getCurrentValue().put(symbol, currentValue.add(value));
}
- // 马上扣除价格，避免因为数据没有拉取导致加不正确
- realtime.setClose(realtime.getClose().add(value));
/*
- * 持久化缓存
+ * 持久化到品种表（重启后 InitHandle 会加载到 AdjustmentValueCache）
*/
Item item = this.itemService.findBySymbol(symbol);
- if (item.getAdjustmentValue().compareTo(AdjustmentValueCache.getCurrentValue().get(symbol)) != 0) {
- item.setAdjustmentValue(AdjustmentValueCache.getCurrentValue().get(symbol));
- itemService.saveOrUpdate(item);
+ BigDecimal cachedAdjust = AdjustmentValueCache.getCurrentValue().get(symbol);
+ if (item != null && cachedAdjust != null) {
+ BigDecimal itemAdjust = item.getAdjustmentValue();
+ if (itemAdjust == null || itemAdjust.compareTo(cachedAdjust) != 0) {
+ item.setAdjustmentValue(cachedAdjust);
+ itemService.saveOrUpdate(item);
+ }
}
} else {
--
Gitblit v1.9.3