瀏覽代碼

水量调度对接实际预测接口数据

1037015548@qq.com 8 月之前
父節點
當前提交
1126c55933
共有 1 個文件被更改,包括 40 次插入40 次删除
  1. 40 40
      src/main/java/com/shkpr/service/aimodelpower/globalmgr/ScheduleTaskMgr.java

+ 40 - 40
src/main/java/com/shkpr/service/aimodelpower/globalmgr/ScheduleTaskMgr.java

@@ -143,62 +143,62 @@ public class ScheduleTaskMgr {
     }
 
     //TODO 启动时执行 测试方法
-    @PostConstruct
-    public void initTest(){
-        String time = LocalDateTime.now().minusYears(1).format(DateTimeFormatter.ofPattern("yyyy-MM"));
-        Timer timer = new Timer();
-        // 创建定时器任务
-        TimerTask timerTask = new TimerTask() {
-            @Override
-            public void run() {
-//                KprAimTapWaterBizFun.checkRecordAllData();
-//                KprAimTapWaterBizFun.checkRecordData();
-                String time = LocalDateTime.now().minusYears(1).format(DateTimeFormatter.ofPattern("yyyy-MM"));
-                KprAimWaterCollecationBizFun.insertYuceDataScheduled(time);
-//                KprAimWaterCollecationBizFun.insertYuceDataScheduled(null);
-            }
-        };
-        timer.schedule(timerTask, 5000);
-
-        Timer timer2 = new Timer();
-        TimerTask timerTask1 = new TimerTask() {
-            @Override
-            public void run() {
-                String time = LocalDateTime.now().minusYears(1).format(DateTimeFormatter.ofPattern("yyyy-MM"));
-                KprAimWaterCollecationBizFun.insertYuceHourDataScheduled(time);
-//                KprAimWaterCollecationBizFun.insertYuceHourDataScheduled(null);
-            }
-        };
-        timer2.schedule(timerTask1, 10000);
-    }
-
-
-    //TODO 启动时执行一次
 //    @PostConstruct
-//    public void initOneTapWater(){
+//    public void initTest(){
+//        String time = LocalDateTime.now().minusYears(1).format(DateTimeFormatter.ofPattern("yyyy-MM"));
 //        Timer timer = new Timer();
 //        // 创建定时器任务
 //        TimerTask timerTask = new TimerTask() {
 //            @Override
 //            public void run() {
-//                KprAimTapWaterBizFun.initTapWaterData();
+////                KprAimTapWaterBizFun.checkRecordAllData();
+////                KprAimTapWaterBizFun.checkRecordData();
+//                String time = LocalDateTime.now().minusYears(1).format(DateTimeFormatter.ofPattern("yyyy-MM"));
+//                KprAimWaterCollecationBizFun.insertYuceDataScheduled(time);
+////                KprAimWaterCollecationBizFun.insertYuceDataScheduled(null);
 //            }
 //        };
-//        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();
+//                String time = LocalDateTime.now().minusYears(1).format(DateTimeFormatter.ofPattern("yyyy-MM"));
+//                KprAimWaterCollecationBizFun.insertYuceHourDataScheduled(time);
+////                KprAimWaterCollecationBizFun.insertYuceHourDataScheduled(null);
 //            }
 //        };
-//        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秒后执行一次
+    }
+
     @Scheduled(cron = "${cron.check.wo.dispatch.plan}")
     public void checkPatrolPlan(){
         ThreadTaskMgr.runTask(new TraceRunnable("S.CHECK.WO.DISPATCH.PLAN.PRODUCE") {