dcc加日志
This commit is contained in:
1
.gitignore
vendored
1
.gitignore
vendored
@@ -174,3 +174,4 @@ spring-boot-*.jar
|
|||||||
*.yaml.bak
|
*.yaml.bak
|
||||||
*.yml.bak
|
*.yml.bak
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -172,7 +172,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
|
|||||||
}
|
}
|
||||||
}, executorService);
|
}, executorService);
|
||||||
long endTime = System.currentTimeMillis();
|
long endTime = System.currentTimeMillis();
|
||||||
log.info("第一个业务场景(总结和分类)执行时间: {} ms", (endTime - startTime));
|
log.info("第一个业务场景(dcc总结和分类)执行时间: {} ms", (endTime - startTime));
|
||||||
//第一个业务场景, 结束
|
//第一个业务场景, 结束
|
||||||
|
|
||||||
long startTime2 = System.currentTimeMillis();
|
long startTime2 = System.currentTimeMillis();
|
||||||
@@ -188,7 +188,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
|
|||||||
JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
|
JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
|
||||||
JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
|
JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
|
||||||
|
|
||||||
log.info("runDify execDifyFlow 返回 ,客户画像场景 dcc: {}", execDifyFlowForPortrait);
|
log.info("runDify execDifyFlow 返回 ,dcc客户画像场景 dcc: {}", execDifyFlowForPortrait);
|
||||||
|
|
||||||
parseDfiyResult(execDifyFlowForPortrait, aicorpusTelephone.getSourceId(), formattedDateStartTime,
|
parseDfiyResult(execDifyFlowForPortrait, aicorpusTelephone.getSourceId(), formattedDateStartTime,
|
||||||
aicorpusTelephone.getAiAnalysisRequestId(), BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode());
|
aicorpusTelephone.getAiAnalysisRequestId(), BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode());
|
||||||
@@ -197,7 +197,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
|
|||||||
}
|
}
|
||||||
}, executorService);
|
}, executorService);
|
||||||
long endTime2 = System.currentTimeMillis();
|
long endTime2 = System.currentTimeMillis();
|
||||||
log.info("第二个业务场景(用户画像)执行时间: {} ms", (endTime2 - startTime2));
|
log.info("第二个业务场景(dcc用户画像)执行时间: {} ms", (endTime2 - startTime2));
|
||||||
//第二个业务场景, 结束
|
//第二个业务场景, 结束
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -205,7 +205,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("parseDfiyResult dcc execDifyFlow: {}", execDifyFlow);
|
||||||
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");
|
||||||
@@ -229,7 +229,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
|
|||||||
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));
|
||||||
}else if (BusinessTypeEnum.SMART_ASSISTANT.getCode().equals(businessType)){ // dcc 总结
|
}else{ // dcc 总结
|
||||||
log.info("send mq 电话语料场景,总结需求, {}",ltoMap);
|
log.info("send mq 电话语料场景,总结需求, {}",ltoMap);
|
||||||
sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap));
|
sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap));
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user