From 3e15c8b9583861175a0d92c3b081ae39dca4dd10 Mon Sep 17 00:00:00 2001 From: diaobisong Date: Fri, 22 Mar 2024 11:38:23 +0800 Subject: [PATCH] fix code --- .../main/java/com/java3y/austin/common/domain/TaskInfo.java | 2 +- .../java/com/java3y/austin/handler/handler/BaseHandler.java | 3 +++ .../handler/receiver/service/impl/ConsumeServiceImpl.java | 1 + 3 files changed, 5 insertions(+), 1 deletion(-) diff --git a/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java b/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java index 1f14e50..f8b8e3a 100644 --- a/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java +++ b/austin-common/src/main/java/com/java3y/austin/common/domain/TaskInfo.java @@ -86,5 +86,5 @@ public class TaskInfo implements Serializable, ProcessModel { */ private Integer sendAccount; - + private AnchorInfo anchorInfo; } diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java b/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java index 125dbae..e116c30 100644 --- a/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java +++ b/austin-handler/src/main/java/com/java3y/austin/handler/handler/BaseHandler.java @@ -58,6 +58,9 @@ public abstract class BaseHandler implements Handler { return; } logUtils.print(AnchorInfo.builder().state(AnchorState.SEND_FAIL.getCode()).bizId(taskInfo.getBizId()).messageId(taskInfo.getMessageId()).businessId(taskInfo.getBusinessId()).ids(taskInfo.getReceiver()).build()); + if(taskInfo.getAnchorInfo() != null) { + taskInfo.getAnchorInfo().setState(AnchorState.SEND_FAIL.getCode()); + } } diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java index a83054e..905e344 100644 --- a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java +++ b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/service/impl/ConsumeServiceImpl.java @@ -61,6 +61,7 @@ public class ConsumeServiceImpl implements ConsumeService { String topicGroupId = GroupIdMappingUtils.getGroupIdByTaskInfo(CollUtil.getFirst(taskInfoLists.iterator())); for (TaskInfo taskInfo : taskInfoLists) { AnchorInfo info = AnchorInfo.builder().bizId(taskInfo.getBizId()).messageId(taskInfo.getMessageId()).ids(taskInfo.getReceiver()).businessId(taskInfo.getBusinessId()).state(AnchorState.RECEIVE.getCode()).build(); + taskInfo.setAnchorInfo(info); logUtils.print(LogParam.builder().bizType(LOG_BIZ_TYPE).object(taskInfo).build(), info); Task task = context.getBean(Task.class).setTaskInfo(taskInfo); taskPendingHolder.route(topicGroupId).execute(task);