From c628249428054a65adcb1b8a4175900936dc1ae5 Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Fri, 19 Sep 2025 14:48:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E4=B8=8A=E8=B0=83=E7=94=A8=E4=B8=9A?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../analytic/center/mq/NameplateKafkaConsumer.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) 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 a4e45b5..f768647 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,17 +53,23 @@ public class NameplateKafkaConsumer { log.info("nameplateKafkaConsumerMessage，消息：{}", recordMessages); if (StringUtils.isEmpty(recordMessages)) { ack.acknowledge(); - log.info("nameplateKafkaConsumerMessage，消息为空"); + log.info("nameplateKafkaConsumer为空"); return; } try { NameplateTableKafkaDTO tmNameplateCorpus = JSON.parseObject(recordMessages, NameplateTableKafkaDTO.class); - if (!"INSERT".equals(tmNameplateCorpus.getType()) || CollectionUtils.isEmpty(tmNameplateCorpus.getData())) { - log.info("nameplateKafkaConsumerMessage，不满足条件"); + if (!"INSERT".equals(tmNameplateCorpus.getType()) ) { + log.info("nameplateKafka不是INSERT"); + } + if (CollectionUtils.isEmpty(tmNameplateCorpus.getData())) { + log.info("nameplateKafkagetData为空"); + ack.acknowledge(); + return; } - + tmNameplateCorpus.getData().forEach(nameplate -> + tmNameplateCorpusService.processItem(nameplate)); } catch (Exception e) { log.error("处理消息失败", e);