From e84b3c45f7ecef39926b582b10d03b30ff77ee95 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 28 Oct 2025 16:36:56 +0800
Subject: [PATCH] 最高最低值优化

---
 trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java |   18 ++++++++++++++++++
 1 files changed, 18 insertions(+), 0 deletions(-)

diff --git a/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java b/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java
index ef57068..9367bb0 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/api/controller/KlineController.java
@@ -8,6 +8,7 @@
 import com.yami.trading.common.exception.YamiShopBindException;
 import com.yami.trading.common.util.DateUtils;
 import com.yami.trading.common.web.ResultObject;
+import com.yami.trading.huobi.data.AdjustmentValueCache;
 import com.yami.trading.huobi.data.internal.KlineService;
 import com.yami.trading.service.data.DataService;
 import com.yami.trading.service.etf.MarketService;
@@ -95,6 +96,23 @@
                             DateUtils.timeStamp2Date(String.valueOf(datum.getTs()), "MM-dd HH:mm"));
                 }
             }
+
+            /*BigDecimal currentValue = AdjustmentValueCache.getCurrentValue().get(symbol);
+            if (currentValue != null) {
+                data.forEach(kline -> {
+                    *//*logger.info("==currentValue==close:{}, low:{}, high:{}, open:{}, currentValue:{}",
+                            kline.getClose(), kline.getLow(), kline.getHigh(), kline.getOpen(), currentValue);*//*
+                    if (!kline.isAdjusted()){
+                        if (kline.getClose().compareTo(kline.getLow()) >= 0 && kline.getClose().compareTo(kline.getHigh()) <= 0) {
+                            kline.setClose(kline.getClose().add(currentValue));
+                        }
+                        kline.setOpen(kline.getOpen().add(currentValue));
+                        kline.setLow(kline.getLow().add(currentValue));
+                        kline.setHigh(kline.getHigh().add(currentValue));
+                        kline.setAdjusted(true);
+                    }
+                });
+            }*/
             return Result.succeed(this.build(data, line, symbol));
         } catch (Exception e) {
             logger.error("getKline error", e);

--
Gitblit v1.9.3