support filter by start and end time in release plan list

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

Author: PetrusZ

pkg/microservice/aslan/core/common/repository/mongodb/release_plan.go

@@ -148,6 +148,8 @@ type ListReleasePlanOption struct {
 	SuccessTimeEnd   int64
 	UpdateTimeStart  int64
 	UpdateTimeEnd    int64
+	StartTime        int64
+	EndTime          int64
 	IsSort           bool
 	SortBy           SortReleasePlanBy
 	ExcludedFields   []string
@@ -190,6 +192,10 @@ func (c *ReleasePlanColl) ListByOptions(opt *ListReleasePlanOption) ([]*models.R
 	if opt.UpdateTimeStart > 0 && opt.UpdateTimeEnd > 0 {
 		query["update_time"] = bson.M{"$gte": opt.UpdateTimeStart, "$lte": opt.UpdateTimeEnd}
 	}
+	if opt.StartTime > 0 && opt.EndTime > 0 {
+		query["start_time"] = bson.M{"$gte": opt.StartTime, "$lte": opt.EndTime}
+		query["end_time"] = bson.M{"$gte": opt.StartTime, "$lte": opt.EndTime}
+	}
 	if opt.Status != "" {
 		query["status"] = opt.Status
 	}

pkg/microservice/aslan/core/release_plan/service/release_plan.go

@@ -1227,11 +1227,12 @@ func cronJobToSchedule(input *commonmodels.Cronjob) *commonmodels.Schedule {
 type ListReleasePlanType string
 
 const (
-	ListReleasePlanTypeName        ListReleasePlanType = "name"
-	ListReleasePlanTypeManager     ListReleasePlanType = "manager"
-	ListReleasePlanTypeSuccessTime ListReleasePlanType = "success_time"
-	ListReleasePlanTypeUpdateTime  ListReleasePlanType = "update_time"
-	ListReleasePlanTypeStatus      ListReleasePlanType = "status"
+	ListReleasePlanTypeName         ListReleasePlanType = "name"
+	ListReleasePlanTypeManager      ListReleasePlanType = "manager"
+	ListReleasePlanTypeSuccessTime  ListReleasePlanType = "success_time"
+	ListReleasePlanTypeUpdateTime   ListReleasePlanType = "update_time"
+	ListReleasePlanTypeStartEndTime ListReleasePlanType = "start_end_time"
+	ListReleasePlanTypeStatus       ListReleasePlanType = "status"
 )
 
 type ListReleasePlanOption struct {
@@ -1321,6 +1322,31 @@ func ListReleasePlans(opt *ListReleasePlanOption) (*ListReleasePlanResp, error)
 			PageSize:        opt.PageSize,
 			ExcludedFields:  []string{"jobs", "logs"},
 		})
+	case ListReleasePlanTypeStartEndTime:
+		timeArr := strings.Split(opt.Keyword, "-")
+		if len(timeArr) != 2 {
+			return nil, errors.New("invalid update time range")
+		}
+
+		timeStart := int64(0)
+		timeEnd := int64(0)
+		timeStart, err = strconv.ParseInt(timeArr[0], 10, 64)
+		if err != nil {
+			return nil, errors.Wrap(err, "invalid update time start")
+		}
+		timeEnd, err = strconv.ParseInt(timeArr[1], 10, 64)
+		if err != nil {
+			return nil, errors.Wrap(err, "invalid update time end")
+		}
+
+		list, total, err = mongodb.NewReleasePlanColl().ListByOptions(&mongodb.ListReleasePlanOption{
+			UpdateTimeStart: timeStart,
+			UpdateTimeEnd:   timeEnd,
+			IsSort:          true,
+			PageNum:         opt.PageNum,
+			PageSize:        opt.PageSize,
+			ExcludedFields:  []string{"jobs", "logs"},
+		})
 	case ListReleasePlanTypeStatus:
 		list, total, err = mongodb.NewReleasePlanColl().ListByOptions(&mongodb.ListReleasePlanOption{
 			Status:         config.ReleasePlanStatus(opt.Keyword),