异步任务管理

ctx := context.Background()

resp, httpRes, err := apiClient.TaskAPI.QueryTask(ctx, "your-library-id", "your-space-id", "12345,12346").
    AccessToken("your-access-token").
    Execute()

if err != nil {
    panic(err)
}

// 返回值为任务数组
for _, task := range *resp {
    fmt.Printf("TaskId: %d, Status: %d\\n", *task.TaskId, *task.Status)
    // task.Result 为 map 或数组结构，按任务类型解析
}

ctx := context.Background()

resp, httpRes, err := apiClient.TaskAPI.QueryLibraryTask(ctx, "your-library-id", "12345,12346").
    AccessToken("your-access-token").
    Execute()

if err != nil {
    panic(err)
}

for _, task := range *resp {
    fmt.Printf("TaskId: %d, Status: %d\\n", *task.TaskId, *task.Status)
}

func (a *TaskAPIService) QueryTaskV2(ctx context.Context, libraryId string, spaceId string, taskId string) TaskAPIQueryTaskV2Request

ctx := context.Background()

resp, httpRes, err := apiClient.TaskAPI.QueryTaskV2(ctx, "your-library-id", "your-space-id", "12345").
    AccessToken("your-access-token").
    Execute()

if err != nil {
    panic(err)
}

fmt.Printf("Query task V2 status: %d\\n", httpRes.StatusCode)
fmt.Printf("Task ID: %s, Type: %s, Status: %d\\n", *resp.TaskId, *resp.TaskType, *resp.Status)

// 根据任务类型处理不同的结果
if resp.BatchMoveResults != nil {
    for _, result := range resp.BatchMoveResults {
        fmt.Printf("Move result - Path: %v, Status: %d\\n", result.Path, *result.Status)
    }
}

if resp.BatchCopyResults != nil {
    for _, result := range resp.BatchCopyResults {
        fmt.Printf("Copy result - Path: %v, Status: %d\\n", result.Path, *result.Status)
    }
}

{
  "taskId": "12345",
  "taskType": "batchMove",
  "status": 200,
  "batchMoveResults": [
    {
      "path": ["dir", "file.txt"],
      "status": 200
    }
  ]
}

func (a *TaskAPIService) QueryLibraryTaskV2(ctx context.Context, libraryId string, taskId string) TaskAPIQueryLibraryTaskV2Request

ctx := context.Background()

resp, httpRes, err := apiClient.TaskAPI.QueryLibraryTaskV2(ctx, "your-library-id", "12345").
    AccessToken("your-access-token").
    Execute()

if err != nil {
    panic(err)
}

fmt.Printf("Query library task V2 status: %d\\n", httpRes.StatusCode)
fmt.Printf("Task ID: %s, Type: %s, Status: %d\\n", *resp.TaskId, *resp.TaskType, *resp.Status)

// 处理清空历史版本任务结果
if resp.ClearLibraryHistoryResult != nil {
    result := resp.ClearLibraryHistoryResult
    fmt.Printf("Clear history result - Status: %d, Code: %s, DeleteCount: %d\\n",
        *result.Status, *result.Code, *result.DeleteCount)
}

{
  "taskId": "12345",
  "taskType": "clearLibraryHistory",
  "status": 200,
  "clearLibraryHistoryResult": {
    "status": 200,
    "code": "OK",
    "deleteCount": 100
  }
}