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 11:48:26 +08:00
parent c9c7306f70
commit e74270e73d
2 changed files with 5 additions and 3 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/CorpusDccMqConsumer.java
View File

@@ -56,6 +56,8 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> {
//总结和客户画像都是这一个:Constant.CHANNEL_DCC //总结和客户画像都是这一个:Constant.CHANNEL_DCC
log.info("dcc_mq接收到消息 ， 总结和客户画像业务场景: " + JSON.toJSONString(aicorpusTelephone)); log.info("dcc_mq接收到消息 ， 总结和客户画像业务场景: " + JSON.toJSONString(aicorpusTelephone));
tmTelephoneCorpusService.runTelephoneCorpusDify(aicorpusTelephone); tmTelephoneCorpusService.runTelephoneCorpusDify(aicorpusTelephone);
}else{
log.info("dcc_mq接收到消息,不是客户画像语料,分类是： "+aicorpusTelephone.getCategoryCode());
} }
//channel_4in1场景 //channel_4in1场景
if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_4IN1)){ if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_4IN1)){

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

@@ -162,7 +162,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
// 使用多线程并行执行两个业务场景 // 使用多线程并行执行两个业务场景
ExecutorService executorService = Executors.newFixedThreadPool(2); ExecutorService executorService = Executors.newFixedThreadPool(2);
log.info("第二个业务场景， 优先执行。 ");
long startTime2 = System.currentTimeMillis(); long startTime2 = System.currentTimeMillis();
CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> { CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> {
//"analysisScene": "分析类型", // 1、企微会话 2、AI通话录音 3、AI铭牌(客流) 4、AI铭牌(试驾) //"analysisScene": "分析类型", // 1、企微会话 2、AI通话录音 3、AI铭牌(客流) 4、AI铭牌(试驾)