脱敏加密

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

@@ -137,6 +137,11 @@ 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);