admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

脱敏加密

Browse Source
This commit is contained in:
lxu75
2025-03-12 14:05:35 +08:00
parent 5da4701e61
commit 0abb7ef7e7
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
View File

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