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 99d25f3..bb65d68 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
@@ -129,7 +129,13 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
             DifyCommunityTargetDTO difyCommunityTargetDTO = new DifyCommunityTargetDTO();
             difyCommunityTargetDTO.setTargetId(communityTargetDTO.getTargetId());
             difyCommunityTargetDTO.setTargetType(communityTargetDTO.getTargetType());
-            difyCommunityTargetDTO.setTargetContent(textContent + sb);
+            //脱敏处理
+            List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(Constant.CHANNEL_DCC);
+            RunMaskingRuleInput runMaskingRuleInput = new RunMaskingRuleInput();
+            runMaskingRuleInput.setDataMaskingRules(maskingRuleItems);
+            runMaskingRuleInput.setOldStr(textContent + sb);
+            String corpusChat = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput);
+            difyCommunityTargetDTO.setTargetContent(corpusChat);
 
             //根据aiAnalysisRequestId更新请求日志表的difyRequest字段
             syncUpdateDiFyRequest(difyCommunityTargetDTO, aiAnalysisRequestId);
@@ -137,11 +143,6 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
             DiFyReq diFyReq = new DiFyReq();
             diFyReq.setUser(user);
             diFyReq.setFlowId(flowId);
-            List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(Constant.CHANNEL_DCC);
-
-            RunMaskingRuleInput runMaskingRuleInput = new RunMaskingRuleInput();
-            runMaskingRuleInput.setDataMaskingRules(maskingRuleItems);
-
             diFyReq.setInputs(difyCommunityTargetDTO);
             //调用舆情文本分析dify工作流
             difResult = (JSONObject) diFyService.getDiFyObject(diFyReq);