Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
B
bigDataSystem
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
张伯涛
bigDataSystem
Commits
cb0acb84
Commit
cb0acb84
authored
Nov 27, 2024
by
LiXuyang
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
任务流设计-任务操作
parent
fd863634
Changes
5
Show whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
177 additions
and
4 deletions
+177
-4
index.vue
src/views/schedulingExecution/taskFlow/index.vue
+13
-0
deleteModel.vue
src/views/taskScheduling/taskFlowDesign/deleteModel.vue
+0
-1
index.vue
src/views/taskScheduling/taskFlowDesign/index.vue
+27
-3
offlineModel.vue
src/views/taskScheduling/taskFlowDesign/offlineModel.vue
+134
-0
uploadModel.vue
src/views/taskScheduling/taskFlowDesign/uploadModel.vue
+3
-0
No files found.
src/views/schedulingExecution/taskFlow/index.vue
0 → 100644
View file @
cb0acb84
<
template
>
</
template
>
<
script
>
export
default
{
name
:
"index"
}
</
script
>
<
style
scoped
>
</
style
>
src/views/taskScheduling/taskFlowDesign/deleteModel.vue
View file @
cb0acb84
...
@@ -126,7 +126,6 @@
...
@@ -126,7 +126,6 @@
pagination
:
false
,
pagination
:
false
,
}
as
BasicTableProps
);
}
as
BasicTableProps
);
async
function
handleSubmit
()
{
async
function
handleSubmit
()
{
createMessage
.
success
(
'版本发布成功。'
);
closeModal
();
closeModal
();
}
}
</
script
>
</
script
>
src/views/taskScheduling/taskFlowDesign/index.vue
View file @
cb0acb84
...
@@ -18,7 +18,12 @@
...
@@ -18,7 +18,12 @@
<a-button
v-if=
"!versionFlag"
type=
"primary"
>
运行当前及下游
</a-button>
<a-button
v-if=
"!versionFlag"
type=
"primary"
>
运行当前及下游
</a-button>
<a-button
v-if=
"!versionFlag"
type=
"primary"
>
调试
</a-button>
<a-button
v-if=
"!versionFlag"
type=
"primary"
>
调试
</a-button>
<a-button
v-if=
"!versionFlag"
type=
"primary"
@
click=
"handleSave"
>
保存
</a-button>
<a-button
v-if=
"!versionFlag"
type=
"primary"
@
click=
"handleSave"
>
保存
</a-button>
<a-button
v-if=
"!versionFlag"
type=
"primary"
@
click=
"handleUpload"
>
发布
</a-button>
<a-button
v-if=
"!versionFlag && !uploadFlag"
type=
"primary"
@
click=
"handleUpload"
>
发布
</a-button
>
<a-button
v-if=
"!versionFlag && uploadFlag"
type=
"primary"
@
click=
"handleOffline"
>
下线
</a-button
>
<div
style=
"display: flex; flex-direction: column; text-align: center"
>
<div
style=
"display: flex; flex-direction: column; text-align: center"
>
<RadioGroup
v-model:value=
"showType"
button-style=
"solid"
size=
"small"
>
<RadioGroup
v-model:value=
"showType"
button-style=
"solid"
size=
"small"
>
<RadioButton
value=
"table"
><UnorderedListOutlined
/></RadioButton>
<RadioButton
value=
"table"
><UnorderedListOutlined
/></RadioButton>
...
@@ -39,7 +44,9 @@
...
@@ -39,7 +44,9 @@
><SwapRightOutlined
:rotate=
"rotate"
/>
按执行计划排序
</a-button
><SwapRightOutlined
:rotate=
"rotate"
/>
按执行计划排序
</a-button
>
>
<a-button
:disabled=
"getRowSelection().selectedRowKeys
<
=
0
"
>
复制
</a-button>
<a-button
:disabled=
"getRowSelection().selectedRowKeys
<
=
0
"
>
复制
</a-button>
<a-button
:disabled=
"getRowSelection().selectedRowKeys
<
=
0
"
>
删除
</a-button>
<a-button
:disabled=
"getRowSelection().selectedRowKeys
<
=
0
"
@
click=
"handleDeleteMore"
>
删除
</a-button
>
<Dropdown
:trigger=
"['click']"
>
<Dropdown
:trigger=
"['click']"
>
<a-button
type=
"primary"
@
click
.
prevent
><PlusOutlined
/>
新建任务
</a-button>
<a-button
type=
"primary"
@
click
.
prevent
><PlusOutlined
/>
新建任务
</a-button>
<template
#
overlay
>
<template
#
overlay
>
...
@@ -116,9 +123,10 @@
...
@@ -116,9 +123,10 @@
<UpstreamModel
@
register=
"upstreamTaskModel"
/>
<UpstreamModel
@
register=
"upstreamTaskModel"
/>
<DependModel
@
register=
"dependModel"
/>
<DependModel
@
register=
"dependModel"
/>
<TaskConfigModel
@
register=
"taskConfigModel"
/>
<TaskConfigModel
@
register=
"taskConfigModel"
/>
<UploadModel
@
register=
"uploadModel"
/>
<UploadModel
@
register=
"uploadModel"
@
set-upload-flag=
"setUploadFlag"
/>
<VersionModel
@
register=
"versionModel"
@
set-version=
"setVersion"
@
show-dag=
"showDag"
/>
<VersionModel
@
register=
"versionModel"
@
set-version=
"setVersion"
@
show-dag=
"showDag"
/>
<DeleteModel
@
register=
"deleteModel"
/>
<DeleteModel
@
register=
"deleteModel"
/>
<OfflineModel
@
register=
"offlineModel"
@
set-upload-flag=
"setUploadFlag"
/>
</PageWrapper>
</PageWrapper>
</template>
</template>
...
@@ -178,6 +186,7 @@
...
@@ -178,6 +186,7 @@
import
UploadModel
from
'./uploadModel.vue'
;
import
UploadModel
from
'./uploadModel.vue'
;
import
VersionModel
from
'./versionModel.vue'
;
import
VersionModel
from
'./versionModel.vue'
;
import
DeleteModel
from
'./deleteModel.vue'
;
import
DeleteModel
from
'./deleteModel.vue'
;
import
OfflineModel
from
'./offlineModel.vue'
;
const
[
taskModel
,
{
openModal
:
openTaskModel
}]
=
useModal
();
const
[
taskModel
,
{
openModal
:
openTaskModel
}]
=
useModal
();
const
[
upstreamTaskModel
,
{
openModal
:
openUpstreamModel
}]
=
useModal
();
const
[
upstreamTaskModel
,
{
openModal
:
openUpstreamModel
}]
=
useModal
();
...
@@ -186,6 +195,7 @@
...
@@ -186,6 +195,7 @@
const
[
uploadModel
,
{
openModal
:
openUploadModel
}]
=
useModal
();
const
[
uploadModel
,
{
openModal
:
openUploadModel
}]
=
useModal
();
const
[
versionModel
,
{
openModal
:
openVersionModel
}]
=
useModal
();
const
[
versionModel
,
{
openModal
:
openVersionModel
}]
=
useModal
();
const
[
deleteModel
,
{
openModal
:
openDeleteModel
}]
=
useModal
();
const
[
deleteModel
,
{
openModal
:
openDeleteModel
}]
=
useModal
();
const
[
offlineModel
,
{
openModal
:
openOfflineModel
}]
=
useModal
();
const
rotate
=
ref
(
90
);
const
rotate
=
ref
(
90
);
const
showType
=
ref
(
'table'
);
const
showType
=
ref
(
'table'
);
const
searchInfo
=
reactive
<
Recordable
>
({});
const
searchInfo
=
reactive
<
Recordable
>
({});
...
@@ -252,6 +262,11 @@
...
@@ -252,6 +262,11 @@
});
});
}
}
}
}
function
handleDeleteMore
()
{
openDeleteModel
(
true
,
{
isUpdate
:
false
,
});
}
function
handleOrderType
()
{
function
handleOrderType
()
{
rotate
.
value
=
rotate
.
value
===
90
?
-
90
:
90
;
rotate
.
value
=
rotate
.
value
===
90
?
-
90
:
90
;
}
}
...
@@ -293,6 +308,15 @@
...
@@ -293,6 +308,15 @@
isUpdate
:
false
,
isUpdate
:
false
,
});
});
}
}
const
uploadFlag
=
ref
(
false
);
function
setUploadFlag
(
flag
)
{
uploadFlag
.
value
=
flag
;
}
function
handleOffline
()
{
openOfflineModel
(
true
,
{
isUpdate
:
false
,
});
}
function
handleExit
()
{
function
handleExit
()
{
versionFlag
.
value
=
false
;
versionFlag
.
value
=
false
;
}
}
...
...
src/views/taskScheduling/taskFlowDesign/offlineModel.vue
0 → 100644
View file @
cb0acb84
<
template
>
<BasicModal
width=
"70%"
v-bind=
"$attrs"
@
register=
"registerModal"
:title=
"getTitle"
@
ok=
"handleSubmit"
>
<Alert
type=
"warning"
show-icon
message=
"任务流存在依赖或引用,请确认是否继续该操作?"
/>
<Row
:gutter=
"16"
>
<Col
:span=
"8"
>
<List>
<template
v-for=
"item in delList1"
:key=
"item.id"
>
<List
.
Item
style=
"cursor: pointer"
@
click=
"handleChange(item)"
:style=
"
{ backgroundColor: selectId === item.id ? '#DCEFFF' : null }"
>
<List
.
Item
.
Meta
>
<template
#
avatar
>
<BranchesOutlined
/>
</
template
>
<
template
#
title
>
<span>
{{
item
.
title
}}
</span>
</
template
>
</List
.Item.Meta
>
</List
.Item
>
</template>
</List>
</Col>
<Col
:span=
"8"
>
<BasicTable
@
register=
"registerTable"
:searchInfo=
"searchInfo"
>
<
template
#
headerCell=
"{ column }"
>
<template
v-if=
"column.key === 'task'"
>
<span>
下游依赖(
{{
getDataSource
().
length
}}
)
</span>
</
template
>
</template>
</BasicTable>
</Col>
<Col
:span=
"8"
>
<BasicTable
@
register=
"rightTable"
:searchInfo=
"searchInfo"
>
<
template
#
headerCell=
"{ column }"
>
<template
v-if=
"column.key === 'task'"
>
<span>
被引入(
{{
getRightList
().
length
}}
)
</span>
</
template
>
</template>
</BasicTable>
</Col>
</Row>
</BasicModal>
</template>
<
script
lang=
"ts"
setup
>
import
{
useTable
,
TableAction
,
BasicTableProps
}
from
'@/components/Table'
;
import
{
ref
,
computed
,
unref
,
reactive
,
defineEmits
}
from
'vue'
;
import
Icon
from
'@/components/Icon/Icon.vue'
;
import
{
Select
,
Alert
,
List
,
Row
,
Col
}
from
'ant-design-vue'
;
import
{
BranchesOutlined
}
from
'@ant-design/icons-vue'
;
import
{
BasicModal
,
useModalInner
}
from
'@/components/Modal'
;
import
{
BasicForm
,
useForm
}
from
'@/components/Form'
;
import
BasicTable
from
'@/components/Table/src/BasicTable.vue'
;
import
{
connectionData
}
from
'@/views/dataWarehousePlanning/logicalModel/modelDetail/modelData'
;
import
{
connectionFormSchema
,
connectionTable
,
}
from
'@/views/dataWarehousePlanning/logicalModel/modelDetail/model.data'
;
import
{
delTableColumn1
,
infoFormSchema
,
uploadModelSchema
,
upstreamTaskColumn
,
}
from
'@/views/taskScheduling/taskFlowDesign/design.data'
;
import
{
useMessage
}
from
'@/hooks/web/useMessage'
;
import
{
delList1
,
delList2
,
delList3
}
from
'./designData.ts'
;
const
emit
=
defineEmits
([
'setUploadFlag'
]);
const
getTitle
=
'任务流依赖/引用提醒'
;
//初始化弹框
const
[
registerModal
,
{
setModalProps
,
closeModal
}]
=
useModalInner
(
async
(
data
)
=>
{
setModalProps
({
confirmLoading
:
false
});
});
const
searchInfo
=
reactive
<
Recordable
>
({});
const
selectId
=
ref
(
1
);
function
handleChange
(
data
)
{
selectId
.
value
=
data
.
id
;
let
list
=
[...
delList2
];
setTableData
([...
list
.
filter
((
item
)
=>
item
.
fid
===
data
.
id
)]);
}
const
{
createMessage
}
=
useMessage
();
const
[
registerTable
,
{
getDataSource
,
setTableData
}]
=
useTable
({
title
:
''
,
// 数据
api
:
async
(
params
)
=>
{
console
.
log
(
'params:'
,
params
);
const
response
=
{
code
:
''
,
message
:
''
,
data
:
delList2
,
};
return
{
...
response
};
},
rowKey
:
'businessId'
,
// 列
columns
:
delTableColumn1
,
striped
:
false
,
showTableSetting
:
false
,
showIndexColumn
:
false
,
pagination
:
false
,
}
as
BasicTableProps
);
const
[
rightTable
,
{
getDataSource
:
getRightList
,
setTableData
:
setRightList
}]
=
useTable
({
title
:
''
,
// 数据
api
:
async
(
params
)
=>
{
console
.
log
(
'params:'
,
params
);
const
response
=
{
code
:
''
,
message
:
''
,
data
:
delList3
,
};
return
{
...
response
};
},
rowKey
:
'businessId'
,
// 列
columns
:
delTableColumn1
,
striped
:
false
,
showTableSetting
:
false
,
showIndexColumn
:
false
,
pagination
:
false
,
}
as
BasicTableProps
);
async
function
handleSubmit
()
{
closeModal
();
emit
(
'setUploadFlag'
,
false
);
createMessage
.
success
(
'下线成功'
);
}
</
script
>
src/views/taskScheduling/taskFlowDesign/uploadModel.vue
View file @
cb0acb84
...
@@ -31,10 +31,12 @@
...
@@ -31,10 +31,12 @@
import
{
useMessage
}
from
'@/hooks/web/useMessage'
;
import
{
useMessage
}
from
'@/hooks/web/useMessage'
;
const
getTitle
=
'发布新版本'
;
const
getTitle
=
'发布新版本'
;
const
emit
=
defineEmits
([
'setUploadFlag'
]);
//初始化弹框
//初始化弹框
const
[
registerModal
,
{
setModalProps
,
closeModal
}]
=
useModalInner
(
async
(
data
)
=>
{
const
[
registerModal
,
{
setModalProps
,
closeModal
}]
=
useModalInner
(
async
(
data
)
=>
{
setModalProps
({
confirmLoading
:
false
});
setModalProps
({
confirmLoading
:
false
});
});
});
const
[
register
]
=
useForm
({
const
[
register
]
=
useForm
({
labelWidth
:
100
,
labelWidth
:
100
,
baseColProps
:
{
lg
:
12
,
md
:
24
},
baseColProps
:
{
lg
:
12
,
md
:
24
},
...
@@ -49,5 +51,6 @@
...
@@ -49,5 +51,6 @@
async
function
handleSubmit
()
{
async
function
handleSubmit
()
{
createMessage
.
success
(
'版本发布成功。'
);
createMessage
.
success
(
'版本发布成功。'
);
closeModal
();
closeModal
();
emit
(
'setUploadFlag'
,
true
);
}
}
</
script
>
</
script
>
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment