接警信息修改

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 接警编号

src/main/java/com/ssf/mysqloracletest/task/MetaHandleAlarmTask.java

@@ -46,16 +46,16 @@ public class MetaHandleAlarmTask {
         try {
             QueryWrapper<JcjCjxxViewMysql> queryWrapper = new QueryWrapper<>();
             queryWrapper.isNull("status");
-            Page<JcjCjxxViewMysql> page = new Page<>(1, 200);
+            Page<JcjCjxxViewMysql> page = new Page<>(1, 1000);
             List<JcjCjxxViewMysql> 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));