From 25da70e7c957bbc5b91d005ff81634e392fc7efd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E5=AD=90=E9=BE=99?= <chenzilong@wodcloud.com>
Date: Fri, 7 Jul 2023 09:37:41 +0800
Subject: [PATCH] =?UTF-8?q?=E8=87=AA=E5=8A=A8=E5=8C=96=E8=BF=90=E7=BB=B4?=
 =?UTF-8?q?=20=E7=AB=8B=E5=8D=B3=E6=89=A7=E8=A1=8C=20fix?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/service/task_manage.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/src/service/task_manage.go b/src/service/task_manage.go
index 3b57f3e..ee2e4a9 100644
--- a/src/service/task_manage.go
+++ b/src/service/task_manage.go
@@ -223,43 +223,54 @@ func (t *TaskManageSvc) ExecScript(req request.ExecScriptReq) (data map[string]i
 	if err != nil {
 		return nil, resp.YamlAnalysisError.WithError(err)
 	}
+	fmt.Println("11111111")
 	req.Script = string(y)
 	//写入执行脚本
 	f2, err := os.Create("/etc/ansible/ansible.yml")
 	if err != nil {
+		fmt.Println("22222222222:", err)
 		return nil, resp.FileExecError.WithError(err)
 	}
 	defer f2.Close()
 	_, err = f2.Write([]byte(req.Script))
 	if err != nil {
+		fmt.Println("3333333333333:", err)
 		return nil, resp.FileExecError.WithError(err)
 	}
+	fmt.Println("4444444444444444:")
 	//写入额外yml参数
 	if req.Type == 1 {
 		//写入执行脚本
 		f3, err := os.Create("/etc/ansible/ansible_extra.yml")
 		if err != nil {
+			fmt.Println("55555555555555555:", err)
 			return nil, resp.FileExecError.WithError(err)
 		}
 		defer f3.Close()
 		_, err = f3.Write([]byte(req.Value))
 		if err != nil {
+			fmt.Println("66666666666666666:", err)
 			return nil, resp.FileExecError.WithError(err)
 		}
 		req.Value = fmt.Sprintf("@/etc/ansible/ansible_extra.yml")
+		fmt.Println("77777777777777777777:")
 	}
+	fmt.Println("88888888888888888888:")
 	var cmd *exec.Cmd
 	if req.Value != "" {
 		cmd = exec.Command("ansible-playbook", "-i", "/etc/ansible/hosts", "/etc/ansible/ansible.yml", "--extra-vars", req.Value)
 	} else {
+		fmt.Println("999999999999999999999999:")
 		cmd = exec.Command("ansible-playbook", "-i", "/etc/ansible/hosts", "/etc/ansible/ansible.yml")
 	}
+	fmt.Println("aaaaaaaaaaaaaaa:")
 	stdout, err := cmd.StdoutPipe()
 	if err != nil {
 		fmt.Println("执行出错：", err)
 		fmt.Println("stdout：", stdout)
 		return nil, resp.CmdExecError.WithError(err)
 	}
+	fmt.Println("bbbbbbbbbbbbbbbbbbbb:")
 	outputBuf := bufio.NewReader(stdout)
 	output, isPrefix, err := outputBuf.ReadLine()
 	//output, err := cmd.Output()
@@ -270,5 +281,6 @@ func (t *TaskManageSvc) ExecScript(req request.ExecScriptReq) (data map[string]i
 	//fmt.Println(string(output))
 	data["step"] = isPrefix
 	data["output"] = string(output)
+	fmt.Println("ccccccccccccccc:")
 	return data, nil
 }
-- 
2.26.0