blame | history | patch | commit | commitdiff | ignore whitespace
zj
2024-05-23 846ff7c7570ef124b10e48d6816955a1bbc02db5 
 src/main/java/com/nq/service/impl/StockServiceImpl.java


@@ -36,6 +36,10 @@


import java.net.URL;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.concurrent.CompletableFuture;


import java.util.concurrent.ExecutorService;


import java.util.concurrent.Executors;


import java.util.stream.Collectors;


import javax.annotation.Resource;


import javax.servlet.http.HttpServletRequest;


import javax.servlet.http.HttpServletResponse;


@@ -168,19 +172,29 @@


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


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


        PageHelper.startPage(pageNum, pageSize);


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


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


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


        if (stockList.size() > 0){


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


        }




        // Use CompletableFuture to perform asynchronous processing for each stockListVO


        ExecutorService executor = Executors.newFixedThreadPool(20); // Create a fixed thread pool with a maximum of 10 threads


        List<CompletableFuture<Void>> futures = stockListVOS.stream()


                .map(stockListVO -> CompletableFuture.supplyAsync(() ->


                                iPriceServices.getNowPrice(stockListVO.getCode(), stockType), executor)


                        .thenAcceptAsync(price -> stockListVO.setNowPrice(price.toString()), executor))


                .collect(Collectors.toList());




        // Wait for all futures to complete


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




        RPageInfo pageInfo = new RPageInfo();


        pageInfo.setList(stockListVOS);


        pageInfo.setStockType(stockType);


        return ServerResponse.createBySuccess(pageInfo);


    }






    public ServerResponse getDateline(HttpServletResponse response, String code) {


        if (StringUtils.isBlank(code))


@@ -262,7 +276,7 @@


        String introduction = null;


        StockVO   stockVO = StockApi.assembleInStockVO(stock);


        stockVO.setDepositAmt(depositAmt);


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


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


        stockVO.setType(stock.getStockType());


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


        stockVO.setCode(stock.getStockCode());