From c403b07aeb2aaee536bd36ba673cbfb5416de63d Mon Sep 17 00:00:00 2001 From: zc Date: Mon, 16 Mar 2026 16:54:57 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/listener/CarMessageListener.java | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) diff --git a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java index cacf4c7..23b6d89 100644 --- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java +++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java @@ -152,8 +152,13 @@ public class CarMessageListener { if (null != imgRsp && imgRsp.getInteger("code") == 200) { record.setUrl(imgRsp.getJSONObject("data").getString("url")); } -// record.setPassTime(DateUtil.date(plateResult.getLong("start_time"))); - record.setPassTime(new Date()); + if (plateResult.containsKey("start_time")) { + log.info("拿到了时间：{}", plateResult.getLong("start_time")); + record.setPassTime(DateUtil.date(plateResult.getLong("start_time"))); + } else { + log.info("没有拿到时间，默认当前时间"); + record.setPassTime(DateUtil.date(new Date())); + } record.setSn(sn); record.setUniqueNo(id); record.setTriggerType(plateResult.getString("triggerType")); @@ -225,8 +230,13 @@ public class CarMessageListener { if (null != imgRsp && imgRsp.getInteger("code") == 200) { record.setUrl(imgRsp.getJSONObject("data").getString("url")); } -// record.setPassTime(DateUtil.date(plateResult.getLong("start_time"))); - record.setPassTime(new Date()); + if (plateResult.containsKey("start_time")) { + log.info("拿到了离线时间：{}", plateResult.getLong("start_time")); + record.setPassTime(DateUtil.date(plateResult.getLong("start_time"))); + } else { + log.info("没有拿到离线时间，默认当前时间"); + record.setPassTime(DateUtil.date(new Date())); + } record.setSn(sn); record.setUniqueNo(id); record.setTriggerType(plateResult.getString("triggerType"));