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());