1

zyy3

2025-11-05 91bbc719126310f09031e55967c059c0a01f20b1

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

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



    /**
     * 加载所有股票数据
     */
@@ -111,55 +113,54 @@
                    .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);
                    item.setName(name);
                    item.setSymbolFullName(name);
                    item.setSymbol(o.getSymbol());
                    item.setSymbolData(o.getSymbol());
                    item.setPips(BigDecimal.valueOf(0.01).doubleValue());
                    item.setPipsAmount(BigDecimal.valueOf(0.02).doubleValue());
                    item.setAdjustmentValue(BigDecimal.ZERO.doubleValue());
                    item.setUnitAmount(BigDecimal.valueOf(1000).doubleValue());
                    item.setUnitFee(BigDecimal.valueOf(30).doubleValue());
                    item.setMarket("FOREVER");
                    item.setDecimals(2);
                    item.setMultiple(BigDecimal.ZERO.doubleValue());
                    item.setBorrowingRate(BigDecimal.ZERO.doubleValue());
                    item.setDelFlag(0);
                    item.setType(Item.US_STOCKS);
                    item.setCategory(Item.US_STOCKS);
                    item.setSorted("100");
                    item.setOpenCloseType(Item.US_STOCKS);
                    item.setFake("0");
                    item.setShowStatus("1");
                    item.setTradeStatus("1");
                    item.setQuoteCurrency("USDT");
                    item.setCrawlStatus("default_active");
                    item.setStockCode(o.getId());

                item = new Item();
                String name = StringUtils.trim(o.getName());
                item.setEnName(name);
                item.setName(name);
                item.setSymbolFullName(name);
                item.setSymbol(o.getSymbol());
                item.setSymbolData(o.getSymbol());
                item.setPips(BigDecimal.valueOf(0.01).doubleValue());
                item.setPipsAmount(BigDecimal.valueOf(0.02).doubleValue());
                item.setAdjustmentValue(BigDecimal.ZERO.doubleValue());
                item.setUnitAmount(BigDecimal.valueOf(1000).doubleValue());
                item.setUnitFee(BigDecimal.valueOf(30).doubleValue());
                item.setMarket("FOREVER");
                item.setDecimals(2);
                item.setMultiple(BigDecimal.ZERO.doubleValue());
                item.setBorrowingRate(BigDecimal.ZERO.doubleValue());
                item.setDelFlag(0);
                item.setType(Item.US_STOCKS);
                item.setCategory(Item.US_STOCKS);
                item.setSorted("100");
                item.setOpenCloseType(Item.US_STOCKS);
                item.setFake("0");
                item.setShowStatus("1");
                item.setTradeStatus("1");
                item.setQuoteCurrency("USDT");
                item.setCrawlStatus("default_active");
                item.setStockCode(o.getId());

                updateStockList.add(item);
                    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);