chore:store task executor user list

actiontech · Jul 27, 2023 · 3af45c7 · 3af45c7
1 parent 339cc8e
commit 3af45c7
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/sqle/model/workflow.go b/sqle/model/workflow.go
@@ -423,8 +423,9 @@ func (s *Storage) CreateWorkflowV2(subject, workflowId, desc string, user *User,
 		allExecutor[i] = executor
 
 		instanceRecords[i] = &WorkflowInstanceRecord{
-			TaskId:     task.ID,
-			InstanceId: task.InstanceId,
+			TaskId:           task.ID,
+			InstanceId:       task.InstanceId,
+			ExecutorUserList: executor,
 		}
 	}
 
@@ -466,6 +467,13 @@ func (s *Storage) CreateWorkflowV2(subject, workflowId, desc string, user *User,
 		return errors.New(errors.ConnectStorageError, err)
 	}
 
+	for _, instanceRecord := range record.InstanceRecords {
+		if tx.Model(instanceRecord).Association("ExecutorUserList").Replace(instanceRecord.ExecutorUserList).Error != nil {
+			tx.Rollback()
+			return errors.New(errors.ConnectStorageError, err)
+		}
+	}
+
 	workflow.WorkflowRecordId = record.ID
 	err = tx.Save(workflow).Error
 	if err != nil {