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));