|
|
@@ -70,7 +70,7 @@
|
|
|
<el-button
|
|
|
type="text"
|
|
|
icon="el-icon-info"
|
|
|
- @click="getJobLog(scope.row)">日志
|
|
|
+ @click="handleJobLog(scope.row)">日志
|
|
|
</el-button>
|
|
|
<el-button
|
|
|
v-if="permissions.job_sys_job_start_job"
|
|
|
@@ -106,453 +106,405 @@
|
|
|
</template>
|
|
|
</avue-crud>
|
|
|
</basic-container>
|
|
|
- <log v-if="dialogFormVisible" ref="log"></log>
|
|
|
+ <jobLog v-if="dialogFormVisible" ref="logRef"></jobLog>
|
|
|
</div>
|
|
|
|
|
|
</template>
|
|
|
|
|
|
<script>
|
|
|
- import {addObj, delObj, fetchList, isValidTaskName, putObj, refreshJobsRa,
|
|
|
- runJobRa, shutDownJobRa, shutdownJobsRa, startJobRa, startJobsRa} from '@/api/daemon/sys-job'
|
|
|
- import {tableOption} from '@/const/crud/daemon/sys-job'
|
|
|
- import {remote} from '@/api/admin/dict'
|
|
|
- import {mapGetters} from 'vuex'
|
|
|
- import {cron} from 'vue-cron'
|
|
|
- import log from './job-log'
|
|
|
+ import {
|
|
|
+ addObj, delObj, fetchList, isValidTaskName, putObj, refreshJobsRa,
|
|
|
+ runJobRa, shutDownJobRa, shutdownJobsRa, startJobRa, startJobsRa
|
|
|
+ } from '@/api/daemon/sys-job'
|
|
|
+ import {tableOption} from '@/const/crud/daemon/sys-job'
|
|
|
+ import {remote} from '@/api/admin/dict'
|
|
|
+ import {mapGetters} from 'vuex'
|
|
|
+ import {cron} from 'vue-cron'
|
|
|
+ import jobLog from './job-log'
|
|
|
|
|
|
- export default {
|
|
|
- name: 'jobIndex',
|
|
|
- components: {cron,log},
|
|
|
- data() {
|
|
|
- return {
|
|
|
- form: {},
|
|
|
- cronPopover: false,
|
|
|
- queryParams: {}, // 全局检索条件
|
|
|
- tableData: [],
|
|
|
- dialogFormVisible: false,
|
|
|
- jobId: '',
|
|
|
- page: {
|
|
|
- total: 0, // 总页数
|
|
|
- currentPage: 1, // 当前页数
|
|
|
- pageSize: 10 // 每页显示多少条,
|
|
|
- },
|
|
|
- tableLoading: false,
|
|
|
- tableOption: tableOption,
|
|
|
- JobExecuteStatusDicCache: [],
|
|
|
- JobStatusDicCache: []
|
|
|
- }
|
|
|
- },
|
|
|
- computed: {
|
|
|
- ...mapGetters(['permissions'])
|
|
|
- },
|
|
|
- mounted: function () {
|
|
|
- this.getDicJobExecuteStatusCache('job_execute_status')// 获取定时任务运行时状态
|
|
|
- this.getDicJobStatusCache('job_status')// 获取定时任务状态
|
|
|
+ export default {
|
|
|
+ name: 'jobIndex',
|
|
|
+ components: {cron, jobLog},
|
|
|
+ data() {
|
|
|
+ return {
|
|
|
+ form: {},
|
|
|
+ cronPopover: false,
|
|
|
+ queryParams: {}, // 全局检索条件
|
|
|
+ tableData: [],
|
|
|
+ dialogFormVisible: false,
|
|
|
+ jobId: '',
|
|
|
+ page: {
|
|
|
+ total: 0, // 总页数
|
|
|
+ currentPage: 1, // 当前页数
|
|
|
+ pageSize: 10 // 每页显示多少条,
|
|
|
},
|
|
|
- methods: {
|
|
|
- changeCron(val) {
|
|
|
- this.form.cronExpression = val
|
|
|
- },
|
|
|
- /**
|
|
|
- * 定时任务分页查询
|
|
|
- */
|
|
|
- getList() {
|
|
|
- this.tableLoading = true
|
|
|
- fetchList(Object.assign({
|
|
|
- descs: 'create_time',
|
|
|
- current: this.page.currentPage,
|
|
|
- size: this.page.pageSize
|
|
|
- }, this.queryParams)).then(response => {
|
|
|
- this.tableData = response.data.data.records
|
|
|
- this.page.pageSize = response.data.data.pageSize
|
|
|
- this.page.total = response.data.data.total
|
|
|
- this.tableLoading = false
|
|
|
- })
|
|
|
- },
|
|
|
- /**
|
|
|
- * 清除全局检索条件
|
|
|
- */
|
|
|
- handleSearchReset() {
|
|
|
- this.queryParams = {}
|
|
|
- },
|
|
|
- /**
|
|
|
- * 定时任务检索查询分页查询
|
|
|
- */
|
|
|
- handleFilter(params) {
|
|
|
- this.queryParams = params
|
|
|
- this.getList(this.page)
|
|
|
- },
|
|
|
- /**
|
|
|
- * 启动定时任务
|
|
|
- */
|
|
|
- handleStartJob(row) {
|
|
|
- const jobStatus = row.jobStatus
|
|
|
- if (jobStatus === '1' || jobStatus === '3') {
|
|
|
- this.$confirm(
|
|
|
- '即将发布或启动(任务名称:' + row.jobName + '), 是否继续?',
|
|
|
- '提示',
|
|
|
- {
|
|
|
- confirmButtonText: '确定',
|
|
|
- cancelButtonText: '取消',
|
|
|
- type: 'warning'
|
|
|
- }
|
|
|
- ).then(() => {
|
|
|
- startJobRa(row.jobId).then(response => {
|
|
|
- const code = response.data.code
|
|
|
- if (code === 0) {
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '启动成功',
|
|
|
- type: 'success'
|
|
|
- })
|
|
|
- this.refreshChange()
|
|
|
- }
|
|
|
- }).catch(() => {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '启动失败'
|
|
|
- })
|
|
|
- })
|
|
|
- })
|
|
|
- } else {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '定时任务已运行'
|
|
|
- })
|
|
|
- }
|
|
|
- },
|
|
|
- /**
|
|
|
- * 执行定时任务
|
|
|
- */
|
|
|
- handleRunJob(row) {
|
|
|
- this.$confirm(
|
|
|
- '立刻执行一次任务(任务名称:' + row.jobName + '), 是否继续?',
|
|
|
- '提示',
|
|
|
- {
|
|
|
- confirmButtonText: '确定',
|
|
|
- cancelButtonText: '取消',
|
|
|
- type: 'warning'
|
|
|
- }
|
|
|
- ).then(() => {
|
|
|
- runJobRa(row.jobId).then(response => {
|
|
|
- const code = response.data.code
|
|
|
- if (code === 0) {
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '执行成功',
|
|
|
- type: 'success'
|
|
|
- })
|
|
|
- this.refreshChange()
|
|
|
- }
|
|
|
- }).catch(() => {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '执行失败'
|
|
|
- })
|
|
|
- })
|
|
|
+ tableLoading: false,
|
|
|
+ tableOption: tableOption,
|
|
|
+ JobExecuteStatusDicCache: [],
|
|
|
+ JobStatusDicCache: []
|
|
|
+ }
|
|
|
+ },
|
|
|
+ computed: {
|
|
|
+ ...mapGetters(['permissions'])
|
|
|
+ },
|
|
|
+ mounted: function () {
|
|
|
+ this.getDicJobExecuteStatusCache('job_execute_status')// 获取定时任务运行时状态
|
|
|
+ this.getDicJobStatusCache('job_status')// 获取定时任务状态
|
|
|
+ },
|
|
|
+ methods: {
|
|
|
+ changeCron(val) {
|
|
|
+ this.form.cronExpression = val
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 定时任务分页查询
|
|
|
+ */
|
|
|
+ getList() {
|
|
|
+ this.tableLoading = true
|
|
|
+ fetchList(Object.assign({
|
|
|
+ descs: 'create_time',
|
|
|
+ current: this.page.currentPage,
|
|
|
+ size: this.page.pageSize
|
|
|
+ }, this.queryParams)).then(response => {
|
|
|
+ this.tableData = response.data.data.records
|
|
|
+ this.page.pageSize = response.data.data.pageSize
|
|
|
+ this.page.total = response.data.data.total
|
|
|
+ this.tableLoading = false
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 清除全局检索条件
|
|
|
+ */
|
|
|
+ handleSearchReset() {
|
|
|
+ this.queryParams = {}
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 定时任务检索查询分页查询
|
|
|
+ */
|
|
|
+ handleFilter(params) {
|
|
|
+ this.queryParams = params
|
|
|
+ this.getList(this.page)
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 启动定时任务
|
|
|
+ */
|
|
|
+ handleStartJob(row) {
|
|
|
+ const jobStatus = row.jobStatus
|
|
|
+ if (jobStatus === '1' || jobStatus === '3') {
|
|
|
+ this.$confirm(
|
|
|
+ '即将发布或启动(任务名称:' + row.jobName + '), 是否继续?',
|
|
|
+ '提示',
|
|
|
+ {
|
|
|
+ confirmButtonText: '确定',
|
|
|
+ cancelButtonText: '取消',
|
|
|
+ type: 'warning'
|
|
|
+ }
|
|
|
+ ).then(() => {
|
|
|
+ startJobRa(row.jobId).then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ if (code === 0) {
|
|
|
+ this.$notify({
|
|
|
+ title: '成功',
|
|
|
+ message: '启动成功',
|
|
|
+ type: 'success'
|
|
|
})
|
|
|
+ this.refreshChange()
|
|
|
+ }
|
|
|
+ }).catch(() => {
|
|
|
+ this.$notify.error({
|
|
|
+ title: '错误',
|
|
|
+ message: '启动失败'
|
|
|
+ })
|
|
|
+ })
|
|
|
+ })
|
|
|
+ } else {
|
|
|
+ this.$notify.error({
|
|
|
+ title: '错误',
|
|
|
+ message: '定时任务已运行'
|
|
|
+ })
|
|
|
+ }
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 执行定时任务
|
|
|
+ */
|
|
|
+ handleRunJob(row) {
|
|
|
+ this.$confirm(
|
|
|
+ '立刻执行一次任务(任务名称:' + row.jobName + '), 是否继续?',
|
|
|
+ '提示',
|
|
|
+ {
|
|
|
+ confirmButtonText: '确定',
|
|
|
+ cancelButtonText: '取消',
|
|
|
+ type: 'warning'
|
|
|
+ }
|
|
|
+ ).then(() => {
|
|
|
+ runJobRa(row.jobId).then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ if (code === 0) {
|
|
|
+ this.$notify({
|
|
|
+ title: '成功',
|
|
|
+ message: '执行成功',
|
|
|
+ type: 'success'
|
|
|
+ })
|
|
|
+ this.refreshChange()
|
|
|
+ }
|
|
|
+ }).catch(() => {
|
|
|
+ this.$notify.error({
|
|
|
+ title: '错误',
|
|
|
+ message: '执行失败'
|
|
|
+ })
|
|
|
+ })
|
|
|
+ })
|
|
|
|
|
|
- },
|
|
|
- handleAdd() {
|
|
|
- this.$refs.crud.rowAdd()
|
|
|
- },
|
|
|
- handleUpdate(row, index) {
|
|
|
- const jobStatus = row.jobStatus
|
|
|
- if (jobStatus === '1' || jobStatus === '3') {
|
|
|
- this.$refs.crud.rowEdit(row, index)
|
|
|
- } else {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '运行中定时任务不可修改，请先暂停后操作'
|
|
|
- })
|
|
|
- }
|
|
|
- },
|
|
|
- /**
|
|
|
- * 暂停定时任务
|
|
|
- */
|
|
|
- handleShutDownJob(row) {
|
|
|
- const jobStatus = row.jobStatus
|
|
|
- if (jobStatus === '2') {
|
|
|
- this.$confirm(
|
|
|
- '即将暂停(任务名称:' + row.jobName + '), 是否继续?',
|
|
|
- '提示',
|
|
|
- {
|
|
|
- confirmButtonText: '确定',
|
|
|
- cancelButtonText: '取消',
|
|
|
- type: 'warning'
|
|
|
- }
|
|
|
- ).then(() => {
|
|
|
- shutDownJobRa(row.jobId).then(response => {
|
|
|
- const code = response.data.code
|
|
|
- if (code === 0) {
|
|
|
- this.getList(this.page)
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '暂停成功',
|
|
|
- type: 'success'
|
|
|
- })
|
|
|
- }
|
|
|
- this.refreshChange()
|
|
|
- }).catch(() => {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '暂停失败'
|
|
|
- })
|
|
|
- })
|
|
|
- })
|
|
|
- } else {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '已暂停，不要重复操作'
|
|
|
- })
|
|
|
- }
|
|
|
- },
|
|
|
- /**
|
|
|
- * 刷新回调
|
|
|
- */
|
|
|
- refreshChange() {
|
|
|
+ },
|
|
|
+ handleAdd() {
|
|
|
+ this.$refs.crud.rowAdd()
|
|
|
+ },
|
|
|
+ handleUpdate(row, index) {
|
|
|
+ const jobStatus = row.jobStatus
|
|
|
+ if (jobStatus === '1' || jobStatus === '3') {
|
|
|
+ this.$refs.crud.rowEdit(row, index)
|
|
|
+ } else {
|
|
|
+ this.$notify.error({
|
|
|
+ title: '错误',
|
|
|
+ message: '运行中定时任务不可修改，请先暂停后操作'
|
|
|
+ })
|
|
|
+ }
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 暂停定时任务
|
|
|
+ */
|
|
|
+ handleShutDownJob(row) {
|
|
|
+ const jobStatus = row.jobStatus
|
|
|
+ if (jobStatus === '2') {
|
|
|
+ this.$confirm(
|
|
|
+ '即将暂停(任务名称:' + row.jobName + '), 是否继续?',
|
|
|
+ '提示',
|
|
|
+ {
|
|
|
+ confirmButtonText: '确定',
|
|
|
+ cancelButtonText: '取消',
|
|
|
+ type: 'warning'
|
|
|
+ }
|
|
|
+ ).then(() => {
|
|
|
+ shutDownJobRa(row.jobId).then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ if (code === 0) {
|
|
|
this.getList(this.page)
|
|
|
- },
|
|
|
- shutdownJobs() {
|
|
|
- this.$confirm(
|
|
|
- '即将暂停全部运行中定时任务, 是否继续?',
|
|
|
- '提示',
|
|
|
- {
|
|
|
- confirmButtonText: '确定',
|
|
|
- cancelButtonText: '取消',
|
|
|
- type: 'warning'
|
|
|
- }
|
|
|
- ).then(() => {
|
|
|
- shutdownJobsRa().then(response => {
|
|
|
- const code = response.data.code
|
|
|
- const msg = response.data.msg
|
|
|
- if (code === 0) {
|
|
|
- this.getList(this.page)
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: msg,
|
|
|
- type: 'success'
|
|
|
- })
|
|
|
- this.refreshChange()
|
|
|
- } else {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '暂停失败'
|
|
|
- })
|
|
|
- }
|
|
|
- }).catch(() => {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '暂停失败'
|
|
|
- })
|
|
|
- })
|
|
|
- })
|
|
|
- },
|
|
|
- /**
|
|
|
- * 启动全部暂停定时任务
|
|
|
- */
|
|
|
- startJobs() {
|
|
|
- this.$confirm(
|
|
|
- '即将启动全部暂定中定时任务, 是否继续?',
|
|
|
- '提示',
|
|
|
- {
|
|
|
- confirmButtonText: '确定',
|
|
|
- cancelButtonText: '取消',
|
|
|
- type: 'warning'
|
|
|
- }
|
|
|
- ).then(() => {
|
|
|
- startJobsRa().then(response => {
|
|
|
- const code = response.data.code
|
|
|
- if (code === 0) {
|
|
|
- this.getList(this.page)
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '启动成功',
|
|
|
- type: 'success'
|
|
|
- })
|
|
|
- this.refreshChange()
|
|
|
- } else {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '启动失败'
|
|
|
- })
|
|
|
- }
|
|
|
- }).catch(() => {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '启动失败'
|
|
|
- })
|
|
|
- })
|
|
|
+ this.$notify({
|
|
|
+ title: '成功',
|
|
|
+ message: '暂停成功',
|
|
|
+ type: 'success'
|
|
|
})
|
|
|
- },
|
|
|
- /**
|
|
|
- * 刷新定时任务
|
|
|
- */
|
|
|
- refreshJobs() {
|
|
|
- this.$confirm(
|
|
|
- '即将刷新全部定时任务, 是否继续?',
|
|
|
- '提示',
|
|
|
- {
|
|
|
- confirmButtonText: '确定',
|
|
|
- cancelButtonText: '取消',
|
|
|
- type: 'warning'
|
|
|
- }
|
|
|
- ).then(() => {
|
|
|
- refreshJobsRa().then(response => {
|
|
|
- const code = response.data.code
|
|
|
- if (code === 0) {
|
|
|
- this.getList(this.page)
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '重置成功',
|
|
|
- type: 'success'
|
|
|
- })
|
|
|
- this.refreshChange()
|
|
|
- } else {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '重置失败'
|
|
|
- })
|
|
|
- }
|
|
|
- }).catch(() => {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '重置失败'
|
|
|
- })
|
|
|
- }
|
|
|
- )
|
|
|
- })
|
|
|
- },
|
|
|
- /**
|
|
|
- * 新增定时任务持久化处理
|
|
|
- */
|
|
|
- save(row, done, loading) {
|
|
|
- isValidTaskName({
|
|
|
- 'jobName': row.jobName,
|
|
|
- 'jobGroup': row.jobGroup
|
|
|
- }).then(response => {
|
|
|
- const result = response.data.code
|
|
|
- if (result !== 0) {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '任务名称与任务组重复，请确认后重新添加'
|
|
|
- })
|
|
|
- } else {
|
|
|
- addObj(row).then(() => {
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '创建成功',
|
|
|
- type: 'success',
|
|
|
- duration: 2000
|
|
|
- })
|
|
|
- }).catch(() => {
|
|
|
- loading()
|
|
|
- })
|
|
|
- }
|
|
|
- done()
|
|
|
- this.getList(this.page)
|
|
|
- })
|
|
|
- },
|
|
|
- /**
|
|
|
- * 更新定时任务持久化处理
|
|
|
- */
|
|
|
- update(row, index, done, loading) {
|
|
|
- putObj(row).then(() => {
|
|
|
- this.getList(this.page)
|
|
|
- done()
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '修改成功',
|
|
|
- type: 'success',
|
|
|
- duration: 2000
|
|
|
- })
|
|
|
- this.refreshChange()
|
|
|
- }).catch(() => {
|
|
|
- loading()
|
|
|
- })
|
|
|
- },
|
|
|
- /**
|
|
|
- * 删除定时任务持久化处理
|
|
|
- */
|
|
|
- handleDelete(row) {
|
|
|
- const jobStatus = row.jobStatus
|
|
|
- if (jobStatus === '1' || jobStatus === '3') {
|
|
|
- this.$confirm('是否确认删除(任务名称:' + row.jobName + '), 是否继续?删除后不可恢复', '警告', {
|
|
|
- confirmButtonText: '确定',
|
|
|
- cancelButtonText: '取消',
|
|
|
- type: 'warning'
|
|
|
- }).then(function () {
|
|
|
- return delObj(row.jobId)
|
|
|
- }).then(() => {
|
|
|
- this.getList(this.page)
|
|
|
- this.$notify({
|
|
|
- title: '成功',
|
|
|
- message: '删除成功',
|
|
|
- type: 'success',
|
|
|
- duration: 2000
|
|
|
- })
|
|
|
- this.refreshChange()
|
|
|
- }).catch(function () {
|
|
|
- })
|
|
|
- } else {
|
|
|
- this.$notify.error({
|
|
|
- title: '错误',
|
|
|
- message: '运行中定时任务不可删除，请先暂停后操作'
|
|
|
- })
|
|
|
- }
|
|
|
- },
|
|
|
- /**
|
|
|
- * 获取字典显示名称并缓存
|
|
|
- */
|
|
|
- getDicJobExecuteStatusCache(type) {
|
|
|
- remote(type).then(response => {
|
|
|
- const code = response.data.code
|
|
|
- if (code === 0) {
|
|
|
- const _data = response.data.data
|
|
|
- this.JobExecuteStatusDicCache = _data
|
|
|
- }
|
|
|
- })
|
|
|
- },
|
|
|
- /**
|
|
|
- * 获取字典显示名称并缓存
|
|
|
- */
|
|
|
- getDicJobStatusCache(type) {
|
|
|
- remote(type).then(response => {
|
|
|
- const code = response.data.code
|
|
|
- if (code === 0) {
|
|
|
- const _data = response.data.data
|
|
|
- this.JobStatusDicCache = _data
|
|
|
- }
|
|
|
- })
|
|
|
- },
|
|
|
- /**
|
|
|
- * 获取字典定时任务执行状态字典值显示名称
|
|
|
- */
|
|
|
- getDicNameJobExecuteStatus(value) {
|
|
|
- let re = ''
|
|
|
- this.JobExecuteStatusDicCache.forEach(obj => {
|
|
|
- if (obj.value === value) {
|
|
|
- re = obj.label
|
|
|
- return
|
|
|
- }
|
|
|
- })
|
|
|
- return re
|
|
|
- },
|
|
|
- /**
|
|
|
- * 获取字典定时任务状态字典值显示名称
|
|
|
- */
|
|
|
- getDicNameJobStatus(value) {
|
|
|
- let re = ''
|
|
|
- this.JobStatusDicCache.forEach(obj => {
|
|
|
- if (obj.value === value) {
|
|
|
- re = obj.label
|
|
|
- return
|
|
|
- }
|
|
|
- })
|
|
|
- return re
|
|
|
+ }
|
|
|
+ this.refreshChange()
|
|
|
+ }).catch(() => {
|
|
|
+ this.$notify.error({
|
|
|
+ title: '错误',
|
|
|
+ message: '暂停失败'
|
|
|
+ })
|
|
|
+ })
|
|
|
+ })
|
|
|
+ } else {
|
|
|
+ this.$notify.error({
|
|
|
+ title: '错误',
|
|
|
+ message: '已暂停，不要重复操作'
|
|
|
+ })
|
|
|
+ }
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 刷新回调
|
|
|
+ */
|
|
|
+ refreshChange() {
|
|
|
+ this.getList(this.page)
|
|
|
+ },
|
|
|
+ shutdownJobs() {
|
|
|
+ this.$confirm(
|
|
|
+ '即将暂停全部运行中定时任务, 是否继续?',
|
|
|
+ '提示',
|
|
|
+ {
|
|
|
+ confirmButtonText: '确定',
|
|
|
+ cancelButtonText: '取消',
|
|
|
+ type: 'warning'
|
|
|
+ }
|
|
|
+ ).then(() => {
|
|
|
+ shutdownJobsRa().then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ const msg = response.data.msg
|
|
|
+ if (code === 0) {
|
|
|
+ this.getList(this.page)
|
|
|
+ this.$notify.success(msg)
|
|
|
+ } else {
|
|
|
+ this.$notify.error('暂停失败')
|
|
|
+ }
|
|
|
+ }).catch(() => {
|
|
|
+ this.$notify.error('暂停失败')
|
|
|
+ })
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 启动全部暂停定时任务
|
|
|
+ */
|
|
|
+ startJobs() {
|
|
|
+ this.$confirm(
|
|
|
+ '即将启动全部暂定中定时任务, 是否继续?',
|
|
|
+ '提示',
|
|
|
+ {
|
|
|
+ confirmButtonText: '确定',
|
|
|
+ cancelButtonText: '取消',
|
|
|
+ type: 'warning'
|
|
|
+ }
|
|
|
+ ).then(() => {
|
|
|
+ startJobsRa().then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ if (code === 0) {
|
|
|
+ this.getList(this.page)
|
|
|
+ this.$notify.success('启动成功')
|
|
|
+ } else {
|
|
|
+ this.$notify.error('启动失败')
|
|
|
+ }
|
|
|
+ }).catch(() => {
|
|
|
+ this.$notify.error('启动失败')
|
|
|
+ })
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 刷新定时任务
|
|
|
+ */
|
|
|
+ refreshJobs() {
|
|
|
+ this.$confirm(
|
|
|
+ '即将刷新全部定时任务, 是否继续?',
|
|
|
+ '提示',
|
|
|
+ {
|
|
|
+ confirmButtonText: '确定',
|
|
|
+ cancelButtonText: '取消',
|
|
|
+ type: 'warning'
|
|
|
+ }
|
|
|
+ ).then(() => {
|
|
|
+ refreshJobsRa().then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ if (code === 0) {
|
|
|
+ this.getList(this.page)
|
|
|
+ this.$notify.success('重置成功')
|
|
|
+ } else {
|
|
|
+ this.$notify.error('重置失败')
|
|
|
+ }
|
|
|
+ }).catch(() => {
|
|
|
+ this.$notify.error('重置失败')
|
|
|
}
|
|
|
+ )
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 新增定时任务持久化处理
|
|
|
+ */
|
|
|
+ save(row, done, loading) {
|
|
|
+ isValidTaskName({
|
|
|
+ 'jobName': row.jobName,
|
|
|
+ 'jobGroup': row.jobGroup
|
|
|
+ }).then(response => {
|
|
|
+ const result = response.data.code
|
|
|
+ if (result !== 0) {
|
|
|
+ this.$notify.error('任务名称与任务组重复，请确认后重新添加')
|
|
|
+ } else {
|
|
|
+ addObj(row).then(() => {
|
|
|
+ this.$notify.success('创建成功')
|
|
|
+ this.getList(this.page)
|
|
|
+ }).catch(() => {
|
|
|
+ loading()
|
|
|
+ })
|
|
|
+ }
|
|
|
+ done()
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 更新定时任务持久化处理
|
|
|
+ */
|
|
|
+ update(row, index, done, loading) {
|
|
|
+ putObj(row).then(() => {
|
|
|
+ this.getList(this.page)
|
|
|
+ done()
|
|
|
+ this.$notify.success('修改成功')
|
|
|
+ }).catch(() => {
|
|
|
+ loading()
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 删除定时任务持久化处理
|
|
|
+ */
|
|
|
+ handleDelete(row) {
|
|
|
+ const jobStatus = row.jobStatus
|
|
|
+ if (jobStatus === '1' || jobStatus === '3') {
|
|
|
+ this.$confirm('是否确认删除(任务名称:' + row.jobName + '), 是否继续?删除后不可恢复', '警告', {
|
|
|
+ confirmButtonText: '确定',
|
|
|
+ cancelButtonText: '取消',
|
|
|
+ type: 'warning'
|
|
|
+ }).then(function () {
|
|
|
+ return delObj(row.jobId)
|
|
|
+ }).then(() => {
|
|
|
+ this.getList(this.page)
|
|
|
+ this.$notify.success('删除成功')
|
|
|
+ }).catch(function () {
|
|
|
+ })
|
|
|
+ } else {
|
|
|
+ this.$notify.error('运行中定时任务不可删除，请先暂停后操作')
|
|
|
}
|
|
|
+ },
|
|
|
+ handleJobLog(row) {
|
|
|
+ this.dialogFormVisible = true
|
|
|
+ this.$nextTick(() => {
|
|
|
+ this.$refs.logRef.getJobLog(row)
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 获取字典显示名称并缓存
|
|
|
+ */
|
|
|
+ getDicJobExecuteStatusCache(type) {
|
|
|
+ remote(type).then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ if (code === 0) {
|
|
|
+ const _data = response.data.data
|
|
|
+ this.JobExecuteStatusDicCache = _data
|
|
|
+ }
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 获取字典显示名称并缓存
|
|
|
+ */
|
|
|
+ getDicJobStatusCache(type) {
|
|
|
+ remote(type).then(response => {
|
|
|
+ const code = response.data.code
|
|
|
+ if (code === 0) {
|
|
|
+ const _data = response.data.data
|
|
|
+ this.JobStatusDicCache = _data
|
|
|
+ }
|
|
|
+ })
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 获取字典定时任务执行状态字典值显示名称
|
|
|
+ */
|
|
|
+ getDicNameJobExecuteStatus(value) {
|
|
|
+ let re = ''
|
|
|
+ this.JobExecuteStatusDicCache.forEach(obj => {
|
|
|
+ if (obj.value === value) {
|
|
|
+ re = obj.label
|
|
|
+ return
|
|
|
+ }
|
|
|
+ })
|
|
|
+ return re
|
|
|
+ },
|
|
|
+ /**
|
|
|
+ * 获取字典定时任务状态字典值显示名称
|
|
|
+ */
|
|
|
+ getDicNameJobStatus(value) {
|
|
|
+ let re = ''
|
|
|
+ this.JobStatusDicCache.forEach(obj => {
|
|
|
+ if (obj.value === value) {
|
|
|
+ re = obj.label
|
|
|
+ return
|
|
|
+ }
|
|
|
+ })
|
|
|
+ return re
|
|
|
+ }
|
|
|
}
|
|
|
+ }
|
|
|
</script>
|
|
|
|
|
|
<style lang="scss" scoped>
|
冷冷