Merge pull request #2635 from actiontech/issue-1807-winfred-5

modify: init stage of workflow in sql version stage

sqle/model/sql_version.go

@@ -55,3 +55,10 @@ const (
 	WorkflowReleaseStatusHaveBeenReleased = "released"
 	WorkflowReleaseStatusNotNeedReleased  = "not_need_release"
 )
+
+func (stage SqlVersionStage) InitialStatusOfWorkflow() string {
+	if len(stage.SqlVersionStagesDependency) > 0 && stage.SqlVersionStagesDependency[0].NextStageID == 0 {
+		return WorkflowReleaseStatusNotNeedReleased
+	}
+	return WorkflowReleaseStatusIsBingReleased
+}

sqle/model/workflow.go

@@ -599,12 +599,14 @@ func (s *Storage) CreateWorkflowV2(subject, workflowId, desc string, user *User,
 			// get the first stage
 			err = tx.Model(&SqlVersionStage{}).
 				Preload("WorkflowVersionStage").
+				Preload("SqlVersionStagesDependency").
 				Where("sql_version_id = ?", sqlVersionId).
 				Order("stage_sequence ASC").First(stage).Error
 		} else {
 			// get specific stage
 			err = tx.Model(&SqlVersionStage{}).
 				Preload("WorkflowVersionStage").
+				Preload("SqlVersionStagesDependency").
 				Where("sql_version_id = ? AND id = ?", sqlVersionId, versionStageId).
 				First(stage).Error
 		}
@@ -614,10 +616,11 @@ func (s *Storage) CreateWorkflowV2(subject, workflowId, desc string, user *User,
 		}
 		// associate sql version with workflow
 		workflowVersionStageRelation := &WorkflowVersionStage{
-			WorkflowID:        workflowId,
-			SqlVersionID:      *sqlVersionId,
-			SqlVersionStageID: stage.ID,
-			WorkflowSequence:  len(stage.WorkflowVersionStage) + 1,
+			WorkflowID:            workflowId,
+			SqlVersionID:          *sqlVersionId,
+			SqlVersionStageID:     stage.ID,
+			WorkflowSequence:      len(stage.WorkflowVersionStage) + 1,
+			WorkflowReleaseStatus: stage.InitialStatusOfWorkflow(),
 		}
 
 		err = tx.Create(workflowVersionStageRelation).Error