diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java index a20f79b..3ba466a 100644 --- a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java +++ b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java @@ -195,7 +195,7 @@ public class DeviceServiceImpl extends ServiceImpl imp @Override public String send(Long deviceId, Integer qos, JSONObject paras) throws JSONException { - Device device = deviceRepo.selectOne(new LambdaQueryWrapper().eq(Device::getId, deviceId)); + DeviceVo device = detail(deviceId); JSONObject payloadJson = new JSONObject(); payloadJson.put("mid", 641); payloadJson.put("serviceId", "runParamsCommand"); @@ -205,6 +205,9 @@ public class DeviceServiceImpl extends ServiceImpl imp payloadJson.put("msgType", "cloudReq"); String payload = payloadJson.toString(); String topic = "/r1/devices/" + device.getClientId() + "/datas"; + if (paras.isEmpty()) { + throw new JSONException("参数不能为空"); + } try { mqttSender.sendMsg(topic, qos, payload); } catch (Exception e) {