src/main/java/com/yssh/service/VocValsService.java
@@ -55,6 +55,15 @@ return vocValsMapper.deleteByTime(time); } public void insertVocSync(List<VocVals> list) { List<List<VocVals>> subLists = Lists.partition(list, 100); for (List<VocVals> sub : subLists) { vocValsMapper.inserts(sub); } logger.info("------ VOC.csv," + list.size() + " 条数据已入库 ------"); } @Async("threadPoolTaskExecutor") public void insertVocVals(List<VocVals> list) throws InterruptedException { List<List<VocVals>> lists = Lists.partition(list, IAsyncService.BATCH_INSERT_500);