diff --git a/apps/web-ele/src/views/infra/job/data.ts b/apps/web-ele/src/views/infra/job/data.ts new file mode 100644 index 00000000..b2dfa08c --- /dev/null +++ b/apps/web-ele/src/views/infra/job/data.ts @@ -0,0 +1,221 @@ +import type { VbenFormSchema } from '#/adapter/form'; +import type { OnActionClickFn, VxeTableGridOptions } from '#/adapter/vxe-table'; +import type { InfraJobApi } from '#/api/infra/job'; + +import { useAccess } from '@vben/access'; + +import { DICT_TYPE, getDictOptions, InfraJobStatusEnum } from '#/utils'; + +const { hasAccessByCodes } = useAccess(); + +/** 新增/修改的表单 */ +export function useFormSchema(): VbenFormSchema[] { + return [ + { + fieldName: 'id', + component: 'Input', + dependencies: { + triggerFields: [''], + show: () => false, + }, + }, + { + fieldName: 'name', + label: '任务名称', + component: 'Input', + componentProps: { + placeholder: '请输入任务名称', + }, + rules: 'required', + }, + { + fieldName: 'handlerName', + label: '处理器的名字', + component: 'Input', + componentProps: { + placeholder: '请输入处理器的名字', + // readonly: ({ values }) => !!values.id, + }, + rules: 'required', + // TODO @芋艿:在修改场景下,禁止调整 + }, + { + fieldName: 'handlerParam', + label: '处理器的参数', + component: 'Input', + componentProps: { + placeholder: '请输入处理器的参数', + }, + }, + { + fieldName: 'cronExpression', + label: 'CRON 表达式', + component: 'Input', + componentProps: { + placeholder: '请输入 CRON 表达式', + }, + rules: 'required', + // TODO @芋艿:未来支持动态的 CRON 表达式选择 + }, + { + fieldName: 'retryCount', + label: '重试次数', + component: 'InputNumber', + componentProps: { + placeholder: '请输入重试次数。设置为 0 时,不进行重试', + min: 0, + }, + rules: 'required', + }, + { + fieldName: 'retryInterval', + label: '重试间隔', + component: 'InputNumber', + componentProps: { + placeholder: '请输入重试间隔,单位:毫秒。设置为 0 时,无需间隔', + min: 0, + }, + rules: 'required', + }, + { + fieldName: 'monitorTimeout', + label: '监控超时时间', + component: 'InputNumber', + componentProps: { + placeholder: '请输入监控超时时间,单位:毫秒', + min: 0, + }, + }, + ]; +} + +/** 列表的搜索表单 */ +export function useGridFormSchema(): VbenFormSchema[] { + return [ + { + fieldName: 'name', + label: '任务名称', + component: 'Input', + componentProps: { + allowClear: true, + placeholder: '请输入任务名称', + }, + }, + { + fieldName: 'status', + label: '任务状态', + component: 'Select', + componentProps: { + options: getDictOptions(DICT_TYPE.INFRA_JOB_STATUS, 'number'), + allowClear: true, + placeholder: '请选择任务状态', + }, + }, + { + fieldName: 'handlerName', + label: '处理器的名字', + component: 'Input', + componentProps: { + allowClear: true, + placeholder: '请输入处理器的名字', + }, + }, + ]; +} + +/** 表格列配置 */ +export function useGridColumns( + onActionClick: OnActionClickFn, +): VxeTableGridOptions['columns'] { + return [ + { + field: 'id', + title: '任务编号', + minWidth: 80, + }, + { + field: 'name', + title: '任务名称', + minWidth: 120, + }, + { + field: 'status', + title: '任务状态', + minWidth: 100, + cellRender: { + name: 'CellDict', + props: { type: DICT_TYPE.INFRA_JOB_STATUS }, + }, + }, + { + field: 'handlerName', + title: '处理器的名字', + minWidth: 180, + }, + { + field: 'handlerParam', + title: '处理器的参数', + minWidth: 140, + }, + { + field: 'cronExpression', + title: 'CRON 表达式', + minWidth: 120, + }, + { + field: 'operation', + title: '操作', + width: 280, + fixed: 'right', + align: 'center', + cellRender: { + attrs: { + nameField: 'name', + nameTitle: '任务', + onClick: onActionClick, + }, + name: 'CellOperation', + options: [ + { + code: 'edit', + show: hasAccessByCodes(['infra:job:update']), + }, + { + code: 'update-status', + text: '开启', + show: (row: any) => + hasAccessByCodes(['infra:job:update']) && + row.status === InfraJobStatusEnum.STOP, + }, + { + code: 'update-status', + text: '暂停', + show: (row: any) => + hasAccessByCodes(['infra:job:update']) && + row.status === InfraJobStatusEnum.NORMAL, + }, + { + code: 'trigger', + text: '执行', + show: hasAccessByCodes(['infra:job:trigger']), + }, + // TODO @芋艿:增加一个“更多”选项 + { + code: 'detail', + text: '详细', + show: hasAccessByCodes(['infra:job:query']), + }, + { + code: 'log', + text: '日志', + show: hasAccessByCodes(['infra:job:query']), + }, + { + code: 'delete', + show: hasAccessByCodes(['infra:job:delete']), + }, + ], + }, + }, + ]; +} diff --git a/apps/web-ele/src/views/infra/job/index.vue b/apps/web-ele/src/views/infra/job/index.vue new file mode 100644 index 00000000..d75fa92b --- /dev/null +++ b/apps/web-ele/src/views/infra/job/index.vue @@ -0,0 +1,222 @@ + + + diff --git a/apps/web-ele/src/views/infra/job/logger/data.ts b/apps/web-ele/src/views/infra/job/logger/data.ts new file mode 100644 index 00000000..c5903edf --- /dev/null +++ b/apps/web-ele/src/views/infra/job/logger/data.ts @@ -0,0 +1,145 @@ +import type { VbenFormSchema } from '#/adapter/form'; +import type { OnActionClickFn, VxeTableGridOptions } from '#/adapter/vxe-table'; +import type { InfraJobLogApi } from '#/api/infra/job-log'; + +import { useAccess } from '@vben/access'; +import { formatDateTime } from '@vben/utils'; + +import dayjs from 'dayjs'; + +import { DICT_TYPE, getDictOptions } from '#/utils'; + +const { hasAccessByCodes } = useAccess(); + +/** 列表的搜索表单 */ +export function useGridFormSchema(): VbenFormSchema[] { + return [ + { + fieldName: 'handlerName', + label: '处理器的名字', + component: 'Input', + componentProps: { + allowClear: true, + placeholder: '请输入处理器的名字', + }, + }, + { + fieldName: 'beginTime', + label: '开始执行时间', + component: 'DatePicker', + componentProps: { + allowClear: true, + placeholder: '选择开始执行时间', + valueFormat: 'YYYY-MM-DD HH:mm:ss', + showTime: { + format: 'HH:mm:ss', + defaultValue: dayjs('00:00:00', 'HH:mm:ss'), + }, + }, + }, + { + fieldName: 'endTime', + label: '结束执行时间', + component: 'DatePicker', + componentProps: { + allowClear: true, + placeholder: '选择结束执行时间', + valueFormat: 'YYYY-MM-DD HH:mm:ss', + showTime: { + format: 'HH:mm:ss', + defaultValue: dayjs('23:59:59', 'HH:mm:ss'), + }, + }, + }, + { + fieldName: 'status', + label: '任务状态', + component: 'Select', + componentProps: { + options: getDictOptions(DICT_TYPE.INFRA_JOB_LOG_STATUS, 'number'), + allowClear: true, + placeholder: '请选择任务状态', + }, + }, + ]; +} + +/** 表格列配置 */ +export function useGridColumns( + onActionClick: OnActionClickFn, +): VxeTableGridOptions['columns'] { + return [ + { + field: 'id', + title: '日志编号', + minWidth: 80, + }, + { + field: 'jobId', + title: '任务编号', + minWidth: 80, + }, + { + field: 'handlerName', + title: '处理器的名字', + minWidth: 180, + }, + { + field: 'handlerParam', + title: '处理器的参数', + minWidth: 140, + }, + { + field: 'executeIndex', + title: '第几次执行', + minWidth: 100, + }, + { + field: 'beginTime', + title: '执行时间', + minWidth: 280, + formatter: ({ row }) => { + return `${formatDateTime(row.beginTime)} ~ ${formatDateTime(row.endTime)}`; + }, + }, + { + field: 'duration', + title: '执行时长', + minWidth: 120, + formatter: ({ row }) => { + return `${row.duration} 毫秒`; + }, + }, + { + field: 'status', + title: '任务状态', + minWidth: 100, + cellRender: { + name: 'CellDict', + props: { type: DICT_TYPE.INFRA_JOB_LOG_STATUS }, + }, + }, + { + field: 'operation', + title: '操作', + width: 80, + fixed: 'right', + align: 'center', + cellRender: { + attrs: { + nameField: 'id', + nameTitle: '日志', + onClick: onActionClick, + }, + name: 'CellOperation', + options: [ + { + code: 'detail', + text: '详细', + show: hasAccessByCodes(['infra:job:query']), + }, + ], + }, + }, + ]; +} diff --git a/apps/web-ele/src/views/infra/job/logger/index.vue b/apps/web-ele/src/views/infra/job/logger/index.vue new file mode 100644 index 00000000..5ef8b093 --- /dev/null +++ b/apps/web-ele/src/views/infra/job/logger/index.vue @@ -0,0 +1,112 @@ + + + diff --git a/apps/web-ele/src/views/infra/job/logger/modules/detail.vue b/apps/web-ele/src/views/infra/job/logger/modules/detail.vue new file mode 100644 index 00000000..7902f819 --- /dev/null +++ b/apps/web-ele/src/views/infra/job/logger/modules/detail.vue @@ -0,0 +1,85 @@ + + + diff --git a/apps/web-ele/src/views/infra/job/modules/detail.vue b/apps/web-ele/src/views/infra/job/modules/detail.vue new file mode 100644 index 00000000..c8aa645f --- /dev/null +++ b/apps/web-ele/src/views/infra/job/modules/detail.vue @@ -0,0 +1,101 @@ + + + diff --git a/apps/web-ele/src/views/infra/job/modules/form.vue b/apps/web-ele/src/views/infra/job/modules/form.vue new file mode 100644 index 00000000..6bd86a91 --- /dev/null +++ b/apps/web-ele/src/views/infra/job/modules/form.vue @@ -0,0 +1,82 @@ + + +