"use client"; import {fetchApi, fetchFile} from "@/app/_modules/func"; import { CaretDownOutlined, CheckOutlined, ClockCircleOutlined, CloseOutlined, DeleteOutlined, ExclamationCircleFilled, EyeOutlined, PlayCircleOutlined, PlusOutlined, ReloadOutlined, ScheduleOutlined, } from "@ant-design/icons"; import type {ActionType, ProColumns, ProFormInstance,} from "@ant-design/pro-components"; import { ModalForm, PageContainer, ProDescriptions, ProForm, ProFormRadio, ProFormSelect, ProFormText, ProTable, } from "@ant-design/pro-components"; import {Button, Dropdown, Input, Modal, Space, Switch,} from "antd"; import {useRouter} from "next/navigation"; import {faDownload, faPenToSquare, faToggleOff, faToggleOn,} from "@fortawesome/free-solid-svg-icons"; import {FontAwesomeIcon} from "@fortawesome/react-fontawesome"; import "./styles.scss"; import {ReQuartzCron} from "@sbzen/re-cron"; import {useRef, useState} from "react"; import {MortnonCronLocalization} from "@/app/_modules/definies"; import globalMessage from "@/app/_modules/globalMessage"; //查询表格数据API const queryAPI = "/api/monitor/job/list"; //新建数据API const newAPI = "/api/monitor/job"; //修改数据API const modifyAPI = "/api/monitor/job"; //查询详情数据API const queryDetailAPI = "/api/monitor/job"; //删除API const deleteAPI = "/api/monitor/job"; //导出API const exportAPI = "/api/monitor/job/export"; //导出文件前缀名 const exportFilePrefix = "job"; //变更任务状态API const changeJobStatusAPI = "/api/monitor/job/changeStatus"; //执行任务API const runAPI = "/api/monitor/job/run"; export default function Job() { const { push } = useRouter(); // 添加用于控制删除确认模态框的状态 const [deleteModalVisible, setDeleteModalVisible] = useState(false); const [deleteJobId, setDeleteJobId] = useState(null); // 添加用于控制切换状态确认模态框的状态 const [statusModalVisible, setStatusModalVisible] = useState(false); const [statusChecked, setStatusChecked] = useState(true); const [statusRecord, setStatusRecord] = useState(null); // 添加用于控制执行任务确认模态框的状态 const [runModalVisible, setRunModalVisible] = useState(false); const [runRecord, setRunRecord] = useState(null); //表格列定义 const columns: ProColumns[] = [ { title: "任务编号", dataIndex: "jobId", search: false, }, { title: "任务名称", fieldProps: { placeholder: "请输入任务名称", }, dataIndex: "jobName", ellipsis: true, order: 3, }, { title: "任务组名", dataIndex: "jobGroup", valueType: "select", valueEnum: { DEFAULT: { text: "默认", status: "DEFAULT", }, SYSTEM: { text: "系统", status: "SYSTEM", }, }, sorter: true, order: 2, }, { title: "调用目标字符串", dataIndex: "invokeTarget", search: false, }, { title: "Cron执行表达式", dataIndex: "cronExpression", search: false, }, { title: "状态", fieldProps: { placeholder: "请选择任务状态", }, dataIndex: "status", valueType: "select", order: 2, valueEnum: { 0: { text: "正常", status: "0", }, 1: { text: "停用", status: "1", }, }, render: (text, record) => { return ( } unCheckedChildren={} defaultChecked={record.status === "0"} checked={rowStatusMap[record.jobId]} onChange={(checked, event) => { showSwitchJobStatusModal(checked, record); }} /> ); }, }, { title: "操作", key: "option", search: false, render: (_, record) => [ , , { showRunOnceModal(record); }} > 执行一次 ), icon: , }, { key: "2", label: showRowModal(record)}>任务详情, icon: , }, { key: "3", label: ( push(`/monitor/job-log/index/${record.jobId}`) } > 调度日志 ), icon: , }, ], }} > e.preventDefault()}> 更多 , ], }, ]; //0.查询表格数据 const queryTableData = async (params: any, sorter: any, filter: any) => { const searchParams = { pageNum: params.current, ...params, }; delete searchParams.current; const queryParams = new URLSearchParams(searchParams); Object.keys(sorter).forEach((key) => { queryParams.append("orderByColumn", key); if (sorter[key] === "ascend") { queryParams.append("isAsc", "ascending"); } else { queryParams.append("isAsc", "descending"); } }); const body = await fetchApi(`${queryAPI}?${queryParams}`, push); if (body !== undefined) { body.rows.forEach((row: any) => { setRowStatusMap({ ...rowStatusMap, [row.userId]: row.status === "0" }); }); } return body; }; //1.新建 //新建对话框表单引用 const addFormRef = useRef(null); //确定新建数据 const executeAddData = async (values: any) => { const body = await fetchApi(newAPI, push, { method: "POST", headers: { "Content-Type": "application/json", }, body: JSON.stringify(values), }); if (body != undefined) { if (body.code == 200) { globalMessage.success(body.msg); if (actionTableRef.current) { actionTableRef.current.reload(); } return true; } globalMessage.error(body.msg); return false; } return false; }; //2.修改 //控制行的状态值的恢复 const [rowStatusMap, setRowStatusMap] = useState<{ [key: number]: boolean }>( {} ); //展示切换任务状态对话框 const showSwitchJobStatusModal = (checked: boolean, record: any) => { setRowStatusMap({ ...rowStatusMap, [record.jobId]: checked }); setStatusChecked(checked); setStatusRecord(record); setStatusModalVisible(true); }; //确认变更任务状态 const executeSwitchStatus = async ( checked: boolean, jobId: string, erroCallback: () => void ) => { const modifyData = { jobId: jobId, status: checked ? "0" : "1", }; const body = await fetchApi(changeJobStatusAPI, push, { method: "PUT", headers: { "Content-Type": "application/json", }, body: JSON.stringify(modifyData), }); if (body !== undefined) { if (body.code == 200) { globalMessage.success(body.msg); } else { globalMessage.error(body.msg); erroCallback(); } } }; //确定切换状态 const confirmSwitchStatus = () => { if (!statusRecord) return; executeSwitchStatus(statusChecked, statusRecord.jobId, () => { setRowStatusMap({ ...rowStatusMap, [statusRecord.jobId]: !statusChecked }); }); setStatusModalVisible(false); setStatusRecord(null); }; //取消切换状态 const cancelSwitchStatus = () => { if (!statusRecord) return; setRowStatusMap({ ...rowStatusMap, [statusRecord.jobId]: !statusChecked }); setStatusModalVisible(false); setStatusRecord(null); }; //是否展示修改对话框 const [isShowModifyDataModal, setIsShowModifyDataModal] = useState(false); //展示修改对话框 const onClickShowRowModifyModal = (record?: any) => { queryRowData(record); setIsShowModifyDataModal(true); }; //修改数据表单引用 const modifyFormRef = useRef(null); //操作当前数据的附加数据 const [operatRowData, setOperateRowData] = useState<{ [key: string]: any; }>({}); //查询并加载待修改数据的详细信息 const queryRowData = async (record?: any) => { const jobId = record !== undefined ? record.jobId : selectedRow.jobId; operatRowData["jobId"] = jobId; setOperateRowData(operatRowData); if (jobId !== undefined) { const body = await fetchApi(`${queryDetailAPI}/${jobId}`, push); if (body !== undefined) { if (body.code == 200) { modifyFormRef?.current?.setFieldsValue({ //需要加载到修改表单中的数据 jobName: body.data.jobName, jobGroup: body.data.jobGroup, invokeTarget: body.data.invokeTarget, cronExpression: body.data.cronExpression, status: body.data.status, misfirePolicy: body.data.misfirePolicy, concurrent: body.data.concurrent, }); setCronValue(body.data.cronExpression); } } } }; //确认修改数据 const executeModifyData = async (values: any) => { values["jobId"] = operatRowData["jobId"]; const body = await fetchApi(modifyAPI, push, { method: "PUT", headers: { "Content-Type": "application/json", }, body: JSON.stringify(values), }); if (body !== undefined) { if (body.code == 200) { globalMessage.success(body.msg); //刷新列表 if (actionTableRef.current) { actionTableRef.current.reload(); } setIsShowModifyDataModal(false); return true; } globalMessage.error(body.msg); return false; } }; //3.删除 //点击删除按钮,展示删除确认框 const onClickDeleteRow = (record?: any) => { const jobId = record !== undefined ? record.jobId : selectedRowKeys.join(","); setDeleteJobId(jobId); setDeleteModalVisible(true); }; //确定删除选中的数据 const executeDeleteRow = async () => { if (deleteJobId === null) return; const body = await fetchApi(`${deleteAPI}/${deleteJobId}`, push, { method: "DELETE", }); if (body !== undefined) { if (body.code == 200) { globalMessage.success("删除成功"); //修改按钮变回不可点击 setRowCanModify(false); //删除按钮变回不可点击 setRowCanDelete(false); //选中行数据重置为空 setSelectedRowKeys([]); //刷新列表 if (actionTableRef.current) { actionTableRef.current.reload(); } } else { globalMessage.error(body.msg); } } setDeleteModalVisible(false); setDeleteJobId(null); }; //4.导出 //导出表格数据 const exportTable = async () => { if (searchTableFormRef.current) { const formData = new FormData(); const data = { pageNum: page, pageSize: pageSize, ...searchTableFormRef.current.getFieldsValue(), }; Object.keys(data).forEach((key) => { if (data[key] !== undefined) { formData.append(key, data[key]); } }); await fetchFile( exportAPI, push, { method: "POST", body: formData, }, `${exportFilePrefix}_${new Date().getTime()}.xlsx` ); } }; //5.选择行 //选中行操作 const [selectedRowKeys, setSelectedRowKeys] = useState([]); const [selectedRow, setSelectedRow] = useState(undefined as any); //修改按钮是否可用,选中行时才可用 const [rowCanModify, setRowCanModify] = useState(false); //删除按钮是否可用,选中行时才可用 const [rowCanDelete, setRowCanDelete] = useState(false); //ProTable rowSelection const rowSelection = { onChange: (newSelectedRowKeys: React.Key[], selectedRows: any[]) => { setSelectedRowKeys(newSelectedRowKeys); setRowCanDelete(newSelectedRowKeys && newSelectedRowKeys.length > 0); if (newSelectedRowKeys && newSelectedRowKeys.length == 1) { setSelectedRow(selectedRows[0]); setRowCanModify(true); } else { setRowCanModify(false); setSelectedRow(undefined); } }, //复选框的额外禁用判断 // getCheckboxProps: (record) => ({ // disabled: record.userId == 1, // }), }; //搜索栏显示状态 const [showSearch, setShowSearch] = useState(true); //action对象引用 const actionTableRef = useRef(null); //搜索表单对象引用 const searchTableFormRef = useRef(null!); //当前页数和每页条数 const [page, setPage] = useState(1); const defaultPageSize = 10; const [pageSize, setPageSize] = useState(defaultPageSize); const pageChange = (page: number, pageSize: number) => { setPage(page); setPageSize(pageSize); }; //是否展示Cron表达式生成框 const [isCronShow, setIsCronShow] = useState(false); //Cron表达式值 const [cronValue, setCronValue] = useState(""); //当前是新建还是修改触发的Cron生成框 const [isNew, setIsNew] = useState(true); //用于重置Cron生成框的key值 const [modalKey, setModalKey] = useState(0); //展示Cron对话框,区分新建用还是修改用 const showCronModal = (isNew: boolean) => { setIsNew(isNew); setIsCronShow(true); }; //回写Cron数据 const getCronData = () => { setIsCronShow(false); if (isNew) { addFormRef?.current?.setFieldsValue({ cronExpression: cronValue, }); } else { modifyFormRef?.current?.setFieldsValue({ cronExpression: cronValue, }); } //重置Cron数据 setCronValue(""); setModalKey((preKey) => preKey + 1); }; //执行任务一次 const showRunOnceModal = (record: any) => { setRunRecord(record); setRunModalVisible(true); }; //执行任务 const executeJob = async (record: any) => { const runData = { jobId: record.jobId, jobGroup: record.jobGroup, }; const body = await fetchApi(runAPI, push, { method: "PUT", headers: { "Content-Type": "application/json", }, body: JSON.stringify(runData), }); if (body !== undefined) { if (body.code == 200) { globalMessage.success("执行成功"); } else { globalMessage.error(body.msg); } } setRunModalVisible(false); setRunRecord(null); }; //取消执行任务 const cancelRunJob = () => { setRunModalVisible(false); setRunRecord(null); }; //是否展示任务详情框 const [isShowDetail, setIsShowDetail] = useState(false); //展示行详情框 const showRowModal = async (record: any) => { const jobId = record.jobId; if (jobId !== undefined) { const body = await fetchApi(`${queryDetailAPI}/${jobId}`, push); setSelectedRow(body.data); } setIsShowDetail(true); }; return ( { // 表单搜索项会从 params 传入,传递给后端接口。 const data = await queryTableData(params, sorter, filter); if (data !== undefined) { return Promise.resolve({ data: data.rows, success: true, total: data.total, }); } return Promise.resolve({ data: [], success: true, }); }} pagination={{ defaultPageSize: defaultPageSize, showQuickJumper: true, showSizeChanger: true, onChange: pageChange, }} search={ showSearch ? { defaultCollapsed: false, searchText: "搜索", } : false } dateFormatter="string" actionRef={actionTableRef} toolbar={{ actions: [ } type="primary"> 新建 } autoFocusFirstInput modalProps={{ destroyOnHidden: true, }} submitTimeout={2000} onFinish={executeAddData} > , } disabled={!rowCanModify} onClick={() => onClickShowRowModifyModal()} > 修改 } open={isShowModifyDataModal} autoFocusFirstInput modalProps={{ destroyOnHidden: true, onCancel: () => { setIsShowModifyDataModal(false); }, }} submitTimeout={2000} onFinish={executeModifyData} > , , , ], settings: [ { key: "switch", icon: showSearch ? ( ) : ( ), tooltip: showSearch ? "隐藏搜索栏" : "显示搜索栏", onClick: (key: string | undefined) => { setShowSearch(!showSearch); }, }, { key: "refresh", tooltip: "刷新", icon: , onClick: (key: string | undefined) => { if (actionTableRef.current) { actionTableRef.current.reload(); } }, }, ], }} /> setIsCronShow(false)} // confirmLoading={confirmLoading} > } value={cronValue} />
{selectedRow !== undefined && ( setIsShowDetail(false)}>关闭} open={isShowDetail} onCancel={() => setIsShowDetail(false)} > {selectedRow.jobId} {selectedRow.jobGroup} {selectedRow.jobName} {selectedRow.createTime} {selectedRow.cronExpression} {selectedRow.nextValidTime} {selectedRow.invokeTarget} {selectedRow.status} {selectedRow.concurrent} {selectedRow.misfirePolicy} )} {/* 删除确认模态框 */} 系统提示 } open={deleteModalVisible} onOk={executeDeleteRow} onCancel={() => { setDeleteModalVisible(false); setDeleteJobId(null); }} okText="确认" cancelText="取消" >

{`确定删除任务编号为“${deleteJobId}”的数据项?`}

{/* 切换状态确认模态框 */} 系统提示 } open={statusModalVisible} onOk={confirmSwitchStatus} onCancel={cancelSwitchStatus} okText="确认" cancelText="取消" >

{`确认要${statusChecked ? "启用" : "停用"}"${statusRecord?.jobName}"任务吗?`}

{/* 执行任务确认模态框 */} 系统提示 } open={runModalVisible} onOk={() => executeJob(runRecord)} onCancel={cancelRunJob} okText="确认" cancelText="取消" >

{`确定要立即执行一次任务“${runRecord?.jobName}”吗?`}

); }