| | |
|---|
| | | var ok bool |
|---|
| | | progressCache, ok = ProgressCacheGet(channel) |
|---|
| | | if !ok { |
|---|
| | | progressCache, err = model.NewProductionProgressSearch(nil).SetDeviceId(conf.Conf.CurrentDeviceID).SetChannel(channel).SetOrder("id desc").First() |
|---|
| | | progressCache, err = model.NewProductionProgressSearch(nil).SetDeviceId(conf.Conf.CurrentDeviceID).SetChannel(channel).SetOrder("id asc").First() |
|---|
| | | if err == gorm.ErrRecordNotFound { |
|---|
| | | return nil, errors.New("progress not found") |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | // 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 删除同步完的记录 |
|---|
