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

开发画像dcc场景

Browse Source
This commit is contained in:
ZLI263
2025-09-09 15:12:21 +08:00
parent 7b7000c2cf
commit 10037968fb
2 changed files with 56 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/enums/CategoryEnum.java
View File

@@ -4,9 +4,8 @@ public enum CategoryEnum {
ENTERPRISE_WECHAT("enterprise_wechat", "企微记录"), ENTERPRISE_WECHAT("enterprise_wechat", "企微记录"),
PHONE_VOICE("phone_voice", "语音电话"), PHONE_VOICE("phone_voice", "语音电话"),
PHONE_VOICE_PORTRAIT("phone_voice_portrait", "语音电话,用户画像"), PORTRAIT_ALLIN("portrait_allin", "语音电话,用户画像"),
NAMEPLATE_VOICE("nameplate_voice", "铭牌"), NAMEPLATE_VOICE("nameplate_voice", "铭牌"),
OTHER("未知", "未知记录"), OTHER("未知", "未知记录"),
; ;
private String code; private String code;

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

@@ -68,6 +68,9 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
@Value("${dify.corpus.telephoneToken}") @Value("${dify.corpus.telephoneToken}")
private String telephoneToken; private String telephoneToken;
@Value("${dify.corpus.portrait.oneToken}")
private String telephoneTokenPortrait;
@Value("${dify.intelligentCustomer.channel4In1Token}") @Value("${dify.intelligentCustomer.channel4In1Token}")
private String channel4In1Token; private String channel4In1Token;
@Autowired @Autowired
@@ -156,8 +159,23 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
corpusReportDTO.setRecordId(aicorpusTelephone.getSourceId()); corpusReportDTO.setRecordId(aicorpusTelephone.getSourceId());
corpusReportDTO.setAnalysisScene(2l); corpusReportDTO.setAnalysisScene(2l);
// 获取配置 // 获取配置
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(), JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId()); JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
log.info("runDify execDifyFlow {}",execDifyFlow); JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
log.info("runDify execDifyFlow 返回 ,总结 {}",execDifyFlow);
parseDfiyResult(execDifyFlow, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(),BusinessTypeEnum.SMART_ASSISTANT.getCode());
// 获取配置
diFyImageReq.setFlowId(telephoneTokenPortrait);
JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
log.info("runDify execDifyFlow 返回 ,客户画像 {}",execDifyFlow);
parseDfiyResult(execDifyFlowForPortrait, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(), BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode());
}
}
private void parseDfiyResult(JSONObject execDifyFlow,String recordId,String communicateDate,
String aiAnalysisRequestIdDB,String businessType) {
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");
@@ -171,18 +189,25 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
Map<String, String> ltoMap = new HashMap(); Map<String, String> ltoMap = new HashMap();
ltoMap.put("analysisRecordId", aiAnalysisRequestId); ltoMap.put("analysisRecordId", aiAnalysisRequestId);
ltoMap.put("analysisScene", "2"); ltoMap.put("analysisScene", "2");
ltoMap.put("recordId", aicorpusTelephone.getSourceId()); ltoMap.put("recordId",recordId);
ltoMap.put("communicateDate", formattedDateStartTime); ltoMap.put("communicateDate", communicateDate);
ltoMap.put("analysisResult", resultStrOne); ltoMap.put("analysisResult", resultStrOne);
ltoMap.put("analysisDetail", resultStrTwo); ltoMap.put("analysisDetail", resultStrTwo);
// 发送MQ // 发送MQ
log.info("send mq {}",ltoMap);
if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像
log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap);
sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(ltoMap));
}else if (BusinessTypeEnum.SMART_ASSISTANT.getCode().equals(businessType)){ // dcc 总结
log.info("send mq 电话语料场景，总结需求， {}",ltoMap);
sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap)); sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap));
}
try { try {
if(StringUtils.isNotEmpty(aicorpusTelephone.getAiAnalysisRequestId())){ if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){
AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors(); AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors();
aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestId); aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestIdDB);
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors); aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors);
} }
@@ -192,7 +217,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
log.info(" 电话语料处理保存报告异常processItem：{} ", e); log.info(" 电话语料处理保存报告异常processItem：{} ", e);
} }
} }
}
} }