From 5816101b464d7ff7410e2a2a1cf3efbfe1ed7d8e Mon Sep 17 00:00:00 2001
From: xingyuv <xingyu4j@vip.qq.com>
Date: Thu, 23 Mar 2023 14:43:30 +0800
Subject: [PATCH] feat: job view

---
 src/views/infra/job/JobModal.vue |  54 +++++++++++++
 src/views/infra/job/index.vue    | 135 ++++++++++++++++++++++++++++++-
 src/views/infra/job/job.data.ts  | 116 ++++++++++++++++++++++++++
 3 files changed, 304 insertions(+), 1 deletion(-)
 create mode 100644 src/views/infra/job/JobModal.vue
 create mode 100644 src/views/infra/job/job.data.ts

diff --git a/src/views/infra/job/JobModal.vue b/src/views/infra/job/JobModal.vue
new file mode 100644
index 0000000..7bc4fde
--- /dev/null
+++ b/src/views/infra/job/JobModal.vue
@@ -0,0 +1,54 @@
+<template>
+  <BasicModal v-bind="$attrs" @register="registerModal" :title="getTitle" @ok="handleSubmit">
+    <BasicForm @register="registerForm" />
+  </BasicModal>
+</template>
+<script lang="ts" setup name="JobModal">
+import { ref, computed, unref } from 'vue'
+import { BasicModal, useModalInner } from '@/components/Modal'
+import { BasicForm, useForm } from '@/components/Form'
+import { formSchema } from './job.data'
+import { createJob, getJob, updateJob } from '@/api/infra/job'
+
+const emit = defineEmits(['success', 'register'])
+const isUpdate = ref(true)
+const rowId = ref()
+
+const [registerForm, { setFieldsValue, resetFields, validate }] = useForm({
+  labelWidth: 100,
+  baseColProps: { span: 24 },
+  schemas: formSchema,
+  showActionButtonGroup: false,
+  actionColOptions: { span: 23 }
+})
+
+const [registerModal, { setModalProps, closeModal }] = useModalInner(async (data) => {
+  resetFields()
+  setModalProps({ confirmLoading: false })
+  isUpdate.value = !!data?.isUpdate
+
+  if (unref(isUpdate)) {
+    const res = await getJob(data.record.id)
+    rowId.value = res.id
+    setFieldsValue({ ...res })
+  }
+})
+
+const getTitle = computed(() => (!unref(isUpdate) ? '新增定时任务' : '编辑定时任务'))
+
+async function handleSubmit() {
+  try {
+    const values = await validate()
+    setModalProps({ confirmLoading: true })
+    if (unref(isUpdate)) {
+      await updateJob(values)
+    } else {
+      await createJob(values)
+    }
+    closeModal()
+    emit('success')
+  } finally {
+    setModalProps({ confirmLoading: false })
+  }
+}
+</script>
diff --git a/src/views/infra/job/index.vue b/src/views/infra/job/index.vue
index 3b64cfc..79b3774 100644
--- a/src/views/infra/job/index.vue
+++ b/src/views/infra/job/index.vue
@@ -1,3 +1,136 @@
 <template>
-  <div>开发中</div>
+  <div>
+    <BasicTable @register="registerTable">
+      <template #toolbar>
+        <a-button type="primary" :preIcon="IconEnum.ADD" @click="handleCreate"> {{ t('action.create') }} </a-button>
+        <a-button type="warning" :preIcon="IconEnum.EXPORT" @click="handleExport"> {{ t('action.export') }} </a-button>
+      </template>
+      <template #bodyCell="{ column, record }">
+        <template v-if="column.key === 'action'">
+          <TableAction
+            :actions="[{ icon: IconEnum.EDIT, label: t('action.edit'), onClick: handleEdit.bind(null, record) }]"
+            :dropDownActions="[
+              { icon: IconEnum.EDIT, label: '开启', onClick: handleChangeStatus.bind(null, record, true) },
+              { icon: IconEnum.EDIT, label: '暂停', onClick: handleChangeStatus.bind(null, record, false) },
+              { icon: IconEnum.EDIT, label: '执行一次', onClick: handleRun.bind(null, record) },
+              { icon: IconEnum.EDIT, label: '任务详细', onClick: handleView.bind(null, record) },
+              { icon: IconEnum.EDIT, label: '调度日志', onClick: handleJobLog.bind(null, record) },
+              {
+                icon: IconEnum.DELETE,
+                color: 'error',
+                label: t('action.delete'),
+                popConfirm: {
+                  title: t('common.delMessage'),
+                  placement: 'left',
+                  confirm: handleDelete.bind(null, record)
+                }
+              }
+            ]"
+          />
+        </template>
+      </template>
+    </BasicTable>
+    <JobModal @register="registerModal" @success="reload()" />
+  </div>
 </template>
+<script lang="ts" setup name="Job">
+import { useI18n } from '@/hooks/web/useI18n'
+import { useMessage } from '@/hooks/web/useMessage'
+import { useModal } from '@/components/Modal'
+import JobModal from './JobModal.vue'
+import { IconEnum } from '@/enums/appEnum'
+import { BasicTable, useTable, TableAction } from '@/components/Table'
+import { JobExportReqVO, deleteJob, exportJob, getJobPage, runJob, updateJobStatus } from '@/api/infra/job'
+import { columns, searchFormSchema } from './job.data'
+import { InfraJobStatusEnum } from '@/enums/systemEnum'
+
+const { t } = useI18n()
+const { createConfirm, createMessage } = useMessage()
+const [registerModal, { openModal }] = useModal()
+
+const [registerTable, { getForm, reload }] = useTable({
+  title: '定时任务列表',
+  api: getJobPage,
+  columns,
+  formConfig: {
+    labelWidth: 120,
+    schemas: searchFormSchema
+  },
+  useSearchForm: true,
+  showTableSetting: true,
+  showIndexColumn: false,
+  actionColumn: {
+    width: 140,
+    title: t('common.action'),
+    dataIndex: 'action',
+    fixed: 'right'
+  }
+})
+
+function handleCreate() {
+  openModal(true, {
+    isUpdate: false
+  })
+}
+
+function handleEdit(record: Recordable) {
+  openModal(true, {
+    record,
+    isUpdate: true
+  })
+}
+
+function handleChangeStatus(record: Recordable, open: boolean) {
+  let status = open ? InfraJobStatusEnum.NORMAL : InfraJobStatusEnum.STOP
+  let statusStr = open ? '开启' : '关闭'
+  createConfirm({
+    title: '调整状态',
+    iconType: 'warning',
+    content: '是否确认' + statusStr + '定时任务编号为"' + record.id + '"的数据项?',
+    async onOk() {
+      await updateJobStatus(record.id, status)
+      createMessage.success(t('common.successText'))
+    }
+  })
+}
+
+function handleRun(record: Recordable) {
+  createConfirm({
+    title: '执行',
+    iconType: 'warning',
+    content: '确认要立即执行一次"' + record.name + '"任务吗?',
+    async onOk() {
+      await runJob(record.id)
+      createMessage.success(t('common.successText'))
+    }
+  })
+}
+
+function handleView(record: Recordable) {
+  // TODO
+  console.info(record)
+}
+
+function handleJobLog(record: Recordable) {
+  // TODO
+  console.info(record)
+}
+
+async function handleExport() {
+  createConfirm({
+    title: t('common.exportTitle'),
+    iconType: 'warning',
+    content: t('common.exportMessage'),
+    async onOk() {
+      await exportJob(getForm().getFieldsValue() as JobExportReqVO)
+      createMessage.success(t('common.exportSuccessText'))
+    }
+  })
+}
+
+async function handleDelete(record: Recordable) {
+  await deleteJob(record.id)
+  createMessage.success(t('common.delSuccessText'))
+  reload()
+}
+</script>
diff --git a/src/views/infra/job/job.data.ts b/src/views/infra/job/job.data.ts
new file mode 100644
index 0000000..9553f10
--- /dev/null
+++ b/src/views/infra/job/job.data.ts
@@ -0,0 +1,116 @@
+import { BasicColumn, FormSchema, useRender } from '@/components/Table'
+import { DICT_TYPE, getIntDictOptions } from '@/utils/dict'
+
+export const columns: BasicColumn[] = [
+  {
+    title: '任务编号',
+    dataIndex: 'id',
+    width: 100
+  },
+  {
+    title: '任务名称',
+    dataIndex: 'name',
+    width: 180
+  },
+  {
+    title: '处理器的名字',
+    dataIndex: 'handlerName',
+    width: 180
+  },
+  {
+    title: '处理器的参数',
+    dataIndex: 'handlerParam',
+    width: 180
+  },
+  {
+    title: 'CRON 表达式',
+    dataIndex: 'cronExpression',
+    width: 200
+  },
+  {
+    title: '任务状态',
+    dataIndex: 'status',
+    width: 180,
+    customRender: ({ text }) => {
+      return useRender.renderDict(text, DICT_TYPE.INFRA_JOB_STATUS)
+    }
+  }
+]
+
+export const searchFormSchema: FormSchema[] = [
+  {
+    label: '任务名称',
+    field: 'name',
+    component: 'Input',
+    colProps: { span: 8 }
+  },
+  {
+    label: '任务状态',
+    field: 'status',
+    component: 'Select',
+    componentProps: {
+      options: getIntDictOptions(DICT_TYPE.INFRA_JOB_STATUS)
+    },
+    colProps: { span: 8 }
+  },
+  {
+    label: '处理器的名字',
+    field: 'handlerName',
+    component: 'Input',
+    colProps: { span: 8 }
+  }
+]
+
+export const formSchema: FormSchema[] = [
+  {
+    label: '任务编号',
+    field: 'id',
+    show: false,
+    component: 'Input'
+  },
+  {
+    label: '任务名称',
+    field: 'name',
+    required: true,
+    component: 'Input'
+  },
+  {
+    label: '处理器的名字',
+    field: 'handlerName',
+    required: true,
+    dynamicDisabled: ({ values }) => !!values.id,
+    component: 'Input'
+  },
+  {
+    label: '处理器的参数',
+    field: 'handlerParam',
+    component: 'Input'
+  },
+  {
+    label: 'CRON 表达式',
+    field: 'cronExpression',
+    required: true,
+    component: 'Input'
+  },
+  {
+    label: '重试次数',
+    field: 'retryCount',
+    required: true,
+    helpMessage: '设置为 0 时，不进行重试',
+    component: 'InputNumber'
+  },
+  {
+    label: '重试间隔',
+    field: 'retryInterval',
+    required: true,
+    helpMessage: '单位：毫秒。设置为 0 时，无需间隔',
+    component: 'InputNumber',
+    suffix: '毫秒'
+  },
+  {
+    label: '监控超时时间',
+    field: 'monitorTimeout',
+    component: 'Input',
+    suffix: '毫秒'
+  }
+]