From 8b5a002f3f02064f3a040765bd39b7c247ca8906 Mon Sep 17 00:00:00 2001
From: chiguyong <chiguyong@beyondsoft.com>
Date: Tue, 24 Mar 2026 00:14:59 +0800
Subject: [PATCH] feat: add maintenance scheduler for preventive maintenance

---
 .../mdm/scheduler/MaintenanceScheduler.java   | 59 +++++++++++++++++++
 .../java/com/ether/pms/PmsApplication.java    |  2 +
 2 files changed, 61 insertions(+)
 create mode 100644 module-mdm/src/main/java/com/ether/pms/mdm/scheduler/MaintenanceScheduler.java

diff --git a/module-mdm/src/main/java/com/ether/pms/mdm/scheduler/MaintenanceScheduler.java b/module-mdm/src/main/java/com/ether/pms/mdm/scheduler/MaintenanceScheduler.java
new file mode 100644
index 0000000..6c7f212
--- /dev/null
+++ b/module-mdm/src/main/java/com/ether/pms/mdm/scheduler/MaintenanceScheduler.java
@@ -0,0 +1,59 @@
+package com.ether.pms.mdm.scheduler;
+
+import com.ether.pms.mdm.entity.MaintenancePlan;
+import com.ether.pms.mdm.service.MaintenancePlanService;
+import com.ether.pms.mdm.service.MaintenanceTaskService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class MaintenanceScheduler {
+
+    private final MaintenancePlanService maintenancePlanService;
+    private final MaintenanceTaskService maintenanceTaskService;
+
+    /**
+     * 检查时间触发的维保计划 - 每天凌晨1点执行
+     */
+    @Scheduled(cron = "0 0 1 * * ?")
+    public void checkTimeBasedMaintenance() {
+        log.info("开始检查时间触发的维保计划...");
+        try {
+            List<MaintenancePlan> plans = maintenancePlanService.getPlansByTriggerType(MaintenancePlan.TriggerType.TIME_BASED);
+            for (MaintenancePlan plan : plans) {
+                try {
+                    maintenanceTaskService.generateTasksFromPlan(plan);
+                    log.info("为计划[{}]生成维保任务完成", plan.getPlanCode());
+                } catch (Exception e) {
+                    log.error("为计划[{}]生成维保任务失败: {}", plan.getPlanCode(), e.getMessage());
+                }
+            }
+            log.info("时间触发维保计划检查完成，共处理 {} 个计划", plans.size());
+        } catch (Exception e) {
+            log.error("检查时间触发维保计划失败: {}", e.getMessage(), e);
+        }
+    }
+
+    /**
+     * 检查逾期任务 - 每小时执行
+     */
+    @Scheduled(cron = "0 0 * * * ?")
+    public void checkOverdueTasks() {
+        log.info("开始检查逾期维保任务...");
+        try {
+            List<?> overdueTasks = maintenanceTaskService.getOverdueTasks();
+            if (!overdueTasks.isEmpty()) {
+                log.warn("发现 {} 个逾期维保任务", overdueTasks.size());
+                // 可以发送通知等后续处理
+            }
+        } catch (Exception e) {
+            log.error("检查逾期维保任务失败: {}", e.getMessage(), e);
+        }
+    }
+}
\ No newline at end of file
diff --git a/pms-starter/src/main/java/com/ether/pms/PmsApplication.java b/pms-starter/src/main/java/com/ether/pms/PmsApplication.java
index 14d1b45..ab285f1 100644
--- a/pms-starter/src/main/java/com/ether/pms/PmsApplication.java
+++ b/pms-starter/src/main/java/com/ether/pms/PmsApplication.java
@@ -3,9 +3,11 @@ package com.ether.pms;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.ComponentScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @ComponentScan(basePackages = {"com.ether.pms"})
+@EnableScheduling
 public class PmsApplication {
 
     public static void main(String[] args) {