vertoryao/iot-gateway
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(iot): 优化设备控制指令发送功能

Browse Source 
- 将设备信息获取方式改为使用 detail 方法，提高代码复用性
-增加对参数为空的校验，避免发送空命令
-
This commit is contained in:
zhuangtianxiang 2025-03-06 17:28:48 +08:00
parent 741eb73137
commit 36f4f8abde
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java
View File

@ -195,7 +195,7 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceRepository, Device> imp
@Override @Override
public String send(Long deviceId, Integer qos, JSONObject paras) throws JSONException { public String send(Long deviceId, Integer qos, JSONObject paras) throws JSONException {
Device device = deviceRepo.selectOne(new LambdaQueryWrapper<Device>().eq(Device::getId, deviceId)); DeviceVo device = detail(deviceId);
JSONObject payloadJson = new JSONObject(); JSONObject payloadJson = new JSONObject();
payloadJson.put("mid", 641); payloadJson.put("mid", 641);
payloadJson.put("serviceId", "runParamsCommand"); payloadJson.put("serviceId", "runParamsCommand");
@ -205,6 +205,9 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceRepository, Device> imp
payloadJson.put("msgType", "cloudReq"); payloadJson.put("msgType", "cloudReq");
String payload = payloadJson.toString(); String payload = payloadJson.toString();
String topic = "/r1/devices/" + device.getClientId() + "/datas"; String topic = "/r1/devices/" + device.getClientId() + "/datas";
if (paras.isEmpty()) {
throw new JSONException("参数不能为空");
}
try { try {
mqttSender.sendMsg(topic, qos, payload); mqttSender.sendMsg(topic, qos, payload);
} catch (Exception e) { } catch (Exception e) {