From 665cc4e0bbc620dc613b66286104b160f78309ed Mon Sep 17 00:00:00 2001
From: chenyifan01 <cyf_uestc@outlook.com>
Date: Wed, 28 Sep 2022 11:16:28 +0800
Subject: [PATCH] #2967 add log

---
 services/task/task.go | 20 +++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/services/task/task.go b/services/task/task.go
index 194a43649..f13dfa5ad 100644
--- a/services/task/task.go
+++ b/services/task/task.go
@@ -61,7 +61,7 @@ func Accomplish(action models.Action) {
 			actions = append(actions, models.Action{
 				ID:        action.ID,
 				OpType:    models.ActionDatasetRecommended,
-				ActUserID: action.UserID,
+				ActUserID: action.ActUserID,
 				UserID:    user.ID,
 				RepoID:    action.RepoID,
 				Content:   action.Content,
@@ -85,7 +85,11 @@ func accomplish(action models.Action, taskType models.TaskType) error {
 			log.Error("PANIC:%v", combinedErr)
 		}
 	}()
+	log.Info("accomplish start.   actionId=%d  userId= %d", action.ID, action.UserID)
 	userId := action.UserID
+	if !isUserAvailable(userId) {
+		return nil
+	}
 
 	//get task config
 	config, err := GetTaskConfig(string(taskType))
@@ -143,3 +147,17 @@ func isLimited(userId int64, config *models.TaskConfig, rejectPolicy models.Limi
 	return false
 
 }
+
+func isUserAvailable(userId int64) bool {
+	if userId < 1 {
+		return false
+	}
+	user, err := models.GetUserByID(userId)
+	if err != nil || user == nil {
+		return false
+	}
+	if user.IsOrganization() {
+		return false
+	}
+	return true
+}