diff --git a/src/service/host_manage.go b/src/service/host_manage.go index 76d821566066a26b6686a9c6f0d16123e08f8361..5bb4a28c1d8e98514f9ac9c871b398057b771514 100644 --- a/src/service/host_manage.go +++ b/src/service/host_manage.go @@ -9,6 +9,7 @@ import ( "gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/vo/response" "gitlab.wodcloud.com/smart-operation/so-operation-api/src/common/client" "gitlab.wodcloud.com/smart-operation/so-operation-api/src/pkg/beagle/resp" + "os" "os/exec" "strings" "time" @@ -308,18 +309,18 @@ func (h *HostManageSvc) ListStateHostManage(req request.StateHostManageReq) (err } //往hosts文件中写入主机组ip - //f, err := os.OpenFile("/etc/ansible/hosts", os.O_APPEND|os.O_CREATE|os.O_RDWR|os.O_TRUNC, 0777) - //if err != nil { - // err = resp.FileExecError.WithError(err) - // return - //} - //defer f.Close() - //for _, v := range hostManageList { - // _, err = f.Write([]byte(fmt.Sprintf("%s ansible_ssh_host=%s ansible_ssh_port=%s ansible_ssh_user=\"%s\" ansible_ssh_pass=\"%s\"\n", v.Ip, v.Ip, v.Port, v.UserName, v.Password))) - // if err != nil { - // return resp.FileExecError.WithError(err) - // } - //} + f, err := os.OpenFile("/etc/ansible/hosts", os.O_APPEND|os.O_CREATE|os.O_RDWR|os.O_TRUNC, 0777) + if err != nil { + err = resp.FileExecError.WithError(err) + return + } + defer f.Close() + for _, v := range hostManageList { + _, err = f.Write([]byte(fmt.Sprintf("%s ansible_ssh_host=%s ansible_ssh_port=%s ansible_ssh_user=\"%s\" ansible_ssh_pass=\"%s\"\n", v.Ip, v.Ip, v.Port, v.UserName, v.Password))) + if err != nil { + return resp.FileExecError.WithError(err) + } + } for _, v := range hostManageList { //状态检测