From 27546ed6bb77594a44d77e1344f8bde3577a42fc Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Tue, 18 Feb 2025 23:00:33 +0800 Subject: [PATCH] =?UTF-8?q?feat(1.4.0-beta1):=201.=20=E4=BF=AE=E6=94=B9ret?= =?UTF-8?q?ry-log=E6=94=B9=E4=B8=BA=20retry-task=202.=20=E8=B0=83=E8=AF=95?= =?UTF-8?q?=E9=87=8D=E8=AF=95=E4=BB=BB=E5=8A=A1=E5=88=97=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/components/common/log-drawer.vue | 10 +++---- src/constants/business.ts | 18 ++++++------ src/locales/langs/en-us.ts | 14 ++++++++- src/locales/langs/zh-cn.ts | 12 ++++++++ src/service/api/index.ts | 2 +- src/service/api/log.ts | 2 +- .../api/{retry-log.ts => retry-task.ts} | 6 ++-- src/service/api/retry.ts | 22 +++++++------- src/typings/api.d.ts | 29 +++++++++---------- src/typings/app.d.ts | 12 ++++++++ src/views/retry/log/index.vue | 6 ++-- .../log/modules/retry-log-detail-drawer.vue | 19 +++--------- .../retry/log/modules/retry-log-search.vue | 22 +++++++------- src/views/retry/task/index.vue | 20 ++++++------- .../modules/retry-task-batch-add-drawer.vue | 2 +- .../task/modules/retry-task-detail-drawer.vue | 10 ++----- .../modules/retry-task-operate-drawer.vue | 4 +-- .../retry/task/modules/retry-task-search.vue | 8 ++--- 18 files changed, 117 insertions(+), 101 deletions(-) rename src/service/api/{retry-log.ts => retry-task.ts} (77%) diff --git a/src/components/common/log-drawer.vue b/src/components/common/log-drawer.vue index 743c280..d79b713 100644 --- a/src/components/common/log-drawer.vue +++ b/src/components/common/log-drawer.vue @@ -25,7 +25,7 @@ interface Props { title?: string; drawer?: boolean; type?: 'job' | 'retry'; - taskData?: Api.Job.JobTask | Api.RetryLog.RetryLog | Api.RetryTask.RetryTask; + taskData?: Api.Job.JobTask | Api.RetryTask.RetryTask; modelValue?: Api.JobLog.JobMessage[]; } @@ -90,10 +90,10 @@ async function getLogList() { } if (props.type === 'retry') { - const taskData = props.taskData! as Api.RetryLog.RetryLog | Api.RetryTask.RetryTask; + const taskData = props.taskData! as Api.RetryTask.RetryTask; const { data, error } = await fetchRetryLogList({ groupName: taskData.groupName, - uniqueId: taskData.uniqueId!, + retryTaskId: taskData.id!, startId, fromIndex, size: 50 @@ -208,8 +208,8 @@ function openNewTab() { if (props.type === 'retry') { query = { type: props.type, - groupName: (props.taskData as Api.RetryLog.RetryLog | Api.RetryTask.RetryTask).groupName, - uniqueId: (props.taskData as Api.RetryLog.RetryLog | Api.RetryTask.RetryTask).uniqueId + groupName: (props.taskData as Api.RetryTask.RetryTask | Api.Retry.Retry).groupName, + retryTaskId: (props.taskData as Api.RetryTask.RetryTask).id }; } const url = router.resolve({ path: '/log', query }); diff --git a/src/constants/business.ts b/src/constants/business.ts index af9b8d5..5ea1bf7 100644 --- a/src/constants/business.ts +++ b/src/constants/business.ts @@ -89,7 +89,7 @@ export const groupConfigYesOrNoRecord: Record = { +export const retryStatusTypeRecord: Record = { 0: 'page.retryTask.retryStatusType.retrying', 1: 'page.retryTask.retryStatusType.finished', 2: 'page.retryTask.retryStatusType.maxRetry', @@ -97,17 +97,17 @@ export const retryStatusTypeRecord: Record = { - 1: 'page.retryTask.retryStatusType.finished', - 2: 'page.retryTask.retryStatusType.maxRetry', - 3: 'page.retryTask.retryStatusType.paused', - 4: 'page.retryTask.retryStatusType.paused', - 5: 'page.retryTask.retryStatusType.paused', - 6: 'page.retryTask.retryStatusType.paused' +export const retryTaskStatusTypeRecord: Record = { + 1: 'common.retryTaskStatus.items.waiting', + 2: 'common.retryTaskStatus.items.running', + 3: 'common.retryTaskStatus.items.success', + 4: 'common.retryTaskStatus.items.fail', + 5: 'common.retryTaskStatus.items.stop', + 6: 'common.retryTaskStatus.items.cancel' }; export const retryTaskStatusTypeOptions = transformRecordToNumberOption(retryTaskStatusTypeRecord); -export const retryTaskTypeRecord: Record = { +export const retryTaskTypeRecord: Record = { 1: 'page.retryTask.taskTypeDict.retry', 2: 'page.retryTask.taskTypeDict.callback' }; diff --git a/src/locales/langs/en-us.ts b/src/locales/langs/en-us.ts index 9633e30..f6c9d65 100644 --- a/src/locales/langs/en-us.ts +++ b/src/locales/langs/en-us.ts @@ -176,6 +176,18 @@ const local: App.I18n.Schema = { skip: 'Skip' } }, + retryTaskStatus: { + label: 'Task Batch Status', + form: 'Please enter task batch status', + items: { + waiting: 'Waiting', + running: 'Running', + success: 'Success', + fail: 'Fail', + stop: 'Stop', + cancel: 'Cancel' + } + }, taskStatus: { label: 'Task Status', form: 'Please enter task status', @@ -718,7 +730,7 @@ const local: App.I18n.Schema = { sceneName2: 'Scene name: 1~64 characters. allowing: digit, letters, underscore or hyphens..', cbTriggerType: 'Please select the retry trigger time', cbTriggerInterval: 'Please enter trigger interval', - cbMaxCount: 'Please enter Maximum number of callback', + cbMaxCount: 'Please enter Maximum number of callback' }, addScene: 'Add Scenes', editScene: 'Add Scenes', diff --git a/src/locales/langs/zh-cn.ts b/src/locales/langs/zh-cn.ts index 1d21d48..26a8337 100644 --- a/src/locales/langs/zh-cn.ts +++ b/src/locales/langs/zh-cn.ts @@ -176,6 +176,18 @@ const local: App.I18n.Schema = { skip: '跳过' } }, + retryTaskStatus: { + label: '执行状态', + form: '请选择执行状态', + items: { + waiting: '待处理', + running: '运行中', + success: '处理成功', + fail: '处理失败', + stop: '任务停止', + cancel: '取消' + } + }, taskStatus: { label: '状态', form: '请选择状态', diff --git a/src/service/api/index.ts b/src/service/api/index.ts index 3208518..0194388 100644 --- a/src/service/api/index.ts +++ b/src/service/api/index.ts @@ -7,7 +7,7 @@ export * from './notify'; export * from './group'; export * from './retry'; export * from './retry-scene'; -export * from './retry-log'; +export * from './retry-task'; export * from './retry-dead-letter'; export * from './workflow'; export * from './job'; diff --git a/src/service/api/log.ts b/src/service/api/log.ts index 841bceb..444bbd9 100644 --- a/src/service/api/log.ts +++ b/src/service/api/log.ts @@ -13,7 +13,7 @@ export function fetchJobLogList(params?: Api.JobLog.JobLogSearchParams, controll /** get Retry Log List */ export function fetchRetryLogList(params?: Api.JobLog.RetryLogSearchParams) { return request({ - url: '/retry-task-log/message/list', + url: '/retry-task/message/list', method: 'get', params }); diff --git a/src/service/api/retry-log.ts b/src/service/api/retry-task.ts similarity index 77% rename from src/service/api/retry-log.ts rename to src/service/api/retry-task.ts index a71d461..14f969a 100644 --- a/src/service/api/retry-log.ts +++ b/src/service/api/retry-task.ts @@ -1,8 +1,8 @@ import { request } from '../request'; /** get retry log list */ -export function fetchRetryLogPageList(params?: Api.RetryLog.RetryTaskSearchParams) { - return request({ +export function fetchRetryLogPageList(params?: Api.RetryTask.RetryTaskSearchParams) { + return request({ url: '/retry-task/list', method: 'get', params @@ -11,7 +11,7 @@ export function fetchRetryLogPageList(params?: Api.RetryLog.RetryTaskSearchParam /** get retry log list */ export function fetchRetryLogById(id: string) { - return request({ + return request({ url: `/retry-task/${id}`, method: 'get' }); diff --git a/src/service/api/retry.ts b/src/service/api/retry.ts index bedc112..f19da17 100644 --- a/src/service/api/retry.ts +++ b/src/service/api/retry.ts @@ -1,8 +1,8 @@ import { request } from '../request'; /** get retryTask list */ -export function fetchGetRetryTaskList(params?: Api.RetryTask.RetryTaskSearchParams) { - return request({ +export function fetchGetRetryTaskList(params?: Api.Retry.RetrySearchParams) { + return request({ url: '/retry/list', method: 'get', params @@ -11,14 +11,14 @@ export function fetchGetRetryTaskList(params?: Api.RetryTask.RetryTaskSearchPara /** get retryTask */ export function fetchGetRetryTaskById(id: string, groupName: string) { - return request({ + return request({ url: `/retry/${id}?groupName=${groupName}`, method: 'get' }); } /** add retryTask */ -export function fetchAddRetryTask(data: Api.RetryTask.RetryTask) { +export function fetchAddRetryTask(data: Api.Retry.Retry) { return request({ url: '/retry', method: 'post', @@ -27,7 +27,7 @@ export function fetchAddRetryTask(data: Api.RetryTask.RetryTask) { } /** batch add retryTask */ -export function fetchBatchAddRetryTask(data: Api.RetryTask.RetryTaskBatchAdd) { +export function fetchBatchAddRetryTask(data: Api.Retry.RetryTaskBatchAdd) { return request({ url: '/retry/batch', method: 'post', @@ -36,7 +36,7 @@ export function fetchBatchAddRetryTask(data: Api.RetryTask.RetryTaskBatchAdd) { } /** edit retryTask */ -export function fetchEditRetryTask(data: Api.RetryTask.RetryTask) { +export function fetchEditRetryTask(data: Api.Retry.Retry) { return request({ url: '/retry', method: 'put', @@ -45,7 +45,7 @@ export function fetchEditRetryTask(data: Api.RetryTask.RetryTask) { } /** update retryTask status */ -export function fetchUpdateRetryTaskStatus(data: Api.RetryTask.RetryTaskUpdateStatusRequest) { +export function fetchUpdateRetryTaskStatus(data: Api.Retry.RetryTaskUpdateStatusRequest) { return request({ url: '/retry/status', method: 'put', @@ -54,7 +54,7 @@ export function fetchUpdateRetryTaskStatus(data: Api.RetryTask.RetryTaskUpdateSt } /** manual execute retryTask */ -export function fetchExecuteRetryTask(data: Api.RetryTask.ManualTriggerTaskRequestVO) { +export function fetchExecuteRetryTask(data: Api.Retry.ManualTriggerTaskRequestVO) { return request({ url: '/retry/manual/trigger/retry/task', method: 'post', @@ -63,7 +63,7 @@ export function fetchExecuteRetryTask(data: Api.RetryTask.ManualTriggerTaskReque } /** manual execute callbackTask */ -export function fetchExecuteCallbackTask(data: Api.RetryTask.ManualTriggerTaskRequestVO) { +export function fetchExecuteCallbackTask(data: Api.Retry.ManualTriggerTaskRequestVO) { return request({ url: '/retry/manual/trigger/callback/task', method: 'post', @@ -72,7 +72,7 @@ export function fetchExecuteCallbackTask(data: Api.RetryTask.ManualTriggerTaskRe } /** batch delete retryTask */ -export function fetchBatchDeleteRetryTask(data: Api.RetryTask.BatchDeleteRetryTaskVO) { +export function fetchBatchDeleteRetryTask(data: Api.Retry.BatchDeleteRetryTaskVO) { return request({ url: '/retry/batch', method: 'delete', @@ -81,7 +81,7 @@ export function fetchBatchDeleteRetryTask(data: Api.RetryTask.BatchDeleteRetryTa } /** generate retryTask idempotent id */ -export function fetchIdempotentIdGenerate(data: Api.RetryTask.GenerateRetryIdempotentIdVO) { +export function fetchIdempotentIdGenerate(data: Api.Retry.GenerateRetryIdempotentIdVO) { return request({ url: '/retry/generate/idempotent-id', method: 'post', diff --git a/src/typings/api.d.ts b/src/typings/api.d.ts index 35ee742..d2fba7d 100644 --- a/src/typings/api.d.ts +++ b/src/typings/api.d.ts @@ -742,7 +742,7 @@ declare namespace Api { * * backend api module: "retryTask" */ - namespace RetryTask { + namespace Retry { type CommonSearchParams = Pick; type RetryStatusType = 0 | 1 | 2 | 3; @@ -752,9 +752,7 @@ declare namespace Api { type TaskType = 1 | 2; /** RetryTask */ - type RetryTask = Common.CommonRecord<{ - /** UniqueId */ - uniqueId?: string; + type Retry = Common.CommonRecord<{ /** 组名称 */ groupName: string; /** 场景名称 */ @@ -799,7 +797,7 @@ declare namespace Api { type ManualTriggerTaskRequestVO = { groupName: string; - uniqueIds: string[]; + retryIds: number[]; }; type BatchDeleteRetryTaskVO = { @@ -819,13 +817,12 @@ declare namespace Api { }; /** RetryTask search params */ - type RetryTaskSearchParams = CommonType.RecordNullable< - Pick & - CommonSearchParams + type RetrySearchParams = CommonType.RecordNullable< + Pick & CommonSearchParams >; /** RetryTask list */ - type RetryTaskList = Common.PaginatingQueryRecord; + type RetryList = Common.PaginatingQueryRecord; } /** @@ -1223,13 +1220,13 @@ declare namespace Api { * * backend api module: "retryLog" */ - namespace RetryLog { - import TaskType = Api.RetryTask.TaskType; - import RetryTaskStatusType = Api.RetryTask.RetryTaskStatusType; + namespace RetryTask { + import TaskType = Api.Retry.TaskType; + import RetryTaskStatusType = Api.Retry.RetryTaskStatusType; type CommonSearchParams = Pick; /** retryLog */ - type RetryLog = Common.CommonRecord<{ + type RetryTask = Common.CommonRecord<{ /** UniqueId */ retryId: string; /** 组名称 */ @@ -1250,12 +1247,12 @@ declare namespace Api { /** retryLog search params */ type RetryTaskSearchParams = CommonType.RecordNullable< - Pick & + Pick & CommonSearchParams & { datetimeRange?: [string, string] } >; /** retryLog list */ - type RetryLogList = Common.PaginatingQueryRecord; + type RetryTaskList = Common.PaginatingQueryRecord; } /** * namespace UserManager @@ -1323,7 +1320,7 @@ declare namespace Api { type RetryLogSearchParams = { groupName: string; - uniqueId: string; + retryTaskId: string; } & LogSearchParams; type LogSearchParams = { diff --git a/src/typings/app.d.ts b/src/typings/app.d.ts index 3d274da..9b0f228 100644 --- a/src/typings/app.d.ts +++ b/src/typings/app.d.ts @@ -457,6 +457,18 @@ declare namespace App { skip: string; }; }; + retryTaskStatus: { + label: string; + form: string; + items: { + waiting: string; + running: string; + success: string; + fail: string; + stop: string; + cancel: string; + }; + }; taskStatus: { label: string; form: string; diff --git a/src/views/retry/log/index.vue b/src/views/retry/log/index.vue index 7bb429e..4203251 100644 --- a/src/views/retry/log/index.vue +++ b/src/views/retry/log/index.vue @@ -14,7 +14,7 @@ import RetryLogDetailDrawer from './modules/retry-log-detail-drawer.vue'; const appStore = useAppStore(); /** 详情页属性数据 */ -const detailData = ref(); +const detailData = ref(); /** 详情页可见状态 */ const { bool: detailVisible, setTrue: openDetail } = useBoolean(false); const taskStatus = history.state.taskStatus; @@ -155,9 +155,9 @@ async function handleDelete(id: any) { onDeleted(); } -async function loadRetryInfo(row: Api.RetryLog.RetryLog) { +async function loadRetryInfo(row: Api.RetryTask.RetryTask) { const res = await fetchRetryLogById(row.id!); - detailData.value = (res.data as Api.RetryLog.RetryLog) || null; + detailData.value = (res.data as Api.RetryTask.RetryTask) || null; } diff --git a/src/views/retry/log/modules/retry-log-detail-drawer.vue b/src/views/retry/log/modules/retry-log-detail-drawer.vue index 9f8143b..ba72dd4 100644 --- a/src/views/retry/log/modules/retry-log-detail-drawer.vue +++ b/src/views/retry/log/modules/retry-log-detail-drawer.vue @@ -1,7 +1,7 @@