| | |
|---|
| | | 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() |
|---|
| | | } |
|---|
