From 6ca466185554ac1671af9556d4b2f9df9c8c9974 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 14 Jan 2026 16:09:41 +0800
Subject: [PATCH] 1

---
 src/main/java/com/nq/service/impl/StockServiceImpl.java |   28 +++++++++++-----------------
 1 files changed, 11 insertions(+), 17 deletions(-)

diff --git a/src/main/java/com/nq/service/impl/StockServiceImpl.java b/src/main/java/com/nq/service/impl/StockServiceImpl.java
index 6d01080..bf35ca2 100644
--- a/src/main/java/com/nq/service/impl/StockServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/StockServiceImpl.java
@@ -931,16 +931,17 @@
                         continue; // 股票不存在,跳过
                     }
                     
-                    // 先获取真实涨跌幅数据
+                    // 先获取真实数据,用于获取前收盘价和当前价格
                     StockRealTimeBean realTimeStock = RedisKeyUtil.getCacheRealTimeStock(stock);
-                    if (realTimeStock == null) {
+                    if (realTimeStock == null || realTimeStock.getPc() == null) {
                         continue; // 无法获取真实数据,跳过
                     }
                     
-                    // 获取当前价格(last)
+                    // 获取前收盘价和当前价格(last)
+                    BigDecimal prevClose = new BigDecimal(realTimeStock.getPc());
                     BigDecimal last = new BigDecimal(realTimeStock.getLast());
                     
-                    // 计算盘前价格
+                    // 计算盘前价格(根据StockSetting配置)
                     BigDecimal premarketPrice;
                     if ("0".equals(setting.getType())) {
                         // type=0: 直接指定价格
@@ -950,19 +951,12 @@
                         premarketPrice = last.multiply(new BigDecimal(setting.getPrice()));
                     }
                     
-                    // 获取真实涨跌幅(相对于前收盘价的涨跌幅,getPcp()返回的是百分比数值,需要除以100转为小数)
-                    BigDecimal realHcrate = new BigDecimal(realTimeStock.getPcp())
-                            .divide(new BigDecimal("100"), 4, RoundingMode.HALF_UP);
-                    
-                    // 计算盘前价格相对于last的变化率 = (盘前价格 - last) / last
-                    BigDecimal premarketChangeRate = BigDecimal.ZERO;
-                    if (last.compareTo(BigDecimal.ZERO) > 0) {
-                        premarketChangeRate = premarketPrice.subtract(last)
-                                .divide(last, 4, RoundingMode.HALF_UP);
+                    // 根据盘前价格计算涨跌幅 = (盘前价格 - 前收盘价) / 前收盘价
+                    BigDecimal hcrate = BigDecimal.ZERO;
+                    if (prevClose.compareTo(BigDecimal.ZERO) > 0) {
+                        hcrate = premarketPrice.subtract(prevClose)
+                                .divide(prevClose, 4, RoundingMode.HALF_UP);
                     }
-                    
-                    // 最终涨跌幅 = 真实涨跌幅 + 盘前价格相对于last的变化率
-                    BigDecimal hcrate = realHcrate.add(premarketChangeRate);
                     
                     // 格式化涨跌幅为带百分号的字符串
                     String hcrateP = hcrate.multiply(new BigDecimal("100"))
@@ -970,7 +964,7 @@
                     
                     PremarketStockVO vo = new PremarketStockVO();
                     vo.setCode(setting.getStockCode());
-                    vo.setPrice(last); // price对应last
+                    vo.setPrice(premarketPrice); // price返回盘前价格
                     vo.setHcrate(hcrate);
                     vo.setHcrateP(hcrateP);
                     resultList.add(vo);

--
Gitblit v1.9.3