package main

import (
	"ShlBackup/Utils/ConfigUtil"
	"ShlBackup/Utils/ObsUtil"
	"fmt"
	"io/ioutil"
	"log"
	"os"
	"os/exec"
	"time"
)

func main() {
	//杀掉老进程
	command:="ps -ef | grep dsBackup | grep -v grep | awk '{print $2}' | xargs kill -9"
	cmd := exec.Command("/bin/bash", "-c", command)

	//1、执行Shell进行备份数据库
	fmt.Println("1、正在备份数据库，请稍等...")
	command = `/usr/local/dsBackup/BackupMysqlFullDataBase.sh`
	cmd = exec.Command("/bin/bash", "-c", command)
	output, err := cmd.Output()
	if err != nil {
		log.Println(err)
	}
	resp := string(output)
	log.Println(resp)

	//2、备份程序目录
	command = `/usr/local/dsMin/dsBackup/BackupApplication.sh`
	cmd = exec.Command("/bin/bash", "-c", command)
	output, err = cmd.Output()
	if err != nil {
		log.Println(err)
	}
	resp = string(output)
	log.Println(resp)
	//3、上传数据库备份到云存储
	fmt.Println("1、正在将备份文件上传到云存储...")
	dirPath := "/home/dsMin/Backup"
	//此目录下，最近2小时内生成的文件，并且以base_db_开头的找出来，应该只有1个
	files, err := ioutil.ReadDir(dirPath) //读取目录下文件
	if err != nil {
		return
	}
	//云存储前缀
	var prefix = ConfigUtil.BackupPrefix
	for _, file := range files {
		if file.IsDir() {
			continue
		} else {
			now := time.Now()
			sumD := now.Sub(file.ModTime())
			if sumD.Hours()<2{
				fmt.Println("2、找到刚刚备份的文件:"+file.Name())
				key := prefix + "/" + file.Name()
				sourceFile := dirPath + "/" + file.Name()
				fmt.Println("3、正在上传备份的文件...")
				ObsUtil.UploadFileMultiPart(key, sourceFile)
			}
			//删除历史文件
			if sumD.Hours()>24*7 {
				sourceFile := dirPath + "/" + file.Name()
				err := os.Remove(sourceFile)
				if err != nil {
					fmt.Println("4、删除历史文件"+sourceFile+"失败！")
				}
			}
		}
	}
	//4、对云备份的文件进行清理
	fmt.Println("5、正在进行云备份文件的清理工作...")
	ObsUtil.DeleteExpireFile(prefix, ConfigUtil.RemainDays)
	//5、提示信息
	fmt.Println("恭喜，备份成功完成！")
}