feat: 添加批量重置探索任务 API 端点

新增 POST /api/discovery/tasks/batch-reset 接口,用于 n8n 探索流程失败后批量重置任务状态。

功能:
- 支持按任务 ID 列表重置
- 支持按状态筛选重置(默认 IN_PROGRESS 和 FAILED)
- 重置时清除 startedAt、completedAt、errorMessage

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
2026-01-26 15:14:51 +08:00
co-authored by Claude
parent 114ae76abb
commit 6c65cb7cc0
2 changed files with 91 additions and 0 deletions
+15
View File
@@ -91,6 +91,20 @@ export const GetDiscoveryTasksQuerySchema = z.object({
offset: z.coerce.number().int().nonnegative().default(0),
})
/**
* 批量重置任务 Schema
* 支持两种模式:按 ID 列表重置 或 按状态筛选重置
*/
export const BatchResetTasksSchema = WebhookAuthSchema.extend({
// 模式1: 指定任务 ID 列表
taskIds: z.array(z.string()).optional(),
// 模式2: 按状态筛选(不传则默认重置 IN_PROGRESS 和 FAILED
statuses: z.array(TaskStatusEnum).optional(),
}).refine(
(data) => data.taskIds || data.statuses,
{ message: '必须提供 taskIds 或 statuses 之一' }
)
/**
* 检查任务去重 Schema
* 用于在创建任务前检查 URL 是否已存在
@@ -125,3 +139,4 @@ export type TaskStatus = z.infer<typeof TaskStatusEnum>
export type CreateDiscoveryTask = z.infer<typeof CreateDiscoveryTaskSchema>
export type UpdateDiscoveryTask = z.infer<typeof UpdateDiscoveryTaskSchema>
export type GetDiscoveryTasksQuery = z.infer<typeof GetDiscoveryTasksQuerySchema>
export type BatchResetTasks = z.infer<typeof BatchResetTasksSchema>