From 1256f9068913160f9893b4382cb408835a54349a Mon Sep 17 00:00:00 2001
From: zyy3 <zyy3@zy.com>
Date: Tue, 03 Mar 2026 16:51:32 +0800
Subject: [PATCH] K线
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java | 88 +++++++++++++++++++++++++++++++++++++++++--
1 files changed, 83 insertions(+), 5 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..160e1b5 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
@@ -2,8 +2,10 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.yami.trading.bean.data.domain.Kline;
import com.yami.trading.bean.data.domain.Realtime;
+import com.yami.trading.bean.data.dto.BeforeClose;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.common.config.RequestDataHelper;
import com.yami.trading.common.constants.Constants;
@@ -24,7 +26,9 @@
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.*;
+import java.time.temporal.ChronoUnit;
import java.util.*;
+import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
@Service
@@ -57,8 +61,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());
@@ -108,11 +112,11 @@
// 1. 确定时间戳单位（假设ts是毫秒级，若为秒级需用ofEpochSecond()）
Instant instant = Instant.ofEpochMilli(ts);
- // 2. 将时间戳转换为当地时区的日期（指定时区更准确，如Asia/Shanghai）
- LocalDate tsDate = instant.atZone(ZoneId.of("Asia/Shanghai")).toLocalDate();
+ // 2. 将时间戳转换为当地时区的日期（指定时区更准确，如Asia/Tokyo）
+ LocalDate tsDate = instant.atZone(ZoneId.of("Asia/Tokyo")).toLocalDate();
// 3. 获取“昨天的日期”（当前日期减1天）
- LocalDate yesterday = LocalDate.now(ZoneId.of("Asia/Shanghai")).minusDays(1);
+ LocalDate yesterday = LocalDate.now(ZoneId.of("Asia/Tokyo")).minusDays(1);
// 4. 判断是否为昨天
boolean isYesterday = tsDate.equals(yesterday);
@@ -138,6 +142,80 @@
return realtime;
}
+ public BeforeClose getBeforeClose(String symbol, String line, Long ts) {
+ BeforeClose beforeClose = (BeforeClose) redisTemplate.opsForValue().get(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line);
+ if (beforeClose == null) {
+ // 直接获取当前时间的毫秒级时间戳（系统默认时区，但值是全球统一的）
+ long currentTimeStamp = System.currentTimeMillis();
+
+ // 如果需要严格基于东京时区的当前时间戳（结果和上面一致，因为时间戳是UTC绝对时间）
+ //long currentTokyoTimeStamp = Instant.now().atZone(ZoneId.of("Asia/Tokyo")).toInstant().toEpochMilli();
+ RequestDataHelper.set("symbol", symbol);
+ QueryWrapper<Realtime> queryWrapper = new QueryWrapper<Realtime>()
+ .eq("symbol", symbol) // 直接写数据库字段名（需和表字段一致）
+ .ge("ts", ts)
+ .le("ts", currentTimeStamp)
+ .select("MAX(close) as maxClose", "MIN(close) as minClose");
+ // 4. 执行聚合查询，用selectMap接收结果（键值对：maxClose/minClose -> 对应值）
+ Map<String, Object> resultMap = realtimeService.getMap(queryWrapper);
+ RequestDataHelper.clear();
+ beforeClose = new BeforeClose();
+ if (resultMap == null || resultMap.isEmpty()) {
+ return beforeClose;
+ }
+ beforeClose.setMaxClose(convertToBigDecimal(resultMap.get("maxClose")));
+ beforeClose.setMinClose(convertToBigDecimal(resultMap.get("minClose")));
+ redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose , 5 , TimeUnit.MINUTES);
+ }
+ return beforeClose;
+ }
+
+ // 辅助方法：统一转换为BigDecimal，避免类型错误
+ private BigDecimal convertToBigDecimal(Object value) {
+ if (value == null) {
+ return BigDecimal.ZERO;
+ }
+ if (value instanceof BigDecimal) {
+ return (BigDecimal) value;
+ }
+ try {
+ return new BigDecimal(value.toString());
+ } catch (NumberFormatException e) {
+ log.error("转换数值为BigDecimal失败：value={}", value, e);
+ return BigDecimal.ZERO;
+ }
+ }
+
+ @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