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

fix bug

Browse Source
This commit is contained in:
lxu75
2025-04-17 17:33:33 +08:00
parent ca0b59d98b
commit 841ecec8e9
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -10,6 +10,7 @@ import com.volvo.ai.analytic.center.constant.ClaimVerificationConstant;
import com.volvo.ai.analytic.center.constant.Constant; import com.volvo.ai.analytic.center.constant.Constant;
import com.volvo.ai.analytic.center.dto.req.ClaimVerificationFileDTO; import com.volvo.ai.analytic.center.dto.req.ClaimVerificationFileDTO;
import com.volvo.ai.analytic.center.dto.req.DiFyReq; import com.volvo.ai.analytic.center.dto.req.DiFyReq;
import com.volvo.ai.analytic.center.dto.req.DifyCommunityTargetDTO;
import com.volvo.ai.analytic.center.dto.req.RunMaskingRuleInput; import com.volvo.ai.analytic.center.dto.req.RunMaskingRuleInput;
import com.volvo.ai.analytic.center.entity.*; import com.volvo.ai.analytic.center.entity.*;
import com.volvo.ai.analytic.center.enums.BusinessTypeEnum; import com.volvo.ai.analytic.center.enums.BusinessTypeEnum;
@@ -120,7 +121,8 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
} }
//构建入参 //构建入参
JSONObject fileToDifyDTO = buildFileToDifyParameter(files, claimVerificationFileAnalysisDTO, aiAnalyticBusinessConfigs); JSONObject fileToDifyDTO = buildFileToDifyParameter(files, claimVerificationFileAnalysisDTO, aiAnalyticBusinessConfigs);
//根据aiAnalysisRequestId更新请求日志表的difyRequest字段
syncUpdateDiFyRequest(fileToDifyDTO.toString(), aiAnalysisRequestId);
DiFyReq diFyReq = new DiFyReq(); DiFyReq diFyReq = new DiFyReq();
diFyReq.setUser(BusinessTypeEnum.CLAIM_VERIFICATION.getCode()); diFyReq.setUser(BusinessTypeEnum.CLAIM_VERIFICATION.getCode());
diFyReq.setFlowId(fileToken); diFyReq.setFlowId(fileToken);
@@ -155,6 +157,8 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
.collect(Collectors.joining(" ")); .collect(Collectors.joining(" "));
//组装审计报告workflow入参 //组装审计报告workflow入参
JSONObject parsedAudit = buildAuditToDify(configDataString, claimVerificationFileAnalysisDTO); JSONObject parsedAudit = buildAuditToDify(configDataString, claimVerificationFileAnalysisDTO);
//根据aiAnalysisRequestId更新请求日志表的difyRequest字段
syncUpdateDiFyRequest(parsedAudit.toString(), aiAnalysisRequestId);
DiFyReq diFyReq = new DiFyReq(); DiFyReq diFyReq = new DiFyReq();
diFyReq.setUser(BusinessTypeEnum.CLAIM_VERIFICATION.getCode()); diFyReq.setUser(BusinessTypeEnum.CLAIM_VERIFICATION.getCode());
diFyReq.setFlowId(verificationToken); diFyReq.setFlowId(verificationToken);
@@ -185,6 +189,13 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
} }
} }
@Async
protected void syncUpdateDiFyRequest(String difyQuery, String aiAnalysisRequestId) {
aiAnalysisRequestLogsMapper.update(new AiAnalysisRequestLogs(),
new UpdateWrapper<AiAnalysisRequestLogs>().set("dify_request", difyQuery)
.eq("ai_analysis_request_id", aiAnalysisRequestId));
}
/** /**
* 保存异常日志 * 保存异常日志
* @param errorMessage * @param errorMessage
@@ -203,9 +214,9 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
private JSONObject buildAuditToDify(String configDataString, ClaimVerificationFileDTO claimVerificationFileAnalysisDTO) { private JSONObject buildAuditToDify(String configDataString, ClaimVerificationFileDTO claimVerificationFileAnalysisDTO) {
JSONObject audit = new JSONObject(); JSONObject audit = new JSONObject();
audit.put("analysisRules", configDataString); audit.put("analysisRules", configDataString);
audit.put("diagnosticReport", claimVerificationFileAnalysisDTO.getDiagnosticReport()); audit.put("diagnosticReport", claimVerificationFileAnalysisDTO.getDiagnosticReport().toString());
audit.put("preCheckReport", claimVerificationFileAnalysisDTO.getPreCheckReport()); audit.put("preCheckReport", claimVerificationFileAnalysisDTO.getPreCheckReport().toString());
audit.put("dtcReport", claimVerificationFileAnalysisDTO.getDtcReport()); audit.put("dtcReport", claimVerificationFileAnalysisDTO.getDtcReport().toString());
//脱敏处理 //脱敏处理
List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(Constant.CHANNEL_DCC); List<DataMaskingRule> maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(Constant.CHANNEL_DCC);