1

zyy

2026-05-19 83af5e3adc1e71c98617be0e1432860a13652df1

 src/main/java/com/nq/utils/task/stock/StockTask.java

@@ -91,8 +91,8 @@

                // 1. 定义需要处理的所有股票类型（集中管理，新增类型只需添加到列表）
                List<EStockType> stockTypes = Arrays.asList(
                        EStockType.US,
                        EStockType.JP
                        EStockType.US/*,
                        EStockType.JP*/
                );

                // 2. 批量创建所有异步任务
@@ -140,7 +140,7 @@
                return;
            }
            List<String> stockCodeList = list.stream().map(DataStockBean::getId).collect(Collectors.toList());
            List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList).ne("is_show", 0));
            List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList));

            List<Stock> updateStockList = new ArrayList<>();
            for (DataStockBean o : list) {
@@ -150,6 +150,9 @@
                        .orElse(null);
                if (stock == null) {
                    stock = new Stock();
                    stock.setAddTime(new Date());
                    stock.setIsLock(0);
                    stock.setIsShow(0);
                }
                stock.setStockCode(o.getId());
                stock.setStockName(StringUtils.trim(o.getName()));
@@ -157,10 +160,12 @@
                //指数数据类型
                stock.setStockGid(EConfigKey.INDICES.getCode());
                stock.setStockSpell(o.getSymbol());
                stock.setIsLock(0);
                stock.setIsShow(0);
                /*stock.setIsLock(0);
                if (null == stock.getIsShow()){
                    stock.setIsShow(0);
                }*/
                stock.setDataBase(0);
                stock.setAddTime(new Date());
                //stock.setAddTime(new Date());
                updateStockList.add(stock);

                RedisKeyUtil.setCaCheKeyBaseStock(eStockType, o);
@@ -266,7 +271,7 @@
                return;
            }
            List<String> stockCodeList = list.stream().map(DataStockBean::getId).collect(Collectors.toList());
            List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList).ne("is_show", 0));
            List<Stock> stockList = stockMapper.selectList(new QueryWrapper<Stock>().in("stock_code", stockCodeList));
            List<Stock> updateStockList = new ArrayList<>();
            for (DataStockBean o : list) {
                //Stock stock = stockMapper.findStockByCode(o.getId());
@@ -276,6 +281,9 @@
                        .orElse(null);
                if (stock == null) {
                    stock = new Stock();
                    stock.setIsLock(0);
                    stock.setIsShow(0);
                    stock.setAddTime(new Date());
                }
                stock.setStockCode(o.getId());
                stock.setStockName(StringUtils.trim(o.getName()));
@@ -286,10 +294,12 @@
                    stock.setStockGid(o.getType());
                }
                stock.setStockSpell(o.getSymbol());
                stock.setIsLock(0);
                stock.setIsShow(0);
                //stock.setIsLock(0);
                if (null == stock.getIsShow()){
                    //stock.setIsShow(0);
                }
                stock.setDataBase(0);
                stock.setAddTime(new Date());
                //stock.setAddTime(new Date());
                updateStockList.add(stock);
                RedisKeyUtil.setCaCheKeyBaseStock(eStockType, o);
            }