fix: 修复各种导入数据为空出错问题

dev_refactor_0120_qoder
Lxy 4 months ago
parent 0f88a02f5a
commit 524b63159b

@ -97,16 +97,25 @@ public class StockDailyTradeServiceImpl implements IStockDailyTradeService
@Override @Override
@Transactional @Transactional
public int importStockDailyTrade(List<TStockDailyTrade> stockDailyTradeList, Date tradeDate) public int importStockDailyTrade(List<TStockDailyTrade> stockDailyTradeList1, Date tradeDate)
{ {
if (stockDailyTradeList == null || stockDailyTradeList.isEmpty()) if (stockDailyTradeList1 == null || stockDailyTradeList1.isEmpty())
{ {
return 0; return 0;
} }
List<TStockDailyTrade> stockDailyTradeList = new ArrayList<>();
// 设置交易日期 // 设置交易日期
for (TStockDailyTrade stockDailyTrade : stockDailyTradeList) for (TStockDailyTrade stockDailyTrade : stockDailyTradeList1)
{ {
if(stockDailyTrade.getStockCode() == null || stockDailyTrade.getStockCode().trim().isEmpty())
continue;
if(stockDailyTrade.getStockName() == null || stockDailyTrade.getStockName().trim().isEmpty())
continue;
if(stockDailyTrade.getIndustryIndexName() == null || stockDailyTrade.getIndustryIndexName().trim().isEmpty())
continue;
if(stockDailyTrade.getClosePrice() == null)
continue;
if (stockDailyTrade.getTradeDate() == null) if (stockDailyTrade.getTradeDate() == null)
{ {
stockDailyTrade.setTradeDate(tradeDate); stockDailyTrade.setTradeDate(tradeDate);
@ -120,6 +129,7 @@ public class StockDailyTradeServiceImpl implements IStockDailyTradeService
{ {
stockDailyTrade.setIsLimitDown(0); stockDailyTrade.setIsLimitDown(0);
} }
stockDailyTradeList.add(stockDailyTrade);
} }
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
@ -203,7 +213,7 @@ public class StockDailyTradeServiceImpl implements IStockDailyTradeService
{ {
// 如果不存在,创建新的股票基础数据记录 // 如果不存在,创建新的股票基础数据记录
// 只有当必要字段不为空时才插入 // 只有当必要字段不为空时才插入
if (stockDailyTrade.getStockCode() != null && stockDailyTrade.getStockName() != null) if (stockDailyTrade.getStockCode() != null && !stockDailyTrade.getStockCode().trim().isEmpty() && stockDailyTrade.getStockName() != null && !stockDailyTrade.getStockName().trim().isEmpty())
{ {
TStockBasic newBasic = new TStockBasic(); TStockBasic newBasic = new TStockBasic();
newBasic.setStockCode(stockDailyTrade.getStockCode()); newBasic.setStockCode(stockDailyTrade.getStockCode());
@ -215,7 +225,7 @@ public class StockDailyTradeServiceImpl implements IStockDailyTradeService
} else { } else {
newBasic.setIndustryIndexCode(""); // 设置默认值 newBasic.setIndustryIndexCode(""); // 设置默认值
} }
if (stockDailyTrade.getIndustryIndexName() != null) { if (stockDailyTrade.getIndustryIndexName() != null && !stockDailyTrade.getIndustryIndexName().trim().isEmpty()) {
newBasic.setIndustryIndexName(stockDailyTrade.getIndustryIndexName()); newBasic.setIndustryIndexName(stockDailyTrade.getIndustryIndexName());
} else { } else {
newBasic.setIndustryIndexName(""); newBasic.setIndustryIndexName("");

Loading…
Cancel
Save