自来水预测数据接口 增加预测数据自添加机制

src/main/java/com/shkpr/service/aimodelpower/bizmgr/KprAimWaterCollecationBizFun.java

@@ -535,6 +535,10 @@ public class KprAimWaterCollecationBizFun {
                                                     //预测比对时间如果不是今年,则变为今年的时间
                                                     //TODO 一天24小时
                                                     for (int j = 0;j<24;j++) {
+                                                        if(key.toString().equals("北碚红工水厂")){
+                                                           boolean fal = dateNow.withYear(LocalDateTime.now().getYear()).toLocalDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")).equals("2024-06-17");
+                                                            System.out.println(fal);
+                                                        }
                                                         //TODO 数据库操作
                                                         Map<String, Object> recordAllEntity = new LinkedHashMap<>();//需要添加的实体数据,此处要用有序map
                                                         DateTimeFormatter formatter2 = DateTimeFormatter.ofPattern("yyyy-MM-dd");

src/main/java/com/shkpr/service/aimodelpower/globalmgr/ScheduleTaskMgr.java

@@ -121,54 +121,54 @@ public class ScheduleTaskMgr {
     }
 
     //TODO 启动时执行 测试方法
-//    @PostConstruct
-//    public void initTest(){
-//        Timer timer = new Timer();
-//        // 创建定时器任务
-//        TimerTask timerTask = new TimerTask() {
-//            @Override
-//            public void run() {
-////                KprAimTapWaterBizFun.checkRecordAllData();
-////                KprAimTapWaterBizFun.checkRecordData();
-//                KprAimWaterCollecationBizFun.insertYuceDataScheduled();
-//            }
-//        };
-//        timer.schedule(timerTask, 5000);
-//
-//        Timer timer2 = new Timer();
-//        TimerTask timerTask1 = new TimerTask() {
-//            @Override
-//            public void run() {
-//                KprAimWaterCollecationBizFun.insertYuceHourDataScheduled();
-//            }
-//        };
-//        timer2.schedule(timerTask1, 10000);
-//    }
-
-
-    //TODO 启动时执行一次
     @PostConstruct
-    public void initOneTapWater(){
+    public void initTest(){
         Timer timer = new Timer();
         // 创建定时器任务
         TimerTask timerTask = new TimerTask() {
             @Override
             public void run() {
-                KprAimTapWaterBizFun.initTapWaterData();
+//                KprAimTapWaterBizFun.checkRecordAllData();
+//                KprAimTapWaterBizFun.checkRecordData();
+                KprAimWaterCollecationBizFun.insertYuceDataScheduled();
             }
         };
-        timer.schedule(timerTask, 10000); // 10秒后执行一次
-    }
+        timer.schedule(timerTask, 5000);
 
-    @PostConstruct
-    public void initWaterRecordAll(){
-        Timer timer = new Timer();
+        Timer timer2 = new Timer();
         TimerTask timerTask1 = new TimerTask() {
             @Override
             public void run() {
-                KprAimTapWaterBizFun.initWaterCollecationReacordAll();
+                KprAimWaterCollecationBizFun.insertYuceHourDataScheduled();
             }
         };
-        timer.schedule(timerTask1,11000);//11秒后执行一次
+        timer2.schedule(timerTask1, 10000);
     }
+
+
+    //TODO 启动时执行一次
+//    @PostConstruct
+//    public void initOneTapWater(){
+//        Timer timer = new Timer();
+//        // 创建定时器任务
+//        TimerTask timerTask = new TimerTask() {
+//            @Override
+//            public void run() {
+//                KprAimTapWaterBizFun.initTapWaterData();
+//            }
+//        };
+//        timer.schedule(timerTask, 10000); // 10秒后执行一次
+//    }
+
+//    @PostConstruct
+//    public void initWaterRecordAll(){
+//        Timer timer = new Timer();
+//        TimerTask timerTask1 = new TimerTask() {
+//            @Override
+//            public void run() {
+//                KprAimTapWaterBizFun.initWaterCollecationReacordAll();
+//            }
+//        };
+//        timer.schedule(timerTask1,11000);//11秒后执行一次
+//    }
 }