diff --git a/escheduler-ui/.env b/escheduler-ui/.env index 52ce563e9b..d4dcd9f473 100644 --- a/escheduler-ui/.env +++ b/escheduler-ui/.env @@ -1,6 +1,6 @@ # 后端接口地址 -API_BASE = http://192.168.220.247:12345 +API_BASE = http://192.168.220.154:12345 # 本地开发如需ip访问项目把"#"号去掉 #DEV_HOST = 192.168.xx.xx diff --git a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/_source/workerGroups.vue b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/_source/workerGroups.vue index 09f5363924..9834801c6c 100644 --- a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/_source/workerGroups.vue +++ b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/_source/workerGroups.vue @@ -22,7 +22,10 @@ }, mixins: [disabledState], props: { - value: Number + value: { + type: Number, + default: -1 + } }, model: { prop: 'value', @@ -37,9 +40,15 @@ watch: { }, created () { - this.workerGroupsList = this.store.state.security.workerGroupsListAll || [] - if (!this.value) { - this.$emit('workerGroupsEvent', this.workerGroupsList[0].id) + let stateWorkerGroupsList = this.store.state.security.workerGroupsListAll || [] + if (stateWorkerGroupsList.length) { + this.workerGroupsList = stateWorkerGroupsList + } else { + this.store.dispatch('security/getWorkerGroupsAll').then(res => { + this.$nextTick(() => { + this.workerGroupsList = res + }) + }) } } } diff --git a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/formModel.vue b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/formModel.vue index a0cdc36713..f185ba80f5 100644 --- a/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/formModel.vue +++ b/escheduler-ui/src/js/conf/home/pages/dag/_source/formModel/formModel.vue @@ -221,7 +221,7 @@ // Task priority taskInstancePriority: 'MEDIUM', // worker group id - workerGroupId: null + workerGroupId: -1 } }, /** diff --git a/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/master.vue b/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/master.vue index 5e71ca176a..e9f9f2947f 100644 --- a/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/master.vue +++ b/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/master.vue @@ -1,13 +1,13 @@ diff --git a/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/zookeeper.vue b/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/zookeeper.vue index 137ddb4239..c86cd4c746 100644 --- a/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/zookeeper.vue +++ b/escheduler-ui/src/js/conf/home/pages/monitor/pages/servers/zookeeper.vue @@ -1,40 +1,49 @@ - - diff --git a/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/start.vue b/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/start.vue index 7d662ab576..64faf85b6d 100644 --- a/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/start.vue +++ b/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/start.vue @@ -14,11 +14,11 @@ -
+
{{$t('Node execution')}}
-
+
{{$t('Backward execution')}} {{$t('Forward execution')}} @@ -49,6 +49,14 @@
+
+
+ Worker分组 +
+
+ +
+
{{$t('Notification group')}} @@ -140,6 +148,7 @@ import store from '@/conf/home/store' import { warningTypeList } from './util' import mPriority from '@/module/components/priority/priority' + import mWorkerGroups from '@/conf/home/pages/dag/_source/formModel/_source/workerGroups' export default { name: 'start-process', @@ -159,7 +168,8 @@ receivers: [], receiversCc: [], runMode: 'RUN_MODE_SERIAL', - processInstancePriority: 'MEDIUM' + processInstancePriority: 'MEDIUM', + workerGroupId: -1 } }, props: { @@ -188,7 +198,8 @@ runMode: this.runMode, processInstancePriority: this.processInstancePriority, receivers: this.receivers.join(',') || '', - receiversCc: this.receiversCc.join(',') || '' + receiversCc: this.receiversCc.join(',') || '', + workerGroupId: this.workerGroupId } // Executed from the specified node if (this.sourceType === 'contextmenu') { @@ -251,7 +262,7 @@ }) }, computed: {}, - components: { mEmail, mPriority } + components: { mEmail, mPriority, mWorkerGroups } } diff --git a/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/timing.vue b/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/timing.vue index e578a43dcd..6b6893acf9 100644 --- a/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/timing.vue +++ b/escheduler-ui/src/js/conf/home/pages/projects/pages/definition/pages/list/_source/timing.vue @@ -79,6 +79,14 @@
+
+
+ Worker分组 +
+
+ +
+
{{$t('Notification group')}} @@ -133,6 +141,7 @@ import { vCrontab } from '~/@vue/crontab/dist' import { formatDate } from '@/module/filter/filter' import mPriority from '@/module/components/priority/priority' + import mWorkerGroups from '@/conf/home/pages/dag/_source/formModel/_source/workerGroups' export default { name: 'timing-process', @@ -152,7 +161,8 @@ receivers: [], receiversCc: [], i18n: i18n.globalScope.LOCALE, - processInstancePriority: 'MEDIUM' + processInstancePriority: 'MEDIUM', + workerGroupId: -1 } }, props: { @@ -190,7 +200,8 @@ processInstancePriority: this.processInstancePriority, warningGroupId: _.isEmpty(this.warningGroupId) ? 0 : this.warningGroupId.id, receivers: this.receivers.join(',') || '', - receiversCc: this.receiversCc.join(',') || '' + receiversCc: this.receiversCc.join(',') || '', + workerGroupId: this.workerGroupId } let msg = '' @@ -255,6 +266,7 @@ this.failureStrategy = item.failureStrategy this.warningType = item.warningType this.processInstancePriority = item.processInstancePriority + this.workerGroupId = item.workerGroupId || -1 this._getNotifyGroupList().then(() => { this.$nextTick(() => { let list = _.filter(this.notifyGroupList, v => v.id === item.warningGroupId) @@ -269,7 +281,7 @@ }).catch(() => this.warningGroupId = { id: 0 }) } }, - components: { vCrontab, mEmail, mPriority } + components: { vCrontab, mEmail, mPriority, mWorkerGroups } } diff --git a/escheduler-ui/src/js/conf/home/store/security/actions.js b/escheduler-ui/src/js/conf/home/store/security/actions.js index be0b1a2226..42f6bf921a 100644 --- a/escheduler-ui/src/js/conf/home/store/security/actions.js +++ b/escheduler-ui/src/js/conf/home/store/security/actions.js @@ -432,8 +432,13 @@ export default { getWorkerGroupsAll ({ state }, payload) { return new Promise((resolve, reject) => { io.get(`worker-group/all-groups`, payload, res => { - state.workerGroupsListAll = res.data - resolve(res.data) + let list = res.data + list.unshift({ + id: -1, + name: 'All' + }) + state.workerGroupsListAll = list + resolve(list) }).catch(e => { reject(e) }) diff --git a/escheduler-ui/src/js/module/components/secondaryMenu/_source/menu.js b/escheduler-ui/src/js/module/components/secondaryMenu/_source/menu.js index a19f4596d8..2b3eef25e0 100644 --- a/escheduler-ui/src/js/module/components/secondaryMenu/_source/menu.js +++ b/escheduler-ui/src/js/module/components/secondaryMenu/_source/menu.js @@ -202,30 +202,30 @@ let menu = { id: 1, disabled: true }, - { - name: 'Alert', - path: 'servers-alert', - id: 2, - disabled: true - }, - { - name: 'RpcServer', - path: 'servers-rpcserver', - id: 3, - disabled: true - }, + // { + // name: 'Alert', + // path: 'servers-alert', + // id: 2, + // disabled: true + // }, + // { + // name: 'RpcServer', + // path: 'servers-rpcserver', + // id: 3, + // disabled: true + // }, { name: 'Zookeeper', path: 'servers-zookeeper', id: 4, disabled: true }, - { - name: 'ApiServer', - path: 'servers-apiserver', - id: 5, - disabled: true - }, + // { + // name: 'ApiServer', + // path: 'servers-apiserver', + // id: 5, + // disabled: true + // }, { name: 'Mysql', path: 'servers-mysql',