XA/mqtt-car
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码优化

Browse Source
This commit is contained in:
zc
2026-02-10 15:39:32 +08:00
parent 55e8e9dbb2
commit 043023b81e
1 changed files with 6 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/PlatePublishTask.java
View File

@@ -71,11 +71,8 @@ public class PlatePublishTask {
po.setId(uuid); po.setId(uuid);
po.setSn(car.getSn()); po.setSn(car.getSn());
po.setName("white_list_operator"); po.setName("white_list_operator");
//构造数据 //构造数据
if (StrUtil.equals(car.getSn(), car.getSn())) { po.setPayload(buildPayload(car));
po.setPayload(buildPayload(car));
}
//更新car_park_record表的clientId，用于回执消息更新下发状态 //更新car_park_record表的clientId，用于回执消息更新下发状态
//必须在发送前更新，不然会导致发送后，还没更新完数据库，回执已经收到，无法更新数据，导致持续下发车牌 //必须在发送前更新，不然会导致发送后，还没更新完数据库，回执已经收到，无法更新数据，导致持续下发车牌
@@ -118,14 +115,12 @@ public class PlatePublishTask {
//构造内层数据 //构造内层数据
List<String> plates = new ArrayList<>(); List<String> plates = new ArrayList<>();
for (CarInfo car : carInfos) { for (CarInfo car : carInfos) {
if (StrUtil.equals(car.getSn(), car.getSn())) { plates.add(car.getPlate());
plates.add(car.getPlate());
CarParkRecord carParkRecord = new CarParkRecord(); CarParkRecord carParkRecord = new CarParkRecord();
carParkRecord.setClientId(uuid); carParkRecord.setClientId(uuid);
carParkRecord.setId(car.getCarParkRecordId()); carParkRecord.setId(car.getCarParkRecordId());
carParkRecords.add(carParkRecord); carParkRecords.add(carParkRecord);
}
} }
po.setPayload(buildPayloadDel(plates)); po.setPayload(buildPayloadDel(plates));