添加定时触发函数
Change-Id: Ic4320637c4f5a0ee95f45fc37c80e244ddecc870
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("停止定时任务服务时被中断");
+ }
+ }
+ }
+}