blame | history | patch | commit | commitdiff | ignore whitespace
1
zj
2025-04-30 4bb0b890438349a7cfd7ab2dc30999346a5acf58 
 src/main/java/com/nq/service/impl/StockServiceImpl.java


@@ -1,20 +1,31 @@


package com.nq.service.impl;




import cn.hutool.core.util.ObjectUtil;


import cn.hutool.http.HttpUtil;


import cn.hutool.json.JSONUtil;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.fasterxml.jackson.core.JsonProcessingException;


import com.fasterxml.jackson.databind.ObjectMapper;


import com.github.pagehelper.PageHelper;


import com.github.pagehelper.PageInfo;


import com.google.common.collect.Lists;


import com.google.common.collect.Maps;


import com.google.gson.Gson;


import com.google.gson.JsonObject;


import com.google.gson.reflect.TypeToken;


import com.nq.common.ServerResponse;


import com.nq.config.StockPoll;


import com.nq.dao.*;


import com.nq.enums.EStockType;


import com.nq.pojo.*;


import com.nq.pojo.reponse.RPageInfo;


import com.nq.pojo.reponse.kResponse;


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;


import com.nq.utils.stock.qq.QqStockApi;


@@ -31,20 +42,31 @@


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 java.util.stream.Collectors;


import javax.annotation.Resource;


import javax.servlet.http.HttpServletRequest;


import javax.servlet.http.HttpServletResponse;




import lombok.Data;


import net.sf.json.JSONArray;


import net.sf.json.JSONObject;


import org.apache.commons.lang3.ObjectUtils;


import org.apache.commons.lang3.StringUtils;


import org.slf4j.Logger;


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;


import static net.sf.jsqlparser.util.validation.metadata.NamedObject.user;




@Service("iStockService")


public class StockServiceImpl implements IStockService {


@@ -87,6 +109,7 @@


    @Autowired


    IPriceServices iPriceServices;






    public ServerResponse getMarket() {


        String market_url = PropertiesUtil.getProperty("sina.market.url");


        String result = null;


@@ -123,7 +146,7 @@


        List<Stock> stockList = new ArrayList<>();


        if (stockType.equals("99")) {


            PageHelper.startPage(pageNum, pageSize);


            stockList.addAll(stockMapper.findZtStockListByKeyWords(keyWords, stockPlate, "IN", Integer.valueOf(0)));


            stockList.addAll(stockMapper.findZtStockListByKeyWords(keyWords, stockPlate, EStockType.ST.getCode(), Integer.valueOf(0)));


        } else if (stockType.equals("100")) {


            User user = iUserService.getCurrentRefreshUser(request);


            if (user == null) {


@@ -160,24 +183,24 @@


    @Override


    public ServerResponse getStockByType(int pageNum, int pageSize, String orderBy, String keyWords, String stockType, HttpServletRequest request) {


        List<Stock> stockList = new ArrayList<>();


        if(stockType.equals(EStockType.IN.getCode())){


            PageHelper.startPage(pageNum, pageSize);


            stockList.addAll(stockMapper.findStockByType(orderBy,stockType,keyWords));


        }else{


            PageHelper.startPage(pageNum, pageSize);


            stockList.addAll(stockMapper.findStockTypeDz(orderBy,EStockType.IN.getCode(), keyWords));


        }








        PageHelper.startPage(pageNum, pageSize);


        stockList.addAll(stockMapper.findStockByType(orderBy,stockType,keyWords));


        List<StockListVO> stockListVOS = Lists.newArrayList();


        if (stockList.size() > 0){


            stockListVOS.addAll(Objects.requireNonNull(StockApi.getStockReailTimes(stockList)));


        }


        for (int i = 0; i <stockListVOS.size() ; i++) {


            stockListVOS.get(i).setNowPrice(iPriceServices.getNowPrice(stockListVOS.get(i).getCode(),stockType).toString());


        RPageInfo<StockListVO> pageInfo = new RPageInfo<StockListVO>();






        if(null != orderBy && orderBy.equals("asc")){


            stockListVOS = stockListVOS.stream().sorted(Comparator.comparing(StockListVO::getHcrate)).collect(Collectors.toList());


        }


        RPageInfo pageInfo = new RPageInfo();




        if(null != orderBy && orderBy.equals("desc")){


            stockListVOS = stockListVOS.stream()


                    .sorted(Comparator.comparing(StockListVO::getHcrate).reversed())


                    .collect(Collectors.toList());


        }


        pageInfo.setList(stockListVOS);


        pageInfo.setStockType(stockType);


        return ServerResponse.createBySuccess(pageInfo);


@@ -189,10 +212,63 @@


    }






    public ServerResponse getSingleStock(String code, HttpServletRequest request) {


    public ServerResponse getSingleStock(String code, HttpServletRequest request) throws JsonProcessingException {




        if(code.equals("XAUUSD")){


            String price =  RedisShardedPoolUtils.get(RedisKeyConstant.XAUUSD);


            getKData(null, "1", code);//只是为了得到下面redis的值


            StockVO stockVO = new StockVO();


            stockVO.setNowPrice(price);


            stockVO.setName(code);


            stockVO.setHcrate(RedisShardedPoolUtils.get(code+"_H"));


            Map map = Maps.newHashMap();


            map.put("stock", stockVO);


            return ServerResponse.createBySuccess(map);


        }else if(code.equals("USOIL")){


            String price = RedisShardedPoolUtils.get(RedisKeyConstant.USOIL);


            StockVO stockVO = new StockVO();


            stockVO.setNowPrice(price);


            stockVO.setName(code);


            stockVO.setHcrate(RedisShardedPoolUtils.get(code+"_H"));


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


            DataStockBean cacheBaseStock = RedisKeyUtil.getCacheBaseStock(stock);


            Integer depositAmt = 0;


            String introduction = null;


            StockVO   stockVO = StockApi.assembleInStockVO(stock);


            stockVO.setDepositAmt(depositAmt);


            stockVO.setNowPrice(iPriceServices.getNowPrice(stock.getStockCode()).toString());


            stockVO.setType(stock.getStockType());


            stockVO.setId(stock.getId().intValue());


            stockVO.setCode(stock.getStockCode());


            stockVO.setName(stock.getStockName());


            stockVO.setSpell(stock.getStockSpell());


            stockVO.setGid(stock.getStockGid().toUpperCase());


            Map<String, Object> newStock = iPriceServices.getNewStock(stock.getStockCode());


            stockVO.setHcrate(newStock.get("ChgPct").toString().replaceAll("%", ""));


            stockVO.setToday_max(newStock.get("High").toString());


            stockVO.setToday_min(newStock.get("Low").toString());


            if(null != cacheBaseStock){


                stockVO.setOpen_px(cacheBaseStock.getOpen());


                stockVO.setPreclose_px(cacheBaseStock.getPrevClose());


            }


            Map map = Maps.newHashMap();


            map.put("introduction", introduction);


            map.put("stock", stockVO);


            return ServerResponse.createBySuccess(map);


        }


    }




    public Map getSingleStock(String code) {


        if (StringUtils.isBlank(code))


            return ServerResponse.createByErrorMsg("");


            return null;


        Stock stock = stockMapper.findStockByCode(code);


        DataStockBean cacheBaseStock = RedisKeyUtil.getCacheBaseStock(stock);


        Integer depositAmt = 0;


        String introduction = null;


        StockVO   stockVO = StockApi.assembleInStockVO(stock);


@@ -204,10 +280,14 @@


        stockVO.setName(stock.getStockName());


        stockVO.setSpell(stock.getStockSpell());


        stockVO.setGid(stock.getStockGid().toUpperCase());


        if(null != cacheBaseStock){


            stockVO.setOpen_px(cacheBaseStock.getOpen());


            stockVO.setPreclose_px(cacheBaseStock.getPrevClose());


        }


        Map map = Maps.newHashMap();


        map.put("introduction", introduction);


        map.put("stock", stockVO);


        return ServerResponse.createBySuccess(map);


        return map;


    }






@@ -385,16 +465,77 @@


        EchartsDataVO echartsDataVO = StockApi.assembleEchartsDataVO(minDataVO);


        return ServerResponse.createBySuccess(echartsDataVO);


    }




    /*股票日线-K线*/


    @Override


    public Object getKData(String pid, String interval, String stockType) {


        EStockType eStockType = EStockType.getEStockTypeByCode(stockType);


        if(eStockType == EStockType.IN){


            return HttpUtil.get(eStockType.stockUrl+"api/all/getKData.do?pid="+pid+"&interval="+interval+"&stockType=in");


        }


        return  HttpUtil.get(eStockType.stockUrl + "kline?pid=" + pid + "&interval=" + interval + "&key=" + eStockType.stockKey);


    @lombok.Data


    class kData {


        long t;


        String c;


        String o;


        String h;


        String l;


        String v;


        String vo;


    }






        /*股票日线-K线*/


    @Override


    public Object getKData(String pid, String interval, String stockType) throws JsonProcessingException {


        if(stockType.equals("XAUUSD")){


            // 使用RestTemplate发起HTTP请求


            String response = RedisShardedPoolUtils.get("k_gold_"+interval.toLowerCase());


            return parseData(interval,response, stockType);


        }else if(stockType.equals("USOIL")){


            // 使用RestTemplate发起HTTP请求


            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();


            List<kData> dataList = gson.fromJson(object.toString(), new TypeToken<List<kData>>(){}.getType());




            Stock stock = stockMapper.selectOne(new LambdaQueryWrapper<Stock>().eq(Stock::getStockCode, pid).eq(Stock::getStockType, EStockType.ST.getCode()));


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


        }


    }




    public List<kData> parseData(String interval,String data,String key) throws JsonProcessingException {


        String price = null;


        if(key.equals("XAUUSD")){


            price =  RedisShardedPoolUtils.get(RedisKeyConstant.XAUUSD);


        }else if(key.equals("USOIL")){


            price = RedisShardedPoolUtils.get(RedisKeyConstant.USOIL);


        }


        List<kData> kDataList = new ArrayList<>();


        // 使用 Gson 解析 JSON 字符串


        Gson gson = new Gson();


        kResponse kResponse = gson.fromJson(data, kResponse.class);




        // 打印 kline_list 的内容


        for (kResponse.KlineData item : kResponse.getData().getKlineList()) {


                kData kData = new kData();


                kData.setT(item.getTimestamp());


                kData.setC(item.getClose_price());


                kData.setO(item.getOpen_price());


                kData.setH(item.getHigh_price());


                kData.setL(item.getLow_price());


                kData.setV(item.getVolume());


                kData.setVo(item.getTurnover());


                kDataList.add(kData);


        }


        kDataList.get(kDataList.size() - 1).setC(price);


        return kDataList;


    }






    @Override


    public ServerResponse getOptionStock(HttpServletRequest request) {


@@ -417,9 +558,9 @@


        return ServerResponse.createBySuccess(this.stockMapper.selectByPrimaryKey(stockId));


    }




    public ServerResponse<PageInfo> listByAdmin(Integer showState, Integer lockState, String code, String name, String stockPlate, String stockType, int pageNum, int pageSize, HttpServletRequest request) {


    public ServerResponse<PageInfo> listByAdmin(String stockGid,Integer showState, Integer lockState, String code, String name, String stockPlate, String stockType, int pageNum, int pageSize, HttpServletRequest request) {


        PageHelper.startPage(pageNum, pageSize);


        List<Stock> stockList = this.stockMapper.listByAdmin(showState, lockState, code, name, stockPlate, stockType);


        List<Stock> stockList = this.stockMapper.listByAdmin(stockGid,showState, lockState, code, name, stockPlate, stockType);


        List<StockAdminListVO> stockAdminListVOS = Lists.newArrayList();


        for (Stock stock : stockList) {


            StockAdminListVO stockAdminListVO = assembleStockAdminListVO(stock);