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 2917fe9..3df23bc 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 @@ -152,22 +152,23 @@ public class PlatePublishTask { } JSONObject dldbRec = new JSONObject(); + JSONObject payload = null; 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("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("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_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(); body.put("operator_type", "update_or_add"); body.put("dldb_rec", dldbRec); - JSONObject payload = new JSONObject(); + payload = new JSONObject(); payload.put("type", "white_list_operator"); payload.put("body", body); return payload;