From 1b0876d735565bdefec7f7ff53243908d4b88952 Mon Sep 17 00:00:00 2001
From: luyya <luya0519>
Date: Mon, 5 Jan 2026 17:42:26 +0800
Subject: [PATCH] =?UTF-8?q?=E7=9C=81=E5=8E=85=E4=BD=8D=E7=BD=AE=E6=B1=87?=
 =?UTF-8?q?=E8=81=9Aconsumer=E8=BF=87=E6=BB=A4=E6=97=B6=E9=97=B42000?=
 =?UTF-8?q?=E7=A7=92=E4=BB=A5=E5=A4=96=E7=9A=84=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/dromara/kafka/consumer/handler/ConsumerWorker.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java b/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
index 23daaa9d..7ca38b8d 100644
--- a/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
+++ b/stwzhj-modules/stwzhj-consumer/src/main/java/org/dromara/kafka/consumer/handler/ConsumerWorker.java
@@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.bean.copier.CopyOptions;
 import cn.hutool.core.convert.ConvertException;
 import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
@@ -102,6 +103,9 @@ public class ConsumerWorker implements Runnable {
         }catch (Exception e){
             logger.error("error_msg={}",e.getMessage());
         }
+        if(DateUtil.between(esGpsInfo.getGpsTime(), new Date(), DateUnit.SECOND) > 2000L){
+            return;
+        }
         logger.info("esGpsInfo={}",esGpsInfo);
         boolean offer = linkedBlockingDeque.offer(esGpsInfo);
         R response = R.ok(offer);