From b28a97e1bf66e3279e78f31ce58122427787ceec Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 11 Jun 2026 09:44:20 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java | 188 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 187 insertions(+), 1 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 a9a5394..eb73aa7 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,9 +2,14 @@
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;
+import com.yami.trading.common.constants.RedisKeys;
import com.yami.trading.common.util.DateUtils;
import com.yami.trading.huobi.data.DataCache;
import com.yami.trading.huobi.data.job.RealtimeQueue;
@@ -13,12 +18,17 @@
import com.yami.trading.service.syspara.SysparaService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcOperations;
import org.springframework.stereotype.Service;
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
@@ -34,6 +44,8 @@
private RealtimeService realtimeService;
@Autowired
private JdbcTemplate jdbcTemplate;
+ @Autowired
+ RedisTemplate redisTemplate;
@Override
public void saveAsyn(Realtime realtime) {
@@ -44,10 +56,22 @@
log.debug("时间没有变化");
return;
}
+
+ //停牌时不更新
+ if (itemService.isSuspended(symbol)) {
+ return;
+ }
+ /*if (realtime.getSymbol().equals("galausdt")) {
+ System.out.println("galausdt111" + realtime);
+ }*/
DataCache.putLatestRealTime(symbol, realtime);
+ DataCache.putLatestOpen(symbol, realtime.getOpen());
// 最近60s内实时价格集合
List<Realtime> list = DataCache.latestRealTimeMap_60s.get(symbol);
+ if (list == null) {
+ return;
+ }
if (list.size() >= KlineConstant.LATEST_REALTIME_LIST_MAX) {
list.remove(0);
}
@@ -78,6 +102,153 @@
RequestDataHelper.clear();
return realtime;
+ }
+
+ @Override
+ public Realtime getBefore(String symbol) {
+ Realtime realtime = (Realtime) redisTemplate.opsForValue().get(RedisKeys.REAL_TIME_BEFORE + symbol);
+ if (realtime != null) {
+ long ts = realtime.getTs();
+ // 1. 确定时间戳单位（假设ts是毫秒级，若为秒级需用ofEpochSecond()）
+ Instant instant = Instant.ofEpochMilli(ts);
+
+ // 2. 将时间戳转换为当地时区的日期（指定时区更准确，如America/New_York）
+ LocalDate tsDate = instant.atZone(ZoneId.of("America/New_York")).toLocalDate();
+
+ // 3. 获取“昨天的日期”（当前日期减1天）
+ LocalDate yesterday = LocalDate.now(ZoneId.of("America/New_York")).minusDays(1);
+
+ // 4. 判断是否为昨天
+ boolean isYesterday = tsDate.equals(yesterday);
+ if (isYesterday) {
+ return realtime;
+ }
+ }
+ // 没缓存重新保存
+ // 计算当天0点的时间戳（毫秒级）
+ LocalDateTime todayStart = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
+ long todayStartTime = todayStart.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli();
+ RequestDataHelper.set("symbol", symbol);
+ LambdaQueryWrapper<Realtime> queryWrapper = new LambdaQueryWrapper<Realtime>()
+ .eq(Realtime::getSymbol, symbol)
+ .lt(Realtime::getTs, todayStartTime)
+ .orderByDesc(Realtime::getTs)
+ .last("LIMIT 1");
+ realtime = realtimeService.getBaseMapper().selectOne(queryWrapper);
+ RequestDataHelper.clear();
+ if (realtime != null) {
+ redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE + symbol, realtime);
+ }
+ return realtime;
+ }
+
+ public BeforeClose getBeforeClose(String symbol, String line, Long ts, Realtime realtime) {
+ BeforeClose beforeClose = (BeforeClose) redisTemplate.opsForValue().get(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line);
+ long queryTs = normalizeToMillis(ts);
+ if (beforeClose == null || queryTs > beforeClose.getTs()) {
+ long currentTimeStamp = System.currentTimeMillis();
+ RequestDataHelper.set("symbol", symbol);
+ QueryWrapper<Realtime> queryWrapper = new QueryWrapper<Realtime>()
+ .eq("symbol", symbol)
+ .ge("ts", queryTs)
+ .le("ts", currentTimeStamp)
+ .select("MAX(CAST(close AS DECIMAL(20,8))) as maxClose",
+ "MIN(CAST(close AS DECIMAL(20,8))) as minClose");
+ Map<String, Object> resultMap = realtimeService.getMap(queryWrapper);
+ RequestDataHelper.clear();
+ beforeClose = new BeforeClose();
+ beforeClose.setTs(queryTs);
+ if (resultMap != null && !resultMap.isEmpty()) {
+ beforeClose.setMaxClose(convertToBigDecimal(resultMap.get("maxClose")));
+ beforeClose.setMinClose(convertToBigDecimal(resultMap.get("minClose")));
+ }
+ redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose);
+ }
+
+ mergeRealtimeIntoBeforeClose(beforeClose, realtime, symbol, line);
+ if (!isValidBeforeClose(beforeClose)) {
+ return null;
+ }
+ return beforeClose;
+ }
+
+ private void mergeRealtimeIntoBeforeClose(BeforeClose beforeClose, Realtime realtime, String symbol, String line) {
+ if (realtime == null || realtime.getClose() == null || realtime.getClose().compareTo(BigDecimal.ZERO) <= 0) {
+ return;
+ }
+ BigDecimal close = realtime.getClose();
+ if (!isValidBeforeClose(beforeClose)) {
+ beforeClose.setMaxClose(close);
+ beforeClose.setMinClose(close);
+ } else {
+ if (close.compareTo(beforeClose.getMaxClose()) > 0) {
+ beforeClose.setMaxClose(close);
+ }
+ if (beforeClose.getMinClose().compareTo(BigDecimal.ZERO) <= 0
+ || close.compareTo(beforeClose.getMinClose()) < 0) {
+ beforeClose.setMinClose(close);
+ }
+ }
+ redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose);
+ }
+
+ private boolean isValidBeforeClose(BeforeClose beforeClose) {
+ return beforeClose != null
+ && beforeClose.getMaxClose() != null && beforeClose.getMaxClose().compareTo(BigDecimal.ZERO) > 0
+ && beforeClose.getMinClose() != null && beforeClose.getMinClose().compareTo(BigDecimal.ZERO) > 0;
+ }
+
+ private long normalizeToMillis(Long ts) {
+ if (ts == null) {
+ return System.currentTimeMillis();
+ }
+ return String.valueOf(ts).length() <= 10 ? ts * 1000 : ts;
+ }
+
+ // 辅助方法：统一转换为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) {
@@ -134,5 +305,20 @@
return realtimes;
}
-
+ @Override
+ public BigDecimal getChangeRatio(Realtime realtime, String symbol) {
+ Item item = itemService.findBySymbol(symbol);
+ if (item.getType().equals(Item.cryptos) && (item.getCurrencyType() != null && item.getCurrencyType() == 1)) {
+ Realtime realtimeBefore = getBefore(symbol);
+ if (realtimeBefore == null) {
+ return BigDecimal.ZERO;
+ }
+ BigDecimal open = realtimeBefore.getClose();
+ BigDecimal changeRatio = realtime.getClose().subtract(open).divide(open, 10, RoundingMode.HALF_UP);
+ changeRatio = changeRatio.multiply(new BigDecimal(100)).setScale(2, RoundingMode.DOWN);
+ return changeRatio;
+ } else {
+ return realtime.getChangeRatio2();
+ }
+ }
}
--
Gitblit v1.9.3