From 370acd0d29132a4a175f658ea04d979707614952 Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Fri, 19 Sep 2025 21:00:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=BD=8D=E4=B8=8D=E6=8E=A8lto?= =?UTF-8?q?=E3=80=82=E5=8A=A0=E6=97=A5=E5=BF=97getFlowId?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java | 2 +- .../center/service/impl/TmTelephoneCorpusServiceImpl.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java index 761942b..77a91a9 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java @@ -70,7 +70,7 @@ public class DiFyServiceImpl implements DiFyService{ } @Override - public synchronized JSONObject executeDifyFlow(DiFyReq diFyReq, String businessType, String businessData, String oldAiAnalysisRequestId) { + public JSONObject executeDifyFlow(DiFyReq diFyReq, String businessType, String businessData, String oldAiAnalysisRequestId) { String aiAnalysisRequestId = StringUtils.isEmpty(oldAiAnalysisRequestId)? AiAnalysisUtils.getAiAnalysisRequestId(businessType):oldAiAnalysisRequestId; try { Map inputMap = JSON.parseObject(JSONObject.toJSONString(diFyReq.getInputs()),Map.class); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java index 1a2f011..4acf299 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java @@ -193,6 +193,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl { try { log.info("铭牌语料可用许可授权数，客户画像场景={}", semaphore.availablePermits()); + Thread.sleep(2000); // 获取许可 - 如果没有可用许可会阻塞等待 semaphore.acquire(); // 创建新的DiFyReq对象以避免线程安全问题