testing execution queue

internal/server/modules/v1/controller/job.go

@@ -17,6 +17,17 @@ func NewJobCtrl() *JobCtrl {
 	return &JobCtrl{}
 }
 
+func (c *JobCtrl) List(ctx iris.Context) {
+	list, err := c.JobService.List()
+
+	if err != nil {
+		ctx.JSON(c.ErrResp(commConsts.CommErr, err.Error()))
+		return
+	}
+
+	ctx.JSON(c.SuccessResp(list))
+}
+
 func (c *JobCtrl) Add(ctx iris.Context) {
 	req := serverDomain.JobReq{}
 	if err := ctx.ReadQuery(&req); err != nil {

internal/server/modules/v1/repo/job.go

@@ -17,6 +17,21 @@ func NewJobRepo() *JobRepo {
 	return &JobRepo{}
 }
 
+func (r *JobRepo) Query() (pos []model.Job, err error) {
+	err = r.DB.
+		Where("progress_status != ? && progress_status != ?",
+			commConsts.ProgressCompleted, commConsts.ProgressTimeout).
+		Where("NOT deleted").
+		Find(&pos).Error
+
+	if err != nil {
+		logUtils.Errorf(color.RedString("list job failed: %s.", err.Error()))
+		return
+	}
+
+	return
+}
+
 func (r *JobRepo) ListByProgressStatus(progress commConsts.ProgressStatus) (pos []model.Job, err error) {
 	err = r.DB.
 		Where("progress_status = ?", progress).

internal/server/modules/v1/service/job.go

@@ -20,6 +20,12 @@ func NewJobService() *JobService {
 	return &JobService{}
 }
 
+func (s *JobService) List() (pos []model.Job, err error) {
+	pos, err = s.JobRepo.Query()
+
+	return
+}
+
 func (s *JobService) Add(req serverDomain.JobReq) (err error) {
 	job := model.Job{}
 	copier.CopyWithOption(&job, req, copier.Option{