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-20 16:58:49 +08:00
parent 5326a6f431
commit 5ae9330b1a
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -237,15 +237,15 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
try { try {
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){ if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
String outputs = execDifyFlow.getString(outputsStr); JSONObject text = execDifyFlow.getJSONObject(outputsStr);
// 发送MQ // 发送MQ
if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像 if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像
log.info("send mq 电话语料场景，客户画像需求， {}",outputs); log.info("send mq 电话语料场景，客户画像需求， {}",text);
sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(outputs)); sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), text.toJSONString());
}else{ // dcc 总结 }else{ // dcc 总结
log.info("send mq 电话语料场景，总结需求， {}",outputs); log.info("send mq 电话语料场景，总结需求， {}",text);
sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(outputs)); sendMq( CategoryEnum.PHONE_VOICE.getCode(), text.toJSONString());
} }
try { try {
if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){ if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){
@@ -254,7 +254,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors); aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors);
} }
aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString(aiAnalysisRequestIdStr)).businessResponse(outputs).build()); aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString(aiAnalysisRequestIdStr)).businessResponse(text.toJSONString()).build());
} catch (Exception e) { } catch (Exception e) {
log.info(" 电话语料处理保存报告异常processItem：{} ", e.getMessage()); log.info(" 电话语料处理保存报告异常processItem：{} ", e.getMessage());
@@ -396,7 +396,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
@Override @Override
public void sendMq(String tag, String message) { public void sendMq(String tag, String message) {
log.info("RocketMQ主题和标签： "+topic+":"+ tag); log.info("RocketMQ主题和标签： "+topic+":"+ tag + message);
rocketMqTemplate.asyncSend(topic+":"+ tag, MessageBuilder.withPayload(message).build(), rocketMqTemplate.asyncSend(topic+":"+ tag, MessageBuilder.withPayload(message).build(),
new SendCallback() { new SendCallback() {
@Override @Override