From 0abb7ef7e7848693aa91fbade7d63e0ea2db6723 Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Wed, 12 Mar 2025 14:05:35 +0800
Subject: [PATCH] =?UTF-8?q?=E8=84=B1=E6=95=8F=E5=8A=A0=E5=AF=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/MqMessageRecordServiceImpl.java    | 13 +++++++------
 1 file changed, 7 insertions(+), 6 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 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);