diff --git a/src/main/java/scheduler/SchedulerService.java b/src/main/java/scheduler/SchedulerService.java
new file mode 100644
index 0000000..2ca443e
--- /dev/null
+++ b/src/main/java/scheduler/SchedulerService.java
@@ -0,0 +1,74 @@
+package scheduler;
+
+import cheat.Cheat;
+import database.Database1;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 定时任务服务，负责定期执行各种维护任务
+ */
+public class SchedulerService {
+    private static final Logger logger = LoggerFactory.getLogger(SchedulerService.class);
+    private final ScheduledExecutorService scheduler;
+    private final Cheat cheat;
+    private final Database1 database1;
+    
+    public SchedulerService() {
+        this.scheduler = Executors.newScheduledThreadPool(2);
+        this.cheat = new Cheat();
+        this.database1 = new Database1();
+        logger.info("SchedulerService 初始化完成");
+    }
+    
+    /**
+     * 启动所有定时任务
+     */
+    public void start() {
+        // 每分钟执行一次 PunishUser 函数
+        scheduler.scheduleAtFixedRate(
+            this::executePunishUser,
+            0, // 初始延迟1分钟
+            1, // 每1分钟执行一次
+            TimeUnit.MINUTES
+        );
+        
+        logger.info("定时任务已启动 - PunishUser 任务将每分钟执行一次");
+    }
+    
+    /**
+     * 执行用户惩罚任务
+     */
+    private void executePunishUser() {
+        try {
+            logger.info("开始执行 PunishUser 定时任务");
+            cheat.PunishUser();
+            database1.SettleBeg();
+            logger.info("PunishUser 定时任务执行完成");
+        } catch (Exception e) {
+            logger.error("执行 PunishUser 定时任务时发生错误: {}", e.getMessage(), e);
+        }
+    }
+    
+    /**
+     * 停止所有定时任务
+     */
+    public void stop() {
+        if (scheduler != null && !scheduler.isShutdown()) {
+            scheduler.shutdown();
+            try {
+                if (!scheduler.awaitTermination(10, TimeUnit.SECONDS)) {
+                    scheduler.shutdownNow();
+                }
+                logger.info("定时任务服务已停止");
+            } catch (InterruptedException e) {
+                scheduler.shutdownNow();
+                Thread.currentThread().interrupt();
+                logger.warn("停止定时任务服务时被中断");
+            }
+        }
+    }
+}