修改入库定时程序

13693261870

2023-06-06 3e42b993000e4505c2f33c9242439da3a101763a

修改入库定时程序

 src/main/java/com/yssh/service/VocValsService.java

@@ -50,7 +50,7 @@
    }

    @Async("threadPoolTaskExecutor")
    public int insertVocVals(List<VocVals> list) throws InterruptedException {
    public void insertVocVals(List<VocVals> list) throws InterruptedException {
        List<List<VocVals>> lists = Lists.partition(list, IAsyncService.BATCH_INSERT_500);

        CountDownLatch countDownLatch = new CountDownLatch(list.size());
@@ -60,8 +60,6 @@

        countDownLatch.await();
        logger.info("------ VOC.csv，" + lists.size() + " 条数据已入库 ------");

        return list.size();
    }

    private void executeAsync(List<VocVals> corpList, CountDownLatch countDownLatch) {

 src/main/resources/application-scheduled.yml

@@ -1,3 +1,3 @@
csv: 
  cron: '0 18 * * * ? '
  voc: '0 19 10 * * ? '
  cron: '0 1 * * * ? '
  voc: '0 21 10 * * ? '