| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | err := model.WithTransaction(func(db *gorm.DB) error { |
|---|
| | | err := service.NewTaskService().UpdateProcedureStatus(db, id, model.ProcedureStatusFinished, procedure.Channel) |
|---|
| | | err := service.NewTaskService().UpdateProcedureStatusAndChannel(db, id, model.ProcedureStatusFinished, procedure.Channel, procedure.ProcessModelNumber) |
|---|
| | | if err != nil { |
|---|
| | | return err |
|---|
| | | } |
|---|
| | |
|---|
| | | 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) |
|---|
| | | } |
|---|
| | | return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{ |
|---|
| | | "status": status, |
|---|
| | | }) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (slf TaskService) UpdateOrderStatus(db *gorm.DB, id uint, status model.OrderStatus) error { |
|---|
| | | return model.NewOrderSearch(db).SetId(id).UpdateByMap(map[string]interface{}{ |
|---|
| | | "status": status, |
|---|
