update - 完善异步操作相关实现的类注释

workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/context/ActivityOperationContext.java

@@ -1,7 +1,7 @@
 package cn.axzo.workflow.core.common.context;
 
 /**
- * TODO
+ * 活动(节点)相关操作上下文
  *
  * @author wangli
  * @since 2024/4/12 16:43

workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/context/NoticeOperationContext.java

@@ -1,7 +1,7 @@
 package cn.axzo.workflow.core.common.context;
 
 /**
- * TODO
+ * 通知相关操作上下文
  *
  * @author wangli
  * @since 2024/4/12 16:47

workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/context/ProcessOperationContext.java

@@ -1,7 +1,7 @@
 package cn.axzo.workflow.core.common.context;
 
 /**
- * TODO
+ * 流程相关操作上下文
  *
  * @author wangli
  * @since 2024/4/9 22:52

workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/context/TaskOperationContext.java

@@ -8,7 +8,7 @@ import java.util.List;
 import java.util.function.Supplier;
 
 /**
- * TODO
+ * 任务相关操作上下文
  *
  * @author wangli
  * @since 2024/4/9 20:59
@@ -24,23 +24,4 @@ public class TaskOperationContext extends CommonContext<TaskOperationContext> {
         return extAxHiTaskInsts;
     }
 
-    //    private Map<String, List<ExtAxHiTaskInst>> extTaskMap = new HashMap<>();
-//
-//    private Map<String, List<ExtAxHiTaskInst>> getExtTaskMap() {
-//        return extTaskMap;
-//    }
-//
-//    private void setExtTaskMap(String key, List<ExtAxHiTaskInst> taskInstList) {
-//        extTaskMap.put(key, taskInstList);
-//    }
-//
-//    public List<ExtAxHiTaskInst> getExtTaskInstList(String key, Supplier<List<ExtAxHiTaskInst>> supplier) {
-//        if (getExtTaskMap().containsKey(key)) {
-//            return getExtTaskMap().get(key);
-//        }
-//        setExtTaskMap(key, supplier.get());
-//        return getExtTaskInstList(key, supplier);
-//    }
-
-
 }

workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/event/ErrorInfoEvent.java

@@ -7,7 +7,7 @@ import org.flowable.job.api.JobInfo;
 import static cn.axzo.workflow.core.engine.event.ErrorInfoEventType.NEW_ERROR;
 
 /**
- * TODO
+ * 用于异步任务执行过程中出现的异常搜集和告警
  *
  * @author wangli
  * @since 2024/4/17 16:45

workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/event/ErrorInfoEventType.java

@@ -8,7 +8,7 @@ import java.util.ArrayList;
 import java.util.List;
 
 /**
- * TODO
+ * 异步任务异常事件类型
  *
  * @author wangli
  * @since 2024/4/17 16:47

workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/exception/handler/CustomAsyncRunnableExecutionExceptionHandler.java

@@ -1,21 +1,24 @@
 package cn.axzo.workflow.core.engine.job.exception.handler;
 
 import cn.axzo.workflow.core.engine.event.ErrorInfoEvent;
+import lombok.extern.slf4j.Slf4j;
 import org.flowable.common.engine.api.delegate.event.FlowableEventDispatcher;
 import org.flowable.job.api.JobInfo;
 import org.flowable.job.service.JobServiceConfiguration;
 import org.flowable.job.service.impl.asyncexecutor.AsyncRunnableExecutionExceptionHandler;
 
 /**
- * TODO
+ * 自定义的异步任务执行异常处理器
  *
  * @author wangli
  * @since 2024/4/17 16:03
  */
+@Slf4j
 public class CustomAsyncRunnableExecutionExceptionHandler implements AsyncRunnableExecutionExceptionHandler {
 
     @Override
     public boolean handleException(JobServiceConfiguration jobServiceConfiguration, JobInfo job, Throwable exception) {
+        log.info("discover exception, jobId: {}, exception: {}", job.getId(), exception.getMessage());
 
         FlowableEventDispatcher eventDispatcher = jobServiceConfiguration.getEventDispatcher();
 

workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/BpmnAsyncExecutionErrorEventListener.java

@@ -4,7 +4,7 @@ import org.flowable.job.api.JobInfo;
 import org.springframework.core.Ordered;
 
 /**
- * TODO
+ * 对引擎内异步任务执行异常的事件扩展监听接口
  *
  * @author wangli
  * @since 2024/4/17 16:54

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

@@ -9,6 +9,8 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 /**
+ * 异步任务执行异常的扩展监听器
+ *
  * @author wangli
  * @since 2024/4/17 16:59
  */