1

zyy3

2025-11-05 91bbc719126310f09031e55967c059c0a01f20b1

 trading-order-admin/src/main/java/com/yami/trading/admin/task/StockTask.java

@@ -79,6 +79,8 @@
        }
    }



    /**
     * 加载所有股票数据
     */
@@ -111,26 +113,24 @@
                    .eq("type", Item.indices));

            log.info("同步股票 已有数据 {} 获取数据 {}", stockList.size(), list.size());
            System.out.println(stockList);
            List<Item> updateStockList = new ArrayList<>();
            for (StockRealTimeBean o : list) {
                //System.out.println(o);
                Item indices = indicesList.stream()
                        .filter(x -> x.getSymbol().equals(o.getSymbol()))
                        .findFirst()
                        .orElse(null);
                if (indices != null) {  //指数不添加
                    continue;
                }


                Item item = stockList.stream()
                        .filter(x -> x.getSymbol().equals(o.getSymbol()) &&
                                x.getStockCode().equals(o.getId()))
                        .findFirst()
                        .orElse(null);
                if (item != null) {  //已有不添加
                    continue;
                }
                item = indicesList.stream()
                        .filter(x -> x.getSymbol().equals(o.getSymbol()))
                        .findFirst()
                        .orElse(null);
                if (item != null) {  //已有不添加
                    continue;
                }

                if (item == null) {
                item = new Item();
                String name = StringUtils.trim(o.getName());
                item.setEnName(name);
@@ -160,6 +160,7 @@
                item.setStockCode(o.getId());

                updateStockList.add(item);
                }


                Realtime realtime = new Realtime();
@@ -191,6 +192,10 @@
        }
    }





    public static void main(String[] args) {
        StockTask task = new StockTask();
        task.loadAllStock(EStockType.US);