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

定位不推lto。加日志

Browse Source
This commit is contained in:
ZLI263
2025-09-19 19:57:35 +08:00
parent 94cbbc4bfe
commit 0a73b49a90
2 changed files with 44 additions and 36 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/mq/NameplateKafkaConsumer.java
View File

@@ -67,6 +67,8 @@ public class NameplateKafkaConsumer {
ack.acknowledge(); ack.acknowledge();
}//去掉业务调用 }//去掉业务调用
tmNameplateCorpus.getData().forEach(nameplate ->
tmNameplateCorpusService.processItem(nameplate));
} catch (Exception e) { } catch (Exception e) {
log.error("处理消息失败", e); log.error("处理消息失败", e);
} finally { } finally {

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

@@ -224,6 +224,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
private void parseDfiyResult(JSONObject execDifyFlow,String recordId,String communicateDate, private void parseDfiyResult(JSONObject execDifyFlow,String recordId,String communicateDate,
String aiAnalysisRequestIdDB,String businessType) { String aiAnalysisRequestIdDB,String businessType) {
log.info("dcc语料 parseDfiyResult ，businessType: {} execDifyFlow: {}", businessType,execDifyFlow); log.info("dcc语料 parseDfiyResult ，businessType: {} execDifyFlow: {}", businessType,execDifyFlow);
try {
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){ if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
String text = execDifyFlow.getJSONObject("outputs").getString("text"); String text = execDifyFlow.getJSONObject("outputs").getString("text");
@@ -241,9 +242,8 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
ltoMap.put("communicateDate", communicateDate); ltoMap.put("communicateDate", communicateDate);
ltoMap.put("analysisResult", resultStrOne); ltoMap.put("analysisResult", resultStrOne);
ltoMap.put("analysisDetail", resultStrTwo); ltoMap.put("analysisDetail", resultStrTwo);
// 发送MQ // 发送MQ
if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像 if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像
log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap); log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap);
sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(ltoMap)); sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(ltoMap));
@@ -264,7 +264,13 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
} catch (Exception e) { } catch (Exception e) {
log.info(" 电话语料处理保存报告异常processItem：{} ", e); log.info(" 电话语料处理保存报告异常processItem：{} ", e);
} }
}else {
log.info("dcc语料 parseDfiyResult 非正常状态");
} }
}catch (Exception e){
log.error("dcc语料 parseDfiyResult 异常，businessType: {} execDifyFlow: {}", businessType,execDifyFlow, e);
}
} }