1.江津版本切换 , 数据采集优化

2.数据源配置优化 删除多余配置 优化配置流程
3.优化江津采集日志相关代码
4.自来水和江津采集增加重试机制
5.数据源配置再优化, 将orcle数据源连接配置优化到主数据源代码中
6.优化自来水采集日志

dc3-gateway/src/main/java/io/github/pnoker/gateway/bizmgr/KprZilaishuiLevelBizFun.java

@@ -41,8 +41,8 @@ public class KprZilaishuiLevelBizFun {
         //TODO ① 首先查询水厂设备配置信息
         try {
 
-            System.out.println("计算小时液位开始时间:"+ TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
-            System.out.println("计算小时液位起始时间:("+startFindTime+")进行中:......");
+            log.info("计算小时液位开始时间:"+ TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
+            log.info("计算小时液位起始时间:("+startFindTime+")进行中:......");
             List<Map<String, Object>> configList = getZilaishuiApi().getWaterLevelCollectionConfigList(null);
             if (!CollectionUtils.isEmpty(configList)) {
                 //TODO 按照设备分组
@@ -172,7 +172,7 @@ public class KprZilaishuiLevelBizFun {
                     }
                 }
                 latch.await();
-                System.out.println("计算小时液位检查机制("+startFindTime+")结束时间:"+TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
+                log.info("计算小时液位检查机制("+startFindTime+")结束时间:"+TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
             }
         }catch(Exception ex){
             log.error(String.format("Batch initWaterCollecationReacordAll ERROR:{%s} "

dc3-gateway/src/main/java/io/github/pnoker/gateway/bizmgr/KprZilaishuiPumpBizFun.java

@@ -41,8 +41,8 @@ public class KprZilaishuiPumpBizFun {
         //TODO ① 首先查询水厂设备配置信息
         try {
 
-            System.out.println("添加小时泵数据开始时间:"+ TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
-            System.out.println("添加小时泵数据起始时间:("+startFindTime+")进行中:......");
+            log.info("添加小时泵数据开始时间:"+ TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
+            log.info("添加小时泵数据起始时间:("+startFindTime+")进行中:......");
             List<Map<String, Object>> configList = getZilaishuiApi().getWaterPumpCollectionConfigList(null);
             if (!CollectionUtils.isEmpty(configList)) {
                 //TODO 按照设备分组
@@ -157,7 +157,7 @@ public class KprZilaishuiPumpBizFun {
                     }
                 }
                 latch.await();
-                System.out.println("添加小时泵数据检查机制("+startFindTime+")结束时间:"+TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
+                log.info("添加小时泵数据检查机制("+startFindTime+")结束时间:"+TimeTool.convertUTC2DateStr(TimeTool.getCurMsUTC(),TimeTool.TIMESTAMP_FORMAT));
             }
         }catch(Exception ex){
             log.error(String.format("Batch initWaterCollecationReacordAll ERROR:{%s} "

dc3-gateway/src/main/java/io/github/pnoker/gateway/bizmgr/KprZilaishuiWaterBizFun.java

@@ -142,10 +142,10 @@ public class KprZilaishuiWaterBizFun {
         long roundedNanos = Math.round((double) nanosecondsSinceEpoch / nanosPerMinute) * nanosPerMinute;
 
         // 输出调试信息
-//        System.out.println("解析的时间: " + dateTime);
-//        System.out.println("时区转换后的时间: " + zonedDateTime);
-//        System.out.println("计算的纳秒数: " + nanosecondsSinceEpoch);
-//        System.out.println("最接近整分的纳秒数: " + roundedNanos);
+//        log.info("解析的时间: " + dateTime);
+//        log.info("时区转换后的时间: " + zonedDateTime);
+//        log.info("计算的纳秒数: " + nanosecondsSinceEpoch);
+//        log.info("最接近整分的纳秒数: " + roundedNanos);
 
         return roundedNanos;
     }
@@ -153,7 +153,7 @@ public class KprZilaishuiWaterBizFun {
     //TODO 数据库视图采集
     public static void initHistoryDb(LocalDateTime startDateTime){
         DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
-        System.out.println("自来水历史数据执行:"+startDateTime.format(formatter));
+        log.info("自来水历史数据执行:"+startDateTime.format(formatter));
         if(startDateTime==null){
             return;
         }
@@ -229,7 +229,7 @@ public class KprZilaishuiWaterBizFun {
                                     +"initHistoryDbNullError");
                         }
                     }
-                    System.out.println(startStr+"到"+endStr+"数据整理完成:"+count);
+                    log.info(startStr+"到"+endStr+"数据整理完成:"+count);
                 }
                 currentDateTime = currentDateTime.plusHours(6); // 增加 6 小时
             }