From 5c3bffcbc8415665ae0c3ac33fcc2e45140a991b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Fri, 10 Jan 2025 13:32:01 +0800
Subject: [PATCH] 'commit'

---
 .../Controller/ReadDataController.java        | 20 ++++++++--------
 .../YunXiaoTools/Cron4j/LingDianTask.java     |  6 +++--
 .../BackupMysqlUtil.java}                     | 23 +++++--------------
 3 files changed, 20 insertions(+), 29 deletions(-)
 rename YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/{BackupUtil.java => Utils/BackupMysqlUtil.java} (88%)

diff --git a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Controller/ReadDataController.java b/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Controller/ReadDataController.java
index d3d3fd8d..fc360932 100644
--- a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Controller/ReadDataController.java
+++ b/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);
     }
 }
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 59fb4b29..44404095 100644
--- a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Cron4j/LingDianTask.java
+++ b/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();
         }
     }
 
diff --git a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/BackupUtil.java b/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Utils/BackupMysqlUtil.java
similarity index 88%
rename from YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/BackupUtil.java
rename to YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/Utils/BackupMysqlUtil.java
index cd531b96..9d1f4f22 100644
--- a/YunXiaoTools/src/main/java/com/dsideal/YunXiaoTools/BackupUtil.java
+++ b/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;
     }
 }
\ No newline at end of file