1

zj

2025-04-23 decfc2ff7244cec365d3f32a5090edf5faeae861

 src/main/java/com/nq/service/impl/StockServiceImpl.java

@@ -21,6 +21,7 @@
import com.nq.service.*;
import com.nq.utils.http.HttpClientRequest;
import com.nq.utils.PropertiesUtil;
import com.nq.utils.redis.RedisKeyConstant;
import com.nq.utils.redis.RedisKeyUtil;
import com.nq.utils.redis.RedisShardedPoolUtils;
import com.nq.utils.stock.pinyin.GetPyByChinese;
@@ -38,6 +39,11 @@
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import javax.annotation.Resource;
@@ -53,6 +59,7 @@
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import static com.nq.utils.timeutil.DateTimeUtil.getWeekDay;

@@ -190,6 +197,24 @@


    public ServerResponse getSingleStock(String code, HttpServletRequest request) {

        if(code.equals("GOLD")){
            String price =  RedisShardedPoolUtils.get(RedisKeyConstant.gold);
            StockVO stockVO = new StockVO();
            stockVO.setNowPrice(price);
            stockVO.setName(code);
            Map map = Maps.newHashMap();
            map.put("stock", stockVO);
            return ServerResponse.createBySuccess(map);
        }else if(code.equals("CRUDE OIL")){
            String price = RedisShardedPoolUtils.get(RedisKeyConstant.crude_oil);
            StockVO stockVO = new StockVO();
            stockVO.setNowPrice(price);
            stockVO.setName(code);
            Map map = Maps.newHashMap();
            map.put("stock", stockVO);
            return ServerResponse.createBySuccess(map);
        }else{
        if (StringUtils.isBlank(code))
            return ServerResponse.createByErrorMsg("");
        Stock stock = stockMapper.findStockByCode(code);
@@ -217,6 +242,7 @@
        map.put("introduction", introduction);
        map.put("stock", stockVO);
        return ServerResponse.createBySuccess(map);
        }
    }

    public Map getSingleStock(String code) {
@@ -432,9 +458,25 @@
    }


    //黄金
    private static final String gold_API_URL = "http://139.196.211.109/ldMetal_k.action?username=Qq112233&password=3ce25a66d5b3a8cd661024fea6c79388&id=AUUSDO&num=-100&period=";

    //原油
    private static final String crude_oil_API_URL = "http://47.112.169.122/fOption_k.action?username=Qq112233&password=3ce25a66d5b3a8cd661024fea6c79388&id=@CL0W&num=-100&period=";

        /*股票日线-K线*/
    @Override
    public Object getKData(String pid, String interval, String stockType) {
        if(stockType.equals("GOLD")){
            // 使用RestTemplate发起HTTP请求
            String response = RedisShardedPoolUtils.get("k_gold_"+interval.toLowerCase());
            return parseData(interval,response, stockType);
        }else if(stockType.equals("CRUDE OIL")){
            // 使用RestTemplate发起HTTP请求
            RestTemplate restTemplate = new RestTemplate();
            String response = RedisShardedPoolUtils.get("k_crude_oil_"+interval.toLowerCase());
            return parseData(interval,response, stockType);
        }else{
        EStockType eStockType = EStockType.getEStockTypeByCode(stockType);
        Object object = HttpUtil.get(eStockType.stockUrl + "kline?pid=" + pid + "&interval=" + interval + "&key=" + eStockType.stockKey);
        Gson gson = new Gson();
@@ -452,6 +494,83 @@
        lastData.setL(stockVO.getToday_min());
        return gson.toJson(dataList);
    }
    }

    public List<kData> parseData(String interval,String data,String key) {
        String price = null;
        if(key.equals("GOLD")){
            price =  RedisShardedPoolUtils.get(RedisKeyConstant.gold);
        }else if(key.equals("CRUDE OIL")){
            price = RedisShardedPoolUtils.get(RedisKeyConstant.crude_oil);
        }
        List<kData> kDataList = new ArrayList<>();

        // 将数据按行分割
        String[] lines = data.split("\n");

        // 跳过第一行（列名）
        for (int i = 1; i < lines.length; i++) {
            String line = lines[i].trim();
            // 确保行不为空
            if (!line.isEmpty()) {
                String[] fields = line.split(",");

                // 确保每行有至少7个字段：日期、开盘价、最高价、最低价、收盘价、成交量、持仓量
                if ((key.equals("CRUDE OIL") && fields.length == 7) || (key.equals("GOLD") && fields.length == 5)) {
                    kData kData = new kData();
                    kData.setT(convDate(fields[0],interval));
                    kData.setC(price);
                    kData.setO(fields[1]);
                    kData.setH(fields[2]);
                    kData.setL(fields[3]);
                    if(key.equals("CRUDE OIL")){
                        kData.setV(fields[4]);
                        kData.setVo(fields[5]);
                    }else{
                        kData.setV("0");
                        kData.setVo("0");
                    }
                    // 将每一条 KData 对象添加到列表中
                    kDataList.add(kData);
                }
            }
        }
        return kDataList;
    }


    // 常量，定义日期格式
    private static final String DATE_PATTERN = "yyyyMMdd";
    private static final String DATE_TIME_PATTERN = "yyyyMMdd HH:mm";

    public long convDate(String dateStr, String interval) {
        // 输入校验，确保 dateStr 和 interval 不为 null 或空
        if (dateStr == null || dateStr.trim().isEmpty() || interval == null || interval.trim().isEmpty()) {
            throw new IllegalArgumentException("日期字符串或时间间隔不能为空。");
        }

        // 根据 interval 的值，选择日期格式
        String pattern = (interval.equalsIgnoreCase("D") || interval.equalsIgnoreCase("W") || interval.equalsIgnoreCase("M"))
                ? DATE_PATTERN : DATE_TIME_PATTERN;

        // 创建 DateTimeFormatter，使用合适的格式
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);

        try {
            // 根据是否包含时间部分，选择 LocalDate 或 LocalDateTime 进行解析
            if (pattern.equals(DATE_PATTERN)) {
                LocalDate localDate = LocalDate.parse(dateStr, formatter);
                Instant timestamp = localDate.atStartOfDay(ZoneOffset.UTC).toInstant();
                return timestamp.getEpochSecond();
            } else {
                LocalDateTime localDateTime = LocalDateTime.parse(dateStr, formatter);
                Instant timestamp = localDateTime.toInstant(ZoneOffset.UTC);
                return timestamp.getEpochSecond();
            }
        } catch (Exception e) {
            throw new IllegalArgumentException("无效的日期格式: " + dateStr, e);
        }
    }

    @Override
    public ServerResponse getOptionStock(HttpServletRequest request) {