Skip to content
Toggle navigation
P
Projects
G
Groups
S
Snippets
Help
熊鹏飞
/
xxljob220
This project
Loading...
Sign in
Toggle navigation
Go to a project
Project
Repository
Issues
0
Merge Requests
0
Pipelines
Wiki
Snippets
Settings
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Commit
1d0e6bcd
authored
Oct 25, 2019
by
xuxueli
Browse files
Options
_('Browse Files')
Download
Plain Diff
Merge branch 'master' of
https://github.com/xuxueli/xxl-job
parents
85cd6361
404500e9
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
11 additions
and
21 deletions
xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java
xxl-job-admin/src/main/java/com/xxl/job/admin/service/impl/XxlJobServiceImpl.java
View file @
1d0e6bcd
...
...
@@ -91,11 +91,12 @@ public class XxlJobServiceImpl implements XxlJobService {
}
// ChildJobId valid
if
(
jobInfo
.
getChildJobId
()!=
null
&&
jobInfo
.
getChildJobId
().
trim
().
length
()>
0
)
{
String
[]
childJobIds
=
jobInfo
.
getChildJobId
().
split
(
","
);
String
childJobId
=
jobInfo
.
getChildJobId
();
if
(
childJobId
!=
null
&&
childJobId
.
trim
().
length
()>
0
)
{
String
[]
childJobIds
=
childJobId
.
split
(
","
);
for
(
String
childJobIdItem:
childJobIds
)
{
if
(
childJobIdItem
!=
null
&&
childJobIdItem
.
trim
().
length
()>
0
&&
isNumeric
(
childJobIdItem
))
{
XxlJobInfo
childJobInfo
=
xxlJobInfoDao
.
loadById
(
Integer
.
valueOf
(
childJobIdItem
));
XxlJobInfo
childJobInfo
=
xxlJobInfoDao
.
loadById
(
Integer
.
parseInt
(
childJobIdItem
));
if
(
childJobInfo
==
null
)
{
return
new
ReturnT
<
String
>(
ReturnT
.
FAIL_CODE
,
MessageFormat
.
format
((
I18nUtil
.
getString
(
"jobinfo_field_childJobId"
)+
"({0})"
+
I18nUtil
.
getString
(
"system_not_found"
)),
childJobIdItem
));
...
...
@@ -106,13 +107,7 @@ public class XxlJobServiceImpl implements XxlJobService {
}
}
String
temp
=
""
;
// join ,
for
(
String
item:
childJobIds
)
{
temp
+=
item
+
","
;
}
temp
=
temp
.
substring
(
0
,
temp
.
length
()-
1
);
jobInfo
.
setChildJobId
(
temp
);
jobInfo
.
setChildJobId
(
childJobId
);
}
// add in db
...
...
@@ -154,11 +149,12 @@ public class XxlJobServiceImpl implements XxlJobService {
}
// ChildJobId valid
if
(
jobInfo
.
getChildJobId
()!=
null
&&
jobInfo
.
getChildJobId
().
trim
().
length
()>
0
)
{
String
[]
childJobIds
=
jobInfo
.
getChildJobId
().
split
(
","
);
String
childJobId
=
jobInfo
.
getChildJobId
();
if
(
childJobId
!=
null
&&
childJobId
.
trim
().
length
()>
0
)
{
String
[]
childJobIds
=
childJobId
.
split
(
","
);
for
(
String
childJobIdItem:
childJobIds
)
{
if
(
childJobIdItem
!=
null
&&
childJobIdItem
.
trim
().
length
()>
0
&&
isNumeric
(
childJobIdItem
))
{
XxlJobInfo
childJobInfo
=
xxlJobInfoDao
.
loadById
(
Integer
.
valueOf
(
childJobIdItem
));
XxlJobInfo
childJobInfo
=
xxlJobInfoDao
.
loadById
(
Integer
.
parseInt
(
childJobIdItem
));
if
(
childJobInfo
==
null
)
{
return
new
ReturnT
<
String
>(
ReturnT
.
FAIL_CODE
,
MessageFormat
.
format
((
I18nUtil
.
getString
(
"jobinfo_field_childJobId"
)+
"({0})"
+
I18nUtil
.
getString
(
"system_not_found"
)),
childJobIdItem
));
...
...
@@ -169,13 +165,7 @@ public class XxlJobServiceImpl implements XxlJobService {
}
}
String
temp
=
""
;
// join ,
for
(
String
item:
childJobIds
)
{
temp
+=
item
+
","
;
}
temp
=
temp
.
substring
(
0
,
temp
.
length
()-
1
);
jobInfo
.
setChildJobId
(
temp
);
jobInfo
.
setChildJobId
(
childJobId
);
}
// group valid
...
...
@@ -216,7 +206,7 @@ public class XxlJobServiceImpl implements XxlJobService {
exists_jobInfo
.
setExecutorBlockStrategy
(
jobInfo
.
getExecutorBlockStrategy
());
exists_jobInfo
.
setExecutorTimeout
(
jobInfo
.
getExecutorTimeout
());
exists_jobInfo
.
setExecutorFailRetryCount
(
jobInfo
.
getExecutorFailRetryCount
());
exists_jobInfo
.
setChildJobId
(
jobInfo
.
getChildJobId
()
);
exists_jobInfo
.
setChildJobId
(
childJobId
);
exists_jobInfo
.
setTriggerNextTime
(
nextTriggerTime
);
xxlJobInfoDao
.
update
(
exists_jobInfo
);
...
...
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