update

zhangqian

2023-10-27 d91a802e7aa2ad4075ed803b8ddc7536a91a0ef0

 service/task.go

@@ -137,20 +137,19 @@
   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) 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) 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) UpdateOrderStatus(db *gorm.DB, id uint, status model.OrderStatus) error {