1

zj

2026-05-21 31e6203a5bb778ad9d1c599171606c89c8edd3a3

 trading-order-huobi/src/main/java/com.yami.trading.huobi/data/internal/DataDBServiceImpl.java

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

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

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

            // 4. 判断是否为昨天
             boolean isYesterday = tsDate.equals(yesterday);
@@ -142,34 +142,67 @@
        return realtime;
    }

    public BeforeClose getBeforeClose(String symbol, String line, Long ts) {
    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) {
            // 直接获取当前时间的毫秒级时间戳（系统默认时区，但值是全球统一的）
        //超出时间重新计算
        if (beforeClose == null || ts > beforeClose.getTs()) {
            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) // 直接写数据库字段名（需和表字段一致）
                    .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 , 1 , TimeUnit.MINUTES);
            BigDecimal maxClose = extractAggregateValue(resultMap, "maxClose");
            BigDecimal minClose = extractAggregateValue(resultMap, "minClose");
            mergeRealtimeIntoBeforeClose(beforeClose, maxClose, minClose, realtime);
            beforeClose.setTs(ts);
            redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose);
        } else if (realtime != null) {
            mergeRealtimeIntoBeforeClose(beforeClose, beforeClose.getMaxClose(), beforeClose.getMinClose(), realtime);
            redisTemplate.opsForValue().set(RedisKeys.REAL_TIME_BEFORE_CLOSE + symbol + line, beforeClose);
        }
        return beforeClose;
    }

    private void mergeRealtimeIntoBeforeClose(BeforeClose beforeClose, BigDecimal maxClose, BigDecimal minClose, Realtime realtime) {
        BigDecimal max = maxClose;
        BigDecimal min = minClose;
        if (realtime != null && realtime.getClose() != null) {
            BigDecimal latest = realtime.getClose();
            if (max == null || max.compareTo(BigDecimal.ZERO) <= 0) {
                max = latest;
            } else {
                max = max.max(latest);
            }
            if (min == null || min.compareTo(BigDecimal.ZERO) <= 0) {
                min = latest;
            } else {
                min = min.min(latest);
            }
        }
        beforeClose.setMaxClose(max == null ? BigDecimal.ZERO : max);
        beforeClose.setMinClose(min == null ? BigDecimal.ZERO : min);
    }

    private BigDecimal extractAggregateValue(Map<String, Object> resultMap, String key) {
        if (resultMap == null || resultMap.isEmpty()) {
            return null;
        }
        if (resultMap.containsKey(key)) {
            return convertToBigDecimal(resultMap.get(key));
        }
        for (Map.Entry<String, Object> entry : resultMap.entrySet()) {
            if (entry.getKey() != null && entry.getKey().equalsIgnoreCase(key)) {
                return convertToBigDecimal(entry.getValue());
            }
        }
        return null;
    }

    // 辅助方法：统一转换为BigDecimal，避免类型错误
    private BigDecimal convertToBigDecimal(Object value) {
        if (value == null) {