Loading escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/_source/timeoutAlarm.vue +1 −1 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ </div> <div class="cont-box"> <label class="label-box"> <x-input v-model="interval" style="width: 128px;" :disabled="isDetails"> <x-input v-model="interval" style="width: 128px;" :disabled="isDetails" maxlength="9"> <span slot="append">{{$t('Minute')}}</span> </x-input> </label> Loading escheduler-ui/src/js/conf/home/pages/dag/_source/udp/udp.vue +44 −1 Original line number Diff line number Diff line Loading @@ -4,6 +4,7 @@ <div class="title"> <span>{{$t('Set the DAG diagram name')}}</span> </div> <div> <x-input type="text" Loading @@ -12,6 +13,7 @@ :placeholder="$t('Please enter name(required)')"> </x-input> </div> <template v-if="router.history.current.name !== 'projects-instance-details'"> <div style="padding-top: 12px;"> <x-input Loading @@ -23,6 +25,21 @@ </x-input> </div> </template> <div class="title" style="padding-top: 6px;"> <span>超时告警</span> <span style="padding-left: 6px;"> <x-switch v-model="checkedTimeout"></x-switch> </span> </div> <div class="content" style="padding-bottom: 10px;" v-if="checkedTimeout"> <span> <x-input v-model="timeout" style="width: 128px;" maxlength="9"> <span slot="append">{{$t('Minute')}}</span> </x-input> </span> </div> <div class="title" style="padding-top: 6px;"> <span>{{$t('Set global')}}</span> </div> Loading Loading @@ -68,7 +85,11 @@ // Global custom parameters udpList: [], // Whether to update the process definition syncDefine: true syncDefine: true, // Timeout alarm timeout: 0, // checked Timeout alarm checkedTimeout: true } }, mixins: [disabledState], Loading @@ -81,6 +102,14 @@ _onLocalParams (a) { this.udpList = a }, _verifTimeout () { const reg = /^[1-9]\d*$/ if (!reg.test(this.timeout)) { alert(1) return false } return true }, /** * submit */ Loading @@ -95,9 +124,15 @@ if (!this.$refs.refLocalParams._verifProp()) { return } // verification timeout if (!this._verifTimeout()) { return } // Storage global globalParams this.store.commit('dag/setGlobalParams', _.cloneDeep(this.udpList)) this.store.commit('dag/setName', _.cloneDeep(this.name)) this.store.commit('dag/setTimeout', _.cloneDeep(this.timeout)) this.store.commit('dag/setDesc', _.cloneDeep(this.desc)) this.store.commit('dag/setSyncDefine', this.syncDefine) Affirm.setIsPop(false) Loading @@ -124,12 +159,20 @@ } }, watch: { checkedTimeout (val) { if (!val) { this.timeout = 0 this.store.commit('dag/setTimeout', _.cloneDeep(this.timeout)) } } }, created () { this.udpList = this.store.state.dag.globalParams this.name = this.store.state.dag.name this.desc = this.store.state.dag.desc this.syncDefine = this.store.state.dag.syncDefine this.timeout = this.store.state.dag.timeout || 0 this.checkedTimeout = this.timeout !== 0 }, mounted () {}, components: { mLocalParams } Loading escheduler-ui/src/js/conf/home/store/dag/actions.js +10 −3 Original line number Diff line number Diff line Loading @@ -112,6 +112,8 @@ export default { state.tasks = processDefinitionJson.tasks // global params state.globalParams = processDefinitionJson.globalParams // timeout state.timeout = processDefinitionJson.timeout resolve(res.data) }).catch(res => { Loading Loading @@ -141,6 +143,8 @@ export default { state.tasks = processInstanceJson.tasks // global params state.globalParams = processInstanceJson.globalParams // timeout state.timeout = processInstanceJson.timeout resolve(res.data) }).catch(res => { Loading @@ -155,7 +159,8 @@ export default { return new Promise((resolve, reject) => { let data = { globalParams: state.globalParams, tasks: state.tasks tasks: state.tasks, timeout: state.timeout } io.post(`projects/${state.projectName}/process/save`, { processDefinitionJson: JSON.stringify(data), Loading @@ -177,7 +182,8 @@ export default { return new Promise((resolve, reject) => { let data = { globalParams: state.globalParams, tasks: state.tasks tasks: state.tasks, timeout: state.timeout } io.post(`projects/${state.projectName}/process/update`, { processDefinitionJson: JSON.stringify(data), Loading @@ -200,7 +206,8 @@ export default { return new Promise((resolve, reject) => { let data = { globalParams: state.globalParams, tasks: state.tasks tasks: state.tasks, timeout: state.timeout } io.post(`projects/${state.projectName}/instance/update`, { processInstanceJson: JSON.stringify(data), Loading escheduler-ui/src/js/conf/home/store/dag/mutations.js +7 −0 Original line number Diff line number Diff line Loading @@ -52,6 +52,12 @@ export default { setName (state, payload) { state.name = payload }, /** * set timeout */ setTimeout (state, payload) { state.timeout = payload }, /** * set global params */ Loading Loading @@ -93,6 +99,7 @@ export default { state.tasks = payload && payload.tasks || [] state.name = payload && payload.name || '' state.desc = payload && payload.desc || '' state.timeout = payload && payload.timeout || 0 state.processListS = payload && payload.processListS || [] state.resourcesListS = payload && payload.resourcesListS || [] state.isDetails = payload && payload.isDetails || false Loading escheduler-ui/src/js/conf/home/store/dag/state.js +2 −0 Original line number Diff line number Diff line Loading @@ -29,6 +29,8 @@ export default { globalParams: [], // Node information tasks: [], // Timeout alarm timeout: 0, // Node location information locations: {}, // Node-to-node connection Loading Loading
escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/_source/timeoutAlarm.vue +1 −1 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ </div> <div class="cont-box"> <label class="label-box"> <x-input v-model="interval" style="width: 128px;" :disabled="isDetails"> <x-input v-model="interval" style="width: 128px;" :disabled="isDetails" maxlength="9"> <span slot="append">{{$t('Minute')}}</span> </x-input> </label> Loading
escheduler-ui/src/js/conf/home/pages/dag/_source/udp/udp.vue +44 −1 Original line number Diff line number Diff line Loading @@ -4,6 +4,7 @@ <div class="title"> <span>{{$t('Set the DAG diagram name')}}</span> </div> <div> <x-input type="text" Loading @@ -12,6 +13,7 @@ :placeholder="$t('Please enter name(required)')"> </x-input> </div> <template v-if="router.history.current.name !== 'projects-instance-details'"> <div style="padding-top: 12px;"> <x-input Loading @@ -23,6 +25,21 @@ </x-input> </div> </template> <div class="title" style="padding-top: 6px;"> <span>超时告警</span> <span style="padding-left: 6px;"> <x-switch v-model="checkedTimeout"></x-switch> </span> </div> <div class="content" style="padding-bottom: 10px;" v-if="checkedTimeout"> <span> <x-input v-model="timeout" style="width: 128px;" maxlength="9"> <span slot="append">{{$t('Minute')}}</span> </x-input> </span> </div> <div class="title" style="padding-top: 6px;"> <span>{{$t('Set global')}}</span> </div> Loading Loading @@ -68,7 +85,11 @@ // Global custom parameters udpList: [], // Whether to update the process definition syncDefine: true syncDefine: true, // Timeout alarm timeout: 0, // checked Timeout alarm checkedTimeout: true } }, mixins: [disabledState], Loading @@ -81,6 +102,14 @@ _onLocalParams (a) { this.udpList = a }, _verifTimeout () { const reg = /^[1-9]\d*$/ if (!reg.test(this.timeout)) { alert(1) return false } return true }, /** * submit */ Loading @@ -95,9 +124,15 @@ if (!this.$refs.refLocalParams._verifProp()) { return } // verification timeout if (!this._verifTimeout()) { return } // Storage global globalParams this.store.commit('dag/setGlobalParams', _.cloneDeep(this.udpList)) this.store.commit('dag/setName', _.cloneDeep(this.name)) this.store.commit('dag/setTimeout', _.cloneDeep(this.timeout)) this.store.commit('dag/setDesc', _.cloneDeep(this.desc)) this.store.commit('dag/setSyncDefine', this.syncDefine) Affirm.setIsPop(false) Loading @@ -124,12 +159,20 @@ } }, watch: { checkedTimeout (val) { if (!val) { this.timeout = 0 this.store.commit('dag/setTimeout', _.cloneDeep(this.timeout)) } } }, created () { this.udpList = this.store.state.dag.globalParams this.name = this.store.state.dag.name this.desc = this.store.state.dag.desc this.syncDefine = this.store.state.dag.syncDefine this.timeout = this.store.state.dag.timeout || 0 this.checkedTimeout = this.timeout !== 0 }, mounted () {}, components: { mLocalParams } Loading
escheduler-ui/src/js/conf/home/store/dag/actions.js +10 −3 Original line number Diff line number Diff line Loading @@ -112,6 +112,8 @@ export default { state.tasks = processDefinitionJson.tasks // global params state.globalParams = processDefinitionJson.globalParams // timeout state.timeout = processDefinitionJson.timeout resolve(res.data) }).catch(res => { Loading Loading @@ -141,6 +143,8 @@ export default { state.tasks = processInstanceJson.tasks // global params state.globalParams = processInstanceJson.globalParams // timeout state.timeout = processInstanceJson.timeout resolve(res.data) }).catch(res => { Loading @@ -155,7 +159,8 @@ export default { return new Promise((resolve, reject) => { let data = { globalParams: state.globalParams, tasks: state.tasks tasks: state.tasks, timeout: state.timeout } io.post(`projects/${state.projectName}/process/save`, { processDefinitionJson: JSON.stringify(data), Loading @@ -177,7 +182,8 @@ export default { return new Promise((resolve, reject) => { let data = { globalParams: state.globalParams, tasks: state.tasks tasks: state.tasks, timeout: state.timeout } io.post(`projects/${state.projectName}/process/update`, { processDefinitionJson: JSON.stringify(data), Loading @@ -200,7 +206,8 @@ export default { return new Promise((resolve, reject) => { let data = { globalParams: state.globalParams, tasks: state.tasks tasks: state.tasks, timeout: state.timeout } io.post(`projects/${state.projectName}/instance/update`, { processInstanceJson: JSON.stringify(data), Loading
escheduler-ui/src/js/conf/home/store/dag/mutations.js +7 −0 Original line number Diff line number Diff line Loading @@ -52,6 +52,12 @@ export default { setName (state, payload) { state.name = payload }, /** * set timeout */ setTimeout (state, payload) { state.timeout = payload }, /** * set global params */ Loading Loading @@ -93,6 +99,7 @@ export default { state.tasks = payload && payload.tasks || [] state.name = payload && payload.name || '' state.desc = payload && payload.desc || '' state.timeout = payload && payload.timeout || 0 state.processListS = payload && payload.processListS || [] state.resourcesListS = payload && payload.resourcesListS || [] state.isDetails = payload && payload.isDetails || false Loading
escheduler-ui/src/js/conf/home/store/dag/state.js +2 −0 Original line number Diff line number Diff line Loading @@ -29,6 +29,8 @@ export default { globalParams: [], // Node information tasks: [], // Timeout alarm timeout: 0, // Node location information locations: {}, // Node-to-node connection Loading