From f2325419e15661d626edecd9b9063056fa836938 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Wed, 27 Aug 2025 15:04:33 +0800
Subject: [PATCH] K线实时刷新
---
src/main/java/com/nq/service/impl/StockServiceImpl.java | 20 ++++++++++++++++++--
1 files changed, 18 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 ffc26df..4d964e1 100644
--- a/src/main/java/com/nq/service/impl/StockServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/StockServiceImpl.java
@@ -810,7 +810,23 @@
}
stockType = stock.getStockType();
Map<String, Object> resultMap = new HashMap<>();
- DataStockBean cacheBaseStock = RedisKeyUtil.getCacheBaseStock(stockType, pid);
+
+ String s = RedisKeyUtil.doPost(pid, stockType);
+ Map<String, Object> stringObjectMap = RedisKeyUtil.jsonToMap(s);
+ resultMap.put("id", pid);
+ resultMap.put("stockType", stockType);
+ resultMap.put("name", stock.getStockName());
+ resultMap.put("last", stringObjectMap.get("Last").toString());
+ resultMap.put("chg", stringObjectMap.get("Chg").toString());
+ resultMap.put("chgPct", stringObjectMap.get("ChgPct").toString());
+ // 获取K线数据
+ Object kData = getKData(pid, "D", stockType);
+ Gson gson = new Gson();
+ List<kData> dataList = gson.fromJson(kData.toString(), new TypeToken<List<kData>>(){}.getType());
+ resultMap.put("kData", dataList);
+ return ServerResponse.createBySuccess(resultMap);
+
+ /*DataStockBean cacheBaseStock = RedisKeyUtil.getCacheBaseStock(stockType, pid);
if (cacheBaseStock != null) {
resultMap.put("id", cacheBaseStock.getId());
resultMap.put("stockType", stockType);
@@ -830,7 +846,7 @@
List<kData> dataList = gson.fromJson(kData.toString(), new TypeToken<List<kData>>(){}.getType());
resultMap.put("kData", dataList);
return ServerResponse.createBySuccess(resultMap);
- }
+ }*/
} catch (Exception e){
e.printStackTrace();
}
--
Gitblit v1.9.3