<template>
|
<div class="sys-job-container">
|
<el-card shadow="hover" :body-style="{ paddingBottom: '0' }">
|
<el-form :model="state.queryParams" ref="queryForm" :inline="true">
|
<el-form-item label="作业编号">
|
<el-input v-model="state.queryParams.jobId" placeholder="作业编号" clearable />
|
</el-form-item>
|
<el-form-item label="组名称">
|
<el-select v-model="state.queryParams.groupName" placeholder="组名称" clearable>
|
<el-option v-for="item in state.groupsData" :key="item" :label="item" :value="item" />
|
</el-select>
|
</el-form-item>
|
<el-form-item label="描述信息">
|
<el-input v-model="state.queryParams.description" placeholder="描述信息" clearable />
|
</el-form-item>
|
<el-form-item>
|
<el-button-group>
|
<el-button type="primary" icon="ele-Search" @click="handleQuery" v-auth="'sysJob:pageJobDetail'"> 查询 </el-button>
|
<el-button icon="ele-Refresh" @click="resetQuery"> 重置 </el-button>
|
</el-button-group>
|
</el-form-item>
|
<el-form-item>
|
<el-button-group style="margin: 0px 12px">
|
<el-tooltip content="增加作业">
|
<el-button icon="ele-CirclePlus" @click="openAddJobDetail" v-auth="'sysJob:addJobDetail'"> </el-button>
|
</el-tooltip>
|
<el-tooltip content="启动所有作业">
|
<el-button icon="ele-VideoPlay" @click="startAllJob" />
|
</el-tooltip>
|
<el-tooltip content="暂停所有作业">
|
<el-button icon="ele-VideoPause" @click="pauseAllJob" />
|
</el-tooltip>
|
</el-button-group>
|
<el-button-group style="margin: 0px 12px 0px 0px">
|
<el-tooltip content="强制唤醒作业调度器">
|
<el-button icon="ele-AlarmClock" @click="cancelSleep" />
|
</el-tooltip>
|
<el-tooltip content="强制触发所有作业持久化">
|
<el-button icon="ele-Connection" @click="persistAll" />
|
</el-tooltip>
|
</el-button-group>
|
<el-button icon="ele-Coin" @click="openJobCluster" plain> 集群控制 </el-button>
|
<el-button icon="ele-Grid" @click="openJobDashboard" plain> 任务看板 </el-button>
|
</el-form-item>
|
</el-form>
|
</el-card>
|
|
<el-card class="full-table" shadow="hover" style="margin-top: 5px">
|
<el-table :data="state.jobData" style="width: 100%" v-loading="state.loading" border>
|
<el-table-column type="expand" fixed>
|
<template #default="scope">
|
<el-table style="margin-left: 48px; width: calc(100% - 48px)" :data="(scope.row as JobDetailOutput).jobTriggers" border size="small">
|
<el-table-column type="index" label="序号" width="55" align="center" fixed />
|
<el-table-column prop="triggerId" label="触发器编号" width="180" header-align="center" fixed show-overflow-tooltip />
|
<el-table-column prop="triggerType" label="类型" width="200" header-align="center" show-overflow-tooltip />
|
<!-- <el-table-column prop="assemblyName" label="程序集" show-overflow-tooltip /> -->
|
<el-table-column prop="args" label="参数" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="description" label="描述" width="120" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="status" label="状态" width="120" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tag type="warning" effect="plain" v-if="(scope.row as SysJobTrigger).status == 0"> 积压 </el-tag>
|
<el-tag effect="plain" v-if="(scope.row as SysJobTrigger).status == 1"> 就绪 </el-tag>
|
<el-tag type="success" effect="plain" v-if="(scope.row as SysJobTrigger).status == 2"> 正在运行 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 3"> 暂停 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 4"> 阻塞 </el-tag>
|
<el-tag effect="plain" v-if="(scope.row as SysJobTrigger).status == 5"> 由失败进入就绪 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 6"> 归档 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 7"> 崩溃 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 8"> 超限 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 9"> 无触发时间 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 10"> 未启动 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 11"> 未知作业触发器 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 12"> 未知作业处理程序 </el-tag>
|
</template>
|
</el-table-column>
|
<el-table-column prop="startTime" label="起始时间" width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="endTime" label="结束时间" width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="lastRunTime" label="最近运行时间" width="130" align="center" show-overflow-tooltip />
|
<el-table-column prop="nextRunTime" label="下一次运行时间" width="130" align="center" show-overflow-tooltip />
|
<el-table-column prop="numberOfRuns" label="触发次数" width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="maxNumberOfRuns" label="最大触发次数" width="120" align="center" show-overflow-tooltip />
|
<el-table-column prop="numberOfErrors" label="出错次数" width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="maxNumberOfErrors" label="最大出错次数" width="120" align="center" show-overflow-tooltip />
|
<el-table-column prop="numRetries" label="重试次数" width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="retryTimeout" label="重试间隔ms" width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="startNow" label="是否立即启动" width="100" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tag v-if="(scope.row as SysJobTrigger).startNow == true"> 是 </el-tag>
|
<el-tag type="info" v-else> 否 </el-tag>
|
</template>
|
</el-table-column>
|
<el-table-column prop="runOnStart" label="是否启动时执行一次" width="150" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tag v-if="(scope.row as SysJobTrigger).runOnStart == true"> 是 </el-tag>
|
<el-tag type="info" v-else> 否 </el-tag>
|
</template>
|
</el-table-column>
|
<el-table-column prop="resetOnlyOnce" label="是否重置触发次数" width="120" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tag v-if="(scope.row as SysJobTrigger).resetOnlyOnce == true"> 是 </el-tag>
|
<el-tag type="info" v-else> 否 </el-tag>
|
</template>
|
</el-table-column>
|
<el-table-column prop="updatedTime" label="更新时间" width="130" align="center" show-overflow-tooltip />
|
<el-table-column label="操作" width="140" align="center" show-overflow-tooltip fixed="right">
|
<template #default="scope">
|
<el-tooltip content="启动触发器">
|
<el-button size="small" type="primary" icon="ele-VideoPlay" text @click="startTrigger(scope.row)" />
|
</el-tooltip>
|
<el-tooltip content="暂停触发器">
|
<el-button size="small" type="primary" icon="ele-VideoPause" text @click="pauseTrigger(scope.row)" />
|
</el-tooltip>
|
<el-tooltip content="编辑触发器">
|
<el-button size="small" type="primary" icon="ele-Edit" text @click="openEditJobTrigger(scope.row)"> </el-button>
|
</el-tooltip>
|
<el-tooltip content="删除触发器">
|
<el-button size="small" type="danger" icon="ele-Delete" text @click="delJobTrigger(scope.row)"> </el-button>
|
</el-tooltip>
|
</template>
|
</el-table-column>
|
</el-table>
|
</template>
|
</el-table-column>
|
<el-table-column type="index" label="序号" width="55" align="center" fixed />
|
<el-table-column prop="jobDetail.jobId" label="作业编号" width="180" header-align="center" fixed>
|
<template #default="scope">
|
<div style="display: flex; align-items: center">
|
<el-icon><timer /></el-icon>
|
<span style="margin-left: 5px">{{ (scope.row as JobDetailOutput).jobDetail?.jobId }}</span>
|
</div>
|
</template>
|
</el-table-column>
|
<el-table-column prop="jobDetail.groupName" label="组名称" width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="jobDetail.jobType" label="类型" width="200" header-align="center" show-overflow-tooltip />
|
<!-- <el-table-column prop="jobDetail.assemblyName" label="程序集" show-overflow-tooltip /> -->
|
<el-table-column prop="jobDetail.description" label="描述" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="jobDetail.concurrent" label="执行方式" width="90" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tag type="success" v-if="(scope.row as JobDetailOutput).jobDetail?.concurrent == true"> 并行 </el-tag>
|
<el-tag type="warning" v-else> 串行 </el-tag>
|
</template>
|
</el-table-column>
|
<el-table-column prop="jobDetail.createType" label="作业创建类型" width="110" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<g-sys-dict v-model="scope.row.jobDetail.createType" code="JobCreateTypeEnum" />
|
</template>
|
</el-table-column>
|
<!-- <el-table-column prop="jobDetail.includeAnnotations" label="扫描特性触发器" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tag v-if="(scope.row as JobDetailOutput).jobDetail?.includeAnnotations == true"> 是 </el-tag>
|
<el-tag v-else> 否 </el-tag>
|
</template>
|
</el-table-column> -->
|
<el-table-column prop="jobDetail.updatedTime" label="更新时间" width="130" align="center" show-overflow-tooltip />
|
<el-table-column prop="jobDetail.properties" label="额外数据" header-align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<span v-if="(scope.row as JobDetailOutput).jobDetail?.createType != JobCreateTypeEnum.NUMBER_2"> {{ (scope.row as JobDetailOutput).jobDetail?.properties }} </span>
|
<div v-else style="text-align: center">
|
<el-popover placement="left" :width="400" trigger="hover">
|
<template #reference>
|
<el-tag effect="plain" type="info"> 请求参数 </el-tag>
|
</template>
|
<el-descriptions title="Http 请求参数" :column="1" size="small" :border="true">
|
<el-descriptions-item label="请求地址" label-align="right" label-class-name="job-index-descriptions-label-style">
|
{{ getHttpJobMessage((scope.row as JobDetailOutput).jobDetail?.properties).requestUri }}
|
</el-descriptions-item>
|
<el-descriptions-item label="请求方法" label-align="right" label-class-name="job-index-descriptions-label-style">
|
{{ getHttpMethodDesc(getHttpJobMessage((scope.row as JobDetailOutput).jobDetail?.properties).httpMethod) }}
|
</el-descriptions-item>
|
<el-descriptions-item label="请求报文体" label-align="right" label-class-name="job-index-descriptions-label-style">
|
{{ getHttpJobMessage((scope.row as JobDetailOutput).jobDetail?.properties).body }}
|
</el-descriptions-item>
|
</el-descriptions>
|
</el-popover>
|
</div>
|
</template>
|
</el-table-column>
|
<el-table-column label="操作" width="270" fixed="right" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tooltip content="执行记录">
|
<el-button size="small" type="primary" icon="ele-Timer" text @click="openJobTriggerRecord(scope.row)"> </el-button>
|
</el-tooltip>
|
<el-tooltip content="增加触发器">
|
<el-button size="small" type="primary" icon="ele-CirclePlus" text @click="openAddJobTrigger(scope.row)"> </el-button>
|
</el-tooltip>
|
<el-tooltip content="执行作业">
|
<el-button size="small" type="primary" icon="ele-CircleCheck" text @click="runJob(scope.row)" />
|
</el-tooltip>
|
<el-tooltip content="启动作业">
|
<el-button size="small" type="primary" icon="ele-VideoPlay" text @click="startJob(scope.row)" />
|
</el-tooltip>
|
<el-tooltip content="暂停作业">
|
<el-button size="small" type="primary" icon="ele-VideoPause" text @click="pauseJob(scope.row)" />
|
</el-tooltip>
|
<el-tooltip content="取消作业">
|
<el-button size="small" type="primary" icon="ele-CircleClose" text @click="cancelJob(scope.row)" />
|
</el-tooltip>
|
<el-tooltip content="编辑作业">
|
<el-button size="small" type="primary" icon="ele-Edit" text @click="openEditJobDetail(scope.row)" v-auth="'sysJob:updateJobDetail'"> </el-button>
|
</el-tooltip>
|
<el-tooltip content="删除作业">
|
<el-button size="small" type="danger" icon="ele-Delete" text @click="delJobDetail(scope.row)" v-auth="'sysJob:deleteJobDetail'"> </el-button>
|
</el-tooltip>
|
</template>
|
</el-table-column>
|
</el-table>
|
<el-pagination
|
v-model:currentPage="state.tableParams.page"
|
v-model:page-size="state.tableParams.pageSize"
|
:total="state.tableParams.total"
|
:page-sizes="[10, 20, 50, 100]"
|
size="small"
|
background
|
@size-change="handleSizeChange"
|
@current-change="handleCurrentChange"
|
layout="total, sizes, prev, pager, next, jumper"
|
/>
|
</el-card>
|
|
<el-drawer v-model="state.isVisibleDrawer" title="作业触发器运行记录" size="45%">
|
<el-card shadow="hover" style="margin: 8px; padding-bottom: 15px">
|
<el-table :data="state.triggerRecordData" style="width: 100%" v-loading="state.loading2" border>
|
<el-table-column type="index" label="序号" width="55" align="center" />
|
<el-table-column prop="jobId" label="作业编号" min-width="120" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="triggerId" label="触发器编号" min-width="120" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="numberOfRuns" label="当前运行次数" min-width="100" align="center" show-overflow-tooltip />
|
<el-table-column prop="lastRunTime" label="最近运行时间" min-width="130" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="nextRunTime" label="下一次运行时间" min-width="130" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="status" label="触发器状态" align="center" show-overflow-tooltip>
|
<template #default="scope">
|
<el-tag type="warning" effect="plain" v-if="(scope.row as SysJobTrigger).status == 0"> 积压 </el-tag>
|
<el-tag effect="plain" v-if="(scope.row as SysJobTrigger).status == 1"> 就绪 </el-tag>
|
<el-tag type="success" effect="plain" v-if="(scope.row as SysJobTrigger).status == 2"> 正在运行 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 3"> 暂停 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 4"> 阻塞 </el-tag>
|
<el-tag effect="plain" v-if="(scope.row as SysJobTrigger).status == 5"> 由失败进入就绪 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 6"> 归档 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 7"> 崩溃 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 8"> 超限 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 9"> 无触发时间 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 10"> 未启动 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 11"> 未知作业触发器 </el-tag>
|
<el-tag type="danger" effect="plain" v-if="(scope.row as SysJobTrigger).status == 12"> 未知作业处理程序 </el-tag>
|
</template>
|
</el-table-column>
|
<el-table-column prop="result" label="执行结果" header-align="center" show-overflow-tooltip />
|
<el-table-column prop="elapsedTime" label="耗时" min-width="80" align="center" show-overflow-tooltip />
|
<el-table-column prop="createdTime" label="创建时间" min-width="130" align="center" show-overflow-tooltip />
|
</el-table>
|
<el-pagination
|
v-model:currentPage="state.tableParams2.page"
|
v-model:page-size="state.tableParams2.pageSize"
|
:total="state.tableParams2.total"
|
:page-sizes="[10, 20, 50, 100]"
|
size="small"
|
background
|
@size-change="handleSizeChange2"
|
@current-change="handleCurrentChange2"
|
layout="total, sizes, prev, pager, next, jumper"
|
/>
|
</el-card>
|
</el-drawer>
|
|
<EditJobDetail ref="editJobDetailRef" :title="state.editJobDetailTitle" @handleQuery="handleQuery" />
|
<EditJobTrigger ref="editJobTriggerRef" :title="state.editJobTriggerTitle" @handleQuery="handleQuery" />
|
<JobCluster ref="editJobClusterRef" />
|
</div>
|
</template>
|
|
<script lang="ts" setup name="sysJob">
|
import { nextTick, onMounted, reactive, ref } from 'vue';
|
import { ElMessageBox, ElMessage } from 'element-plus';
|
import { useRouter } from 'vue-router';
|
import { Timer } from '@element-plus/icons-vue';
|
import { getAPI } from '/@/utils/axios-utils';
|
import { SysJobApi } from '/@/api-services/api';
|
import { JobCreateTypeEnum, JobDetailOutput, SysJobTrigger } from '/@/api-services/models';
|
import EditJobDetail from '/@/views/system/job/component/editJobDetail.vue';
|
import EditJobTrigger from '/@/views/system/job/component/editJobTrigger.vue';
|
import JobCluster from '/@/views/system/job/component/jobCluster.vue';
|
|
const router = useRouter();
|
const editJobDetailRef = ref<InstanceType<typeof EditJobDetail>>();
|
const editJobTriggerRef = ref<InstanceType<typeof EditJobTrigger>>();
|
const editJobClusterRef = ref<InstanceType<typeof JobCluster>>();
|
const state = reactive({
|
loading: false,
|
jobData: [] as Array<JobDetailOutput>,
|
queryParams: {
|
jobId: undefined,
|
groupName: undefined,
|
description: undefined,
|
},
|
tableParams: {
|
page: 1,
|
pageSize: 50,
|
total: 0 as any,
|
},
|
tableParams2: {
|
page: 1,
|
pageSize: 50,
|
total: 0 as any,
|
},
|
editJobDetailTitle: '',
|
editJobTriggerTitle: '',
|
loading2: false,
|
isVisibleDrawer: false,
|
triggerRecordData: [] as any,
|
currentJob: {} as any,
|
groupsData: [] as Array<string>,
|
});
|
|
onMounted(async () => {
|
await handleQuery();
|
// 获取组名称下拉集合
|
nextTick(async () => {
|
const { data } = await getAPI(SysJobApi).apiSysJobListJobGroupPost();
|
state.groupsData = data.result ?? [];
|
});
|
});
|
|
// 查询操作
|
const handleQuery = async () => {
|
state.loading = true;
|
let params = Object.assign(state.queryParams, state.tableParams);
|
var res = await getAPI(SysJobApi).apiSysJobPageJobDetailPost(params);
|
state.jobData = res.data.result?.items ?? [];
|
state.tableParams.total = res.data.result?.total;
|
state.loading = false;
|
};
|
|
// 重置操作
|
const resetQuery = async () => {
|
state.queryParams.jobId = undefined;
|
state.queryParams.groupName = undefined;
|
state.queryParams.description = undefined;
|
await handleQuery();
|
};
|
|
// 打开新增作业页面
|
const openAddJobDetail = () => {
|
state.editJobDetailTitle = '添加作业';
|
editJobDetailRef.value?.openDialog({ concurrent: true, includeAnnotations: true, groupName: 'default', createType: JobCreateTypeEnum.NUMBER_2 });
|
};
|
|
// 打开编辑作业页面
|
const openEditJobDetail = (row: JobDetailOutput) => {
|
state.editJobDetailTitle = '编辑作业';
|
editJobDetailRef.value?.openDialog(row.jobDetail);
|
};
|
|
// 删除作业
|
const delJobDetail = (row: JobDetailOutput) => {
|
ElMessageBox.confirm(`确定删除作业：【${row.jobDetail?.jobId}】?`, '提示', {
|
confirmButtonText: '确定',
|
cancelButtonText: '取消',
|
type: 'warning',
|
})
|
.then(async () => {
|
await getAPI(SysJobApi).apiSysJobDeleteJobDetailPost({ jobId: row.jobDetail?.jobId });
|
await handleQuery();
|
ElMessage.success('删除成功');
|
})
|
.catch(() => {});
|
};
|
|
// 打开新增触发器页面
|
const openAddJobTrigger = (row: JobDetailOutput) => {
|
state.editJobTriggerTitle = '添加触发器';
|
editJobTriggerRef.value?.openDialog({
|
jobId: row.jobDetail?.jobId,
|
retryTimeout: 1000,
|
startNow: true,
|
runOnStart: true,
|
resetOnlyOnce: true,
|
triggerType: 'Furion.Schedule.PeriodTrigger',
|
});
|
};
|
|
// 打开编辑触发器页面
|
const openEditJobTrigger = (row: SysJobTrigger) => {
|
state.editJobTriggerTitle = '编辑触发器';
|
editJobTriggerRef.value?.openDialog(row);
|
};
|
|
// 删除触发器
|
const delJobTrigger = (row: SysJobTrigger) => {
|
ElMessageBox.confirm(`确定删除触发器：【${row.triggerId}】?`, '提示', {
|
confirmButtonText: '确定',
|
cancelButtonText: '取消',
|
type: 'warning',
|
})
|
.then(async () => {
|
await getAPI(SysJobApi).apiSysJobDeleteJobTriggerPost({ jobId: row.jobId, triggerId: row.triggerId });
|
await handleQuery();
|
ElMessage.success('删除成功');
|
})
|
.catch(() => {});
|
};
|
|
// 改变页面容量
|
const handleSizeChange = async (val: number) => {
|
state.tableParams.pageSize = val;
|
await handleQuery();
|
};
|
|
// 改变页码序号
|
const handleCurrentChange = async (val: number) => {
|
state.tableParams.page = val;
|
await handleQuery();
|
};
|
|
// 启动所有作业
|
const startAllJob = async () => {
|
await getAPI(SysJobApi).apiSysJobStartAllJobPost();
|
ElMessage.success('启动所有作业');
|
};
|
|
// 暂停所有作业
|
const pauseAllJob = async () => {
|
await getAPI(SysJobApi).apiSysJobPauseAllJobPost();
|
ElMessage.success('暂停所有作业');
|
};
|
|
// 执行某个作业
|
const runJob = async (row: JobDetailOutput) => {
|
await getAPI(SysJobApi).apiSysJobRunJobPost({ jobId: row.jobDetail?.jobId });
|
ElMessage.success('执行作业');
|
};
|
|
// 启动某个作业
|
const startJob = async (row: JobDetailOutput) => {
|
await getAPI(SysJobApi).apiSysJobStartJobPost({ jobId: row.jobDetail?.jobId });
|
ElMessage.success('启动作业');
|
};
|
|
// 暂停某个作业
|
const pauseJob = async (row: JobDetailOutput) => {
|
await getAPI(SysJobApi).apiSysJobPauseJobPost({ jobId: row.jobDetail?.jobId });
|
ElMessage.success('暂停作业');
|
};
|
|
// 取消某个作业
|
const cancelJob = async (row: JobDetailOutput) => {
|
await getAPI(SysJobApi).apiSysJobCancelJobPost({ jobId: row.jobDetail?.jobId });
|
ElMessage.success('取消作业');
|
};
|
|
// 启动触发器
|
const startTrigger = async (row: SysJobTrigger) => {
|
await getAPI(SysJobApi).apiSysJobStartTriggerPost({ jobId: row.jobId, triggerId: row.triggerId });
|
ElMessage.success('启动触发器');
|
};
|
|
// 暂停触发器
|
const pauseTrigger = async (row: SysJobTrigger) => {
|
await getAPI(SysJobApi).apiSysJobPauseTriggerPost({ jobId: row.jobId, triggerId: row.triggerId });
|
ElMessage.success('暂停触发器');
|
};
|
|
// 强制唤醒作业调度器
|
const cancelSleep = async () => {
|
await getAPI(SysJobApi).apiSysJobCancelSleepPost();
|
ElMessage.success('强制唤醒作业调度器');
|
};
|
|
// 强制触发所有作业持久化
|
const persistAll = async () => {
|
await getAPI(SysJobApi).apiSysJobPersistAllPost();
|
ElMessage.success('强制触发所有作业持久化');
|
};
|
|
// 打开集群控制页面
|
const openJobCluster = () => {
|
editJobClusterRef.value?.openDrawer();
|
};
|
|
// 打开任务看板
|
const openJobDashboard = () => {
|
router.push({
|
path: '/platform/job/dashboard',
|
});
|
};
|
|
// 根据任务属性获取 HttpJobMessage
|
const getHttpJobMessage = (properties: string | undefined | null): HttpJobMessage => {
|
if (properties === undefined || properties === null || properties === '') return {};
|
|
const propData = JSON.parse(properties);
|
const httpJobMessageNet = JSON.parse(propData['HttpJob']); // 后端大写开头的 HttpJobMessage
|
|
return {
|
requestUri: httpJobMessageNet.RequestUri,
|
httpMethod: JSON.stringify(httpJobMessageNet.HttpMethod),
|
body: httpJobMessageNet.Body,
|
};
|
};
|
|
// 获取请求方法的对应描述
|
const getHttpMethodDesc = (httpMethodStr: string | undefined | null): string => {
|
if (httpMethodStr === undefined || httpMethodStr === null || httpMethodStr === '') return '';
|
|
for (const key in editJobDetailRef.value?.httpMethodDef) {
|
if (editJobDetailRef.value?.httpMethodDef[key] === httpMethodStr) return key;
|
}
|
return '';
|
};
|
|
// 打开作业触发器运行记录
|
const openJobTriggerRecord = async (row: any) => {
|
state.currentJob = row;
|
state.isVisibleDrawer = true;
|
await handleQuery2();
|
};
|
|
// 作业触发器运行记录查询操作
|
const handleQuery2 = async () => {
|
state.loading2 = true;
|
let params = Object.assign({ jobId: state.currentJob.jobDetail.jobId }, state.tableParams2); //state.currentJob.jobTriggers[0].triggerId
|
var res = await getAPI(SysJobApi).apiSysJobPageJobTriggerRecordPost(params);
|
state.triggerRecordData = res.data.result?.items ?? [];
|
state.tableParams2.total = res.data.result?.total;
|
state.loading2 = false;
|
};
|
|
// 作业触发器运行记录-改变页面容量
|
const handleSizeChange2 = async (val: number) => {
|
state.tableParams2.pageSize = val;
|
await handleQuery2();
|
};
|
|
// 作业触发器运行记录-改变页码序号
|
const handleCurrentChange2 = async (val: number) => {
|
state.tableParams2.page = val;
|
await handleQuery2();
|
};
|
</script>
|
|
<style>
|
/* 此样式不能为 scoped */
|
.job-index-descriptions-label-style {
|
width: 80px;
|
}
|
</style>
|
