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


@@ -5,6 +5,8 @@


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;


@@ -18,9 +20,11 @@


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;


@@ -38,8 +42,14 @@


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;


@@ -53,8 +63,10 @@


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 {


@@ -134,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) {


@@ -171,36 +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)));


        }


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




        // Create a list to hold Futures


        List<CompletableFuture<Void>> futures = new ArrayList<>();




        // Use CompletableFuture to perform asynchronous processing for each stockListVO


//        for (StockListVO stockListVO : stockListVOS) {


//            CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {


//                stockListVO.setNowPrice(iPriceServices.getNowPrice(stockListVO.getCode(), stockType).toString());


//                Map<String, Object> newStock = iPriceServices.getNewStock(stockListVO.getCode());


//                stockListVO.setHcrateP(newStock.get("pcp").toString());


//            });


//            futures.add(future);


//        }


//


//        // Wait for all futures to complete


//        CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();


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


@@ -212,34 +212,56 @@


    }






    public ServerResponse getSingleStock(String code, HttpServletRequest request) {


        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("pcp").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());


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


        }


        Map map = Maps.newHashMap();


        map.put("introduction", introduction);


        map.put("stock", stockVO);


        return ServerResponse.createBySuccess(map);


    }




    public Map getSingleStock(String code) {


@@ -457,14 +479,22 @@




        /*股票日线-K线*/


    @Override


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


        EStockType eStockType = EStockType.getEStockTypeByCode(stockType);


        if(eStockType == EStockType.IN){


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


    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, "IN"));


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


@@ -475,10 +505,37 @@


            lastData.setH(stockVO.getToday_max());


            lastData.setL(stockVO.getToday_min());


            return gson.toJson(dataList);




        }


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


    }




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


@@ -501,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);