OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

t

Browse Source
This commit is contained in:
simonzhangsz
2023-08-18 17:19:21 +08:00
parent 23967c1a79
commit 38147d0ae7
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crontask/tasks.go
View File

@@ -280,7 +280,7 @@ func (t *TaskFunc) TaskDBBackupCSVGetBySQL(uri, params, body string) {
var response *resty.Response
tableName := t.GetTableNameFromUri(uri)
filePath := fmt.Sprintf("%s/%s-%s.csv", GetYamlConfig().Database.Backup, tableName, time.Now().Local().Format(global.DateData))
filePath := fmt.Sprintf("/tmp/%s-%s.csv", GetYamlConfig().Database.Backup, tableName, time.Now().Local().Format(global.DateData))
pa := fmt.Sprintf(params, filePath)
requestURI := fmt.Sprintf("%s?%s", uri, pa)
requestURL := fmt.Sprintf("%s%s", yamlConfig.OMC.HostUri, requestURI)
@@ -298,6 +298,13 @@ func (t *TaskFunc) TaskDBBackupCSVGetBySQL(uri, params, body string) {
log.Debug("StatusCode: ", response.StatusCode())
switch response.StatusCode() {
case http.StatusOK, http.StatusCreated, http.StatusNoContent, http.StatusAccepted:
cmd := exec.Command("cp", "-rf", filePath, GetYamlConfig().Database.Backup)
out, err := cmd.CombinedOutput()
log.Tracef("Exec output: %v", string(out))
if err != nil {
log.Errorf("Faile to exec:", err)
return
}
log.Debug("response body:", string(response.Body()))
body := new(map[string]interface{})
_ = json.Unmarshal(response.Body(), &body)