江津数据采集 增加历史数据采集, 增加采集任务机制

dc3-gateway/src/main/java/io/github/pnoker/gateway/comtool/ScheduleTaskMgr.java

@@ -247,6 +247,7 @@ public class ScheduleTaskMgr {
                 }
             }
         },7000);
+        //TODO 启动是同步当前月一号到当前时间的所有历史数据
         new Timer().schedule(new TimerTask() {
             @Override
             public void run() {
@@ -259,9 +260,26 @@ public class ScheduleTaskMgr {
         },8000);
     }
 
+    //TODO 每分钟的第五秒执行
     @Scheduled(cron = "5 * * * * ?")
     public void executeTask() {
         KprJiangjinWaterBizfun.InitRealDb();
     }
 
+    //TODO 每天凌晨1点执行前一天的
+    @Scheduled(cron = "0 0 1 * * ?")
+    public void executeHistoryTask() {
+        //TODO 执行前一天的数据到当前
+        KprJiangjinWaterBizfun.initHistoryDb(LocalDate.now().minusDays(1).atStartOfDay());
+    }
+
+    //TODO 每个月的1号凌晨2点执行
+    @Scheduled(cron = "0 0 2 1 * ?")
+    public void executeMonthlyTask() {
+        LocalDateTime firstDayOfLastMonthMidnight = LocalDate.now()
+                .minusMonths(1)  // 减去一个月
+                .withDayOfMonth(1)  // 设置为该月的第一天
+                .atStartOfDay();  // 设置时间为凌晨0点
+        KprJiangjinWaterBizfun.initHistoryDb(firstDayOfLastMonthMidnight);
+    }
 }