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

下发白名单非必填数据添加校验

Browse Source
This commit is contained in:
liuzhu
2026-01-06 13:48:54 +08:00
parent 46e3039004
commit 55e8e9dbb2
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -152,22 +152,23 @@ public class PlatePublishTask {
} }
JSONObject dldbRec = new JSONObject(); JSONObject dldbRec = new JSONObject();
JSONObject payload = null;
dldbRec.put("create_time", DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN)); dldbRec.put("create_time", DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN));
dldbRec.put("enable_time", DateUtil.format(carInfo.getEnableTime(), DatePattern.NORM_DATETIME_PATTERN)); dldbRec.put("enable_time", DateUtil.format(carInfo.getEnableTime(), DatePattern.NORM_DATETIME_PATTERN));
dldbRec.put("overdue_time", DateUtil.format(carInfo.getOverdueTime(), DatePattern.NORM_DATETIME_PATTERN)); dldbRec.put("overdue_time", DateUtil.format(carInfo.getOverdueTime(), DatePattern.NORM_DATETIME_PATTERN));
dldbRec.put("enable", Integer.parseInt(carInfo.getEnable())); dldbRec.put("enable", StrUtil.isBlank(carInfo.getEnable()) ? 0 : Integer.parseInt(carInfo.getEnable()));
dldbRec.put("plate", carInfo.getPlate()); dldbRec.put("plate", carInfo.getPlate());
dldbRec.put("time_seg_enable", Integer.parseInt(carInfo.getTimeSegEnable())); dldbRec.put("time_seg_enable", StrUtil.isBlank(carInfo.getTimeSegEnable()) ? 0 : Integer.parseInt(carInfo.getTimeSegEnable()));
dldbRec.put("seg_time_start", carInfo.getSegTimeStart() == null ? "00:00:00" : carInfo.getSegTimeStart()); dldbRec.put("seg_time_start", carInfo.getSegTimeStart() == null ? "00:00:00" : carInfo.getSegTimeStart());
dldbRec.put("seg_time_end", carInfo.getSegTimeEnd() == null ? "00:00:00" : carInfo.getSegTimeEnd()); dldbRec.put("seg_time_end", carInfo.getSegTimeEnd() == null ? "00:00:00" : carInfo.getSegTimeEnd());
dldbRec.put("need_alarm", Integer.parseInt(carInfo.getNeedAlarm())); dldbRec.put("need_alarm", StrUtil.isBlank(carInfo.getNeedAlarm()) ? 0 : Integer.parseInt(carInfo.getNeedAlarm()));
JSONObject body = new JSONObject(); JSONObject body = new JSONObject();
body.put("operator_type", "update_or_add"); body.put("operator_type", "update_or_add");
body.put("dldb_rec", dldbRec); body.put("dldb_rec", dldbRec);
JSONObject payload = new JSONObject(); payload = new JSONObject();
payload.put("type", "white_list_operator"); payload.put("type", "white_list_operator");
payload.put("body", body); payload.put("body", body);
return payload; return payload;