From 9031a352bc5e867eb4b61fa4fac3339bcc076ff4 Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Wed, 17 Sep 2025 11:21:27 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E7=BB=93=E6=9E=84=E4=BD=93?= =?UTF-8?q?=E4=B8=8D=E4=B8=80=E8=87=B4=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/TmNameplateCorpusServiceImpl.java | 107 +++++++++--------- .../TmOdsVdqwMessagearchivingServiceImpl.java | 2 +- 2 files changed, 54 insertions(+), 55 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java index 6fa618d..3f6c3e9 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java @@ -235,67 +235,66 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl 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 queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(TmNameplateCorpus::getCustomerFlowId, customerFlowId); - List tmNameplateCorpusList = tmNameplateCorpusMapper.selectList(queryWrapper); - if (CollectionUtils.isNotEmpty(tmNameplateCorpusList)){ //这是补偿机制 - log.info("66666666666666"); - sendNameplateLto(difyJson,aiAnalysisRequestId, tmNameplateCorpusList.get(0),businessType); - LambdaQueryWrapper 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 queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(TmNameplateCorpus::getCustomerFlowId, customerFlowId); + List tmNameplateCorpusList = tmNameplateCorpusMapper.selectList(queryWrapper); + if (CollectionUtils.isNotEmpty(tmNameplateCorpusList)){ //这是补偿机制 + log.info("66666666666666"); + sendNameplateLto(difyJson,aiAnalysisRequestId, tmNameplateCorpusList.get(0),businessType); + LambdaQueryWrapper 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 diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java index d00d23f..d1feb2d 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmOdsVdqwMessagearchivingServiceImpl.java @@ -227,7 +227,7 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl