wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update(REQ-2324) - 控制异常3次重试报错信息，仅在最后一次重试仍失败的时候提示

Browse Source
This commit is contained in:
wangli 2024-05-27 19:45:41 +08:00
parent 16b2c80ab7
commit 43e5e1219f
4 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineNoticeEventListener.java
View File

@ -63,43 +63,43 @@ public class EngineNoticeEventListener extends AbstractFlowableEventListener {
stopWatch.start("PUSH-NOTICE Event Execution Time");
getOrderedListeners().forEach(i -> i.onNotice(event));
stopWatch.stop();
log.info("PUSH-NOTICE StopWatch : running time = " + stopWatch.getTotalTimeSeconds() + " 's,processInstanceId: {}", event.getProcessInstanceId());
log.info("PUSH-NOTICE StopWatch : running time = {} 's,processInstanceId: {}", stopWatch.getTotalTimeSeconds(), event.getProcessInstanceId());
break;
case PENDING_PUSH:
stopWatch.start("PUSH-PENDING Event Execution Time");
getOrderedListeners().forEach(i -> i.onPendingPush(event));
stopWatch.stop();
log.info("PUSH-PENDING StopWatch : running time = " + stopWatch.getTotalTimeSeconds() + " 's,processInstanceId: {}", event.getProcessInstanceId());
log.info("PUSH-PENDING StopWatch : running time = {} 's,processInstanceId: {}", stopWatch.getTotalTimeSeconds(), event.getProcessInstanceId());
break;
case PENDING_COMPLETE:
stopWatch.start("PUSH-PENDING-COMPLETE Event Execution Time");
getOrderedListeners().forEach(i -> i.onPendingComplete(event));
stopWatch.stop();
log.info("PUSH-PENDING-COMPLETE StopWatch : running time = " + stopWatch.getTotalTimeSeconds() + " 's,processInstanceId: {}", event.getProcessInstanceId());
log.info("PUSH-PENDING-COMPLETE StopWatch : running time = {} 's,processInstanceId: {}", stopWatch.getTotalTimeSeconds(), event.getProcessInstanceId());
break;
case PENDING_ROLLBACK:
stopWatch.start("PUSH-PENDING-ROLLBACK Event Execution Time");
getOrderedListeners().forEach(i -> i.onPendingRollback(event));
stopWatch.stop();
log.info("PUSH-PENDING-ROLLBACK StopWatch : running time = " + stopWatch.getTotalTimeSeconds() + " 's");
log.info("PUSH-PENDING-ROLLBACK StopWatch : running time = {} 's", stopWatch.getTotalTimeSeconds());
break;
case CARBON_COPY:
stopWatch.start("CARBON-COPY Event Execution Time");
getOrderedListeners().forEach(i -> i.onCarbonCopy(event));
stopWatch.stop();
log.info("CARBON-COPY StopWatch : running time = " + stopWatch.getTotalTimeSeconds() + " 's,processInstanceId: {}", event.getProcessInstanceId());
log.info("CARBON-COPY StopWatch : running time = {} 's,processInstanceId: {}", stopWatch.getTotalTimeSeconds(), event.getProcessInstanceId());
break;
case CARBON_COPY_COMPLETE:
stopWatch.start("CARBON-COPY-COMPLETE Event Execution Time");
getOrderedListeners().forEach(i -> i.onCarbonCopyComplete(event));
stopWatch.stop();
log.info("CARBON-COPY-COMPLETE StopWatch : running time = " + stopWatch.getTotalTimeSeconds() + " 's,processInstanceId: {}", event.getProcessInstanceId());
log.info("CARBON-COPY-COMPLETE StopWatch : running time = {} 's,processInstanceId: {}", stopWatch.getTotalTimeSeconds(), event.getProcessInstanceId());
break;
case SMS:
stopWatch.start("SMS Event Execution Time");
getOrderedListeners().forEach(i -> i.onSms(event));
stopWatch.stop();
log.info("SMS StopWatch : running time = " + stopWatch.getTotalTimeSeconds() + " 's,processInstanceId: {}", event.getProcessInstanceId());
log.info("SMS StopWatch : running time = {} 's,processInstanceId: {}", stopWatch.getTotalTimeSeconds(), event.getProcessInstanceId());
break;
default:
}

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/common/aspectj/ErrorReportAspect.java
View File

@ -65,7 +65,7 @@ public class ErrorReportAspect implements Ordered {
watch.start(signature.toShortString());
Object result = joinPoint.proceed();
watch.stop();
log.info("StopWatch '" + watch.getLastTaskName() + "': running time = " + watch.getTotalTimeSeconds() + " s");
log.info("StopWatch '{}': running time = {} 's", watch.getLastTaskName(), watch.getTotalTimeSeconds());
if (!signature.toShortString().contains("ExtAxApiLogServiceImpl")) {
String type = getType(joinPoint);

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/delegate/AbstractBpmnTaskAssigneeSelector.java
View File

@ -115,7 +115,7 @@ public abstract class AbstractBpmnTaskAssigneeSelector implements BpmnTaskAssign
ApiResult<T> result = supplier.get();
stopWatch.stop();
log.info("{}-Cost:{}, Result: {}", operatorDesc,
"API StopWatch '" + stopWatch.getId() + "': running time = " + stopWatch.getTotalTimeSeconds() + " s",
"API StopWatch '" + stopWatch.getId() + "': running time = " + stopWatch.getTotalTimeSeconds() + " 's",
JSONUtil.toJsonStr(result));
try {
if (stopWatch.getTotalTimeSeconds() > executionStartListener.getApiTimeout()) {

4
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ErrorReporterEventListener.java
View File

@ -50,7 +50,9 @@ public class ErrorReporterEventListener implements BpmnAsyncJobEventListener {
} else if (Lists.newArrayList("live", "master").contains(profile)) {
reporterType = ReporterType.ONLY_LOG;
}
reporterType.executeAction(profile, "异步任务执行异常, 剩余重试次数:" + job.getRetries(), sendDingTalk, new Object[]{job}, "act_ru_job", throwable, false);
if (job.getRetries() <= 1) {
reporterType.executeAction(profile, "异步任务执行异常, 重试 3 次后仍未成功", sendDingTalk, new Object[]{job}, "act_ru_job", throwable, false);
}
}
@Override