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 {
@@ -191,3 +190,13 @@
func (slf TaskService) SaveTaskStatusSync(db *gorm.DB, record *model.TaskStatusSync) (err error) {
   return model.NewTaskStatusSyncSearch(db).Create(record)
}

// GetTaskStatusSync 获取待同步任务信息
func (slf TaskService) GetTaskStatusSync(limit int) ([]*model.TaskStatusSync, error) {
   return model.NewTaskStatusSyncSearch(nil).SetOrder("id desc").SetPage(1, limit).FindNotTotal()
}

// RemoveTaskStatusSync 删除同步完的记录
func (slf TaskService) RemoveTaskStatusSync(ids []uint) (err error) {
   return model.NewTaskStatusSyncSearch(nil).SetIDs(ids).Delete()
}