'commit'

YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/LingDianTask.java

@@ -1,9 +1,7 @@
 package com.dsideal.YunXiaoTools.Cron4j;
 
 import com.dsideal.YunXiaoTools.Service.MysqlBackupService;
-import com.dsideal.YunXiaoTools.Service.MysqlRestoreService;
 import com.dsideal.YunXiaoTools.Start;
-import com.dsideal.YunXiaoTools.Utils.CommonUtil;
 import com.jfinal.plugin.cron4j.ITask;
 import lombok.SneakyThrows;
 
@@ -11,20 +9,11 @@ import lombok.SneakyThrows;
 public class LingDianTask implements ITask {
     @SneakyThrows
     public void run() {
-        //如果是读取侧
+        //读取侧
         if (Start.DEPLOY_ID == 1) {
             MysqlBackupService bm = new MysqlBackupService();
             bm.doAction();
         }
-        //如果是写入侧
-        else {
-            //获取最后一次上传的数据库文件
-            String key = CommonUtil.getLastDataBaseZip();
-            //还原数据库
-            MysqlRestoreService mr = new MysqlRestoreService();
-            int total = mr.restore(mr.jdbcUrl, mr.username, mr.password, key);
-            System.out.println("恭喜，成功还原数据表:" + total + "个。");
-        }
     }
 
     public void stop() {

YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/YiDianTask.java

@@ -0,0 +1,27 @@
+package com.dsideal.YunXiaoTools.Cron4j;
+
+import com.dsideal.YunXiaoTools.Service.MysqlRestoreService;
+import com.dsideal.YunXiaoTools.Start;
+import com.dsideal.YunXiaoTools.Utils.CommonUtil;
+import com.jfinal.plugin.cron4j.ITask;
+import lombok.SneakyThrows;
+
+//0点任务
+public class YiDianTask implements ITask {
+    @SneakyThrows
+    public void run() {
+        //写入侧
+        if (Start.DEPLOY_ID == 2) {
+            //获取最后一次上传的数据库文件
+            String key = CommonUtil.getLastDataBaseZip();
+            //还原数据库
+            MysqlRestoreService mr = new MysqlRestoreService();
+            int total = mr.restore(mr.jdbcUrl, mr.username, mr.password, key);
+            System.out.println("恭喜，成功还原数据表:" + total + "个。");
+        }
+    }
+
+    public void stop() {
+        // 这里的代码会在 task 被关闭前调用
+    }
+}

YunXiaoTools/src/main/resources/cron4j.properties

@@ -7,9 +7,16 @@
 # 星号 *：表示每一个时间点，例如 * * * * * 表示每分钟执行
 # 除号 /：表示指定一个值的增加幅度。例如 n/m表示从 n 开始，每次增加 m 的时间点执行
 # cron4j 集成cron 只有 分 时 天 月 周  没有秒
-cron4j=LingDianTask
+cron4j=LingDianTask,YiDianTask
+
 # 每天凌晨0点执行一次
 LingDianTask.cron=0 0 * * *
 LingDianTask.class=com.dsideal.YunXiaoTools.Cron4j.LingDianTask
 LingDianTask.daemon=true
-LingDianTask.enable=true
+LingDianTask.enable=true
+
+# 每天凌晨1点执行一次
+YiDianTask.cron=0 1 * * *
+YiDianTask.class=com.dsideal.YunXiaoTools.Cron4j.YiDianTask
+YiDianTask.daemon=true
+YiDianTask.enable=true