1

zyy

2026-05-29 7289903c3b78d4e6e141e3a5e976ddef52e9fc97

 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,7 +61,11 @@
        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);
@@ -104,11 +112,11 @@
            // 1. 确定时间戳单位（假设ts是毫秒级，若为秒级需用ofEpochSecond()）
            Instant instant = Instant.ofEpochMilli(ts);

            // 2. 将时间戳转换为当地时区的日期（指定时区更准确，如Asia/Shanghai）
            LocalDate tsDate = instant.atZone(ZoneId.of("Asia/Shanghai")).toLocalDate();
            // 2. 将时间戳转换为当地时区的日期（指定时区更准确，如America/New_York）
            LocalDate tsDate = instant.atZone(ZoneId.of("America/New_York")).toLocalDate();

            // 3. 获取“昨天的日期”（当前日期减1天）
            LocalDate yesterday = LocalDate.now(ZoneId.of("Asia/Shanghai")).minusDays(1);
            LocalDate yesterday = LocalDate.now(ZoneId.of("America/New_York")).minusDays(1);

            // 4. 判断是否为昨天
             boolean isYesterday = tsDate.equals(yesterday);
@@ -134,6 +142,149 @@
        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);
        //超出时间重新计算
        if (beforeClose == null || ts > beforeClose.getTs()) {
            beforeClose = calcBeforeClose(symbol, line, ts);
            if (beforeClose.getMaxClose().compareTo(BigDecimal.ZERO) > 0) {
                redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose);
            }
        }

        if (realtime != null && realtime.getClose() != null) {
            if (beforeClose.getMaxClose() == null || beforeClose.getMaxClose().compareTo(BigDecimal.ZERO) <= 0) {
                beforeClose.setMaxClose(realtime.getClose());
            } else if (realtime.getClose().compareTo(beforeClose.getMaxClose()) > 0) {
                beforeClose.setMaxClose(realtime.getClose());
            }
            if (beforeClose.getMinClose() == null || beforeClose.getMinClose().compareTo(BigDecimal.ZERO) <= 0) {
                beforeClose.setMinClose(realtime.getClose());
            } else if (realtime.getClose().compareTo(beforeClose.getMinClose()) < 0) {
                beforeClose.setMinClose(realtime.getClose());
            }
            redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose);
        }
        return beforeClose;
    }

    private BeforeClose calcBeforeClose(String symbol, String line, Long ts) {
        BeforeClose beforeClose = new BeforeClose();
        beforeClose.setTs(ts);
        int interval = sysparaService.find("data_interval").getInteger() / 1000;
        if (interval <= 0) {
            interval = 1;
        }
        HighLow highLow = null;
        switch (line) {
            case Kline.PERIOD_1MIN:
                highLow = HighLowHandle.get(symbol, 60 / interval, interval);
                break;
            case Kline.PERIOD_5MIN:
                highLow = HighLowHandle.get(symbol, (60 * 5) / interval, interval);
                break;
            case Kline.PERIOD_15MIN:
                highLow = HighLowHandle.get(symbol, (60 * 15) / interval, interval);
                break;
            case Kline.PERIOD_30MIN:
                highLow = HighLowHandle.get(symbol, (60 * 30) / interval, interval);
                break;
            case Kline.PERIOD_60MIN:
                highLow = HighLowHandle.get(symbol, (60 * 60) / interval, interval);
                break;
            case Kline.PERIOD_4HOUR:
                highLow = HighLowHandle.get(symbol, (60 * 60 * 4) / interval, interval);
                break;
            case Kline.PERIOD_1DAY:
                highLow = HighLowHandle.get(symbol, (60 * 60 * 24) / interval, interval);
                break;
            case Kline.PERIOD_1WEEK:
                highLow = HighLowHandle.getByDay(symbol, 7);
                break;
            case Kline.PERIOD_1MON:
                highLow = HighLowHandle.getByDay(symbol, 30);
                break;
            default:
                break;
        }
        if (highLow != null && highLow.getHigh() != null) {
            beforeClose.setMaxClose(highLow.getHigh());
        }
        if (highLow != null && highLow.getLow() != null) {
            beforeClose.setMinClose(highLow.getLow());
        }
        if (beforeClose.getMaxClose().compareTo(BigDecimal.ZERO) > 0) {
            return beforeClose;
        }
        long currentTimeStamp = System.currentTimeMillis();
        RequestDataHelper.set("symbol", symbol);
        QueryWrapper<Realtime> queryWrapper = new QueryWrapper<Realtime>()
                .eq("symbol", symbol)
                .ge("ts", ts)
                .le("ts", currentTimeStamp)
                .select("MAX(CAST(close AS DECIMAL(10,4))) as maxClose",
                        "MIN(CAST(close AS DECIMAL(10,4))) as minClose");
        Map<String, Object> resultMap = realtimeService.getMap(queryWrapper);
        RequestDataHelper.clear();
        if (resultMap != null && !resultMap.isEmpty()) {
            BigDecimal maxClose = convertToBigDecimal(resultMap.get("maxClose"));
            BigDecimal minClose = convertToBigDecimal(resultMap.get("minClose"));
            if (maxClose.compareTo(BigDecimal.ZERO) > 0) {
                beforeClose.setMaxClose(maxClose);
            }
            if (minClose.compareTo(BigDecimal.ZERO) > 0) {
                beforeClose.setMinClose(minClose);
            }
        }
        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();