gorm版本v2改成v1

zhangqian

2023-10-07 3ca8f1290232818ca2720fa3a9a736ca1d52a1a8

 service/task.go

@@ -11,7 +11,7 @@
   "apsClient/pkg/logx"
   "apsClient/pkg/structx"
   "fmt"
   "gorm.io/gorm"
   "github.com/jinzhu/gorm"
   "time"
)

@@ -129,7 +129,7 @@
   return NoRepeatedWorkers
}

func (slf TaskService) GetProcedureById(id int) (*model.Procedures, int) {
func (slf TaskService) GetProcedureById(id uint) (*model.Procedures, int) {
   procedure, err := model.NewProceduresSearch(nil).SetId(id).First()
   if err != nil {
      return nil, ecode.DBErr
@@ -137,7 +137,7 @@
   return procedure, ecode.OK
}

func (slf TaskService) UpdateProcedureStatusAndChannel(db *gorm.DB, id int, status model.ProcedureStatus, channel int32) error {
func (slf TaskService) UpdateProcedureStatusAndChannel(db *gorm.DB, id uint, status model.ProcedureStatus, channel int32) error {
   if status == model.ProcedureStatusFinished {
      ProgressCacheUnset(channel)
   }
@@ -147,7 +147,7 @@
   })
}

func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id int, status model.ProcedureStatus, channel int32) error {
func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id uint, status model.ProcedureStatus, channel int32) error {
   if status == model.ProcedureStatusFinished {
      ProgressCacheUnset(channel)
   }