diff --git a/src/main/java/com/ssf/mysqloracletest/task/AlarmInfoTask.java b/src/main/java/com/ssf/mysqloracletest/task/AlarmInfoTask.java index aad22fe..4f796a3 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/AlarmInfoTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/AlarmInfoTask.java @@ -82,6 +82,7 @@ public class AlarmInfoTask { JcjJjxxViewMysql jjxxViewMysqlCp = new JcjJjxxViewMysql(); try { BeanUtils.copyProperties(bean, jjxxViewMysqlCp); + MetaAlarmInfo alarmInfo = new MetaAlarmInfo(); //设置目标字段的值 //alarm_code<-----JJBH 接警编号 diff --git a/src/main/java/com/ssf/mysqloracletest/task/MetaHandleAlarmTask.java b/src/main/java/com/ssf/mysqloracletest/task/MetaHandleAlarmTask.java index 28c8309..850f8ec 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/MetaHandleAlarmTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/MetaHandleAlarmTask.java @@ -46,16 +46,16 @@ public class MetaHandleAlarmTask { try { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.isNull("status"); - Page page = new Page<>(1, 200); + Page page = new Page<>(1, 1000); List resultList = jcjCjxxViewMysqlService.page(page, queryWrapper).getRecords(); CountDownLatch latch = new CountDownLatch(resultList.size()); - ExecutorService cjxxPool = Executors.newFixedThreadPool(5); +// ExecutorService cjxxPool = Executors.newFixedThreadPool(5); for (JcjCjxxViewMysql bean : resultList) { - cjxxPool.submit(() -> { +// cjxxPool.submit(() -> { cleanCjxx(bean); latch.countDown(); - }); +// }); } @@ -66,7 +66,7 @@ public class MetaHandleAlarmTask { e.printStackTrace(); } // 关闭线程池 - cjxxPool.shutdown(); +// cjxxPool.shutdown(); } catch (Exception e) { logger.info(StringKit.getTrace(e));