Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
B
byit-myth-job
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
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
liyuan
byit-myth-job
Commits
f1fed922
Commit
f1fed922
authored
May 18, 2020
by
huangfusuper
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
。。
parent
52922e57
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
15 additions
and
14 deletions
+15
-14
CommandAndScriptProcessingMachine.java
...com/byit/node/impl/CommandAndScriptProcessingMachine.java
+15
-14
No files found.
byit-myth-executor/myth-executor-server/src/main/java/com/byit/node/impl/CommandAndScriptProcessingMachine.java
View file @
f1fed922
...
...
@@ -47,23 +47,24 @@ public class CommandAndScriptProcessingMachine implements ProcessingMachine {
String
command
=
scriptDto
.
getCommand
();
log
.
debug
(
"-----初始命令为{}------------"
,
command
);
String
param
=
scriptDto
.
getParam
();
ScriptParamAndPlaceholderDto
paramAndPlaceholderDto
=
null
;
if
(
StringUtils
.
isNotBlank
(
param
))
{
ScriptParamAndPlaceholderDto
paramAndPlaceholderDto
=
JSON
.
parseObject
(
param
,
ScriptParamAndPlaceholderDto
.
class
);
//判断是否需要拉取文件服务器的文件,包含biz_file的条件下会对这个字段进行替换
if
(
command
.
contains
(
PlaceholderEnum
.
BIZ_SCRIPT_FILE
.
getName
()))
{
String
scriptPath
=
byteArrayToFile
(
scriptDto
.
getRemotePath
(),
paramAndPlaceholderDto
);
log
.
debug
(
"-----远程地址的文件被拉取到:[{}]------------"
,
scriptPath
);
//初始化命令信息
command
=
PlaceholderUtils
.
initCommand
(
command
,
scriptPath
);
log
.
debug
(
"-----执行命令初始化完成,命令为:[{}]------------"
,
command
);
scriptDto
.
setCommand
(
command
);
}
//执行命令参数的替换
command
=
PlaceholderUtils
.
commandReplace
(
command
,
paramAndPlaceholderDto
.
getParam
());
log
.
debug
(
"-----命令参数替换完成,命令为:[{}]------------"
,
command
);
paramAndPlaceholderDto
=
JSON
.
parseObject
(
param
,
ScriptParamAndPlaceholderDto
.
class
);
}
//判断是否需要拉取文件服务器的文件,包含biz_file的条件下会对这个字段进行替换
if
(
command
.
contains
(
PlaceholderEnum
.
BIZ_SCRIPT_FILE
.
getName
()))
{
String
scriptPath
=
byteArrayToFile
(
scriptDto
.
getRemotePath
(),
paramAndPlaceholderDto
);
log
.
debug
(
"-----远程地址的文件被拉取到:[{}]------------"
,
scriptPath
);
//初始化命令信息
command
=
PlaceholderUtils
.
initCommand
(
command
,
scriptPath
);
log
.
debug
(
"-----执行命令初始化完成,命令为:[{}]------------"
,
command
);
scriptDto
.
setCommand
(
command
);
}
//执行命令参数的替换
command
=
PlaceholderUtils
.
commandReplace
(
command
,
paramAndPlaceholderDto
.
getParam
());
log
.
debug
(
"-----命令参数替换完成,命令为:[{}]------------"
,
command
);
scriptDto
.
setCommand
(
command
);
//将脚本的携带的参数 拼接在命令后方 python test.py -sex 男 -name 张三 -age 14
log
.
info
(
"---------命令及脚本参数处理完成,此节点处理数据为:[{}]-----------"
,
scriptDto
);
processingNodeChain
.
doProcessing
(
scriptDto
,
processingNodeChain
);
...
...
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