codingapi · xlorne · Mar 11, 2026 · Mar 11, 2026 · Mar 11, 2026 · Mar 11, 2026
diff --git a/...ine-example/src/main/java/com/codingapi/example/handler/MyFlowRecordUrgeEventHandler.java b/...ine-example/src/main/java/com/codingapi/example/handler/MyFlowRecordUrgeEventHandler.java
@@ -0,0 +1,16 @@
+package com.codingapi.example.handler;
+
+import com.codingapi.flow.event.FlowRecordUrgeEvent;
+import com.codingapi.springboot.framework.event.IHandler;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class MyFlowRecordUrgeEventHandler implements IHandler<FlowRecordUrgeEvent> {
+
+    @Override
+    public void handler(FlowRecordUrgeEvent event) {
+        log.info("催办 event:{}",event);
+    }
+}
diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/domain/UrgeInterval.java b/flow-engine-framework/src/main/java/com/codingapi/flow/domain/UrgeInterval.java
@@ -21,6 +21,6 @@ public class UrgeInterval {
     public UrgeInterval(FlowRecord flowRecord) {
         this.processId = flowRecord.getProcessId();
         this.recordId = flowRecord.getId();
-        this.createTime = flowRecord.getCreateTime();
+        this.createTime = System.currentTimeMillis();
     }
 }
diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/exception/FlowStateException.java b/flow-engine-framework/src/main/java/com/codingapi/flow/exception/FlowStateException.java
@@ -114,7 +114,7 @@ public static FlowStateException nodeNotSupportRevoke() {
      *
      * @return exception
      */
-    public static FlowStateException recordNotSupportUrge() {
-        return new FlowStateException("record.notSupportUrge", "record not support urge");
+    public static FlowStateException recordLimitUrgeError() {
+        return new FlowStateException("record.urge.limit", "record urge limit error");
     }
 }
diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/manager/NodeStrategyManager.java b/flow-engine-framework/src/main/java/com/codingapi/flow/manager/NodeStrategyManager.java
@@ -38,7 +38,7 @@ public long getTimeoutTime() {
     /**
      * 是否可合并
      */
-    public boolean isMergeable() {
+    public boolean isEnableMergeable() {
         List<INodeStrategy> strategies = this.strategies;
         for (INodeStrategy strategy : strategies) {
             if (strategy instanceof RecordMergeStrategy) {
@@ -48,6 +48,19 @@ public boolean isMergeable() {
         return false;
     }
 
+    /**
+     * 是否支持撤回
+     */
+    public boolean isEnableRevoke(){
+        List<INodeStrategy> strategies = this.strategies;
+        for (INodeStrategy strategy : strategies) {
+            if (strategy instanceof RevokeStrategy) {
+                return ((RevokeStrategy) strategy).isEnable();
+            }
+        }
+        return false;
+    }
+
     /**
      * 是否按顺序执行的审批策略
      */

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/node/BaseAuditNode.java b/flow-engine-framework/src/main/java/com/codingapi/flow/node/BaseAuditNode.java
@@ -64,7 +64,7 @@ public void fillNewRecord(FlowSession session, FlowRecord flowRecord) {
         NodeStrategyManager nodeStrategyManager = this.strategyManager();
         flowRecord.setTitle(nodeStrategyManager.generateTitle(session));
         flowRecord.setTimeoutTime(nodeStrategyManager.getTimeoutTime());
-        flowRecord.setMergeable(nodeStrategyManager.isMergeable());
+        flowRecord.setMergeable(nodeStrategyManager.isEnableMergeable());
         flowRecord.newRecord();
     }
 

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/pojo/response/FlowContent.java b/flow-engine-framework/src/main/java/com/codingapi/flow/pojo/response/FlowContent.java
@@ -93,7 +93,7 @@ public class FlowContent {
     /**
      * 流程按钮
      */
-    private List<Map<String,Object>> actions;
+    private List<Map<String, Object>> actions;
 
     /**
      * 是否可合并
@@ -130,6 +130,44 @@ public class FlowContent {
      */
     private List<NodeOption> nodes;
 
+    /**
+     * 支持撤销
+     */
+    private boolean revoke;
+
+    /**
+     * 支持催办
+     */
+    private boolean urge;
+
+
+    /**
+     * 设置操作动作按钮
+     *
+     */
+    public void setOperationAction(Workflow workflow, FlowRecord flowRecord) {
+        if (flowRecord == null) {
+            this.revoke = false;
+            this.urge = false;
+        } else {
+            if (flowRecord.isFinish()) {
+                this.revoke = false;
+                this.urge = false;
+            }
+
+            if (flowRecord.isTodo()) {
+                this.revoke = false;
+                this.urge = false;
+            }
+
+            if (flowRecord.isDone() && !flowRecord.isFinish()) {
+                IFlowNode node = workflow.getFlowNode(flowRecord.getNodeId());
+                this.revoke = node.strategyManager().isEnableRevoke();
+                this.urge = workflow.strategyManager().isEnableUrge();
+            }
+        }
+    }
+
 
     public void pushCurrentNode(IFlowNode currentNode) {
         ActionManager actionManager = currentNode.actionManager();
@@ -141,7 +179,7 @@ public void pushCurrentNode(IFlowNode currentNode) {
         this.nodeName = currentNode.getName();
         this.nodeType = currentNode.getType();
         this.fieldPermissions = strategyManager.getFieldPermissions();
-        Map<String,Object> nodeData = currentNode.toMap();
+        Map<String, Object> nodeData = currentNode.toMap();
         this.view = (String) nodeData.get("view");
     }
 
@@ -162,7 +200,7 @@ public void pushRecords(FlowRecord record, List<FlowRecord> mergeRecords) {
         this.title = record.getTitle();
 
         this.todos = new ArrayList<>();
-        for (FlowRecord item : mergeRecords){
+        for (FlowRecord item : mergeRecords) {
             Body body = new Body();
             body.setRecordId(item.getId());
             body.setTitle(item.getTitle());
@@ -173,9 +211,9 @@ public void pushRecords(FlowRecord record, List<FlowRecord> mergeRecords) {
         }
     }
 
-    public void pushHistory(Workflow workflow,List<FlowRecord> historyRecords) {
+    public void pushHistory(Workflow workflow, List<FlowRecord> historyRecords) {
         this.histories = new ArrayList<>();
-        for (FlowRecord item : historyRecords){
+        for (FlowRecord item : historyRecords) {
             IFlowNode node = workflow.getFlowNode(item.getNodeId());
             History history = new History();
             history.setRecordId(item.getId());
@@ -193,18 +231,18 @@ public void pushHistory(Workflow workflow,List<FlowRecord> historyRecords) {
 
     public void pushCurrentOperator(IFlowOperator currentOperator) {
         this.currentOperator = new FlowOperator(currentOperator);
-        this.createOperator =  new FlowOperator(currentOperator);
+        this.createOperator = new FlowOperator(currentOperator);
     }
 
 
     @Data
-    public static class History{
+    public static class History {
         /**
          * 流程编号
          */
         private long recordId;
         /**
-         *  流程标题
+         * 流程标题
          */
         private String title;
 
@@ -246,15 +284,15 @@ public static class History{
     @Data
     public static class Body {
         /**
-         *  流程记录编号
+         * 流程记录编号
          */
         private long recordId;
         /**
-         *  流程标题
+         * 流程标题
          */
         private String title;
         /**
-         *  表单数据
+         * 表单数据
          */
         private Map<String, Object> data;
 

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/record/FlowRecord.java b/flow-engine-framework/src/main/java/com/codingapi/flow/record/FlowRecord.java
@@ -210,7 +210,7 @@ public class FlowRecord {
     private long timeoutTime;
     /**
      * 是否可合并
-     * {@link FlowRecord#getMergeKey()}
+     * {@link FlowRecord#getTodoKey()}
      */
     private boolean mergeable;
     /**
@@ -247,7 +247,7 @@ public class FlowRecord {
      * 数据合并的依据,当开启时值为固定值，否则为随机数据
      * 相同的 {@link FlowRecord#currentOperatorId} {@link FlowRecord#workRuntimeId} {@link FlowRecord#nodeId}字段的数据合并到一条记录上。
      */
-    public String getMergeKey() {
+    public String getTodoKey() {
         if (mergeable) {
             return String.format("%s-%s-%s", currentOperatorId, workRuntimeId, nodeId);
         } else {
@@ -461,7 +461,7 @@ public void notifyRecord(FlowSession flowSession) {
         NodeStrategyManager nodeStrategyManager = currentNode.strategyManager();
         this.setTitle(nodeStrategyManager.generateTitle(flowSession));
         this.setTimeoutTime(nodeStrategyManager.getTimeoutTime());
-        this.setMergeable(nodeStrategyManager.isMergeable());
+        this.setMergeable(nodeStrategyManager.isEnableMergeable());
         this.update(flowSession, true);
         this.notify = true;
         this.forwardOperatorId = 0;

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/record/FlowTodoRecord.java b/flow-engine-framework/src/main/java/com/codingapi/flow/record/FlowTodoRecord.java
@@ -80,7 +80,7 @@ public class FlowTodoRecord {
 
     /**
      * 合并记录id,当存在合并记录数据时待办记录数量不会增加，内容会更新至最新的待办数据信息。
-     * {@link FlowRecord#getMergeKey()}
+     * {@link FlowRecord#getTodoKey()}
      */
     private String mergeKey;
 
@@ -126,7 +126,7 @@ public void update(FlowRecord flowRecord) {
         this.createTime = flowRecord.getCreateTime();
         this.createOperatorId = flowRecord.getCreateOperatorId();
         this.createOperatorName = flowRecord.getCreateOperatorName();
-        this.mergeKey = flowRecord.getMergeKey();
+        this.mergeKey = flowRecord.getTodoKey();
         this.mergeable = flowRecord.isMergeable();
         this.recordId = flowRecord.getId();
         this.timeoutTime = flowRecord.getTimeoutTime();

diff --git a/...ngine-framework/src/main/java/com/codingapi/flow/repository/FlowTodoRecordRepository.java b/...ngine-framework/src/main/java/com/codingapi/flow/repository/FlowTodoRecordRepository.java
@@ -8,7 +8,7 @@ public interface FlowTodoRecordRepository {
 
     void saveAll(List<FlowTodoRecord> margeRecords);
 
-    FlowTodoRecord getByMergeKey(String key);
+    FlowTodoRecord getByTodoKey(String key);
 
     void delete(FlowTodoRecord margeRecord);
 

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/service/FlowRecordSaveService.java b/flow-engine-framework/src/main/java/com/codingapi/flow/service/FlowRecordSaveService.java
@@ -44,7 +44,7 @@ private void saveTodoMargeRecords() {
         List<FlowTodoRecord> flowTodoRecords = new ArrayList<>();
         for (FlowRecord flowRecord : flowRecords) {
             if (flowRecord.isTodo()) {
-                FlowTodoRecord todoMargeRecord = flowTodoRecordRepository.getByMergeKey(flowRecord.getMergeKey());
+                FlowTodoRecord todoMargeRecord = flowTodoRecordRepository.getByTodoKey(flowRecord.getTodoKey());
                 if (todoMargeRecord == null) {
                     todoMargeRecord = new FlowTodoRecord(flowRecord);
                 } else {
@@ -83,7 +83,7 @@ private void removeTodoMergeRecords() {
         for (FlowRecord flowRecord : flowRecords) {
             if (flowRecord.isDone()) {
                 if (flowRecord.isMergeable()) {
-                    FlowTodoRecord todoMargeRecord = flowTodoRecordRepository.getByMergeKey(flowRecord.getMergeKey());
+                    FlowTodoRecord todoMargeRecord = flowTodoRecordRepository.getByTodoKey(flowRecord.getTodoKey());
                     if (todoMargeRecord != null) {
                         List<FlowTodoMerge> margeRelations = flowTodoMergeRepository.findByTodoId(todoMargeRecord.getId());
                         if (margeRelations != null && !margeRelations.isEmpty()) {
@@ -101,7 +101,14 @@ private void removeTodoMergeRecords() {
                         }
                     }
                 } else {
-                    FlowTodoRecord flowTodoRecord = flowTodoRecordRepository.getByMergeKey(flowRecord.getMergeKey());
+                    FlowTodoRecord flowTodoRecord = flowTodoRecordRepository.getByTodoKey(flowRecord.getTodoKey());
+                    if (flowTodoRecord != null) {
+                        flowTodoRecordRepository.delete(flowTodoRecord);
+                    }
+                }
+            }else {
+                if(flowRecord.isRevoked()){
+                    FlowTodoRecord flowTodoRecord = flowTodoRecordRepository.getByTodoKey(flowRecord.getTodoKey());
                     if (flowTodoRecord != null) {
                         flowTodoRecordRepository.delete(flowTodoRecord);
                     }

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/service/FlowRecordService.java b/flow-engine-framework/src/main/java/com/codingapi/flow/service/FlowRecordService.java
@@ -48,7 +48,7 @@ public void saveFlowRecord(FlowRecord flowRecord) {
      * @return 流程合并记录
      */
     public List<FlowRecord> getMergeRecord(String mergeKey){
-        FlowTodoRecord todoRecord = flowTodoRecordRepository.getByMergeKey(mergeKey);
+        FlowTodoRecord todoRecord = flowTodoRecordRepository.getByTodoKey(mergeKey);
         List<FlowTodoMerge> todoMerges = flowTodoMergeRepository.findByTodoId(todoRecord.getId());
         return this.findFlowRecordByIds(todoMerges.stream().map(FlowTodoMerge::getRecordId).toList());
     }

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/service/impl/FlowDetailService.java b/flow-engine-framework/src/main/java/com/codingapi/flow/service/impl/FlowDetailService.java
@@ -86,8 +86,8 @@ private void loadWorkflow(){
 
         private void loadTodoFlowRecords(){
             if(this.flowRecord!=null){
-                if(this.flowRecord.isMergeable()){
-                    List<FlowRecord> margeRecords = flowRecordService.getMergeRecord(flowRecord.getMergeKey());
+                if(this.flowRecord.isMergeable() && this.flowRecord.isTodo()){
+                    List<FlowRecord> margeRecords = flowRecordService.getMergeRecord(flowRecord.getTodoKey());
                     this.flowContent.pushRecords(this.flowRecord, margeRecords);
                 }else {
                     this.flowContent.pushRecords(this.flowRecord,List.of(this.flowRecord));
@@ -122,6 +122,8 @@ public FlowContent create() {
             this.loadCurrentNode();
             this.loadTodoFlowRecords();
             this.loadHistoryRecords();
+
+            flowContent.setOperationAction(this.workflow,this.flowRecord);
             return flowContent;
         }
     }

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/service/impl/FlowUrgeService.java b/flow-engine-framework/src/main/java/com/codingapi/flow/service/impl/FlowUrgeService.java
@@ -71,7 +71,7 @@ public void urge() {
             if (strategyManager.isEnableUrge()) {
                 UrgeStrategy urgeStrategy = strategyManager.getStrategy(UrgeStrategy.class);
                 if (!urgeStrategy.hasUrge(urgeInterval)) {
-                    throw FlowStateException.recordNotSupportUrge();
+                    throw FlowStateException.recordLimitUrgeError();
                 }
             }
         }

diff --git a/flow-engine-framework/src/main/java/com/codingapi/flow/strategy/workflow/UrgeStrategy.java b/flow-engine-framework/src/main/java/com/codingapi/flow/strategy/workflow/UrgeStrategy.java
@@ -56,7 +56,7 @@ public static UrgeStrategy fromMap(Map<String, Object> map) {
     }
 
     /**
-     * 是否有催办
+     * 是否可催办
      */
     public boolean hasUrge(UrgeInterval urgeInterval) {
         long interval = this.interval * 1000L;

diff --git a/...e-framework/src/test/java/com/codingapi/flow/repository/FlowTodoRecordRepositoryImpl.java b/...e-framework/src/test/java/com/codingapi/flow/repository/FlowTodoRecordRepositoryImpl.java
@@ -37,7 +37,7 @@ public void delete(FlowTodoRecord margeRecord) {
     }
 
     @Override
-    public FlowTodoRecord getByMergeKey(String key) {
+    public FlowTodoRecord getByTodoKey(String key) {
         return cacheByMageKey.get(key);
     }
 

diff --git a/flow-engine-framework/src/test/java/com/codingapi/flow/service/FlowMergeableServiceTest.java b/flow-engine-framework/src/test/java/com/codingapi/flow/service/FlowMergeableServiceTest.java
@@ -143,7 +143,7 @@ void mergeableRecords() {
         assertEquals(count, bossRecordList.size());
         assertEquals(count, bossRecordList.stream().filter(FlowRecord::isMergeable).toList().size());
 
-        List<String> mergeIdList = bossRecordList.stream().map(FlowRecord::getMergeKey).toList();
+        List<String> mergeIdList = bossRecordList.stream().map(FlowRecord::getTodoKey).toList();
         Set<String> set = new HashSet<>(mergeIdList);
         assertEquals(1,set.size());
 

diff --git a/...ine-starter-api/src/main/java/com/codingapi/flow/api/controller/FlowRecordController.java b/...ine-starter-api/src/main/java/com/codingapi/flow/api/controller/FlowRecordController.java
@@ -1,10 +1,7 @@
 package com.codingapi.flow.api.controller;
 
 import com.codingapi.flow.operator.IFlowOperator;
-import com.codingapi.flow.pojo.request.FlowActionRequest;
-import com.codingapi.flow.pojo.request.FlowCreateRequest;
-import com.codingapi.flow.pojo.request.FlowDetailRequest;
-import com.codingapi.flow.pojo.request.FlowProcessNodeRequest;
+import com.codingapi.flow.pojo.request.*;
 import com.codingapi.flow.pojo.response.FlowContent;
 import com.codingapi.flow.pojo.response.ProcessNode;
 import com.codingapi.flow.service.FlowService;
@@ -45,6 +42,21 @@ public SingleResponse<Long> create(@RequestBody FlowCreateRequest request) {
     }
 
 
+    @PostMapping("/urge")
+    public Response urge(@RequestBody IdRequest request) {
+        IFlowOperator current = (IFlowOperator) UserContext.getInstance().current();
+        flowService.urge(new FlowUrgeRequest(request.getLongId(),current.getUserId()));
+        return Response.buildSuccess();
+    }
+
+    @PostMapping("/revoke")
+    public Response revoke(@RequestBody IdRequest request) {
+        IFlowOperator current = (IFlowOperator) UserContext.getInstance().current();
+        flowService.revoke(new FlowRevokeRequest(request.getLongId(),current.getUserId()));
+        return Response.buildSuccess();
+    }
+
+
     @PostMapping("/action")
     public Response action(@RequestBody FlowActionRequest request) {
         IFlowOperator current = (IFlowOperator) UserContext.getInstance().current();

diff --git a/...ine-starter-infra/src/main/java/com/codingapi/flow/infra/entity/FlowTodoRecordEntity.java b/...ine-starter-infra/src/main/java/com/codingapi/flow/infra/entity/FlowTodoRecordEntity.java
@@ -78,7 +78,7 @@ public class FlowTodoRecordEntity {
 
     /**
      * 合并记录id,当存在合并记录数据时待办记录数量不会增加，内容会更新至最新的待办数据信息。
-     * {@link FlowRecord#getMergeKey()}
+     * {@link FlowRecord#getTodoKey()}
      */
     private String mergeKey;