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

修改sonar扫出的问题

Browse Source
This commit is contained in:
ZLI263
2025-09-12 15:28:31 +08:00
parent 634d15ca93
commit 90e33a3a66
2 changed files with 2 additions and 17 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/CorpusProcessKafkaProducer.java
View File

@@ -76,7 +76,7 @@ public class CorpusProcessKafkaProducer {
JSONObject jsonObject = JSONObject.parseObject( aicorpusTelephone.getDisplay()); JSONObject jsonObject = JSONObject.parseObject( aicorpusTelephone.getDisplay());
Long audioDuration = jsonObject.getLong("audio_duration"); // 毫秒 Long audioDuration = jsonObject.getLong("audio_duration"); // 毫秒
if(audioDuration/1000 <=10){ if(audioDuration <= 10000){//时间单位是 毫秒
log.info("电话语料时长小于10秒，不进行dify处理"); log.info("电话语料时长小于10秒，不进行dify处理");
return; return;
} }

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

@@ -157,12 +157,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
// 使用多线程并行执行两个业务场景 // 使用多线程并行执行两个业务场景
ExecutorService executorService = Executors.newFixedThreadPool(2); ExecutorService executorService = Executors.newFixedThreadPool(2);
//第一个业务场景 开始： 总结和分类业务场景
// JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
// JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
// log.info("runDify execDifyFlow 返回 ,总结场景 ： {}",execDifyFlow);
// parseDfiyResult(execDifyFlow, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(),
// BusinessTypeEnum.SMART_ASSISTANT.getCode());
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
CompletableFuture<Void> summaryFuture = CompletableFuture.runAsync(() -> { CompletableFuture<Void> summaryFuture = CompletableFuture.runAsync(() -> {
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(), JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
@@ -176,16 +171,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
log.info("第一个业务场景（总结和分类）执行时间: {} ms", (endTime - startTime)); log.info("第一个业务场景（总结和分类）执行时间: {} ms", (endTime - startTime));
//第一个业务场景， 结束 //第一个业务场景， 结束
//TODO 是否传给LOT 穿行改成并行
//第二个业务场景： 用户画像业务场景。 开始
// diFyImageReq.setFlowId(telephoneTokenPortrait);
// JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
// JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId()); //调用dify平台。
// log.info("runDify execDifyFlow 返回 ,客户画像场景： {}",execDifyFlowForPortrait);
// parseDfiyResult(execDifyFlowForPortrait, aicorpusTelephone.getSourceId(), formattedDateStartTime,
// aicorpusTelephone.getAiAnalysisRequestId(), BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode()); // 发送mq消息。
long startTime2 = System.currentTimeMillis(); long startTime2 = System.currentTimeMillis();
CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> { CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> {