'commit'

YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Controller/ReadDataController.java

@@ -1,25 +1,25 @@
 package com.dsideal.YunXiaoTools.Controller;
 
+import com.dsideal.YunXiaoTools.Utils.BackupMysqlUtil;
 import com.jfinal.aop.Before;
 import com.jfinal.core.Controller;
 import com.jfinal.ext.interceptor.GET;
 import com.jfinal.kit.Kv;
 
-import java.io.IOException;
 
 public class ReadDataController extends Controller {
     /**
-     * 读取mysql数据，并上传到OBS上
-     * @throws IOException
+     * 备份mysql数据，并上传到OBS上
      */
-    // http://10.10.21.20:9008/readMysql
+    // http://10.10.21.20:9008/backupMysql
     @Before({GET.class})
-    public void readMysql() throws IOException {
-        //String url=ReadDataUtil.doAction();
-        Kv kv=Kv.create();
-        kv.set("success",true);
-        kv.set("message","获取并上传数据到OBS成功！");
-        //kv.set("url",url);
+    public void backupMysql() {
+        BackupMysqlUtil bm = new BackupMysqlUtil();
+        String url = bm.doAction();
+        Kv kv = Kv.create();
+        kv.set("success", true);
+        kv.set("message", "获取并上传数据到OBS成功！");
+        kv.set("url", url);
         renderJson(kv);
     }
 }

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

@@ -1,5 +1,6 @@
 package com.dsideal.YunXiaoTools.Cron4j;
 
+import com.dsideal.YunXiaoTools.Utils.BackupMysqlUtil;
 import com.dsideal.YunXiaoTools.Start;
 import com.jfinal.plugin.cron4j.ITask;
 import lombok.SneakyThrows;
@@ -9,8 +10,9 @@ public class LingDianTask implements ITask {
     @SneakyThrows
     public void run() {
         //如果是读取侧
-        if(Start.DEPLOY_ID ==1){
-           // ReadDataUtil.doAction();
+        if (Start.DEPLOY_ID == 1) {
+            BackupMysqlUtil bm = new BackupMysqlUtil();
+            bm.doAction();
         }
     }
 

YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Utils/BackupMysqlUtil.java

@@ -1,8 +1,7 @@
-package com.dsideal.YunXiaoTools;
+package com.dsideal.YunXiaoTools.Utils;
 
 import cn.hutool.core.io.FileUtil;
 import cn.hutool.core.util.ZipUtil;
-import com.dsideal.YunXiaoTools.Utils.ObsUtil;
 import com.jfinal.kit.PropKit;
 
 import java.io.*;
@@ -11,7 +10,7 @@ import java.time.format.DateTimeFormatter;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
-public class BackupUtil {
+public class BackupMysqlUtil {
     //数据库连接串
     public static String jdbcUrl;
     //数据库用户名
@@ -79,7 +78,6 @@ public class BackupUtil {
             // 等待命令执行完成
             int exitCode = process.waitFor();
             if (exitCode == 0) {
-                //System.out.println("数据库备份成功: " + backupPath);
                 return backupPath;
             } else {
                 throw new RuntimeException("数据库备份失败，错误信息：\n" + errorOutput);
@@ -139,29 +137,20 @@ public class BackupUtil {
         }
     }
 
-    public static void doAction() {
-        BackupUtil backup = new BackupUtil();
-        String sourceFile = backup.backup();
-
+    public String doAction() {
+        String sourceFile = backup();
         //压缩成ZIP文件
         String zipFile = sourceFile.replace(".sql", ".zip");
         ZipUtil.zip(sourceFile, zipFile);
-
         //文件名称
         String fileName = new File(zipFile).getName();
         // 上传到华为云OBS
         String key = "HuangHai/YunXiao/" + fileName;
         ObsUtil.uploadToObs(zipFile, key);
-
         //清理此路径下旧的文件
-        String url = "https://dsideal.obs.cn-north-1.myhuaweicloud.com/" + key;
-        System.out.println(url);
-        //清理
         FileUtil.del(sourceFile);
         FileUtil.del(zipFile);
-    }
-
-    public static void main(String[] args) {
-        doAction();
+        //返回文件路径
+        return "https://dsideal.obs.cn-north-1.myhuaweicloud.com/" + key;
     }
 }