From 73e608df889ebeca1c87cb8d77676923b8872a83 Mon Sep 17 00:00:00 2001
From: dd <gitluke@outlook.com>
Date: Fri, 26 Dec 2025 02:40:01 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/StockServiceImpl.java | 54 +++++++++++++++++++++++++++++++++++-------------------
1 files changed, 35 insertions(+), 19 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/StockServiceImpl.java b/src/main/java/com/nq/service/impl/StockServiceImpl.java
index 99caac7..73243ce 100644
--- a/src/main/java/com/nq/service/impl/StockServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/StockServiceImpl.java
@@ -177,23 +177,6 @@
if (stockList.size() > 0){
stockListVOS.addAll(Objects.requireNonNull(StockApi.getStockReailTimes(stockList)));
}
-
- // Create a list to hold Futures
- List<CompletableFuture<Void>> futures = new ArrayList<>();
-
- // Use CompletableFuture to perform asynchronous processing for each stockListVO
-// for (StockListVO stockListVO : stockListVOS) {
-// CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
-// stockListVO.setNowPrice(iPriceServices.getNowPrice(stockListVO.getCode(), stockType).toString());
-// Map<String, Object> newStock = iPriceServices.getNewStock(stockListVO.getCode());
-// stockListVO.setHcrateP(newStock.get("pcp").toString());
-// });
-// futures.add(future);
-// }
-//
-// // Wait for all futures to complete
-// CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
-
RPageInfo pageInfo = new RPageInfo();
pageInfo.setList(stockListVOS);
pageInfo.setStockType(stockType);
@@ -449,9 +432,41 @@
}
- /*股票日线-K线*/
+ /*股票日线-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();
@@ -461,12 +476,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