From 043023b81ee9c621320ad5731bc4716542cc3007 Mon Sep 17 00:00:00 2001 From: zc Date: Tue, 10 Feb 2026 15:39:32 +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 --- .../mica/mqtt/server/task/PlatePublishTask.java | 17 ++++++----------- 1 file changed, 6 insertions(+), 11 deletions(-) diff --git a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/PlatePublishTask.java b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/PlatePublishTask.java index 3df23bc..eccfab4 100644 --- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/PlatePublishTask.java +++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/PlatePublishTask.java @@ -71,11 +71,8 @@ public class PlatePublishTask { po.setId(uuid); po.setSn(car.getSn()); po.setName("white_list_operator"); - //构造数据 - if (StrUtil.equals(car.getSn(), car.getSn())) { - po.setPayload(buildPayload(car)); - } + po.setPayload(buildPayload(car)); //更新car_park_record表的clientId，用于回执消息更新下发状态 //必须在发送前更新，不然会导致发送后，还没更新完数据库，回执已经收到，无法更新数据，导致持续下发车牌 @@ -118,14 +115,12 @@ public class PlatePublishTask { //构造内层数据 List plates = new ArrayList<>(); for (CarInfo car : carInfos) { - if (StrUtil.equals(car.getSn(), car.getSn())) { - plates.add(car.getPlate()); + plates.add(car.getPlate()); - CarParkRecord carParkRecord = new CarParkRecord(); - carParkRecord.setClientId(uuid); - carParkRecord.setId(car.getCarParkRecordId()); - carParkRecords.add(carParkRecord); - } + CarParkRecord carParkRecord = new CarParkRecord(); + carParkRecord.setClientId(uuid); + carParkRecord.setId(car.getCarParkRecordId()); + carParkRecords.add(carParkRecord); } po.setPayload(buildPayloadDel(plates));