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-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java | 35 +++++++++++++++++++++++++++++++++--
1 files changed, 33 insertions(+), 2 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java
index 4a33d1e..e5aee0b 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java
@@ -24,6 +24,7 @@
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.*;
+import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.stream.Collectors;
@@ -57,8 +58,8 @@
if (itemService.isSuspended(symbol)) {
return;
}
- /*if (realtime.getSymbol().equals("axsusdt")) {
- System.out.println("axsusdt1" + realtime);
+ /*if (realtime.getSymbol().equals("galausdt")) {
+ System.out.println("galausdt111" + realtime);
}*/
DataCache.putLatestRealTime(symbol, realtime);
DataCache.putLatestOpen(symbol, realtime.getOpen());
@@ -138,6 +139,36 @@
return realtime;
}
+ @Override
+ public void cacheBefore24Hour(String symbol) {
+ // 计算“24小时前”的时间戳（毫秒级）
+ long twentyFourHoursAgo = Instant.now().minus(24, ChronoUnit.HOURS).toEpochMilli();
+ RequestDataHelper.set("symbol", symbol);
+ LambdaQueryWrapper<Realtime> queryWrapper = new LambdaQueryWrapper<Realtime>()
+ .eq(Realtime::getSymbol, symbol)
+ .ge(Realtime::getTs, twentyFourHoursAgo) // 时间戳 >= 24小时前（前24小时内）
+ .orderByDesc(Realtime::getClose) // 24小时最高
+ .last("LIMIT 1");
+ Realtime realtimeHigh = realtimeService.getBaseMapper().selectOne(queryWrapper);
+ LambdaQueryWrapper<Realtime> queryWrapper2 = new LambdaQueryWrapper<Realtime>()
+ .eq(Realtime::getSymbol, symbol)
+ .ge(Realtime::getTs, twentyFourHoursAgo) // 时间戳 >= 24小时前（前24小时内）
+ .orderByAsc(Realtime::getClose) // 24小时最低
+ .last("LIMIT 1");
+ Realtime realtimeLow = realtimeService.getBaseMapper().selectOne(queryWrapper2);
+ RequestDataHelper.clear();
+ System.out.println("realtimeHigh:" + realtimeHigh);
+ System.out.println("realtimeLow:" + realtimeLow);
+ if (realtimeHigh != null) {
+ DataCache.getRealtimeHigh().put(symbol, realtimeHigh.getClose().doubleValue());
+ System.out.println("putRealtimeHigh:" + realtimeHigh.getClose().doubleValue());
+ }
+ if (realtimeLow != null) {
+ DataCache.getRealtimeLow().put(symbol, realtimeLow.getClose().doubleValue());
+ System.out.println("putRealtimeLow:" + realtimeLow.getClose().doubleValue());
+ }
+ }
+
public void deleteRealtime(int days) {
for (int i = 0; i <= Constants.TABLE_PARTITIONS - 1; i++) {
Map<String, Object> parameters = new HashMap();
--
Gitblit v1.9.3