Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
E
ETL-admin
Overview
Overview
Details
Activity
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
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
莫晓莉
ETL-admin
Commits
654c5194
Commit
654c5194
authored
Apr 02, 2021
by
莫晓莉
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
流程图转换
parent
4ae20246
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
180 additions
and
44 deletions
+180
-44
src/views/dialogs-components/global/trans-graph/main.vue
+180
-44
No files found.
src/views/dialogs-components/global/trans-graph/main.vue
View file @
654c5194
...
...
@@ -3,9 +3,9 @@
<el-dialog
title=
"转换"
:visible
.
sync=
"transGraphVisible"
width=
"1
0
00px"
width=
"1
2
00px"
:before-close=
"handleClose"
@
open=
"
doTrans
"
@
open=
"
openFunc
"
top=
"10%"
append-to-body
>
...
...
@@ -20,20 +20,20 @@
</el-tab-pane>
<el-tab-pane
label=
"日志"
name=
"second"
>
<div
style=
"height:50vh;overflow-y:auto;"
>
{{mylog}}
</div>
</el-tab-pane>
<el-tab-pane
label=
"执行历史"
name=
"third "
>
<el-tab-pane
label=
"执行历史"
name=
"third "
disabled=
"true"
>
3333
</el-tab-pane>
<el-tab-pane
label=
"性能图"
name=
"fourth"
>
<el-tab-pane
label=
"性能图"
name=
"fourth"
disabled=
"true"
>
4444
</el-tab-pane>
<el-tab-pane
label=
"Metrics"
name=
"fiveth "
>
<el-tab-pane
label=
"Metrics"
name=
"fiveth "
disabled=
"true"
>
5555
</el-tab-pane>
<el-tab-pane
label=
"Preview Data"
name=
"sixth "
>
<el-tab-pane
label=
"Preview Data"
name=
"sixth "
disabled=
"true"
>
6666
</el-tab-pane>
</el-tabs>
...
...
@@ -49,11 +49,14 @@
<
script
>
import
{
doTrans
,
//获取表输出
doRun
,
//启动
}
from
"@/api/kettle/file"
;
export
default
({
name
:
"trans-graph"
,
data
(){
return
{
executionId
:
null
,
//执行转换返回id
mylog
:
''
,
//日志
field
:
false
,
//编辑弹窗
checkedCities
:
[
'上海'
,
'北京'
],
editDia
:
false
,
//编辑表字段
...
...
@@ -94,54 +97,94 @@ export default ({
// 表头数据
// tableHead:[
// {
// column_name: "column_name",column_comment:"表字段"
// },
// {
// column_name: "stream_name",column_comment:"流字段"
// },
// ],
tableHead
:[
{
column_name
:
"
column_name"
,
column_comment
:
"表字段
"
column_name
:
"
name"
,
column_comment
:
"步骤名称
"
},
{
column_name
:
"stream_name"
,
column_comment
:
"流字段"
column_name
:
"num"
,
column_comment
:
"复制的记录行数"
},
{
column_name
:
"r"
,
column_comment
:
"读"
},
{
column_name
:
"x"
,
column_comment
:
"写"
},
{
column_name
:
"i"
,
column_comment
:
"输入"
},
{
column_name
:
"o"
,
column_comment
:
"输出"
},
{
column_name
:
"u"
,
column_comment
:
"更新"
},
],
// 表格数据
tableData
:
[{
stream_name
:
'3'
,
column_name
:
'鞠婧祎'
,
},
{
stream_name
:
'25'
,
column_name
:
'魏大勋'
,
},
{
stream_name
:
'18'
,
column_name
:
'关晓彤'
,
}],
// 表头数据
tableHead2
:[
{
column_name
:
"column_name"
,
column_comment
:
"表字段"
column_name
:
"f"
,
column_comment
:
"拒绝"
},
{
column_name
:
"e"
,
column_comment
:
"错误"
},
{
column_name
:
"
column_age"
,
column_comment
:
"流字段
"
column_name
:
"
a"
,
column_comment
:
"激活
"
},
{
column_name
:
"t"
,
column_comment
:
"时间"
},
{
column_name
:
"s"
,
column_comment
:
"速度(条记录/秒)"
},
{
column_name
:
"pio"
,
column_comment
:
"Pri/in/out"
},
],
// 表格数据
tableData2
:
[{
column_age
:
'3'
,
column_name
:
'鞠婧祎'
,
},
{
column_age
:
'25'
,
column_name
:
'魏大勋'
,
tableData
:
[{
name
:
'3'
,
num
:
'鞠婧祎'
,
r
:
''
,
x
:
''
,
i
:
''
,
o
:
''
,
u
:
''
,
f
:
''
,
e
:
''
,
a
:
''
,
t
:
''
,
s
:
''
,
pio
:
''
,
},
{
column_age
:
'18'
,
column_name
:
'关晓彤'
,
}],
],
// 表格数据
// tableData: [{
// stream_name: '3',
// column_name: '鞠婧祎',
// },
// {
// stream_name: '25',
// column_name: '魏大勋',
// },
// {
// stream_name: '18',
// column_name: '关晓彤',
// }],
}
},
props
:[
"transGraphVisible"
],
props
:[
"transGraphVisible"
,
"getXmlVal"
],
mounted
(){
...
...
@@ -153,17 +196,110 @@ export default ({
handleClose
(){
this
.
$emit
(
"update:transGraphVisible"
,
false
);
},
//打开弹窗执行方法
openFunc
(){
this
.
doRun
();
// if(this.executionId !=''){
// this.doTrans();
// }
},
// 执行
doTrans
(){
let
pamer
=
new
FormData
();
// 创建form对象
pamer
.
append
(
"executionId"
,
"62fd0f2a89b0401bbe6e7aabbb842b56"
);
var
myexecutionId
=
this
.
executionId
;
// "62fd0f2a89b0401bbe6e7aabbb842b56"
pamer
.
append
(
"executionId"
,
myexecutionId
);
doTrans
(
pamer
).
then
((
res
)
=>
{
if
(
res
){
this
.
tableData
=
res
;
console
.
log
(
'返回执行的数据===='
,
res
);
// this.tableData=res;
this
.
stepMeasure
=
res
.
stepMeasure
this
.
mylog
=
res
.
log
let
tableKeyArr
=
[
"name"
,
"num"
,
"r"
,
"x"
,
"i"
,
"o"
,
"u"
,
"f"
,
"e"
,
"a"
,
"t"
,
"s"
,
"pio"
]
let
tableData
=
[]
//表格数据
res
.
stepMeasure
.
forEach
(
item
=>
{
let
newObj
=
{}
item
.
forEach
((
v
,
i
)
=>
{
newObj
[
tableKeyArr
[
i
]]
=
v
})
tableData
.
push
(
newObj
)
})
this
.
tableData
=
tableData
}
})
},
// 启动
doRun
(){
let
pamer
=
new
FormData
();
// 创建form对象
pamer
.
append
(
"graphXml"
,
this
.
getXmlVal
);
var
executParam
=
{
"exec_local"
:
"Y"
,
"exec_remote"
:
"N"
,
"pass_export"
:
"N"
,
"exec_cluster"
:
"N"
,
"cluster_post"
:
"Y"
,
"cluster_prepare"
:
"Y"
,
"cluster_start"
:
"Y"
,
"cluster_show_trans"
:
"N"
,
"parameters"
:[
],
"variables"
:[
{
"name"
:
"Internal.Entry.Current.Directory"
,
"value"
:
"/"
},
{
"name"
:
"Internal.Job.Filename.Directory"
,
"value"
:
"Parent Job File Directory"
},
{
"name"
:
"Internal.Job.Filename.Name"
,
"value"
:
"Parent Job Filename"
},
{
"name"
:
"Internal.Job.Name"
,
"value"
:
"Parent Job Name"
},
{
"name"
:
"Internal.Job.Repository.Directory"
,
"value"
:
"Parent Job Repository Directory"
}
],
"arguments"
:[
],
"safe_mode"
:
"N"
,
"log_level"
:
"Basic"
,
"clear_log"
:
"Y"
,
"gather_metrics"
:
"Y"
,
"log_file"
:
"N"
,
"log_file_append"
:
"N"
,
"show_subcomponents"
:
"Y"
,
"create_parent_folder"
:
"N"
,
"remote_server"
:
""
,
"replay_date"
:
""
}
// JSON.parse(executParam);
pamer
.
append
(
"executionConfiguration"
,
JSON
.
stringify
(
executParam
));
doRun
(
pamer
).
then
((
res
)
=>
{
if
(
res
.
success
){
console
.
log
(
'返回run的id===='
,
res
.
message
);
this
.
executionId
=
res
.
message
;
if
(
this
.
executionId
){
this
.
doTrans
();
}
}
})
}
...
...
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