获取盘前交易列表

zj

2026-01-14 3a1977e8cc0c5fffbc6490f220f30116af6cce86

 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;
        }
    }
}