766 lines
20 KiB
Vue
766 lines
20 KiB
Vue
<template>
|
|
<div class="dataset-on-time de-search-table">
|
|
<el-row class="top-operate">
|
|
<el-col :span="10">
|
|
<deBtn
|
|
type="primary"
|
|
icon="el-icon-plus"
|
|
@click="() => selectDataset()"
|
|
>{{ $t("dataset.add_task") }}
|
|
</deBtn>
|
|
<deBtn
|
|
:disabled="!multipleSelection.length"
|
|
secondary
|
|
@click="confirmDelete"
|
|
>{{ $t("organization.delete") }}
|
|
</deBtn>
|
|
</el-col>
|
|
<el-col
|
|
:span="14"
|
|
class="right-user"
|
|
>
|
|
<el-input
|
|
ref="search"
|
|
v-model="nickName"
|
|
:placeholder="$t('components.by_task_name')"
|
|
prefix-icon="el-icon-search"
|
|
class="name-email-search"
|
|
size="small"
|
|
clearable
|
|
@blur="initSearch"
|
|
@clear="initSearch"
|
|
/>
|
|
<deBtn
|
|
:secondary="!filterTexts.length"
|
|
:plain="!!filterTexts.length"
|
|
icon="iconfont icon-icon-filter"
|
|
@click="filterShow"
|
|
>{{
|
|
$t("user.filter")
|
|
}}
|
|
<template v-if="filterTexts.length">
|
|
({{ filterTexts.length }})
|
|
</template>
|
|
</deBtn>
|
|
<el-dropdown
|
|
trigger="click"
|
|
:hide-on-click="false"
|
|
>
|
|
<deBtn
|
|
secondary
|
|
icon="el-icon-setting"
|
|
>{{ $t("user.list") }}
|
|
</deBtn>
|
|
<el-dropdown-menu
|
|
slot="dropdown"
|
|
class="list-columns-select"
|
|
>
|
|
<p class="title">{{ $t("user.list_info") }}</p>
|
|
<el-checkbox
|
|
v-model="checkAll"
|
|
:indeterminate="isIndeterminate"
|
|
@change="handleCheckAllChange"
|
|
>{{ $t("dataset.check_all") }}
|
|
</el-checkbox>
|
|
<el-checkbox-group
|
|
v-model="checkedColumnNames"
|
|
@change="handleCheckedColumnNamesChange"
|
|
>
|
|
<el-checkbox
|
|
v-for="column in columnNames"
|
|
:key="column.props"
|
|
:label="column.props"
|
|
>{{ $t(column.label) }}
|
|
</el-checkbox>
|
|
</el-checkbox-group>
|
|
</el-dropdown-menu>
|
|
</el-dropdown>
|
|
</el-col>
|
|
</el-row>
|
|
<div
|
|
v-if="filterTexts.length"
|
|
class="filter-texts"
|
|
>
|
|
<span class="sum">{{ paginationConfig.total }}</span>
|
|
<span class="title">{{ $t("user.result_one") }}</span>
|
|
<el-divider direction="vertical" />
|
|
<i
|
|
v-if="showScroll"
|
|
class="el-icon-arrow-left arrow-filter"
|
|
@click="scrollPre"
|
|
/>
|
|
<div class="filter-texts-container">
|
|
<p
|
|
v-for="(ele, index) in filterTexts"
|
|
:key="ele"
|
|
class="text"
|
|
>
|
|
{{ ele }} <i
|
|
class="el-icon-close"
|
|
@click="clearOneFilter(index)"
|
|
/>
|
|
</p>
|
|
</div>
|
|
<i
|
|
v-if="showScroll"
|
|
class="el-icon-arrow-right arrow-filter"
|
|
@click="scrollNext"
|
|
/>
|
|
<el-button
|
|
type="text"
|
|
class="clear-btn"
|
|
icon="el-icon-delete"
|
|
@click="clearFilter"
|
|
>{{ $t("user.clear_filter") }}
|
|
</el-button>
|
|
</div>
|
|
<div
|
|
id="resize-for-filter"
|
|
class="table-container"
|
|
:class="[filterTexts.length ? 'table-container-filter' : '']"
|
|
>
|
|
<grid-table
|
|
ref="multipleTable"
|
|
v-loading="$store.getters.loadingMap[$store.getters.currentPath]"
|
|
:table-data="data"
|
|
:columns="checkedColumnNames"
|
|
:multiple-selection="multipleSelection"
|
|
:pagination="paginationConfig"
|
|
@selection-change="handleSelectionChange"
|
|
@size-change="handleSizeChange"
|
|
@current-change="handleCurrentChange"
|
|
>
|
|
<el-table-column
|
|
type="selection"
|
|
width="55"
|
|
/>
|
|
<el-table-column
|
|
key="name"
|
|
min-width="178"
|
|
prop="name"
|
|
:label="$t('dataset.task_name')"
|
|
>
|
|
<template slot-scope="scope">
|
|
<span>
|
|
<el-link
|
|
@click="jumpTaskRecord(scope.row)"
|
|
>{{ scope.row.name }}</el-link>
|
|
</span>
|
|
</template>
|
|
</el-table-column>
|
|
<el-table-column
|
|
key="datasetName"
|
|
min-width="178"
|
|
prop="datasetName"
|
|
:label="$t('dataset.task.dataset')"
|
|
/>
|
|
<el-table-column
|
|
key="rate"
|
|
min-width="100"
|
|
prop="rate"
|
|
:label="$t('dataset.execute_rate')"
|
|
>
|
|
<template slot-scope="scope">
|
|
<span v-if="scope.row.rate === 'SIMPLE'">{{
|
|
$t("dataset.execute_once")
|
|
}}</span>
|
|
<span v-if="scope.row.rate === 'CRON'">{{
|
|
$t("dataset.cron_config")
|
|
}}</span>
|
|
<span v-if="scope.row.rate === 'SIMPLE_CRON'">{{
|
|
$t("dataset.simple_cron")
|
|
}}</span>
|
|
</template>
|
|
</el-table-column>
|
|
|
|
<el-table-column
|
|
key="lastExecTime"
|
|
prop="lastExecTime"
|
|
min-width="178"
|
|
:label="$t('dataset.task.last_exec_time')"
|
|
>
|
|
<template slot-scope="scope">
|
|
<span>
|
|
{{ scope.row.lastExecTime | timestampFormatDate }}
|
|
</span>
|
|
</template>
|
|
</el-table-column>
|
|
|
|
<el-table-column
|
|
key="lastExecStatus"
|
|
prop="lastExecStatus"
|
|
min-width="140"
|
|
:label="$t('dataset.task.last_exec_status')"
|
|
>
|
|
<template slot-scope="scope">
|
|
<span
|
|
v-if="scope.row.lastExecStatus"
|
|
:class="[`de-${scope.row.lastExecStatus}-pre`, 'de-status']"
|
|
>{{
|
|
$t(`dataset.${scope.row.lastExecStatus.toLocaleLowerCase()}`)
|
|
}}
|
|
<svg-icon
|
|
v-if="scope.row.lastExecStatus === 'Error'"
|
|
style="cursor: pointer;"
|
|
icon-class="icon-maybe"
|
|
class="field-icon-location"
|
|
@click="showErrorMassage(scope.row.msg)"
|
|
/>
|
|
</span>
|
|
<span v-else>-</span>
|
|
</template>
|
|
</el-table-column>
|
|
|
|
<el-table-column
|
|
key="nextExecTime"
|
|
prop="nextExecTime"
|
|
min-width="178"
|
|
:label="$t('dataset.task.next_exec_time')"
|
|
>
|
|
<template slot-scope="scope">
|
|
<span
|
|
v-if="
|
|
scope.row.nextExecTime &&
|
|
scope.row.nextExecTime !== -1 &&
|
|
scope.row.rate !== 'SIMPLE' &&
|
|
scope.row.status !== 'Pending'
|
|
"
|
|
>
|
|
{{ scope.row.nextExecTime | timestampFormatDate }}
|
|
</span>
|
|
<span
|
|
v-if="!scope.row.nextExecTime || scope.row.rate === 'SIMPLE'"
|
|
>-</span>
|
|
</template>
|
|
</el-table-column>
|
|
|
|
<el-table-column
|
|
key="status"
|
|
min-width="120"
|
|
prop="status"
|
|
:label="$t('dataset.task.task_status')"
|
|
>
|
|
<template slot-scope="scope">
|
|
<span
|
|
:class="[`de-${scope.row.status}-result`, 'de-status']"
|
|
>{{ $t(`dataset.task.${scope.row.status.toLocaleLowerCase()}`) }}
|
|
</span>
|
|
</template>
|
|
</el-table-column>
|
|
<el-table-column
|
|
slot="__operation"
|
|
key="__operation"
|
|
:label="$t('commons.operating')"
|
|
fixed="right"
|
|
width="160"
|
|
>
|
|
<template slot-scope="scope">
|
|
<el-button
|
|
class="de-text-btn mar3 mar6"
|
|
type="text"
|
|
@click="selectDataset(scope.row)"
|
|
>{{ $t(disableEdit(scope.row) ? "auth.view" : "commons.edit") }}
|
|
</el-button>
|
|
<el-button
|
|
class="de-text-btn mar3 mar6"
|
|
:disabled="disableExec(scope.row)"
|
|
type="text"
|
|
@click="execTask(scope.row)"
|
|
>{{ $t("emailtask.execute_now") }}
|
|
</el-button>
|
|
<el-dropdown
|
|
size="medium"
|
|
trigger="click"
|
|
@command="(type) => handleCommand(type, scope.row)"
|
|
>
|
|
<i
|
|
class="el-icon-more"
|
|
@click.stop
|
|
/>
|
|
<el-dropdown-menu
|
|
slot="dropdown"
|
|
class="de-card-dropdown"
|
|
>
|
|
<template
|
|
v-if="!['Exec'].includes(scope.row.status)"
|
|
>
|
|
<el-dropdown-item
|
|
v-if="scope.row.status === 'Pending'"
|
|
command="continue"
|
|
>
|
|
{{ $t("components.continue") }}
|
|
</el-dropdown-item>
|
|
<el-dropdown-item
|
|
v-if="scope.row.status === 'Underway'"
|
|
command="pause"
|
|
>
|
|
{{ $t("dataset.task.pending") }}
|
|
</el-dropdown-item>
|
|
</template>
|
|
<el-dropdown-item
|
|
:disabled="disableDelete(scope.row)"
|
|
command="delete"
|
|
>
|
|
{{ $t("commons.delete") }}
|
|
</el-dropdown-item>
|
|
</el-dropdown-menu>
|
|
</el-dropdown>
|
|
</template>
|
|
</el-table-column>
|
|
</grid-table>
|
|
</div>
|
|
|
|
<keep-alive>
|
|
<filterUser
|
|
ref="filterUser"
|
|
@search="filterDraw"
|
|
/>
|
|
</keep-alive>
|
|
|
|
<el-dialog
|
|
v-dialogDrag
|
|
:title="$t('dataset.error') + $t('dataset.detail')"
|
|
:visible.sync="show_error_massage"
|
|
width="600px"
|
|
class="de-dialog-form"
|
|
>
|
|
<span class="err-msg">{{ error_massage }}</span>
|
|
<span
|
|
slot="footer"
|
|
class="dialog-footer"
|
|
>
|
|
<deBtn
|
|
secondary
|
|
@click="show_error_massage = false"
|
|
>{{
|
|
$t("dataset.close")
|
|
}}</deBtn>
|
|
</span>
|
|
</el-dialog>
|
|
</div>
|
|
</template>
|
|
|
|
<script>
|
|
import { columnOptions } from './options'
|
|
import { formatOrders } from '@/utils/index'
|
|
import { datasetTaskList, post } from '@/api/dataset/dataset'
|
|
import { hasDataPermission } from '@/utils/permission'
|
|
import GridTable from '@/components/gridTable/index.vue'
|
|
import filterUser from './FilterUser.vue'
|
|
import msgCfm from '@/components/msgCfm/index'
|
|
import _ from 'lodash'
|
|
import keyEnter from '@/components/msgCfm/keyEnter.js'
|
|
|
|
export default {
|
|
name: 'DatasetTaskList',
|
|
components: { GridTable, filterUser },
|
|
mixins: [msgCfm, keyEnter],
|
|
props: {
|
|
transCondition: {
|
|
type: Object,
|
|
default: () => {
|
|
}
|
|
}
|
|
},
|
|
data() {
|
|
return {
|
|
nickName: '',
|
|
showScroll: false,
|
|
checkAll: true,
|
|
multipleSelection: [],
|
|
checkedColumnNames: columnOptions.map((ele) => ele.props),
|
|
columnNames: columnOptions,
|
|
isIndeterminate: false,
|
|
filterTexts: [],
|
|
paginationConfig: {
|
|
currentPage: 1,
|
|
pageSize: 10,
|
|
total: 0
|
|
},
|
|
cacheCondition: [],
|
|
data: [],
|
|
orderConditions: [],
|
|
selectDatasetFlag: false,
|
|
table: {},
|
|
show_error_massage: false,
|
|
error_massage: '',
|
|
customType: ['db', 'sql', 'api']
|
|
}
|
|
},
|
|
watch: {
|
|
filterTexts: {
|
|
handler() {
|
|
this.getScrollStatus()
|
|
},
|
|
deep: true
|
|
}
|
|
},
|
|
created() {
|
|
const { taskId, name } = this.transCondition
|
|
if (taskId) {
|
|
this.nickName = name
|
|
}
|
|
this.search()
|
|
this.timer = setInterval(() => {
|
|
this.search(false)
|
|
}, 10000)
|
|
},
|
|
beforeDestroy() {
|
|
clearInterval(this.timer)
|
|
},
|
|
mounted() {
|
|
this.resizeObserver()
|
|
},
|
|
methods: {
|
|
getScrollStatus() {
|
|
this.$nextTick(() => {
|
|
const dom = document.querySelector('.filter-texts-container')
|
|
this.showScroll = dom && dom.scrollWidth > dom.offsetWidth
|
|
})
|
|
},
|
|
resizeObserver() {
|
|
this.resizeForFilter = new ResizeObserver((entries) => {
|
|
if (!this.filterTexts.length) return
|
|
this.layoutResize()
|
|
})
|
|
this.resizeForFilter.observe(
|
|
document.querySelector('#resize-for-filter')
|
|
)
|
|
},
|
|
layoutResize: _.debounce(function() {
|
|
this.getScrollStatus()
|
|
}, 200),
|
|
scrollPre() {
|
|
const dom = document.querySelector('.filter-texts-container')
|
|
dom.scrollLeft -= 10
|
|
if (dom.scrollLeft <= 0) {
|
|
dom.scrollLeft = 0
|
|
}
|
|
},
|
|
scrollNext() {
|
|
const dom = document.querySelector('.filter-texts-container')
|
|
dom.scrollLeft += 10
|
|
const width = dom.scrollWidth - dom.offsetWidth
|
|
if (dom.scrollLeft > width) {
|
|
dom.scrollLeft = width
|
|
}
|
|
},
|
|
clearFilter() {
|
|
this.$refs.filterUser.clearFilter()
|
|
},
|
|
clearOneFilter(index) {
|
|
this.$refs.filterUser.clearOneFilter(index)
|
|
this.$refs.filterUser.search()
|
|
},
|
|
filterDraw(condition, filterTexts = []) {
|
|
this.cacheCondition = condition
|
|
this.filterTexts = filterTexts
|
|
this.initSearch()
|
|
},
|
|
filterShow() {
|
|
this.$refs.filterUser.init()
|
|
},
|
|
handleCommand(key, row) {
|
|
switch (key) {
|
|
case 'exec':
|
|
this.execTask(row)
|
|
break
|
|
case 'delete':
|
|
this.deleteTask(row)
|
|
break
|
|
default:
|
|
this.changeTaskStatus(row)
|
|
break
|
|
}
|
|
},
|
|
handleSelectionChange(val) {
|
|
this.multipleSelection = val
|
|
},
|
|
handleCheckAllChange(val) {
|
|
this.checkedColumnNames = val
|
|
? columnOptions.map((ele) => ele.props)
|
|
: []
|
|
this.isIndeterminate = false
|
|
},
|
|
handleCheckedColumnNamesChange(value) {
|
|
const checkedCount = value.length
|
|
this.checkAll = checkedCount === this.columnNames.length
|
|
this.isIndeterminate =
|
|
checkedCount > 0 && checkedCount < this.columnNames.length
|
|
},
|
|
handleSizeChange(pageSize) {
|
|
this.paginationConfig.currentPage = 1
|
|
this.paginationConfig.pageSize = pageSize
|
|
this.search()
|
|
},
|
|
handleCurrentChange(currentPage) {
|
|
this.paginationConfig.currentPage = currentPage
|
|
this.search()
|
|
},
|
|
initSearch() {
|
|
this.handleCurrentChange(1)
|
|
},
|
|
search(showLoading = true) {
|
|
const { taskId, name } = this.transCondition
|
|
const param = {
|
|
orders: formatOrders(this.orderConditions),
|
|
conditions: [...this.cacheCondition]
|
|
}
|
|
if (this.nickName) {
|
|
param.conditions.push({
|
|
field: `dataset_table_task.name`,
|
|
operator: 'like',
|
|
value: this.nickName
|
|
})
|
|
}
|
|
if (taskId && this.nickName === name) {
|
|
param.conditions.push({
|
|
operator: 'eq',
|
|
value: taskId,
|
|
field: 'dataset_table_task.id'
|
|
})
|
|
}
|
|
const { currentPage, pageSize } = this.paginationConfig
|
|
datasetTaskList(currentPage, pageSize, param, showLoading).then(
|
|
(response) => {
|
|
const multipleSelection = this.multipleSelection.map(ele => ele.id)
|
|
this.data = response.data?.listObject
|
|
this.paginationConfig.total = response.data?.itemCount
|
|
if (multipleSelection.length) {
|
|
this.$nextTick(() => {
|
|
this.data.forEach(row => {
|
|
if (multipleSelection.includes(row.id)) {
|
|
this.$refs.multipleTable.toggleRowSelection(row)
|
|
}
|
|
})
|
|
})
|
|
}
|
|
}
|
|
)
|
|
},
|
|
batchDelete() {
|
|
post(
|
|
'/dataset/task/batchDelete',
|
|
this.multipleSelection.map((ele) => ele.id),
|
|
false
|
|
).then(() => {
|
|
this.initSearch()
|
|
this.openMessageSuccess('commons.delete_success')
|
|
})
|
|
},
|
|
confirmDelete() {
|
|
const options = {
|
|
title: '确定删除该任务吗？',
|
|
type: 'primary',
|
|
cb: this.batchDelete
|
|
}
|
|
this.handlerConfirm(options)
|
|
},
|
|
taskStatus(item) {
|
|
post('/dataset/task/lastExecStatus', item, false).then((response) => {
|
|
if (!item.lastExecStatus) {
|
|
item.lastExecStatus = response.data.lastExecStatus
|
|
}
|
|
if (!item.lastExecTime) {
|
|
item.lastExecTime = response.data.lastExecTime
|
|
}
|
|
item.msg = response.data.msg
|
|
})
|
|
},
|
|
changeTaskStatus(task) {
|
|
const { status } = task
|
|
if (!['Pending', 'Underway'].includes(status)) {
|
|
return
|
|
}
|
|
const param = {
|
|
...task,
|
|
status: status === 'Underway' ? 'Pending' : 'Underway'
|
|
}
|
|
post('/dataset/task/updateStatus', param)
|
|
.then((response) => {
|
|
if (response.success) {
|
|
task.status = param.status
|
|
this.$message({
|
|
message: this.$t('dataset.task.change_success'),
|
|
type: 'success',
|
|
showClose: true
|
|
})
|
|
} else {
|
|
this.initSearch(false)
|
|
}
|
|
})
|
|
.catch(() => {
|
|
this.initSearch(false)
|
|
})
|
|
},
|
|
execTask(task) {
|
|
this.$confirm(
|
|
this.$t('dataset.task.confirm_exec'),
|
|
this.$t('dataset.tips'),
|
|
{
|
|
confirmButtonText: this.$t('dataset.confirm'),
|
|
cancelButtonText: this.$t('dataset.cancel'),
|
|
type: 'warning'
|
|
}
|
|
)
|
|
.then(() => {
|
|
post('/dataset/task/execTask', task).then((response) => {
|
|
this.initSearch(true)
|
|
})
|
|
})
|
|
.catch(() => {
|
|
})
|
|
},
|
|
selectDataset(row) {
|
|
if (row) {
|
|
const { datasetName, id, tableId } = row
|
|
this.$router.push({
|
|
path: '/task-ds-form',
|
|
query: {
|
|
datasetName,
|
|
id,
|
|
tableId
|
|
}
|
|
})
|
|
} else {
|
|
this.$router.push('/task-ds-form')
|
|
}
|
|
},
|
|
disableEdit(task) {
|
|
return (
|
|
task.rate === 'SIMPLE' ||
|
|
task.status === 'Stopped' ||
|
|
!hasDataPermission('manage', task.privileges)
|
|
)
|
|
},
|
|
disableExec(task) {
|
|
return ((task.status === 'Stopped' && task.rate !== 'SIMPLE') || task.status === 'Pending' || task.status ==='Exec' || !hasDataPermission('manage', task.privileges))
|
|
},
|
|
disableDelete(task) {
|
|
return false
|
|
// !hasDataPermission('manage',task.privileges)
|
|
},
|
|
deleteTask(task) {
|
|
const options = {
|
|
title: '确定删除该任务吗？',
|
|
type: 'primary',
|
|
cb: () => {
|
|
post('/dataset/task/delete/' + task.id, null).then((response) => {
|
|
this.openMessageSuccess('commons.delete_success')
|
|
this.initSearch()
|
|
})
|
|
}
|
|
}
|
|
this.handlerConfirm(options)
|
|
},
|
|
showErrorMassage(massage) {
|
|
this.show_error_massage = true
|
|
this.error_massage = massage
|
|
},
|
|
jumpTaskRecord(item) {
|
|
this.$emit('jumpTaskRecord', item)
|
|
}
|
|
}
|
|
}
|
|
</script>
|
|
|
|
<style scoped>
|
|
.codemirror {
|
|
height: 100px;
|
|
overflow-y: auto;
|
|
}
|
|
|
|
.codemirror ::v-deep .CodeMirror-scroll {
|
|
height: 100px;
|
|
overflow-y: auto;
|
|
}
|
|
|
|
.err-msg {
|
|
font-size: 12px;
|
|
word-break: normal;
|
|
width: auto;
|
|
display: block;
|
|
white-space: pre-wrap;
|
|
word-wrap: break-word;
|
|
overflow: hidden;
|
|
}
|
|
</style>
|
|
<style lang="scss" scoped>
|
|
.dataset-on-time {
|
|
margin: 0;
|
|
width: 100%;
|
|
overflow: auto;
|
|
background-color: var(--ContentBG, #fff);
|
|
padding: 24px;
|
|
height: 100%;
|
|
|
|
::v-deep.el-link--inner {
|
|
color: var(--primary, #3370ff) !important;
|
|
}
|
|
|
|
.el-icon-more {
|
|
width: 24px;
|
|
height: 24px;
|
|
line-height: 24px;
|
|
text-align: center;
|
|
font-size: 12px;
|
|
color: var(--primary, #3370ff);
|
|
}
|
|
|
|
.el-icon-more:hover {
|
|
background: var(--deWhiteHover, #3370ff);
|
|
border-radius: 4px;
|
|
}
|
|
|
|
.el-icon-more:active {
|
|
background: var(--deWhiteActive, #3370ff);
|
|
border-radius: 4px;
|
|
}
|
|
}
|
|
|
|
.table-container {
|
|
height: calc(100% - 50px);
|
|
|
|
.mar6 {
|
|
margin-right: 6px;
|
|
}
|
|
|
|
.mar3 {
|
|
margin-left: -3px;
|
|
}
|
|
}
|
|
|
|
.table-container-filter {
|
|
height: calc(100% - 110px);
|
|
}
|
|
</style>
|
|
<style lang="scss">
|
|
.list-columns-select {
|
|
padding: 8px 11px !important;
|
|
width: 238px;
|
|
|
|
.title,
|
|
.el-checkbox {
|
|
font-family: PingFang SC;
|
|
font-size: 14px;
|
|
font-weight: 400;
|
|
padding: 5px 0;
|
|
margin: 0;
|
|
color: #8f959e;
|
|
}
|
|
|
|
.el-checkbox {
|
|
color: #1f2329;
|
|
width: 100%;
|
|
}
|
|
}
|
|
|
|
.de-card-dropdown {
|
|
margin-top: 0 !important;
|
|
|
|
.popper__arrow {
|
|
display: none !important;
|
|
}
|
|
}
|
|
</style>
|