| | |
| | | </template>
|
| | |
|
| | | <script setup name="Job">
|
| | | import { listJob, getJob, delJob, addJob, updateJob, runJob, changeJobStatus } from "@/api/monitor/job";
|
| | | import { listJob, getJob, delJob, addJob, updateJob, runJob, changeJobStatus } from "@/api/monitor/job"
|
| | | import Crontab from '@/components/Crontab'
|
| | | const router = useRouter();
|
| | | const { proxy } = getCurrentInstance();
|
| | | const { sys_job_group, sys_job_status } = proxy.useDict("sys_job_group", "sys_job_status");
|
| | | const router = useRouter()
|
| | | const { proxy } = getCurrentInstance()
|
| | | const { sys_job_group, sys_job_status } = proxy.useDict("sys_job_group", "sys_job_status")
|
| | |
|
| | | const jobList = ref([]);
|
| | | const open = ref(false);
|
| | | const loading = ref(true);
|
| | | const showSearch = ref(true);
|
| | | const ids = ref([]);
|
| | | const single = ref(true);
|
| | | const multiple = ref(true);
|
| | | const total = ref(0);
|
| | | const title = ref("");
|
| | | const openView = ref(false);
|
| | | const openCron = ref(false);
|
| | | const expression = ref("");
|
| | | const jobList = ref([])
|
| | | const open = ref(false)
|
| | | const loading = ref(true)
|
| | | const showSearch = ref(true)
|
| | | const ids = ref([])
|
| | | const single = ref(true)
|
| | | const multiple = ref(true)
|
| | | const total = ref(0)
|
| | | const title = ref("")
|
| | | const openView = ref(false)
|
| | | const openCron = ref(false)
|
| | | const expression = ref("")
|
| | |
|
| | | const data = reactive({
|
| | | form: {},
|
| | |
| | | invokeTarget: [{ required: true, message: "调用目标字符串不能为空", trigger: "blur" }],
|
| | | cronExpression: [{ required: true, message: "cron执行表达式不能为空", trigger: "change" }]
|
| | | }
|
| | | });
|
| | | })
|
| | |
|
| | | const { queryParams, form, rules } = toRefs(data);
|
| | | const { queryParams, form, rules } = toRefs(data)
|
| | |
|
| | | /** 查询定时任务列表 */
|
| | | function getList() {
|
| | | loading.value = true;
|
| | | loading.value = true
|
| | | listJob(queryParams.value).then(response => {
|
| | | jobList.value = response.rows;
|
| | | total.value = response.total;
|
| | | loading.value = false;
|
| | | });
|
| | | jobList.value = response.rows
|
| | | total.value = response.total
|
| | | loading.value = false
|
| | | })
|
| | | }
|
| | |
|
| | | /** 任务组名字典翻译 */
|
| | | function jobGroupFormat(row, column) {
|
| | | return proxy.selectDictLabel(sys_job_group.value, row.jobGroup);
|
| | | return proxy.selectDictLabel(sys_job_group.value, row.jobGroup)
|
| | | }
|
| | |
|
| | | /** 取消按钮 */
|
| | | function cancel() {
|
| | | open.value = false;
|
| | | reset();
|
| | | open.value = false
|
| | | reset()
|
| | | }
|
| | |
|
| | | /** 表单重置 */
|
| | |
| | | misfirePolicy: 1,
|
| | | concurrent: 1,
|
| | | status: "0"
|
| | | };
|
| | | proxy.resetForm("jobRef");
|
| | | }
|
| | | proxy.resetForm("jobRef")
|
| | | }
|
| | |
|
| | | /** 搜索按钮操作 */
|
| | | function handleQuery() {
|
| | | queryParams.value.pageNum = 1;
|
| | | getList();
|
| | | queryParams.value.pageNum = 1
|
| | | getList()
|
| | | }
|
| | |
|
| | | /** 重置按钮操作 */
|
| | | function resetQuery() {
|
| | | proxy.resetForm("queryRef");
|
| | | handleQuery();
|
| | | proxy.resetForm("queryRef")
|
| | | handleQuery()
|
| | | }
|
| | |
|
| | | // 多选框选中数据
|
| | | function handleSelectionChange(selection) {
|
| | | ids.value = selection.map(item => item.jobId);
|
| | | single.value = selection.length != 1;
|
| | | multiple.value = !selection.length;
|
| | | ids.value = selection.map(item => item.jobId)
|
| | | single.value = selection.length != 1
|
| | | multiple.value = !selection.length
|
| | | }
|
| | |
|
| | | // 更多操作触发
|
| | | function handleCommand(command, row) {
|
| | | switch (command) {
|
| | | case "handleRun":
|
| | | handleRun(row);
|
| | | break;
|
| | | handleRun(row)
|
| | | break
|
| | | case "handleView":
|
| | | handleView(row);
|
| | | break;
|
| | | handleView(row)
|
| | | break
|
| | | case "handleJobLog":
|
| | | handleJobLog(row);
|
| | | break;
|
| | | handleJobLog(row)
|
| | | break
|
| | | default:
|
| | | break;
|
| | | break
|
| | | }
|
| | | }
|
| | |
|
| | | // 任务状态修改
|
| | | function handleStatusChange(row) {
|
| | | let text = row.status === "0" ? "启用" : "停用";
|
| | | let text = row.status === "0" ? "启用" : "停用"
|
| | | proxy.$modal.confirm('确认要"' + text + '""' + row.jobName + '"任务吗?').then(function () {
|
| | | return changeJobStatus(row.jobId, row.status);
|
| | | return changeJobStatus(row.jobId, row.status)
|
| | | }).then(() => {
|
| | | proxy.$modal.msgSuccess(text + "成功");
|
| | | proxy.$modal.msgSuccess(text + "成功")
|
| | | }).catch(function () {
|
| | | row.status = row.status === "0" ? "1" : "0";
|
| | | });
|
| | | row.status = row.status === "0" ? "1" : "0"
|
| | | })
|
| | | }
|
| | |
|
| | | /* 立即执行一次 */
|
| | | function handleRun(row) {
|
| | | proxy.$modal.confirm('确认要立即执行一次"' + row.jobName + '"任务吗?').then(function () {
|
| | | return runJob(row.jobId, row.jobGroup);
|
| | | return runJob(row.jobId, row.jobGroup)
|
| | | }).then(() => {
|
| | | proxy.$modal.msgSuccess("执行成功");})
|
| | | .catch(() => {});
|
| | | proxy.$modal.msgSuccess("执行成功")})
|
| | | .catch(() => {})
|
| | | }
|
| | |
|
| | | /** 任务详细信息 */
|
| | | function handleView(row) {
|
| | | getJob(row.jobId).then(response => {
|
| | | form.value = response.data;
|
| | | openView.value = true;
|
| | | });
|
| | | form.value = response.data
|
| | | openView.value = true
|
| | | })
|
| | | }
|
| | |
|
| | | /** cron表达式按钮操作 */
|
| | | function handleShowCron() {
|
| | | expression.value = form.value.cronExpression;
|
| | | openCron.value = true;
|
| | | expression.value = form.value.cronExpression
|
| | | openCron.value = true
|
| | | }
|
| | |
|
| | | /** 确定后回传值 */
|
| | | function crontabFill(value) {
|
| | | form.value.cronExpression = value;
|
| | | form.value.cronExpression = value
|
| | | }
|
| | |
|
| | | /** 任务日志列表查询 */
|
| | | function handleJobLog(row) {
|
| | | const jobId = row.jobId || 0;
|
| | | const jobId = row.jobId || 0
|
| | | router.push('/monitor/job-log/index/' + jobId)
|
| | | }
|
| | |
|
| | | /** 新增按钮操作 */
|
| | | function handleAdd() {
|
| | | reset();
|
| | | open.value = true;
|
| | | title.value = "添加任务";
|
| | | reset()
|
| | | open.value = true
|
| | | title.value = "添加任务"
|
| | | }
|
| | |
|
| | | /** 修改按钮操作 */
|
| | | function handleUpdate(row) {
|
| | | reset();
|
| | | const jobId = row.jobId || ids.value;
|
| | | reset()
|
| | | const jobId = row.jobId || ids.value
|
| | | getJob(jobId).then(response => {
|
| | | form.value = response.data;
|
| | | open.value = true;
|
| | | title.value = "修改任务";
|
| | | });
|
| | | form.value = response.data
|
| | | open.value = true
|
| | | title.value = "修改任务"
|
| | | })
|
| | | }
|
| | |
|
| | | /** 提交按钮 */
|
| | |
| | | if (valid) {
|
| | | if (form.value.jobId != undefined) {
|
| | | updateJob(form.value).then(response => {
|
| | | proxy.$modal.msgSuccess("修改成功");
|
| | | open.value = false;
|
| | | getList();
|
| | | });
|
| | | proxy.$modal.msgSuccess("修改成功")
|
| | | open.value = false
|
| | | getList()
|
| | | })
|
| | | } else {
|
| | | addJob(form.value).then(response => {
|
| | | proxy.$modal.msgSuccess("新增成功");
|
| | | open.value = false;
|
| | | getList();
|
| | | });
|
| | | proxy.$modal.msgSuccess("新增成功")
|
| | | open.value = false
|
| | | getList()
|
| | | })
|
| | | }
|
| | | }
|
| | | });
|
| | | })
|
| | | }
|
| | |
|
| | | /** 删除按钮操作 */
|
| | | function handleDelete(row) {
|
| | | const jobIds = row.jobId || ids.value;
|
| | | const jobIds = row.jobId || ids.value
|
| | | proxy.$modal.confirm('是否确认删除定时任务编号为"' + jobIds + '"的数据项?').then(function () {
|
| | | return delJob(jobIds);
|
| | | return delJob(jobIds)
|
| | | }).then(() => {
|
| | | getList();
|
| | | proxy.$modal.msgSuccess("删除成功");
|
| | | }).catch(() => {});
|
| | | getList()
|
| | | proxy.$modal.msgSuccess("删除成功")
|
| | | }).catch(() => {})
|
| | | }
|
| | |
|
| | | /** 导出按钮操作 */
|
| | | function handleExport() {
|
| | | proxy.download("monitor/job/export", {
|
| | | ...queryParams.value,
|
| | | }, `job_${new Date().getTime()}.xlsx`);
|
| | | }, `job_${new Date().getTime()}.xlsx`)
|
| | | }
|
| | |
|
| | | getList();
|
| | | getList()
|
| | | </script>
|