自动化运维 fix

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 {
 		//状态检测