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:
zren25
2025-04-14 19:28:12 +08:00
parent 26967db89d
commit a9607e88de
2 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -23,7 +23,7 @@ public class DataMaskingRuleServiceImpl extends ServiceImpl<DataMaskingRuleMappe
log.info("getDataMaskingRuleListByApplicationChannel {}", applicationChannel); log.info("getDataMaskingRuleListByApplicationChannel {}", applicationChannel);
//根据适用渠道applicationChannel获取数据脱敏规则List //根据适用渠道applicationChannel获取数据脱敏规则List
List<DataMaskingRule> dataMaskingRuleList = this.lambdaQuery() List<DataMaskingRule> dataMaskingRuleList = this.lambdaQuery()
// .eq(DataMaskingRule::getApplicationChannel, applicationChannel) .like(DataMaskingRule::getApplicationChannel, applicationChannel)
.eq(DataMaskingRule::getRuleStatus, YesOrNoConstants.YES) .eq(DataMaskingRule::getRuleStatus, YesOrNoConstants.YES)
.eq(DataMaskingRule::getIsDeleted, YesOrNoConstants.NO) .eq(DataMaskingRule::getIsDeleted, YesOrNoConstants.NO)
.list(); .list();

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

@@ -88,19 +88,27 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
RunMaskingRuleInput runMaskingRuleInput = new RunMaskingRuleInput(); RunMaskingRuleInput runMaskingRuleInput = new RunMaskingRuleInput();
runMaskingRuleInput.setDataMaskingRules(maskingRuleItems); runMaskingRuleInput.setDataMaskingRules(maskingRuleItems);
Map<String, Object> inputMap = new HashMap(); Map<String, Object> inputMap = new HashMap();
DiFyReq diFyImageReq = new DiFyReq(); DiFyReq diFyImageReq = new DiFyReq();
diFyImageReq.setUser(ConstantStr.INTELLIGENT_CUSTOMER_4IN1); diFyImageReq.setUser(ConstantStr.INTELLIGENT_CUSTOMER_4IN1);
diFyImageReq.setFlowId(fourInOneToken); diFyImageReq.setFlowId(fourInOneToken);
inputMap.put("workOrderContent", fourInOneRequestDTO.getWorkOrderContent()); runMaskingRuleInput.setOldStr(fourInOneRequestDTO.getWorkOrderContent());
inputMap.put("relationCorpusContent", fourInOneRequestDTO.getRelationCorpusContent()); String corkOrderContent = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput);
inputMap.put("workOrderContent", corkOrderContent);
runMaskingRuleInput.setOldStr(fourInOneRequestDTO.getRelationCorpusContent());
String relationCorpusContent = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput);
inputMap.put("relationCorpusContent", relationCorpusContent);
inputMap.put("laiyuan",fourInOneRequestDTO.getWorkOrderSource()); inputMap.put("laiyuan",fourInOneRequestDTO.getWorkOrderSource());
inputMap.put("workOrderId",fourInOneRequestDTO.getWorkOrderId()); inputMap.put("workOrderId",fourInOneRequestDTO.getWorkOrderId());
inputMap.put("aiAnalysisRequestId", aiAnalysisRequestId); inputMap.put("aiAnalysisRequestId", aiAnalysisRequestId);
diFyImageReq.setInputs(inputMap); diFyImageReq.setInputs(inputMap);
// 获取配置 // 获取配置
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode(), JSONObject.toJSONString(fourInOneRequestDTO), aiAnalysisRequestId); JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.INTELLIGENT_CUSTOMER.getCode(), JSONObject.toJSONString(fourInOneRequestDTO), aiAnalysisRequestId);
log.info("runDify execDifyFlow {}",execDifyFlow); log.info("runDify execDifyFlow {}",execDifyFlow);
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){ if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
try { try {
@@ -124,6 +132,7 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
} }
@Override @Override
public void sendMq(Object message) { public void sendMq(Object message) {
rocketMqTemplate.asyncSend(topic, MessageBuilder.withPayload(message).build(), rocketMqTemplate.asyncSend(topic, MessageBuilder.withPayload(message).build(),