From c9423960265c4ea4a0cca53fd227e257d9c2976f Mon Sep 17 00:00:00 2001 From: zren25 Date: Mon, 31 Mar 2025 22:14:37 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=97=B6=E9=97=B4=E6=A0=BC?= =?UTF-8?q?=E5=BC=8F=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/analytic/center/mq/CorpusProcessKafkaProducer.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java index 35519cc..1716c6d 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java @@ -20,6 +20,7 @@ import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.listener.ConsumerSeekAware; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Component; +import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; @@ -57,6 +58,7 @@ public class CorpusProcessKafkaProducer implements ConsumerSeekAware { @Resource private RocketMQTemplate rocketMqTemplate; + @PostMapping("corpusProcessKafkaProducer") @KafkaListener(topics = "${spring.kafka.topic}", groupId = "${spring.kafka.group}") public void listen(List recordMessages) { long startTime = System.currentTimeMillis(); @@ -76,8 +78,9 @@ public class CorpusProcessKafkaProducer implements ConsumerSeekAware { String transcribeTimeStr = aicorpusTelephone.getTranscribeTime(); if (transcribeTimeStr != null) { - LocalDateTime transcribeTime = LocalDateTime.parse(transcribeTimeStr, DateTimeFormatter.ISO_LOCAL_DATE_TIME); - LocalDateTime kafkaStartTime = LocalDateTime.parse(kafkaTimeLimit, DateTimeFormatter.ISO_LOCAL_DATE_TIME); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + LocalDateTime transcribeTime = LocalDateTime.parse(transcribeTimeStr, formatter); + LocalDateTime kafkaStartTime = LocalDateTime.parse(kafkaTimeLimit, formatter); if (transcribeTime.isBefore(kafkaStartTime)) { return; } @@ -129,6 +132,5 @@ public class CorpusProcessKafkaProducer implements ConsumerSeekAware { - }