From 0a73b49a90e9139fc99c3b87a811815eb6e037f0 Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Fri, 19 Sep 2025 19:57:35 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=BD=8D=E4=B8=8D=E6=8E=A8lto?= =?UTF-8?q?=E3=80=82=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../center/mq/NameplateKafkaConsumer.java | 2 + .../impl/TmTelephoneCorpusServiceImpl.java | 78 ++++++++++--------- 2 files changed, 44 insertions(+), 36 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java index a8787be..a460437 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java @@ -67,6 +67,8 @@ public class NameplateKafkaConsumer { ack.acknowledge(); }//去掉业务调用 + tmNameplateCorpus.getData().forEach(nameplate -> + tmNameplateCorpusService.processItem(nameplate)); } catch (Exception e) { log.error("处理消息失败", e); } finally { diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java index 27944c9..7fbb4f4 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java @@ -224,48 +224,54 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl ltoMap = new HashMap(); - ltoMap.put("analysisRecordId", aiAnalysisRequestId); - ltoMap.put("analysisScene", "2"); - ltoMap.put("recordId",recordId); - ltoMap.put("communicateDate", communicateDate); - ltoMap.put("analysisResult", resultStrOne); - ltoMap.put("analysisDetail", resultStrTwo); - // 发送MQ - - - if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像 - log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap); - sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(ltoMap)); - }else{ // dcc 总结 - log.info("send mq 电话语料场景，总结需求， {}",ltoMap); - sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap)); - } - - try { - if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){ - AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors(); - aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestIdDB); - aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1"); - aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors); + String text = execDifyFlow.getJSONObject("outputs").getString("text"); + String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "任务1", "任务2"); + String resultStrTwo =FlowResultSplitUtil.flowOutputTextSplit(text, "任务2", null); + if (StringUtils.isBlank(resultStrOne) || StringUtils.isBlank(resultStrTwo)){ + log.info("电话语料解析为空，text:{}", text); + return; } - aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(JSONObject.toJSONString(ltoMap)).build()); + String aiAnalysisRequestId = execDifyFlow.getString("aiAnalysisRequestId"); + Map ltoMap = new HashMap(); + ltoMap.put("analysisRecordId", aiAnalysisRequestId); + ltoMap.put("analysisScene", "2"); + ltoMap.put("recordId",recordId); + ltoMap.put("communicateDate", communicateDate); + ltoMap.put("analysisResult", resultStrOne); + ltoMap.put("analysisDetail", resultStrTwo); - } catch (Exception e) { - log.info(" 电话语料处理保存报告异常processItem：{} ", e); + // 发送MQ + if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像 + log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap); + sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(ltoMap)); + }else{ // dcc 总结 + log.info("send mq 电话语料场景，总结需求， {}",ltoMap); + sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap)); + } + + try { + if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){ + AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors(); + aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestIdDB); + aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1"); + aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors); + } + aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(JSONObject.toJSONString(ltoMap)).build()); + + } catch (Exception e) { + log.info(" 电话语料处理保存报告异常processItem：{} ", e); + } + }else { + log.info("dcc语料 parseDfiyResult 非正常状态"); } + }catch (Exception e){ + log.error("dcc语料 parseDfiyResult 异常，businessType: {} execDifyFlow: {}", businessType,execDifyFlow, e); } + }