add filter by status feature for tapd (#4276)

Signed-off-by: Patrick Zhao <[email protected]>

Author: PetrusZ

pkg/microservice/aslan/core/common/repository/models/workflow_v4.go

@@ -1360,13 +1360,14 @@ type PingCodeJobSpec struct {
 }
 
 type TapdJobSpec struct {
-	TapdID      string                     `bson:"tapd_id"             json:"tapd_id"             yaml:"tapd_id"`
-	Source      config.ParamSourceType     `bson:"source"              json:"source"              yaml:"source"`
-	Type        string                     `bson:"type"                json:"type"                yaml:"type"`
-	ProjectID   string                     `bson:"project_id"          json:"project_id"          yaml:"project_id"`
-	ProjectName string                     `bson:"project_name"        json:"project_name"        yaml:"project_name"`
-	Status      config.TapdIterationStatus `bson:"status"              json:"status"              yaml:"status"`
-	Iterations  []*TapdIteration           `bson:"iterations"          json:"iterations"          yaml:"iterations"`
+	TapdID       string                     `bson:"tapd_id"             json:"tapd_id"             yaml:"tapd_id"`
+	Source       config.ParamSourceType     `bson:"source"              json:"source"              yaml:"source"`
+	Type         string                     `bson:"type"                json:"type"                yaml:"type"`
+	ProjectID    string                     `bson:"project_id"          json:"project_id"          yaml:"project_id"`
+	ProjectName  string                     `bson:"project_name"        json:"project_name"        yaml:"project_name"`
+	SourceStatus config.TapdIterationStatus `bson:"source_status"       json:"source_status"       yaml:"source_status"`
+	Status       config.TapdIterationStatus `bson:"status"              json:"status"              yaml:"status"`
+	Iterations   []*TapdIteration           `bson:"iterations"          json:"iterations"          yaml:"iterations"`
 }
 
 type WorkflowTriggerJobSpec struct {

pkg/microservice/aslan/core/system/handler/tapd.go

@@ -54,5 +54,6 @@ func ListTapdProjectIterations(c *gin.Context) {
 
 	id := c.Param("id")
 	projectID := c.Param("projectID")
-	ctx.Resp, ctx.RespErr = service.ListTapdIterations(id, projectID)
+	status := c.Query("status")
+	ctx.Resp, ctx.RespErr = service.ListTapdIterations(id, projectID, status)
 }

pkg/microservice/aslan/core/system/service/tapd.go

@@ -40,7 +40,7 @@ func ListTapdProjects(id string) ([]*tapd.Workspace, error) {
 	return projectList, nil
 }
 
-func ListTapdIterations(id, projectID string) ([]*tapd.Iteration, error) {
+func ListTapdIterations(id, projectID, status string) ([]*tapd.Iteration, error) {
 	spec, err := mongodb.NewProjectManagementColl().GetTapdSpec(id)
 	if err != nil {
 		return nil, err
@@ -51,7 +51,7 @@ func ListTapdIterations(id, projectID string) ([]*tapd.Iteration, error) {
 		return nil, err
 	}
 
-	iterations, err := client.ListIterations(projectID)
+	iterations, err := client.ListIterations(projectID, status)
 	if err != nil {
 		return nil, err
 	}

pkg/tool/tapd/client.go

@@ -189,7 +189,7 @@ func (c *TapdClient) GetIterationCount(projectID string) (int, error) {
 	return count.Count, nil
 }
 
-func (c *TapdClient) ListIterations(projectID string) ([]*Iteration, error) {
+func (c *TapdClient) ListIterations(projectID, status string) ([]*Iteration, error) {
 	count, err := c.GetIterationCount(projectID)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get iteration count: %w", err)
@@ -211,6 +211,10 @@ func (c *TapdClient) ListIterations(projectID string) ([]*Iteration, error) {
 			"workspace_id": projectID,
 		}
 
+		if status != "" {
+			queryParams["status"] = status
+		}
+
 		result := &Response{}
 		resp, err := httpclient.Get(iterationURL,
 			httpclient.SetHeader("Authorization", fmt.Sprintf("Bearer %s", c.AccessToken)),