From 467796b55a5b84bb299fbad5b4e9d49a1269e0bd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=99=AF=E9=98=B3?= <1656488874@qq.com>
Date: Wed, 16 Oct 2019 10:11:00 +0800
Subject: [PATCH] =?UTF-8?q?fix=20=E4=B8=80=E4=BA=9B=E4=B8=9C=E8=A5=BF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/services/task.go | 19 +++----------------
 1 file changed, 3 insertions(+), 16 deletions(-)

diff --git a/backend/services/task.go b/backend/services/task.go
index 50b902cb..78c11f17 100644
--- a/backend/services/task.go
+++ b/backend/services/task.go
@@ -124,7 +124,6 @@ func SetLogConfig(cmd *exec.Cmd, path string) error {
 		debug.PrintStack()
 		return err
 	}
-	defer fLog.Close()
 	cmd.Stdout = fLog
 	cmd.Stderr = fLog
 	return nil
@@ -247,6 +246,7 @@ func MakeLogDir(t model.Task) (fileDir string, err error) {
 	// 如果日志目录不存在，生成该目录
 	if !utils.Exists(fileDir) {
 		if err := os.MkdirAll(fileDir, 0777); err != nil {
+			log.Errorf("execute task, make log dir error: %s", err.Error())
 			debug.PrintStack()
 			return "", err
 		}
@@ -321,11 +321,9 @@ func ExecuteTask(id int) {
 	// 节点队列任务
 	var msg string
 	if msg, err = database.RedisClient.LPop(queueCur); err != nil {
-		log.Errorf("get current node task error: %s", err.Error())
 		// 节点队列没有任务，获取公共队列任务
 		queuePub := "tasks:public"
 		if msg, err = database.RedisClient.LPop(queuePub); err != nil {
-			log.Errorf("get public task error: %s", err.Error())
 		}
 	}
 
@@ -355,24 +353,13 @@ func ExecuteTask(id int) {
 	}
 
 	// 创建日志目录
-	fileDir, err := MakeLogDir(t)
-	if err != nil {
-		log.Errorf("execute task, make log dir error: %s", err.Error())
+	var fileDir string
+	if fileDir, err = MakeLogDir(t); err != nil {
 		return
 	}
-
 	// 获取日志文件路径
 	t.LogPath = GetLogFilePaths(fileDir)
 
-	// 创建日志目录文件夹
-	fileStdoutDir := filepath.Dir(t.LogPath)
-	if !utils.Exists(fileStdoutDir) {
-		if err := os.MkdirAll(fileStdoutDir, os.ModePerm); err != nil {
-			log.Errorf(GetWorkerPrefix(id) + err.Error())
-			return
-		}
-	}
-
 	// 工作目录
 	cwd := filepath.Join(
 		viper.GetString("spider.path"),