From 3a1977e8cc0c5fffbc6490f220f30116af6cce86 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 14 Jan 2026 15:17:07 +0800
Subject: [PATCH] 获取盘前交易列表
---
src/main/java/com/nq/service/impl/StockServiceImpl.java | 83 +++++++++++++++++++++++++++++++++++++++++
src/main/java/com/nq/vo/stock/PremarketStockVO.java | 11 +++++
src/main/java/com/nq/controller/StockApiController.java | 10 +++++
src/main/java/com/nq/service/IStockService.java | 2 +
4 files changed, 106 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/nq/controller/StockApiController.java b/src/main/java/com/nq/controller/StockApiController.java
index 71b648a..2c6e21a 100644
--- a/src/main/java/com/nq/controller/StockApiController.java
+++ b/src/main/java/com/nq/controller/StockApiController.java
@@ -172,4 +172,14 @@
return this.iStockService.getIndicesAndKData(pid, stockType);
}
+ /**
+ * 查询盘前交易数据
+ * 只返回当前时间在交易时间内的盘前数据，返回code和price两个字段
+ */
+ @RequestMapping("getPremarketStock.do")
+ @ResponseBody
+ public ServerResponse getPremarketStock() {
+ return this.iStockService.getPremarketStock();
+ }
+
}
diff --git a/src/main/java/com/nq/service/IStockService.java b/src/main/java/com/nq/service/IStockService.java
index 23ebff4..cfdb535 100644
--- a/src/main/java/com/nq/service/IStockService.java
+++ b/src/main/java/com/nq/service/IStockService.java
@@ -126,4 +126,6 @@
ServerResponse getIndicesAndKData(String pid, String stockType);
ServerResponse getStocksByKeyWords(int pageNum, int pageSize, String keyWords);
+
+ ServerResponse getPremarketStock();
}
diff --git a/src/main/java/com/nq/service/impl/StockServiceImpl.java b/src/main/java/com/nq/service/impl/StockServiceImpl.java
index ae6453f..ed73412 100644
--- a/src/main/java/com/nq/service/impl/StockServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/StockServiceImpl.java
@@ -32,6 +32,7 @@
import java.lang.reflect.Type;
import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
import java.util.*;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
@@ -79,6 +80,9 @@
@Autowired
StockConfigMapper stockConfigMapper;
+
+ @Resource
+ StockSettingMapper stockSettingMapper;
public ServerResponse getMarket() {
String market_url = PropertiesUtil.getProperty("sina.market.url");
@@ -905,4 +909,83 @@
}
return ServerResponse.createByError();
}
+
+ @Override
+ public ServerResponse getPremarketStock() {
+ try {
+ List<StockSetting> stockSettings = stockSettingMapper.selectList(new QueryWrapper<>());
+ List<PremarketStockVO> resultList = new ArrayList<>();
+
+ Date now = new Date();
+ SimpleDateFormat timeFormat = new SimpleDateFormat("HH:mm");
+ String currentTime = timeFormat.format(now);
+
+ for (StockSetting setting : stockSettings) {
+ String startTime = setting.getStartTime();
+ String endTime = setting.getEndTime();
+
+ // 判断当前时间是否在交易时间内
+ if (isTimeInRange(currentTime, startTime, endTime)) {
+ PremarketStockVO vo = new PremarketStockVO();
+ vo.setCode(setting.getStockCode());
+
+ // 计算价格
+ BigDecimal price;
+ if ("0".equals(setting.getType())) {
+ // type=0: 直接指定价格
+ price = new BigDecimal(setting.getPrice());
+ } else {
+ // type=1: 百分比调价格，需要获取当前价格
+ Stock stock = stockMapper.selectOne(new QueryWrapper<Stock>().eq("stock_code", setting.getStockCode()));
+ if (stock != null) {
+ String s = RedisKeyUtil.doPost(stock.getStockCode(), stock.getStockType());
+ if (s != null) {
+ Map<String, Object> stringObjectMap = RedisKeyUtil.jsonToMap(s);
+ BigDecimal currentPrice = new BigDecimal(stringObjectMap.get("Last").toString());
+ price = currentPrice.multiply(new BigDecimal(setting.getPrice()));
+ } else {
+ continue; // 无法获取当前价格，跳过
+ }
+ } else {
+ continue; // 股票不存在，跳过
+ }
+ }
+ vo.setPrice(price);
+ resultList.add(vo);
+ }
+ }
+
+ return ServerResponse.createBySuccess(resultList);
+ } catch (Exception e) {
+ log.error("getPremarketStock error", e);
+ return ServerResponse.createByErrorMsg("查询盘前交易数据失败");
+ }
+ }
+
+ /**
+ * 判断当前时间是否在指定时间范围内
+ * @param currentTime 当前时间，格式：HH:mm
+ * @param startTime 开始时间，格式：HH:mm
+ * @param endTime 结束时间，格式：HH:mm
+ * @return
+ */
+ private boolean isTimeInRange(String currentTime, String startTime, String endTime) {
+ try {
+ java.time.LocalTime current = java.time.LocalTime.parse(currentTime);
+ java.time.LocalTime start = java.time.LocalTime.parse(startTime);
+ java.time.LocalTime end = java.time.LocalTime.parse(endTime);
+
+ // 如果结束时间小于或等于开始时间，说明跨天
+ if (end.isBefore(start) || end.equals(start)) {
+ // 跨天情况：当前时间 >= 开始时间 或 当前时间 <= 结束时间
+ return current.isAfter(start) || current.isBefore(end) || current.equals(start) || current.equals(end);
+ } else {
+ // 正常情况：开始时间 <= 当前时间 <= 结束时间
+ return (current.isAfter(start) || current.equals(start)) && (current.isBefore(end) || current.equals(end));
+ }
+ } catch (Exception e) {
+ log.error("isTimeInRange error", e);
+ return false;
+ }
+ }
}
diff --git a/src/main/java/com/nq/vo/stock/PremarketStockVO.java b/src/main/java/com/nq/vo/stock/PremarketStockVO.java
new file mode 100644
index 0000000..38b4508
--- /dev/null
+++ b/src/main/java/com/nq/vo/stock/PremarketStockVO.java
@@ -0,0 +1,11 @@
+package com.nq.vo.stock;
+
+import lombok.Data;
+import java.math.BigDecimal;
+
+@Data
+public class PremarketStockVO {
+ private String code;
+ private BigDecimal price;
+}
+
--
Gitblit v1.9.3