refactor(scheduler api): 简化api函数写法并新增批量操作接口

1. 将所有单行api函数改写为箭头函数简化写法
2. 新增批量暂停、恢复、软删除任务的api接口
3. 新增工作台异常任务列表查询接口
This commit is contained in:
Kris 2026-07-11 21:44:21 +08:00
parent 4206c3a60f
commit 1642c8fae6

View File

@ -34,20 +34,20 @@ export function buildQueryString(params = {}) {
// ===== 查询类apiGet===== // ===== 查询类apiGet=====
// 分页列出定时任务 // 分页列出定时任务
export const listTasksApi = (params = {}) => export const listTasksApi = (params = {}) => apiGet(`${BASE_URL}/tasks${buildQueryString(params)}`)
apiGet(`${BASE_URL}/tasks${buildQueryString(params)}`)
// 获取任务详情 // 获取任务详情
export const getTaskApi = (taskId) => export const getTaskApi = (taskId) => apiGet(`${BASE_URL}/tasks/${taskId}`)
apiGet(`${BASE_URL}/tasks/${taskId}`)
// 列出即将执行的任务(未来 24 小时内) // 列出即将执行的任务(未来 24 小时内)
export const listUpcomingApi = (params = {}) => export const listUpcomingApi = (params = {}) =>
apiGet(`${BASE_URL}/tasks/upcoming${buildQueryString(params)}`) apiGet(`${BASE_URL}/tasks/upcoming${buildQueryString(params)}`)
// 按状态计数任务 // 按状态计数任务
export const countByStatusApi = () => export const countByStatusApi = () => apiGet(`${BASE_URL}/tasks/count-by-status`)
apiGet(`${BASE_URL}/tasks/count-by-status`)
// 列出工作台异常任务聚合(死信 / 连续失败 / 长期未执行)
export const listAnomaliesApi = () => apiGet(`${BASE_URL}/tasks/anomalies`)
// 列出任务执行日志 // 列出任务执行日志
export const listRunLogsApi = (taskId, params = {}) => export const listRunLogsApi = (taskId, params = {}) =>
@ -58,20 +58,17 @@ export const listAllRunLogsApi = (params = {}) =>
apiGet(`${BASE_URL}/run-logs${buildQueryString(params)}`) apiGet(`${BASE_URL}/run-logs${buildQueryString(params)}`)
// 获取执行日志详情 // 获取执行日志详情
export const getRunLogApi = (runId) => export const getRunLogApi = (runId) => apiGet(`${BASE_URL}/run-logs/${runId}`)
apiGet(`${BASE_URL}/run-logs/${runId}`)
// 列出 handler 聚合摘要 // 列出 handler 聚合摘要
export const listHandlerSummaryApi = () => export const listHandlerSummaryApi = () => apiGet(`${BASE_URL}/handlers/summary`)
apiGet(`${BASE_URL}/handlers/summary`)
// 列出日聚合统计 // 列出日聚合统计
export const listDailyStatsApi = (params = {}) => export const listDailyStatsApi = (params = {}) =>
apiGet(`${BASE_URL}/stats/daily${buildQueryString(params)}`) apiGet(`${BASE_URL}/stats/daily${buildQueryString(params)}`)
// 获取调度器健康状态 // 获取调度器健康状态
export const getHealthApi = () => export const getHealthApi = () => apiGet(`${BASE_URL}/health`)
apiGet(`${BASE_URL}/health`)
// ===== 回收站apiAdminGet===== // ===== 回收站apiAdminGet=====
@ -82,24 +79,19 @@ export const listDeletedTasksApi = (params = {}) =>
// ===== 写操作类apiAdmin*===== // ===== 写操作类apiAdmin*=====
// 创建定时任务 // 创建定时任务
export const createTaskApi = (data) => export const createTaskApi = (data) => apiAdminPost(`${BASE_URL}/tasks`, data)
apiAdminPost(`${BASE_URL}/tasks`, data)
// 更新定时任务(部分更新) // 更新定时任务(部分更新)
export const updateTaskApi = (taskId, data) => export const updateTaskApi = (taskId, data) => apiAdminPut(`${BASE_URL}/tasks/${taskId}`, data)
apiAdminPut(`${BASE_URL}/tasks/${taskId}`, data)
// 删除定时任务(软删除) // 删除定时任务(软删除)
export const deleteTaskApi = (taskId) => export const deleteTaskApi = (taskId) => apiAdminDelete(`${BASE_URL}/tasks/${taskId}`)
apiAdminDelete(`${BASE_URL}/tasks/${taskId}`)
// 暂停任务 // 暂停任务
export const pauseTaskApi = (taskId) => export const pauseTaskApi = (taskId) => apiAdminPost(`${BASE_URL}/tasks/${taskId}/pause`)
apiAdminPost(`${BASE_URL}/tasks/${taskId}/pause`)
// 恢复任务 // 恢复任务
export const resumeTaskApi = (taskId) => export const resumeTaskApi = (taskId) => apiAdminPost(`${BASE_URL}/tasks/${taskId}/resume`)
apiAdminPost(`${BASE_URL}/tasks/${taskId}/resume`)
// 手动触发任务执行 // 手动触发任务执行
// payload 为 null/undefined 时不发送请求体;为对象时发送 { payload: {...} } // payload 为 null/undefined 时不发送请求体;为对象时发送 { payload: {...} }
@ -112,12 +104,22 @@ export const triggerTaskApi = (taskId, payload) => {
} }
// 恢复已删除任务 // 恢复已删除任务
export const restoreTaskApi = (taskId) => export const restoreTaskApi = (taskId) => apiAdminPost(`${BASE_URL}/tasks/${taskId}/restore`)
apiAdminPost(`${BASE_URL}/tasks/${taskId}/restore`)
// 硬删除任务(不可恢复) // 硬删除任务(不可恢复)
export const hardDeleteTaskApi = (taskId) => export const hardDeleteTaskApi = (taskId) => apiAdminDelete(`${BASE_URL}/tasks/${taskId}/hard`)
apiAdminDelete(`${BASE_URL}/tasks/${taskId}/hard`)
// 批量暂停任务
export const batchPauseTasksApi = (taskIds) =>
apiAdminPost(`${BASE_URL}/tasks/batch-pause`, { task_ids: taskIds })
// 批量恢复任务
export const batchResumeTasksApi = (taskIds) =>
apiAdminPost(`${BASE_URL}/tasks/batch-resume`, { task_ids: taskIds })
// 批量删除任务(软删除)
export const batchDeleteTasksApi = (taskIds) =>
apiAdminPost(`${BASE_URL}/tasks/batch-delete`, { task_ids: taskIds })
// 回收僵尸执行记录 // 回收僵尸执行记录
export const reclaimStaleRunsApi = (data = {}) => export const reclaimStaleRunsApi = (data = {}) =>