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-16 12:39:32 +08:00
parent e74270e73d
commit 342dcf7484
1 changed files with 23 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -162,28 +162,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
// 使用多线程并行执行两个业务场景
ExecutorService executorService = Executors.newFixedThreadPool(2);
log.info("第二个业务场景， 优先执行。 ");
long startTime2 = System.currentTimeMillis();
CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> {
//"analysisScene": "分析类型", // 1、企微会话 2、AI通话录音 3、AI铭牌(客流) 4、AI铭牌(试驾)
inputMap.put("businessId",item.getCustomerFlowId());
inputMap.put("communicateDate",item.getNameplateEndTime());
inputMap.put("analysisScene", "3");
diFyImageReq.setInputs(inputMap);
// 创建新的DiFyReq对象以避免线程安全问题
diFyImageReq.setFlowId(oneTokenPortrait);
log.info("runDify execDifyFlow ,客户画像场景 ，token ： {} , 对象： {}", oneTokenPortrait, diFyImageReq);
JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode(),
JSONObject.toJSONString(corpusReportDTO), null);
log.info("runDify execDifyFlow ,铭牌语料 ,客户画像场景，返回： {}", execDifyFlowForPortrait);
}, executorService);
long endTime2 = System.currentTimeMillis();
log.info("第二个业务场景（用户画像）执行时间: {} ms", (endTime2 - startTime2));
log.info("第1个业务场景， 优先执行。 ");
long startTime = System.currentTimeMillis();
CompletableFuture<Void> summaryFuture = CompletableFuture.runAsync(() -> {
//第一个业务场景 开始： 总结和分类业务场景
@@ -195,6 +174,28 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
log.info("第一个业务场景（总结和分类）执行时间: {} ms", (endTime - startTime));
//第一个业务场景， 结束
long startTime2 = System.currentTimeMillis();
CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> {
//"analysisScene": "分析类型", // 1、企微会话 2、AI通话录音 3、AI铭牌(客流) 4、AI铭牌(试驾)
Map<String, Object> inputMap2 = new HashMap<>();
inputMap2.put("businessId",item.getCustomerFlowId());
inputMap2.put("communicateDate",item.getNameplateEndTime());
inputMap2.put("analysisScene", "3");
diFyImageReq.setInputs(inputMap2);
// 创建新的DiFyReq对象以避免线程安全问题
diFyImageReq.setFlowId(oneTokenPortrait);
log.info("runDify execDifyFlow ,客户画像场景 ，token ： {} , 对象： {}", oneTokenPortrait, diFyImageReq);
JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode(),
JSONObject.toJSONString(corpusReportDTO), null);
log.info("runDify execDifyFlow ,铭牌语料 ,客户画像场景，返回： {}", execDifyFlowForPortrait);
}, executorService);
long endTime2 = System.currentTimeMillis();
log.info("第二个业务场景（用户画像）执行时间: {} ms", (endTime2 - startTime2));
} catch (Exception e) {