From 5ba35fa6a49a7c0a2a3bc8aac99e2f85ec9d18a4 Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Sun, 27 Apr 2025 16:10:09 +0800
Subject: [PATCH] =?UTF-8?q?=E8=88=86=E6=83=85=E4=BA=8C=E6=9C=9F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/MqMessageRecordServiceImpl.java      | 20 ++++++++++++-------
 1 file changed, 13 insertions(+), 7 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
index 983d488..317c65c 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
@@ -68,8 +68,14 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
     @Value("${dify.user}")
     private String user;
 
-    @Value("${dify.community.targetToken}")
-    private String flowId;
+    @Value("${dify.community.clueAnalysisToken}")
+    private String clueAnalysisToken;
+
+    @Value("${dify.community.caseToken}")
+    private String caseToken;
+
+    @Value("${dify.community.keywordToken}")
+    private String keywordToken;
 
     @Value("${dify.community.imageToken}")
     private String imageFlowId;
@@ -142,11 +148,11 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
     private void processDify(DiFyReq diFyReq, JSONArray difyResult, String aiAnalysisRequestId) throws InterruptedException, ExecutionException {
         // 并行调用三个workflow
         //舆情案件分析
-        CompletableFuture<JSONObject> caseWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(diFyReq,"app-cB5rd2VGIZn95u5GWgAnysj0"));
+        CompletableFuture<JSONObject> caseWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(diFyReq,caseToken));
         //内容主题关键词打标
-        CompletableFuture<JSONObject> keywordWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(diFyReq,"app-zJCgRBAedbOAQQUqx1IOLXNv"));
+        CompletableFuture<JSONObject> keywordWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(diFyReq,keywordToken));
         //litecrm线索分析
-        CompletableFuture<JSONObject> clueAnalysisWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(diFyReq,"app-1NZjZVMl3WEel6zhSGZa2rv9"));
+        CompletableFuture<JSONObject> clueAnalysisWorkFlow = CompletableFuture.supplyAsync(() -> callCommunityWorkFlow(diFyReq,clueAnalysisToken));
         CompletableFuture<Void> allFutures = CompletableFuture.allOf(caseWorkFlow, keywordWorkFlow, clueAnalysisWorkFlow);
         // 等待所有API调用完成
         allFutures.get();
@@ -251,7 +257,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
         aiAnalysisRequestLogsMapper.insert(AiAnalysisRequestLogs.builder()
                 .aiAnalysisRequestId(aiAnalysisRequestId)
                 .businessRequest(message)
-                .difyAgentKey(flowId)
+                .difyAgentKey(clueAnalysisToken+keywordToken+caseToken)
                 .aiAnalysisRequestType(BusinessTypeEnum.COMMUNITYTARGET.getCode())
                 .build());
     }
@@ -457,7 +463,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
 
             DiFyReq diFyReq = new DiFyReq();
             diFyReq.setUser(user);
-            diFyReq.setFlowId(flowId);
+//            diFyReq.setFlowId(flowId);
             diFyReq.setInputs(record);
             JSONObject difResult = (JSONObject) diFyService.getDiFyObject(diFyReq);
             output.setHandleStatus(HandleStatusEnum.ANALYSIS_NORMAL.getCode());