| | |
|---|
| | | upMap := map[string]interface{}{"status": status} |
|---|
| | | if status == model.ProcedureStatusProcessing { |
|---|
| | | upMap["process_model_number"] = processModelNumber |
|---|
| | | upMap["real_start_time"] = time.Now().Unix() |
|---|
| | | } else if status == model.ProcedureStatusWaitProcess { |
|---|
| | | upMap["process_model_number"] = "" |
|---|
| | | } else if status == model.ProcedureStatusFinished { |
|---|
| | | upMap["real_end_time"] = time.Now().Unix() |
|---|
| | | } |
|---|
| | | |
|---|
| | | return model.NewProceduresSearch(db).SetId(id).UpdateByMap(upMap) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (slf TaskService) UpdateProcessModelNumber(db *gorm.DB, id uint, processModelNumber string) error { |
|---|
| | | upMap := map[string]interface{}{"process_model_number": processModelNumber} |
|---|
| | | return model.NewProceduresSearch(db).SetId(id).UpdateByMap(upMap) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id uint, status model.ProcedureStatus, channel int32) error { |
|---|
| | | if status == model.ProcedureStatusFinished { |
|---|
| | | ProgressCacheUnset(channel) |
|---|
