diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java index e8a3ea2..91b8e4d 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java @@ -53,8 +53,7 @@ public class NameplateKafkaConsumer { NameplateTableKafkaDTO tmNameplateCorpus = JSON.parseObject(recordMessages, NameplateTableKafkaDTO.class); if (!"INSERT".equals(tmNameplateCorpus.getType()) || CollectionUtils.isEmpty(tmNameplateCorpus.getData())) { ack.acknowledge(); -// return; - //TODO 临时去掉,uat联调 + // 此处应返回 return; } tmNameplateCorpus.getData().forEach(nameplate -> tmNameplateCorpusService.processItem(nameplate)); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java index affe2dd..0a9671f 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java @@ -162,17 +162,6 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl summaryFuture = CompletableFuture.runAsync(() -> { - //第一个业务场景 开始: 总结和分类业务场景 -// JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode(), -// JSONObject.toJSONString(corpusReportDTO),null); -// log.info("runDify execDifyFlow ,铭牌语料 ,总结和分类业务,返回: {}", execDifyFlow); - log.info("runDify execDifyFlow ,铭牌语料 ,总结和分类业务,开始: {}", diFyImageReq); - }, executorService); - long endTime = System.currentTimeMillis(); - log.info("第一个业务场景(总结和分类)执行时间: {} ms", (endTime - startTime)); - //第一个业务场景, 结束 long startTime2 = System.currentTimeMillis(); CompletableFuture portraitFuture = CompletableFuture.runAsync(() -> { @@ -195,6 +184,19 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl summaryFuture = CompletableFuture.runAsync(() -> { + //第一个业务场景 开始: 总结和分类业务场景 + JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode(), + JSONObject.toJSONString(corpusReportDTO),null); + log.info("runDify execDifyFlow ,铭牌语料 ,总结和分类业务,返回: {}", execDifyFlow); + }, executorService); + long endTime = System.currentTimeMillis(); + log.info("第一个业务场景(总结和分类)执行时间: {} ms", (endTime - startTime)); + //第一个业务场景, 结束 + + + } catch (Exception e) { log.error("nameplate processItem error {}", e.getMessage()); }