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
3d204f0a
Commit
3d204f0a
authored
May 09, 2020
by
guominglei
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/developer' into developer
parents
10eec08d
0b342a84
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
2 additions
and
4 deletions
+2
-4
RunRecordingEnum.java
...n-core/src/main/java/com/byit/enums/RunRecordingEnum.java
+0
-1
RunRecordingServiceImpl.java
...n/java/com/byit/service/impl/RunRecordingServiceImpl.java
+1
-2
RunRecordingAndJobTaskServiceImpl.java
...ce/mapservice/impl/RunRecordingAndJobTaskServiceImpl.java
+1
-1
No files found.
byit-myth-core/myth-admin-core/src/main/java/com/byit/enums/RunRecordingEnum.java
View file @
3d204f0a
...
@@ -15,7 +15,6 @@ public enum RunRecordingEnum {
...
@@ -15,7 +15,6 @@ public enum RunRecordingEnum {
,
FLOW_STATUS_RUN_ING
(
"2"
,
"工作流运行中"
)
,
FLOW_STATUS_RUN_ING
(
"2"
,
"工作流运行中"
)
,
FLOW_STATUS_IS_STOP
(
"3"
,
"工作流被暂停"
)
,
FLOW_STATUS_IS_STOP
(
"3"
,
"工作流被暂停"
)
,
FLOW_STATUS_IS_END
(
"4"
,
"工作流已经完结"
)
,
FLOW_STATUS_IS_END
(
"4"
,
"工作流已经完结"
)
,
FLOW_STATUS_IS_LOAD
(
"5"
,
"工作流已经被加载"
)
,
FAIL_FAST_NO
(
"0"
,
"不快速失败"
)
,
FAIL_FAST_NO
(
"0"
,
"不快速失败"
)
,
FAIL_FAST_YES
(
"1"
,
"快速失败"
)
,
FAIL_FAST_YES
(
"1"
,
"快速失败"
)
;
;
...
...
byit-myth-core/myth-admin-core/src/main/java/com/byit/service/impl/RunRecordingServiceImpl.java
View file @
3d204f0a
...
@@ -89,8 +89,7 @@ public class RunRecordingServiceImpl implements RunRecordingService {
...
@@ -89,8 +89,7 @@ public class RunRecordingServiceImpl implements RunRecordingService {
for
(
RunRecording
runRecording
:
runRecordings
)
{
for
(
RunRecording
runRecording
:
runRecordings
)
{
//判断当前的实例 中是否有 未完成的
//判断当前的实例 中是否有 未完成的
if
(
RunRecordingEnum
.
FLOW_STATUS_RUN_ING
.
getCode
().
equals
(
runRecording
.
getFlowStatus
())
||
if
(
RunRecordingEnum
.
FLOW_STATUS_RUN_ING
.
getCode
().
equals
(
runRecording
.
getFlowStatus
())
||
RunRecordingEnum
.
FLOW_STATUS_IS_STOP
.
getCode
().
equals
(
runRecording
.
getFlowStatus
())
||
RunRecordingEnum
.
FLOW_STATUS_IS_STOP
.
getCode
().
equals
(
runRecording
.
getFlowStatus
()))
{
RunRecordingEnum
.
FLOW_STATUS_IS_LOAD
.
getCode
().
equals
(
runRecording
.
getFlowStatus
()))
{
return
true
;
return
true
;
}
}
}
}
...
...
byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/RunRecordingAndJobTaskServiceImpl.java
View file @
3d204f0a
...
@@ -61,7 +61,7 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
...
@@ -61,7 +61,7 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
* @throws Exception
* @throws Exception
*/
*/
@Override
@Override
public
void
saveRunRecordingAndTask
(
JobTask
jobTask
)
throws
UnknownHostException
,
ParseException
{
public
void
saveRunRecordingAndTask
(
JobTask
jobTask
)
throws
UnknownHostException
,
ParseException
{
log
.
info
(
"-----------saveRunRecordingAndTask start【虚节点保存服务】--------------"
);
log
.
info
(
"-----------saveRunRecordingAndTask start【虚节点保存服务】--------------"
);
//根据 map_flow_id查询当前的版本的工作流 使用祝工作流的runId 保存到执行记录表和任务表
//根据 map_flow_id查询当前的版本的工作流 使用祝工作流的runId 保存到执行记录表和任务表
Integer
mapFlowId
=
jobTask
.
getMapFlowId
();
Integer
mapFlowId
=
jobTask
.
getMapFlowId
();
...
...
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