获取任务，未完成的开始时间小于等于当前时间，结束时间大于当前时间的任务

zhangqian

2023-09-21 5b84285b7b1feec082deaeb12d8a2240a0c4b64b

获取任务，未完成的开始时间小于等于当前时间，结束时间大于当前时间的任务

 model/procedures.go

@@ -33,6 +33,7 @@
        Orm          *gorm.DB
        Preload      bool
        StartTimeMax int64
        EndTimeMin   int64
        StatusNot    ProcedureStatus
        ProcedureIds []string
    }
@@ -97,6 +98,11 @@
    return slf
}

func (slf *ProceduresSearch) SetEndTimeMin(ts int64) *ProceduresSearch {
    slf.EndTimeMin = ts
    return slf
}

func (slf *ProceduresSearch) SetId(id int) *ProceduresSearch {
    slf.ID = id
    return slf
@@ -154,6 +160,10 @@
        db = db.Where("start_time <= ?", slf.StartTimeMax)
    }

    if slf.EndTimeMin != 0 {
        db = db.Where("end_time > ?", slf.EndTimeMin)
    }

    if slf.Status != 0 {
        db = db.Where("status = ?", slf.Status)
    }

 service/task.go

@@ -23,7 +23,7 @@
    return &TaskService{}
}

// GetTask 获取任务，未完成的开始时间最早的任务
// GetTask 获取任务，未完成的开始时间小于等于当前时间，结束时间大于当前时间
func (slf TaskService) GetTask(page, pageSize int) (taskResp *response.TaskResponse, code int) {
    var taskList []*response.TaskData
    var count int64
@@ -37,6 +37,7 @@
    )
    procedures, err = model.NewProceduresSearch(nil).SetOrder("start_time asc").
        SetStartTimeMax(nowTs).
        SetEndTimeMin(nowTs).
        SetDeviceId(conf.Conf.System.DeviceId).
        SetStatusNot(model.ProcedureStatusFinished).
        SetPage(page, pageSize).