diff --git a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/LingDianTask.java b/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/LingDianTask.java index 3e6afe77..787fd609 100644 --- a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/LingDianTask.java +++ b/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() { diff --git a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/YiDianTask.java b/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/YiDianTask.java new file mode 100644 index 00000000..8c87cf7e --- /dev/null +++ b/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 被关闭前调用 + } +} diff --git a/YunXiaoTools/src/main/resources/cron4j.properties b/YunXiaoTools/src/main/resources/cron4j.properties index a454f812..5ec508b5 100644 --- a/YunXiaoTools/src/main/resources/cron4j.properties +++ b/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 \ No newline at end of file +LingDianTask.enable=true + +# 每天凌晨1点执行一次 +YiDianTask.cron=0 1 * * * +YiDianTask.class=com.dsideal.YunXiaoTools.Cron4j.YiDianTask +YiDianTask.daemon=true +YiDianTask.enable=true \ No newline at end of file