| | |
|---|
| | | |
|---|
| | | // GetTaskStatusSync 获取待同步任务信息 |
|---|
| | | func (slf TaskService) GetTaskStatusSync(limit int) ([]*model.TaskStatusSync, error) { |
|---|
| | | return model.NewTaskStatusSyncSearch(nil).SetOrder("id asc").SetPage(1, limit).FindNotTotal() |
|---|
| | | return model.NewTaskStatusSyncSearch(nil).SetOrder("id asc").SetSyncWait().SetPage(1, limit).FindNotTotal() |
|---|
| | | } |
|---|
| | | |
|---|
| | | // RemoveTaskStatusSync 删除同步完的记录 |
|---|
| | |
|---|
| | | return model.NewTaskStatusSyncSearch(nil).SetIDs(ids).Delete() |
|---|
| | | } |
|---|
| | | |
|---|
| | | // FinishTaskStatusSync 设置已同步完成 |
|---|
| | | func (slf TaskService) FinishTaskStatusSync(ids []uint) (err error) { |
|---|
| | | return model.NewTaskStatusSyncSearch(nil).SetIDs(ids).UpdateByMap(map[string]interface{}{"sync_status": constvar.SyncStatusOk}) |
|---|
| | | } |
|---|
| | | |
|---|
| | | // GetTask2 获取任务列表2 |
|---|
| | | func (slf TaskService) GetTask2(deviceID string, offset, limit int, channels []int32, queryType request.QueryType) (taskResp *response.TaskResponse, err error) { |
|---|
| | | var taskList []*response.TaskData |
|---|
