From cca0b258ffefd2ad478b9e5115200f5a223eb09f Mon Sep 17 00:00:00 2001
From: dd <gitluke@outlook.com>
Date: Fri, 26 Dec 2025 02:31:05 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/StockServiceImpl.java | 38 ++++++++++++++++++++++++++++++++++++--
1 files changed, 36 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/StockServiceImpl.java b/src/main/java/com/nq/service/impl/StockServiceImpl.java
index 5aefa76..09fa4f9 100644
--- a/src/main/java/com/nq/service/impl/StockServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/StockServiceImpl.java
@@ -40,6 +40,7 @@
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.locks.ReentrantLock;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@@ -432,9 +433,41 @@
}
- /*股票日线-K线*/
+
+ // 只需要缓存一个最近返回的Object
+ private static Object lastResult = null;
+ private static long lastExecuteTime = 0;
+ private static final long MIN_INTERVAL_MS = 3000;
+ private static final Object cacheLock = new Object();
+
@Override
public Object getKData(String pid, String interval, String stockType) {
+ long currentTime = System.currentTimeMillis();
+
+ // 第一次快速检查（不加锁）
+ if (lastResult != null && (currentTime - lastExecuteTime) < MIN_INTERVAL_MS) {
+ return lastResult;
+ }
+
+ // 同步块内再次检查并更新
+ synchronized (cacheLock) {
+ currentTime = System.currentTimeMillis();
+ if (lastResult != null && (currentTime - lastExecuteTime) < MIN_INTERVAL_MS) {
+ return lastResult;
+ }
+
+ // 获取新数据
+ Object newResult = doGetKData(pid, interval, stockType);
+
+ // 更新缓存
+ lastResult = newResult;
+ lastExecuteTime = System.currentTimeMillis();
+
+ return newResult;
+ }
+ }
+
+ private Object doGetKData(String pid, String interval, String stockType) {
EStockType eStockType = EStockType.getEStockTypeByCode(stockType);
Object object = HttpUtil.get(eStockType.stockUrl + "kline?pid=" + pid + "&interval=" + interval + "&key=" + eStockType.stockKey);
Gson gson = new Gson();
@@ -444,12 +477,13 @@
BigDecimal nowPrice = iPriceServices.getNowPrice(stock.getStockCode());
Map singleStock = getSingleStock(stock.getStockCode());
StockVO stockVO = (StockVO)singleStock.get("stock");
- // 修改 List 中的最后一条数据
+
kData lastData = dataList.get(dataList.size() - 1);
lastData.setC(nowPrice.toString());
lastData.setO(stockVO.getOpen_px());
lastData.setH(stockVO.getToday_max());
lastData.setL(stockVO.getToday_min());
+
return gson.toJson(dataList);
}
--
Gitblit v1.9.3