sdz/shihezi-admin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

flat:初始化

Browse Source
This commit is contained in:
史典卓
2024-11-18 16:38:38 +08:00
commit 903776f4b9
242 changed files with 24577 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

131
src/pages/Monitor/Job/detail.tsx Normal file
View File

@@ -0,0 +1,131 @@
import React, { useEffect } from 'react';
import { Modal, Descriptions, Button } from 'antd';
import { FormattedMessage, useIntl } from '@umijs/max';
import { getValueEnumLabel } from '@/utils/options';
import { DictValueEnumObj } from '@/components/DictTag';
/* *
*
* @author whiteshader@163.com
* @datetime 2023/02/07
*
* */
export type OperlogFormValueType = Record<string, unknown> & Partial<API.Monitor.Job>;
export type OperlogFormProps = {
onCancel: (flag?: boolean, formVals?: OperlogFormValueType) => void;
open: boolean;
values: Partial<API.Monitor.Job>;
statusOptions: DictValueEnumObj;
};
const OperlogForm: React.FC<OperlogFormProps> = (props) => {
const { values, statusOptions } = props;
useEffect(() => {}, [props]);
const intl = useIntl();
const misfirePolicy: any = {
'0': '默认策略',
'1': '立即执行',
'2': '执行一次',
'3': '放弃执行',
};
const handleCancel = () => {
props.onCancel();
};
return (
<Modal
width={800}
title={intl.formatMessage({
id: 'monitor.job.detail',
defaultMessage: '操作日志详细信息',
})}
open={props.open}
destroyOnClose
onCancel={handleCancel}
footer={[
<Button key="back" onClick={handleCancel}>
关闭
</Button>,
]}
>
<Descriptions column={24}>
<Descriptions.Item
span={12}
label={<FormattedMessage id="monitor.job.job_id" defaultMessage="任务编号" />}
>
{values.jobId}
</Descriptions.Item>
<Descriptions.Item
span={12}
label={<FormattedMessage id="monitor.job.job_name" defaultMessage="任务名称" />}
>
{values.jobName}
</Descriptions.Item>
<Descriptions.Item
span={12}
label={<FormattedMessage id="monitor.job.job_group" defaultMessage="任务组名" />}
>
{values.jobGroup}
</Descriptions.Item>
<Descriptions.Item
span={12}
label={<FormattedMessage id="monitor.job.concurrent" defaultMessage="是否并发执行" />}
>
{values.concurrent === '1' ? '禁止' : '允许'}
</Descriptions.Item>
<Descriptions.Item
span={12}
label={
<FormattedMessage id="monitor.job.misfire_policy" defaultMessage="计划执行错误策略" />
}
>
{misfirePolicy[values.misfirePolicy ? values.misfirePolicy : '0']}
</Descriptions.Item>
<Descriptions.Item
span={12}
label={<FormattedMessage id="monitor.job.create_time" defaultMessage="创建时间" />}
>
{values.createTime?.toString()}
</Descriptions.Item>
<Descriptions.Item
span={12}
label={<FormattedMessage id="monitor.job.status" defaultMessage="状态" />}
>
{getValueEnumLabel(statusOptions, values.status, '未知')}
</Descriptions.Item>
<Descriptions.Item
span={12}
label={
<FormattedMessage id="monitor.job.next_valid_time" defaultMessage="下次执行时间" />
}
>
{values.nextValidTime}
</Descriptions.Item>
<Descriptions.Item
span={24}
label={
<FormattedMessage id="monitor.job.cron_expression" defaultMessage="cron执行表达式" />
}
>
{values.cronExpression}
</Descriptions.Item>
<Descriptions.Item
span={24}
label={
<FormattedMessage id="monitor.job.invoke_target" defaultMessage="调用目标字符串" />
}
>
{values.invokeTarget}
</Descriptions.Item>
</Descriptions>
</Modal>
);
};
export default OperlogForm;

232
src/pages/Monitor/Job/edit.tsx Normal file
View File

@@ -0,0 +1,232 @@
import React, { useEffect } from 'react';
import {
ProForm,
ProFormDigit,
ProFormText,
ProFormTextArea,
ProFormRadio,
ProFormSelect,
ProFormCaptcha,
} from '@ant-design/pro-components';
import { Form, Modal } from 'antd';
import { useIntl, FormattedMessage } from '@umijs/max';
import { DictOptionType, DictValueEnumObj } from '@/components/DictTag';
/**
* 定时任务调度 Edit Form
*
* @author whiteshader
* @date 2023-02-07
*/
export type JobFormData = Record<string, unknown> & Partial<API.Monitor.Job>;
export type JobFormProps = {
onCancel: (flag?: boolean, formVals?: JobFormData) => void;
onSubmit: (values: JobFormData) => Promise<void>;
open: boolean;
values: Partial<API.Monitor.Job>;
jobGroupOptions: DictOptionType[];
statusOptions: DictValueEnumObj;
};
const JobForm: React.FC<JobFormProps> = (props) => {
const [form] = Form.useForm();
const { jobGroupOptions, statusOptions } = props;
useEffect(() => {
form.resetFields();
form.setFieldsValue({
jobId: props.values.jobId,
jobName: props.values.jobName,
jobGroup: props.values.jobGroup,
invokeTarget: props.values.invokeTarget,
cronExpression: props.values.cronExpression,
misfirePolicy: props.values.misfirePolicy,
concurrent: props.values.concurrent,
status: props.values.status,
createBy: props.values.createBy,
createTime: props.values.createTime,
updateBy: props.values.updateBy,
updateTime: props.values.updateTime,
remark: props.values.remark,
});
}, [form, props]);
const intl = useIntl();
const handleOk = () => {
form.submit();
};
const handleCancel = () => {
props.onCancel();
form.resetFields();
};
const handleFinish = async (values: Record<string, any>) => {
props.onSubmit(values as JobFormData);
};
return (
<Modal
width={640}
title={intl.formatMessage({
id: 'monitor.job.title',
defaultMessage: '编辑定时任务调度',
})}
open={props.open}
forceRender
destroyOnClose
onOk={handleOk}
onCancel={handleCancel}
>
<ProForm
form={form}
grid={true}
submitter={false}
layout="horizontal"
onFinish={handleFinish}>
<ProFormDigit
name="jobId"
label={intl.formatMessage({
id: 'monitor.job.job_id',
defaultMessage: '任务编号',
})}
colProps={{ md: 24 }}
placeholder="请输入任务编号"
disabled
hidden={true}
rules={[
{
required: false,
message: <FormattedMessage id="请输入任务编号！" defaultMessage="请输入任务编号！" />,
},
]}
/>
<ProFormText
name="jobName"
label={intl.formatMessage({
id: 'monitor.job.job_name',
defaultMessage: '任务名称',
})}
colProps={{ md: 24 }}
placeholder="请输入任务名称"
rules={[
{
required: false,
message: <FormattedMessage id="请输入任务名称！" defaultMessage="请输入任务名称！" />,
},
]}
/>
<ProFormSelect
name="jobGroup"
options={jobGroupOptions}
label={intl.formatMessage({
id: 'monitor.job.job_group',
defaultMessage: '任务组名',
})}
colProps={{ md: 24 }}
placeholder="请输入任务组名"
rules={[
{
required: false,
message: <FormattedMessage id="请输入任务组名！" defaultMessage="请输入任务组名！" />,
},
]}
/>
<ProFormTextArea
name="invokeTarget"
label={intl.formatMessage({
id: 'monitor.job.invoke_target',
defaultMessage: '调用目标字符串',
})}
colProps={{ md: 24 }}
placeholder="请输入调用目标字符串"
rules={[
{
required: true,
message: <FormattedMessage id="请输入调用目标字符串！" defaultMessage="请输入调用目标字符串！" />,
},
]}
/>
<ProFormCaptcha
name="cronExpression"
label={intl.formatMessage({
id: 'monitor.job.cron_expression',
defaultMessage: 'cron执行表达式',
})}
captchaTextRender={() => "生成表达式"}
onGetCaptcha={() => {
// form.setFieldValue('cronExpression', '0/20 * * * * ?');
return new Promise((resolve, reject) => {
reject();
});
}}
/>
<ProFormRadio.Group
name="misfirePolicy"
label={intl.formatMessage({
id: 'monitor.job.misfire_policy',
defaultMessage: '计划执行错误策略',
})}
colProps={{ md: 24 }}
placeholder="请输入计划执行错误策略"
valueEnum={{
0: '立即执行',
1: '执行一次',
3: '放弃执行'
}}
rules={[
{
required: false,
message: <FormattedMessage id="请输入计划执行错误策略！" defaultMessage="请输入计划执行错误策略！" />,
},
]}
fieldProps={{
optionType: "button",
buttonStyle: "solid"
}}
/>
<ProFormRadio.Group
name="concurrent"
label={intl.formatMessage({
id: 'monitor.job.concurrent',
defaultMessage: '是否并发执行',
})}
colProps={{ md: 24 }}
placeholder="请输入是否并发执行"
valueEnum={{
0: '允许',
1: '禁止',
}}
rules={[
{
required: false,
message: <FormattedMessage id="请输入是否并发执行！" defaultMessage="请输入是否并发执行！" />,
},
]}
fieldProps={{
optionType: "button",
buttonStyle: "solid"
}}
/>
<ProFormRadio.Group
valueEnum={statusOptions}
name="status"
label={intl.formatMessage({
id: 'monitor.job.status',
defaultMessage: '状态',
})}
colProps={{ md: 24 }}
placeholder="请输入状态"
rules={[
{
required: false,
message: <FormattedMessage id="请输入状态！" defaultMessage="请输入状态！" />,
},
]}
/>
</ProForm>
</Modal>
);
};
export default JobForm;

460
src/pages/Monitor/Job/index.tsx Normal file
View File

@@ -0,0 +1,460 @@
import React, { useState, useRef, useEffect } from 'react';
import { useIntl, FormattedMessage, useAccess, history } from '@umijs/max';
import { Dropdown, FormInstance, Space } from 'antd';
import { Button, message, Modal } from 'antd';
import { ActionType, FooterToolbar, PageContainer, ProColumns, ProTable } from '@ant-design/pro-components';
import { PlusOutlined, DeleteOutlined, ExclamationCircleOutlined, DownOutlined, EditOutlined } from '@ant-design/icons';
import { getJobList, removeJob, addJob, updateJob, exportJob, runJob } from '@/services/monitor/job';
import { getDictSelectOption, getDictValueEnum } from '@/services/system/dict';
import UpdateForm from './edit';
import DetailForm from './detail';
import DictTag from '@/components/DictTag';
/**
* 定时任务调度 List Page
*
* @author whiteshader
* @date 2023-02-07
*/
/**
* 添加节点
*
* @param fields
*/
const handleAdd = async (fields: API.Monitor.Job) => {
const hide = message.loading('正在添加');
try {
const resp = await addJob({ ...fields });
hide();
if (resp.code === 200) {
message.success('添加成功');
} else {
message.error(resp.msg);
}
return true;
} catch (error) {
hide();
message.error('添加失败请重试！');
return false;
}
};
/**
* 更新节点
*
* @param fields
*/
const handleUpdate = async (fields: API.Monitor.Job) => {
const hide = message.loading('正在更新');
try {
const resp = await updateJob(fields);
hide();
if (resp.code === 200) {
message.success('更新成功');
} else {
message.error(resp.msg);
}
return true;
} catch (error) {
hide();
message.error('配置失败请重试！');
return false;
}
};
/**
* 删除节点
*
* @param selectedRows
*/
const handleRemove = async (selectedRows: API.Monitor.Job[]) => {
const hide = message.loading('正在删除');
if (!selectedRows) return true;
try {
const resp = await removeJob(selectedRows.map((row) => row.jobId).join(','));
hide();
if (resp.code === 200) {
message.success('删除成功，即将刷新');
} else {
message.error(resp.msg);
}
return true;
} catch (error) {
hide();
message.error('删除失败，请重试');
return false;
}
};
const handleRemoveOne = async (selectedRow: API.Monitor.Job) => {
const hide = message.loading('正在删除');
if (!selectedRow) return true;
try {
const params = [selectedRow.jobId];
const resp = await removeJob(params.join(','));
hide();
if (resp.code === 200) {
message.success('删除成功，即将刷新');
} else {
message.error(resp.msg);
}
return true;
} catch (error) {
hide();
message.error('删除失败，请重试');
return false;
}
};
/**
* 导出数据
*
*/
const handleExport = async () => {
const hide = message.loading('正在导出');
try {
await exportJob();
hide();
message.success('导出成功');
return true;
} catch (error) {
hide();
message.error('导出失败，请重试');
return false;
}
};
const JobTableList: React.FC = () => {
const formTableRef = useRef<FormInstance>();
const [modalVisible, setModalVisible] = useState<boolean>(false);
const [detailModalVisible, setDetailModalVisible] = useState<boolean>(false);
const actionRef = useRef<ActionType>();
const [currentRow, setCurrentRow] = useState<API.Monitor.Job>();
const [selectedRows, setSelectedRows] = useState<API.Monitor.Job[]>([]);
const [jobGroupOptions, setJobGroupOptions] = useState<any>([]);
const [statusOptions, setStatusOptions] = useState<any>([]);
const access = useAccess();
/** 国际化配置 */
const intl = useIntl();
useEffect(() => {
getDictSelectOption('sys_job_group').then((data) => {
setJobGroupOptions(data);
});
getDictValueEnum('sys_normal_disable').then((data) => {
setStatusOptions(data);
});
}, []);
const columns: ProColumns<API.Monitor.Job>[] = [
{
title: <FormattedMessage id="monitor.job.job_id" defaultMessage="任务编号" />,
dataIndex: 'jobId',
valueType: 'text',
hideInSearch: true,
},
{
title: <FormattedMessage id="monitor.job.job_name" defaultMessage="任务名称" />,
dataIndex: 'jobName',
valueType: 'text',
render: (dom, record) => {
return (
<a
onClick={() => {
setDetailModalVisible(true);
setCurrentRow(record);
}}
>
{dom}
</a>
);
},
},
{
title: <FormattedMessage id="monitor.job.job_group" defaultMessage="任务组名" />,
dataIndex: 'jobGroup',
valueType: 'text',
valueEnum: jobGroupOptions,
render: (_, record) => {
return (<DictTag options={jobGroupOptions} value={record.jobGroup} />);
},
},
{
title: <FormattedMessage id="monitor.job.invoke_target" defaultMessage="调用目标字符串" />,
dataIndex: 'invokeTarget',
valueType: 'textarea',
},
{
title: <FormattedMessage id="monitor.job.cron_expression" defaultMessage="cron执行表达式" />,
dataIndex: 'cronExpression',
valueType: 'text',
},
{
title: <FormattedMessage id="monitor.job.status" defaultMessage="状态" />,
dataIndex: 'status',
valueType: 'select',
valueEnum: statusOptions,
render: (_, record) => {
return (<DictTag enums={statusOptions} value={record.status} />);
},
},
{
title: <FormattedMessage id="pages.searchTable.titleOption" defaultMessage="操作" />,
dataIndex: 'option',
width: '220px',
valueType: 'option',
render: (_, record) => [
<Button
type="link"
size="small"
key="edit"
icon = <EditOutlined />
hidden={!access.hasPerms('monitor:job:edit')}
onClick={() => {
setModalVisible(true);
setCurrentRow(record);
}}
>
编辑
</Button>,
<Button
type="link"
size="small"
danger
key="batchRemove"
icon = <DeleteOutlined />
hidden={!access.hasPerms('monitor:job:remove')}
onClick={async () => {
Modal.confirm({
title: '删除',
content: '确定删除该项吗？',
okText: '确认',
cancelText: '取消',
onOk: async () => {
const success = await handleRemoveOne(record);
if (success) {
if (actionRef.current) {
actionRef.current.reload();
}
}
},
});
}}
>
删除
</Button>,
<Dropdown
key="more"
menu={{
items: [
{
label: '执行一次',
key: 'runOnce',
},
{
label: '详细',
key: 'detail',
},
{
label: '历史',
key: 'log',
},
],
onClick: ({ key }) => {
if (key === 'runOnce') {
Modal.confirm({
title: '警告',
content: '确认要立即执行一次？',
okText: '确认',
cancelText: '取消',
onOk: async () => {
const success = await runJob(record.jobId, record.jobGroup);
if (success) {
message.success('执行成功');
}
},
});
}
else if (key === 'detail') {
setDetailModalVisible(true);
setCurrentRow(record);
}
else if( key === 'log') {
history.push(`/monitor/job-log/index/${record.jobId}`);
}
}
}}
>
<a className="ant-dropdown-link" onClick={(e) => e.preventDefault()}>
<Space>
<DownOutlined />
更多
</Space>
</a>
</Dropdown>,
],
},
];
return (
<PageContainer>
<div style={{ width: '100%', float: 'right' }}>
<ProTable<API.Monitor.Job>
headerTitle={intl.formatMessage({
id: 'pages.searchTable.title',
defaultMessage: '信息',
})}
actionRef={actionRef}
formRef={formTableRef}
rowKey="jobId"
key="jobList"
search={{
labelWidth: 120,
}}
toolBarRender={() => [
<Button
type="primary"
key="add"
hidden={!access.hasPerms('monitor:job:add')}
onClick={async () => {
setCurrentRow(undefined);
setModalVisible(true);
}}
>
<PlusOutlined /> <FormattedMessage id="pages.searchTable.new" defaultMessage="新建" />
</Button>,
<Button
type="primary"
key="remove"
danger
hidden={selectedRows?.length === 0 || !access.hasPerms('monitor:job:remove')}
onClick={async () => {
Modal.confirm({
title: '是否确认删除所选数据项?',
icon: <ExclamationCircleOutlined />,
content: '请谨慎操作',
async onOk() {
const success = await handleRemove(selectedRows);
if (success) {
setSelectedRows([]);
actionRef.current?.reloadAndRest?.();
}
},
onCancel() { },
});
}}
>
<DeleteOutlined />
<FormattedMessage id="pages.searchTable.delete" defaultMessage="删除" />
</Button>,
<Button
type="primary"
key="export"
hidden={!access.hasPerms('monitor:job:export')}
onClick={async () => {
handleExport();
}}
>
<PlusOutlined />
<FormattedMessage id="pages.searchTable.export" defaultMessage="导出" />
</Button>,
]}
request={(params) =>
getJobList({ ...params } as API.Monitor.JobListParams).then((res) => {
const result = {
data: res.rows,
total: res.total,
success: true,
};
return result;
})
}
columns={columns}
rowSelection={{
onChange: (_, selectedRows) => {
setSelectedRows(selectedRows);
},
}}
/>
</div>
{selectedRows?.length > 0 && (
<FooterToolbar
extra={
<div>
<FormattedMessage id="pages.searchTable.chosen" defaultMessage="已选择" />
<a style={{ fontWeight: 600 }}>{selectedRows.length}</a>
<FormattedMessage id="pages.searchTable.item" defaultMessage="项" />
</div>
}
>
<Button
key="remove"
danger
hidden={!access.hasPerms('monitor:job:del')}
onClick={async () => {
Modal.confirm({
title: '删除',
content: '确定删除该项吗？',
okText: '确认',
cancelText: '取消',
onOk: async () => {
const success = await handleRemove(selectedRows);
if (success) {
setSelectedRows([]);
actionRef.current?.reloadAndRest?.();
}
},
});
}}
>
<FormattedMessage id="pages.searchTable.batchDeletion" defaultMessage="批量删除" />
</Button>
</FooterToolbar>
)}
<UpdateForm
onSubmit={async (values) => {
let success = false;
if (values.jobId) {
success = await handleUpdate({ ...values } as API.Monitor.Job);
} else {
success = await handleAdd({ ...values } as API.Monitor.Job);
}
if (success) {
setModalVisible(false);
setCurrentRow(undefined);
if (actionRef.current) {
actionRef.current.reload();
}
}
}}
onCancel={() => {
setModalVisible(false);
setCurrentRow(undefined);
}}
open={modalVisible}
values={currentRow || {}}
jobGroupOptions={jobGroupOptions||{}}
statusOptions={statusOptions}
/>
<DetailForm
onCancel={() => {
setDetailModalVisible(false);
setCurrentRow(undefined);
}}
open={detailModalVisible}
values={currentRow || {}}
statusOptions={statusOptions}
/>
</PageContainer>
);
};
export default JobTableList;