fix code

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;
 }

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());
+        }
     }
 
 

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);