feat(REQ-2752) - 新增模块

pom.xml

@@ -56,6 +56,11 @@
                 <artifactId>workflow-engine-api</artifactId>
                 <version>${project.version}</version>
             </dependency>
+            <dependency>
+                <groupId>cn.axzo.workflow</groupId>
+                <artifactId>workflow-engine-axzo-ext</artifactId>
+                <version>${project.version}</version>
+            </dependency>
             <dependency>
                 <groupId>${project.groupId}</groupId>
                 <artifactId>workflow-engine-common</artifactId>
@@ -157,11 +162,12 @@
     </repositories>
     <modules>
         <module>workflow-engine-api</module>
+        <module>workflow-engine-axzo-ext</module>
         <module>workflow-engine-common</module>
         <module>workflow-engine-core</module>
+        <module>workflow-engine-elasticsearch</module>
         <module>workflow-engine-server</module>
         <module>workflow-engine-support</module>
         <module>workflow-engine-spring-boot-starter</module>
-        <module>workflow-engine-elasticsearch</module>
     </modules>
 </project>

workflow-engine-axzo-ext/pom.xml

@@ -0,0 +1,19 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>workflow-engine</artifactId>
+        <groupId>cn.axzo.workflow</groupId>
+        <version>${revision}</version>
+    </parent>
+    <artifactId>workflow-engine-axzo-ext</artifactId>
+    <packaging>jar</packaging>
+    <name>Workflow Engine Axzo Extension</name>
+
+    <dependencies>
+        <dependency>
+            <groupId>cn.axzo.workflow</groupId>
+            <artifactId>workflow-engine-common</artifactId>
+        </dependency>
+    </dependencies>
+</project>

workflow-engine-elasticsearch/pom.xml

@@ -7,6 +7,7 @@
         <version>${revision}</version>
     </parent>
     <artifactId>workflow-engine-elasticsearch</artifactId>
+    <packaging>jar</packaging>
     <name>Workflow Engine ElasticSearch</name>
 
     <properties>
@@ -17,6 +18,10 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>cn.axzo.workflow</groupId>
+            <artifactId>workflow-engine-axzo-ext</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.elasticsearch.client</groupId>
             <artifactId>elasticsearch-rest-high-level-client</artifactId>

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

@@ -5,6 +5,9 @@ import cn.axzo.workflow.common.util.ThreadUtil;
 import static cn.axzo.workflow.common.enums.RpcInvokeModeEnum.ASYNC;
 import static cn.axzo.workflow.common.enums.RpcInvokeModeEnum.SYNC;
 import cn.axzo.workflow.client.annotation.WorkflowEngineFeignClient;
+import cn.axzo.workflow.common.annotation.Manageable;
+import cn.axzo.workflow.common.model.request.bpmn.activity.BpmnActivityTimeoutCallbackDTO;
+import cn.axzo.workflow.common.model.request.bpmn.activity.BpmnActivityTimeoutTriggerDTO;
 import cn.axzo.workflow.common.model.request.bpmn.task.BpmnActivitySetAssigneeDTO;
 import cn.axzo.workflow.common.model.request.bpmn.task.BpmnActivityTriggerDTO;
 import cn.azxo.framework.common.model.CommonResponse;
@@ -16,7 +19,6 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 import javax.validation.constraints.NotBlank;
 import cn.axzo.workflow.common.annotation.InvokeMode;
-import cn.axzo.workflow.common.annotation.Manageable;
 import cn.axzo.workflow.common.model.request.bpmn.process.BpmnProcessInstanceAbortDTO;
 import cn.axzo.workflow.common.model.request.bpmn.process.BpmnProcessInstanceAdminPageReqVO;
 import cn.axzo.workflow.common.model.request.bpmn.process.BpmnProcessInstanceCancelDTO;

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

@@ -28,6 +28,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 import javax.validation.constraints.NotBlank;
 import javax.validation.constraints.NotNull;
+import cn.axzo.workflow.common.model.request.bpmn.activity.BpmnActivityTimeoutCallbackDTO;
+import cn.axzo.workflow.common.model.request.bpmn.activity.BpmnActivityTimeoutTriggerDTO;
 import cn.axzo.workflow.common.model.request.bpmn.task.BpmnActivitySetAssigneeDTO;
 import cn.axzo.workflow.common.model.request.bpmn.task.BpmnActivityTriggerDTO;
 import cn.axzo.workflow.common.model.request.bpmn.process.BpmnProcessInstanceAbortDTO;
@@ -240,6 +242,26 @@ public interface WorkflowManageService {
     @InvokeMode(SYNC)
     List<String> getModelTenantIds();
 
+    /**
+     * 该功能应该利用引擎的 TimerBoundaryEvent 来实现，但为了简便，先利用引擎的任务调度来实现
+     *
+     * @return
+     */
+    @PostMapping("/api/process/activity/timeout/trigger")
+    @Manageable
+    @Operation(summary = "设置指定业务节点定时继续往下执行")
+    Boolean setTimeoutTrigger(@Validated @RequestBody BpmnActivityTimeoutTriggerDTO dto);
+
+    /**
+     * 为指定业务节点设置定时回调
+     *
+     * @return
+     */
+    @Manageable
+    @PostMapping("/api/process/activity/timeout/callback")
+    @Operation(summary = "设置指定业务节点定时回调")
+    Boolean setTimeoutCallback(@Validated @RequestBody BpmnActivityTimeoutCallbackDTO dto);
+
     /**
      * 创建审批流程并带上表单
      *