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

update - REQ-2364-调整类名

Browse Source
This commit is contained in:
yangqicheng 2024-05-20 19:53:01 +08:00
parent 165dd2e525
commit 06a84d0bcd
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/AsyncJobRetryHandler.java → workflow-engine-server/src/main/java/cn/axzo/workflow/server/xxljob/DeadLetterJobRetryHandler.java
View File

@ -26,7 +26,7 @@ import static com.xxl.job.core.biz.model.ReturnT.FAIL_CODE;
@Component
@RequiredArgsConstructor
@Slf4j
public class AsyncJobRetryHandler extends IJobHandler {
public class DeadLetterJobRetryHandler extends IJobHandler {
@Resource
private BpmnProcessVariableService variableService;
@ -35,7 +35,7 @@ public class AsyncJobRetryHandler extends IJobHandler {
private BpmnProcessJobService jobService;
@Override
@XxlJob("asyncJobRetry")
@XxlJob("deadLetterJobRetry")
public ReturnT<String> execute(String param) {
if (StringUtils.isBlank(param)) {
return new ReturnT<>(FAIL_CODE, "参数不能为空");
@ -50,7 +50,7 @@ public class AsyncJobRetryHandler extends IJobHandler {
}
//设置变量
if (bean.getVariables() != null && !bean.getVariables().isEmpty()) {
variableService.updateVariables(bean.getProcessInstanceId(), bean.variables);
variableService.updateVariables(bean.getProcessInstanceId(), bean.getVariables());
}
//进行重试
jobService.executeDeadLetterJobActionByProcInstId(bean.getProcessInstanceId());