Browse Source

流程优化

24282 1 năm trước cách đây
mục cha
commit
be861bd5ad

+ 4 - 0
hx-flow/src/main/java/com/fjhx/flow/core/FlowThreadLocalUtil.java

@@ -151,6 +151,10 @@ public class FlowThreadLocalUtil {
         getData().nextHandleUserId = nextHandleUserId;
     }
 
+    public static void remove() {
+        FLOW_HOLDER.remove();
+    }
+
     private static FlowThreadLocalUtil getData() {
         FlowThreadLocalUtil flowThreadLocalData = FLOW_HOLDER.get();
         if (flowThreadLocalData == null) {

+ 6 - 0
hx-flow/src/main/java/com/fjhx/flow/service/flow/impl/FlowProcessServiceImpl.java

@@ -195,6 +195,9 @@ public class FlowProcessServiceImpl implements FlowProcessService {
         // 推送
         pushInitiateMessage(flowId, flowDefinition, nextNodeType, flowExample);
 
+        // 清空ThreadLocal
+        FlowThreadLocalUtil.remove();
+
         return new FlowResult(true);
     }
 
@@ -261,6 +264,9 @@ public class FlowProcessServiceImpl implements FlowProcessService {
         // 消息推送
         pushJumpMessage(context);
 
+        // 清空ThreadLocal
+        FlowThreadLocalUtil.remove();
+
         return flowResult;
     }