hosts fix

src/service/host_manage.go

@@ -352,22 +352,22 @@ 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()
-	_, err = f.Write([]byte(fmt.Sprintf("%s%d\n", AnsibleGroup, req.Id)))
-	if err != nil {
-		return resp.FileExecError.WithError(err)
-	}
-	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, 0777)
+	//if err != nil {
+	//	err = resp.FileExecError.WithError(err)
+	//	return
+	//}
+	//defer f.Close()
+	//_, err = f.Write([]byte(fmt.Sprintf("%s%d\n", AnsibleGroup, req.Id)))
+	//if err != nil {
+	//	return resp.FileExecError.WithError(err)
+	//}
+	//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 {
 		//修改状态
 		_, err = session.Table("host_manage_list").Where("is_delete = 0 AND id = ?", v.Id).
@@ -416,7 +416,7 @@ func (h *HostManageSvc) SaveStateHostManage(hostManageList []request.HostManageL
 	}
 
 	//往hosts文件中写入主机组ip
-	f, err := os.OpenFile("/etc/ansible/hosts", os.O_APPEND|os.O_CREATE|os.O_RDWR|os.O_TRUNC, 0777)
+	f, err := os.Open("/etc/ansible/hosts")
 	if err != nil {
 		err = resp.FileExecError.WithError(err)
 		return