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:
ZLI263
2025-09-17 11:21:27 +08:00
parent 020a40d013
commit 9031a352bc
2 changed files with 54 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -235,67 +235,66 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
@Override
public ResultMsg<Object> updateNameplate(String message) {
if(StringUtils.isNotEmpty(message)){
log.info("updateNameplate 回调 message: {}", message);
JSONObject analysisResp = JSONObject.parseObject(message);
String aiAnalysisRequestId = analysisResp.getString(aiAnalysisRequestIdFinal);
String difyResponse = analysisResp.getString("difyResponse");
String customerFlowId = analysisResp.getString("customerFlowId");
try {
String text = analysisResp.getString(outputsFinal);
JSONObject outputs = JSONObject.parseObject(text);
String businessId = outputs.getString("businessId");
String businessType = outputs.getString("businessType");
if(StringUtils.isNotEmpty(message)){
log.info("updateNameplate 回调 message: {}", message);
JSONObject analysisResp = JSONObject.parseObject(message);
String aiAnalysisRequestId = analysisResp.getString(aiAnalysisRequestIdFinal);
String difyResponse = analysisResp.getString("difyResponse");
String customerFlowId = analysisResp.getString("customerFlowId");
String businessType;
if (aiAnalysisRequestId==null){
aiAnalysisRequestId = outputs.getString(aiAnalysisRequestIdFinal);
}
log.info("aiAnalysisRequestId is : ",analysisResp.getString(aiAnalysisRequestIdFinal));
log.info("businessType is : ", businessType);
if (aiAnalysisRequestId.indexOf(BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode())>=0){
businessType=BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode();
customerFlowId = businessId;
log.info("客户画像场景 businessType is : ", businessType);
}else {
businessType = BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode();
}
Optional.ofNullable(aiAnalysisRequestLogsService.queryByAiAnalysisRequestId(aiAnalysisRequestId))
.orElseThrow(() -> new IllegalArgumentException("AiAnalysisRequestId查询对象为空！"));
log.info("1111111111111,{}", customerFlowId);
AiAnalysisRequestLogs aiAnalysisRequestLogs = new AiAnalysisRequestLogs();
aiAnalysisRequestLogs.setAiAnalysisRequestId(aiAnalysisRequestId);
aiAnalysisRequestLogs.setDifyResponse(difyResponse);
JSONObject difyJson = JSONObject.parseObject(difyResponse);
aiAnalysisRequestLogs.setBusinessResponse(difyJson.getString(outputsFinal));
aiAnalysisRequestLogs.setAiAnalysisRequestType(businessType);
aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(aiAnalysisRequestLogs);
log.info("333333333333");
LambdaQueryWrapper<TmNameplateCorpus> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(TmNameplateCorpus::getCustomerFlowId, customerFlowId);
List<TmNameplateCorpus> tmNameplateCorpusList = tmNameplateCorpusMapper.selectList(queryWrapper);
if (CollectionUtils.isNotEmpty(tmNameplateCorpusList)){ //这是补偿机制
log.info("66666666666666");
sendNameplateLto(difyJson,aiAnalysisRequestId, tmNameplateCorpusList.get(0),businessType);
LambdaQueryWrapper<AiAnalysisErrors> errorQueryWrapper = new LambdaQueryWrapper<>();
errorQueryWrapper.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisRequestId);
errorQueryWrapper.eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0");
errorQueryWrapper.eq(AiAnalysisErrors::getIsDeleted, "0");
AiAnalysisErrors oldAiAnalysisErrors = aiAnalysisErrorsMapper.selectOne(errorQueryWrapper);
if (oldAiAnalysisErrors != null) {
aiAnalysisErrorsMapper.update(AiAnalysisErrors.builder().aiAnalysisRequestId(oldAiAnalysisErrors.getAiAnalysisRequestId()).aiAnalysisErrorHandlingStatus("1").build(), errorQueryWrapper);
AiAnalysisRequestLogs aiAnalysisRequestLogs = new AiAnalysisRequestLogs();
JSONObject difyJson =null;
if (StringUtils.isEmpty(customerFlowId)){ // 客户画像场景
log.info(" customerFlowId 为空,客户画像场景");
String text = analysisResp.getString(outputsFinal);
JSONObject outputs = JSONObject.parseObject(text);
customerFlowId = outputs.getString("businessId");
aiAnalysisRequestId=analysisResp.getString(aiAnalysisRequestIdFinal);
businessType=BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode();
aiAnalysisRequestLogs.setBusinessResponse(text);
}else { //总结+分类
businessType = BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode();
difyJson = JSONObject.parseObject(difyResponse);
aiAnalysisRequestLogs.setBusinessResponse(difyJson.getString(outputsFinal));
}
}else {
log.info("555555555555");
Optional.ofNullable(aiAnalysisRequestLogsService.queryByAiAnalysisRequestId(aiAnalysisRequestId))
.orElseThrow(() -> new IllegalArgumentException("AiAnalysisRequestId查询对象为空！"));
log.info("1111111111111,{}", customerFlowId);
aiAnalysisRequestLogs.setAiAnalysisRequestId(aiAnalysisRequestId);
aiAnalysisRequestLogs.setDifyResponse(difyResponse);
aiAnalysisRequestLogs.setAiAnalysisRequestType(businessType);
aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(aiAnalysisRequestLogs);
log.info("333333333333");
LambdaQueryWrapper<TmNameplateCorpus> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(TmNameplateCorpus::getCustomerFlowId, customerFlowId);
List<TmNameplateCorpus> tmNameplateCorpusList = tmNameplateCorpusMapper.selectList(queryWrapper);
if (CollectionUtils.isNotEmpty(tmNameplateCorpusList)){ //这是补偿机制
log.info("66666666666666");
sendNameplateLto(difyJson,aiAnalysisRequestId, tmNameplateCorpusList.get(0),businessType);
LambdaQueryWrapper<AiAnalysisErrors> errorQueryWrapper = new LambdaQueryWrapper<>();
errorQueryWrapper.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisRequestId);
errorQueryWrapper.eq(AiAnalysisErrors::getAiAnalysisErrorHandlingStatus, "0");
errorQueryWrapper.eq(AiAnalysisErrors::getIsDeleted, "0");
AiAnalysisErrors oldAiAnalysisErrors = aiAnalysisErrorsMapper.selectOne(errorQueryWrapper);
if (oldAiAnalysisErrors != null) {
aiAnalysisErrorsMapper.update(AiAnalysisErrors.builder().aiAnalysisRequestId(oldAiAnalysisErrors.getAiAnalysisRequestId()).aiAnalysisErrorHandlingStatus("1").build(), errorQueryWrapper);
}
}else {
log.info("没找到语料记录");
}
return ResultMsg.ok();
}
return ResultMsg.ok();
} catch (Exception e) {
log.error("updateNameplate error {}", e);
}
return ResultMsg.failed();
}
@Override

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

@@ -227,7 +227,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) {
JSONObject text = execDifyFlow.getJSONObject("outputs");
// 发送MQ
log.info("send mq {}", text);
log.info("send mq企微总结 {}", text);
tmTelephoneCorpusService.sendMq( CategoryEnum.ENTERPRISE_WECHAT.getCode(), text.toJSONString());
try {