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
eb11d56a
Commit
eb11d56a
authored
Aug 06, 2020
by
huangfusuper
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修正邮箱告警有不对的地方
parent
68a0e9f2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
5 additions
and
1 deletion
+5
-1
RunRecordingAndJobTaskServiceImpl.java
...ce/mapservice/impl/RunRecordingAndJobTaskServiceImpl.java
+1
-1
ClosingExampleThreadRunHelper.java
...com/byit/thread/helper/ClosingExampleThreadRunHelper.java
+4
-0
No files found.
byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/RunRecordingAndJobTaskServiceImpl.java
View file @
eb11d56a
...
@@ -63,7 +63,7 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
...
@@ -63,7 +63,7 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
* @throws Exception
* @throws Exception
*/
*/
@Override
@Override
public
void
saveRunRecordingAndTask
(
JobTask
jobTask
,
boolean
repair
)
throws
UnknownHostException
,
ParseException
{
public
void
saveRunRecordingAndTask
(
JobTask
jobTask
,
boolean
repair
)
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
();
...
...
byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/ClosingExampleThreadRunHelper.java
View file @
eb11d56a
package
com
.
byit
.
thread
.
helper
;
package
com
.
byit
.
thread
.
helper
;
import
com.byit.enums.EmailEnum
;
import
com.byit.enums.NodeRunStatusPropertyEnum
;
import
com.byit.enums.NodeRunStatusPropertyEnum
;
import
com.byit.enums.RunRecordingEnum
;
import
com.byit.enums.RunRecordingEnum
;
import
com.byit.event.EndFlowEvent
;
import
com.byit.event.EndFlowEvent
;
...
@@ -68,6 +69,7 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
...
@@ -68,6 +69,7 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
runRecording
.
setFlowRunResult
(
runCode
);
runRecording
.
setFlowRunResult
(
runCode
);
log
.
debug
(
"----------------扫描到有完结的运行实例{},{}-------------"
,
runCode
,
RunRecordingEnum
.
FLOW_STATUS_IS_END
.
getCode
());
log
.
debug
(
"----------------扫描到有完结的运行实例{},{}-------------"
,
runCode
,
RunRecordingEnum
.
FLOW_STATUS_IS_END
.
getCode
());
runRecording
.
setFlowStatus
(
RunRecordingEnum
.
FLOW_STATUS_IS_END
.
getCode
());
runRecording
.
setFlowStatus
(
RunRecordingEnum
.
FLOW_STATUS_IS_END
.
getCode
());
runRecording
.
setIsAlarm
(
EmailEnum
.
IS_ALARM_NO
.
getCode
());
runRecording
.
setEndTime
(
new
Date
());
runRecording
.
setEndTime
(
new
Date
());
runRecordingService
.
updateRunRecordingById
(
runRecording
);
runRecordingService
.
updateRunRecordingById
(
runRecording
);
applicationEventPublisher
.
publishEvent
(
new
EndFlowEvent
(
this
,
flowId
));
applicationEventPublisher
.
publishEvent
(
new
EndFlowEvent
(
this
,
flowId
));
...
@@ -76,6 +78,8 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
...
@@ -76,6 +78,8 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
String
reRunId
=
runRecording
.
getReRunId
();
String
reRunId
=
runRecording
.
getReRunId
();
Integer
flowId1
=
runRecording
.
getFlowId
();
Integer
flowId1
=
runRecording
.
getFlowId
();
RunRecording
runRecordingByFlowIdAndRunId
=
runRecordingService
.
findRunRecordingByFlowIdAndRunId
(
flowId1
,
reRunId
);
RunRecording
runRecordingByFlowIdAndRunId
=
runRecordingService
.
findRunRecordingByFlowIdAndRunId
(
flowId1
,
reRunId
);
runRecordingByFlowIdAndRunId
.
setIsAlarm
(
EmailEnum
.
IS_ALARM_NO
.
getCode
());
runRecordingByFlowIdAndRunId
.
setEndTime
(
new
Date
());
runRecordingByFlowIdAndRunId
.
setFlowStatus
(
RunRecordingEnum
.
FLOW_STATUS_IS_END
.
getCode
());
runRecordingByFlowIdAndRunId
.
setFlowStatus
(
RunRecordingEnum
.
FLOW_STATUS_IS_END
.
getCode
());
runRecordingService
.
updateRunRecordingById
(
runRecordingByFlowIdAndRunId
);
runRecordingService
.
updateRunRecordingById
(
runRecordingByFlowIdAndRunId
);
}
}
...
...
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