diff --git a/crontask/tasks.go b/crontask/tasks.go index a83b8686..a08021a4 100644 --- a/crontask/tasks.go +++ b/crontask/tasks.go @@ -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)