Merge branch 'master' into test

workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/FlowableConfiguration.java

@@ -114,7 +114,6 @@ public class FlowableConfiguration {
             configuration.addCustomJobHandler(new AsyncRejectTaskJobHandler(extAxHiTaskInstService));
             configuration.addCustomJobHandler(new AsyncTransferUserTaskJobHandler());
 //            configuration.addCustomJobHandler(new AsyncTermNodeAlterJobHandler(refreshProperties));
-            configuration.addCustomJobHandler(new AsyncCountersignUserTaskJobHandler(extAxHiTaskInstService));
             configuration.addCustomJobHandler(new AsyncActivityLeaveJobHandler(bpmnProcessActivityService));
             configuration.addCustomJobHandler(new AsyncActivityCallbackJobHandler());
             configuration.addCustomJobHandler(new AsyncApproveTaskWithFormJobHandler());

workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/WorkflowEngineStarterProperties.java

@@ -41,6 +41,10 @@ public class WorkflowEngineStarterProperties {
      */
     private Boolean joinContainerGroup = false;
 
+    /**
+     * 是否创建本地调试专用的 GID 消费组
+     */
+    private Boolean createDebugGroup = false;
     /**
      * <h3>该参数只针对<strong color=orange>非</strong>容器环境生效</h3>
      * 配合 joinContainerGroup 使用，且只在 joinContainerGroup = false 时生效
@@ -116,6 +120,14 @@ public class WorkflowEngineStarterProperties {
         this.joinContainerGroup = joinContainerGroup;
     }
 
+    public Boolean getCreateDebugGroup() {
+        return createDebugGroup;
+    }
+
+    public void setCreateDebugGroup(Boolean createDebugGroup) {
+        this.createDebugGroup = createDebugGroup;
+    }
+
     public String getSpecialId() {
         return specialId;
     }

workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/common/condition/NonContainerEnvironmentCondition.java

@@ -44,6 +44,18 @@ public class NonContainerEnvironmentCondition implements Condition {
             return true;
         }
 
+        Boolean createDebugGroup = environment.getProperty("workflow.engine.starter.create-debug-group", Boolean.class);
+        if (Objects.isNull(createDebugGroup)) {
+            // 获取是否创建调试专用消费组
+            createDebugGroup = new WorkflowEngineStarterProperties().getCreateDebugGroup();
+        }
+        if (log.isDebugEnabled()) {
+            log.debug("workflow engine starter create-debug-group status: {} ", createDebugGroup);
+        }
+        if (!createDebugGroup) {
+            return false;
+        }
+
         // 优先外部化配置
         Boolean joinContainerGroup = environment.getProperty("workflow.engine.starter.join-container-group", Boolean.class);
         if (Objects.isNull(joinContainerGroup)) {

workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/check/ImplementationReadyChecker.java

@@ -72,10 +72,10 @@ public class ImplementationReadyChecker implements ApplicationListener<Applicati
         } else {
             int finalResult = getBinaryResult(methodImplemented) | getBinaryResult(methodImplemented2);
             boolean[] booleansAdaptive = toBooleansAdaptive(finalResult);
-            log.error("----------------------------------------");
+            log.warn("----------------------------------------");
-            log.error("最终事件实现情况：(二进制:{})，(十进制:{})", String.format("%4s", Integer.toBinaryString(finalResult)).replace(' ', '0'), finalResult);
+            log.warn("最终事件实现情况：(二进制:{})，(十进制:{})", String.format("%4s", Integer.toBinaryString(finalResult)).replace(' ', '0'), finalResult);
-            log.error("警告：未通过必接事件的校验！未实现的方法：{}，请确保实现了 {} 接口的Bean被Spring扫描，或者在EventConsumer注册了 ProcessInstanceEventEnum 的 EventCode。", String.join(", ", getUnImplementedMethods(booleansAdaptive)), TARGET_INTERFACE.getName());
+            log.warn("警告：未通过必接事件的校验！未实现的方法：{}，请确保实现了 {} 接口的Bean被Spring扫描，或者在EventConsumer注册了 ProcessInstanceEventEnum 的 EventCode。", String.join(", ", getUnImplementedMethods(booleansAdaptive)), TARGET_INTERFACE.getName());
-            log.error("----------------------------------------");
+            log.warn("----------------------------------------");
             sendAlter(context, getUnImplementedMethods(booleansAdaptive));
         }