From 83af5e3adc1e71c98617be0e1432860a13652df1 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 19 May 2026 18:21:37 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/utils/task/stock/StockTask.java | 30 ++++++++++++++++++++----------
1 files changed, 20 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/nq/utils/task/stock/StockTask.java b/src/main/java/com/nq/utils/task/stock/StockTask.java
index 48db8e8..f48a756 100644
--- a/src/main/java/com/nq/utils/task/stock/StockTask.java
+++ b/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);
}
--
Gitblit v1.9.3