| | |
|---|
| | | SetOrder("start_time asc") |
|---|
| | | } else if mode == constvar.TaskModeCurrent { |
|---|
| | | search.SetStatus(model.ProcedureStatusProcessing). |
|---|
| | | SetOrder("status desc, start_time asc") |
|---|
| | | SetOrder("start_time asc") |
|---|
| | | } else if mode == constvar.TaskModeLastFinished { |
|---|
| | | search.SetStatus(model.ProcedureStatusFinished).SetOrder("updated_at desc") |
|---|
| | | if len(channels) > 0 { |
|---|
| | |
|---|
| | | return procedure, ecode.OK |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (slf TaskService) UpdateProcedureStatusAndChannel(db *gorm.DB, id int, status model.ProcedureStatus, channel int32) error { |
|---|
| | | if status == model.ProcedureStatusFinished { |
|---|
| | | func (slf TaskService) UpdateProcedureStatusAndChannel(db *gorm.DB, id int, status model.ProcedureStatus, channel int32, processModelNumber string) error { |
|---|
| | | if status == model.ProcedureStatusFinished || status == model.ProcedureStatusWaitProcess { |
|---|
| | | ProgressCacheUnset(channel) |
|---|
| | | } |
|---|
| | | return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{ |
|---|
| | | "status": status, |
|---|
| | | "channel": channel, |
|---|
| | | }) |
|---|
| | | |
|---|
| | | upMap := map[string]interface{}{"status": status} |
|---|
| | | if status == model.ProcedureStatusProcessing { |
|---|
| | | upMap["process_model_number"] = processModelNumber |
|---|
| | | } else if status == model.ProcedureStatusWaitProcess { |
|---|
| | | upMap["process_model_number"] = "" |
|---|
| | | } |
|---|
| | | |
|---|
| | | return model.NewProceduresSearch(db).SetId(id).UpdateByMap(upMap) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id int, status model.ProcedureStatus, channel int32) error { |
|---|
