| | |
|---|
| | | package service |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "apsClient/conf" |
|---|
| | | "apsClient/constvar" |
|---|
| | | "apsClient/model" |
|---|
| | | "apsClient/model/common" |
|---|
| | |
|---|
| | | |
|---|
| | | func (slf TaskService) UpdateProcedureStatusAndChannel(db *gorm.DB, id uint, status model.ProcedureStatus, channel int32, processModelNumber string) error { |
|---|
| | | if status == model.ProcedureStatusFinished || status == model.ProcedureStatusWaitProcess { |
|---|
| | | ProgressCacheUnset(channel) |
|---|
| | | ProgressCacheUnset(conf.Conf.CurrentDeviceID, channel) |
|---|
| | | } |
|---|
| | | |
|---|
| | | upMap := map[string]interface{}{"status": status} |
|---|
| | |
|---|
| | | logx.Errorf("TaskStart GetProcessModel err:%v", err) |
|---|
| | | return nil, err |
|---|
| | | } |
|---|
| | | if err == gorm.ErrRecordNotFound { |
|---|
| | | return nil, err |
|---|
| | | } |
|---|
| | | if err == nil { |
|---|
| | | return data, nil |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | // GetTaskStatusSync 获取待同步任务信息 |
|---|
| | | func (slf TaskService) GetTaskStatusSync(limit int) ([]*model.TaskStatusSync, error) { |
|---|
| | | return model.NewTaskStatusSyncSearch(nil).SetOrder("id desc").SetPage(1, limit).FindNotTotal() |
|---|
| | | return model.NewTaskStatusSyncSearch(nil).SetOrder("id asc").SetPage(1, limit).FindNotTotal() |
|---|
| | | } |
|---|
| | | |
|---|
| | | // RemoveTaskStatusSync 删除同步完的记录 |
|---|
