From 018c4bb9eb64f05729ab9039d537c323e7448453 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Mon, 1 Jul 2024 15:17:36 +0800
Subject: [PATCH] =?UTF-8?q?hotfix/improve-batch-operation=20-=20=E9=99=90?=
 =?UTF-8?q?=E5=88=B6=E5=90=8C=E6=97=B6=E6=93=8D=E4=BD=9C=E5=90=8C=E4=B8=80?=
 =?UTF-8?q?=E4=B8=AA=E5=AE=9E=E4=BE=8B=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../interceptor/CustomLockProcessInstanceInterceptor.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/interceptor/CustomLockProcessInstanceInterceptor.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/interceptor/CustomLockProcessInstanceInterceptor.java
index cb9f25af6..5906ff39f 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/interceptor/CustomLockProcessInstanceInterceptor.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/interceptor/CustomLockProcessInstanceInterceptor.java
@@ -18,7 +18,6 @@ import org.springframework.data.redis.core.types.Expiration;
 import java.nio.charset.Charset;
 import java.util.Objects;
 import java.util.UUID;
-import java.util.concurrent.TimeUnit;
 
 /**
  * 增加一个拦截器,用来控制多个操作,不允许同时操作同一个实例
@@ -27,7 +26,7 @@ import java.util.concurrent.TimeUnit;
  * @since 2024/7/1 13:51
  */
 public class CustomLockProcessInstanceInterceptor extends AbstractCommandInterceptor {
-    private String key_prefix = "operation:processInstance:";
+    private static final String KEY_PREFIX = "operation:processInstance:";
     /**
      * 解锁脚本，原子操作
      */
@@ -52,7 +51,7 @@ public class CustomLockProcessInstanceInterceptor extends AbstractCommandInterce
             String token = null;
             try {
                 do {
-                    token = getLock(abstractCommand.getProcessInstanceId(), 10 * 1000, 11 * 1000);
+                    token = getLock(KEY_PREFIX + abstractCommand.getProcessInstanceId(), 10 * 1000, 11 * 1000);
                 } while (Objects.isNull(token));
                 return next.execute(config, command, commandExecutor);
             } finally {