diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanDeviceDataRule.java b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanDeviceDataRule.java index 17dce0ed..b2e89a4c 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanDeviceDataRule.java +++ b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/xinghan/XinghanDeviceDataRule.java @@ -186,6 +186,9 @@ public class XinghanDeviceDataRule implements MqttMessageRule { */ private DeviceAlarmBo createAlarmBo(String deviceImei, AlarmType type) { Device device = deviceService.selectDeviceByImei(deviceImei); + if (device == null) { + return null; + } DeviceAlarmBo bo = new DeviceAlarmBo(); bo.setDeviceId(device.getId()); bo.setDeviceImei(deviceImei);