[waterflow] waterflow性能优化回合

Author: FUNK6666

app-builder/jane/plugins/aipp-plugin/src/main/java/modelengine/fit/jober/aipp/service/impl/AppChatServiceImpl.java

@@ -12,7 +12,6 @@
 import static modelengine.fit.jober.aipp.constants.AippConst.BUSINESS_INFOS_KEY;
 import static modelengine.fit.jober.aipp.constants.AippConst.BUSINESS_INPUT_KEY;
 import static modelengine.fit.jober.aipp.enums.AppTypeEnum.APP;
-import static modelengine.fit.jober.aipp.service.impl.AippRunTimeServiceImpl.getMetaByAppId;
 
 import modelengine.fit.jade.waterflow.FlowsService;
 import modelengine.fit.jane.common.entity.OperationContext;
@@ -41,7 +40,12 @@
 import modelengine.fit.jober.aipp.service.AippLogService;
 import modelengine.fit.jober.aipp.service.AippRunTimeService;
 import modelengine.fit.jober.aipp.service.AppChatService;
-import modelengine.fit.jober.aipp.util.*;
+import modelengine.fit.jober.aipp.util.AippLogUtils;
+import modelengine.fit.jober.aipp.util.AppUtils;
+import modelengine.fit.jober.aipp.util.CacheUtils;
+import modelengine.fit.jober.aipp.util.FlowUtils;
+import modelengine.fit.jober.aipp.util.JsonUtils;
+import modelengine.fit.jober.aipp.util.UUIDUtil;
 import modelengine.fit.jober.common.ServerInternalException;
 import modelengine.fitframework.annotation.Component;
 import modelengine.fitframework.annotation.Value;

app-builder/waterflow/java/waterflow-service/src/main/java/modelengine/fit/waterflow/common/utils/UUIDUtil.java

@@ -0,0 +1,46 @@
+/*---------------------------------------------------------------------------------------------
+ *  Copyright (c) 2025 Huawei Technologies Co., Ltd. All rights reserved.
+ *  This file is a part of the ModelEngine Project.
+ *  Licensed under the MIT License. See License.txt in the project root for license information.
+ *--------------------------------------------------------------------------------------------*/
+
+package modelengine.fit.waterflow.common.utils;
+
+import java.util.UUID;
+import java.util.concurrent.ThreadLocalRandom;
+
+/**
+ * Uuid的Utils类。
+ *
+ * @author 孙怡菲
+ * @since 1.0
+ */
+public class UUIDUtil {
+    /**
+     * 随机生成uuid。
+     *
+     * @return 随机生成的uuid的 {@link String}。
+     */
+    public static String uuid() {
+        return UUID.randomUUID().toString().replace("-", "");
+    }
+
+    /**
+     * 使用线程本地随机数生成UUID。
+     * 生成的 UUID 在唯一性和不可预测性上可能不如 UUID.randomUUID()，但在性能上有显著提升
+     *
+     * @return 生成的UUID。
+     */
+    public static String fastUuid() {
+        long mostSigBits = ThreadLocalRandom.current().nextLong();
+        long leastSigBits = ThreadLocalRandom.current().nextLong();
+
+        // 设置版本4和变体IETF
+        mostSigBits &= 0xffffffffffff0fffL;
+        mostSigBits |= 0x0000000000004000L;
+        leastSigBits &= 0x3fffffffffffffffL;
+        leastSigBits |= 0x8000000000000000L;
+
+        return new UUID(mostSigBits, leastSigBits).toString().replace("-", "");
+    }
+}

app-builder/waterflow/java/waterflow-service/src/main/java/modelengine/fit/waterflow/flowsengine/domain/flows/context/repo/flowcontext/FlowContextPersistRepo.java

@@ -169,24 +169,17 @@ public void save(List<FlowContext<FlowData>> flowContexts) {
         if (flowContexts == null || flowContexts.size() == 0) {
             return;
         }
-        log.warn("save before after");
         FlowContextPO flowContextPO = contextMapper.find(flowContexts.get(0).getId());
-        log.warn("save find after");
         List<FlowContextPO> flowContextPOS = flowContexts.stream().map(this::serializer).collect(Collectors.toList());
-        log.warn("save after serializer");
         if (flowContextPO == null) {
             contextMapper.batchCreate(flowContextPOS);
-            log.warn("save after batchCreate");
         } else {
             batchUpdate(flowContextPOS);
-            log.warn("save after batchUpdate");
         }
     }
 
     private void batchUpdate(List<FlowContextPO> flowContextPOS) {
-        log.warn("batchUpdate before");
         contextMapper.batchUpdate(flowContextPOS);
-        log.warn("batchUpdate after");
     }
 
     @Override

app-builder/waterflow/java/waterflow-service/src/main/java/modelengine/fit/waterflow/flowsengine/utils/OhScriptExecutor.java

@@ -16,8 +16,8 @@
 import modelengine.fit.ohscript.script.interpreter.ASTEnv;
 import modelengine.fit.ohscript.script.parser.AST;
 import modelengine.fit.ohscript.script.parser.ParserBuilder;
-import modelengine.fit.ohscript.util.UUIDUtil;
 import modelengine.fit.waterflow.common.Constant;
+import modelengine.fit.waterflow.common.utils.UUIDUtil;
 import modelengine.fit.waterflow.flowsengine.domain.flows.context.FlowData;
 import modelengine.fitframework.log.Logger;
 import modelengine.fitframework.util.ObjectUtils;