luhaojie/agricultural-monitoring-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改设备下发指令消息服务质量

Browse Source
This commit is contained in:
蒾酒 2024-12-29 11:21:46 +08:00
parent 4ffee61949
commit eac745676b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
fastbee-open-api/src/main/java/com/fastbee/data/controller/DeviceOperationController.java
View File

@ -76,7 +76,7 @@ public class DeviceOperationController {
Map<String,Object> data = new HashMap<>(); Map<String,Object> data = new HashMap<>();
data.put("addr",deviceOperationDTO.getAddr()); data.put("addr",deviceOperationDTO.getAddr());
param.put("data",data); param.put("data",data);
pubMqttClient.publish(1,true,topic, JSONUtil.toJsonStr(param)); pubMqttClient.publish(0,true,topic, JSONUtil.toJsonStr(param));
return AjaxResult.success(); return AjaxResult.success();
} }
@ -91,7 +91,7 @@ public class DeviceOperationController {
} }
//构建主题 //构建主题
// String topic ="hzlink/"+productId+"/"+deviceNumber+"/cmd/down"; // String topic ="hzlink/"+productId+"/"+deviceNumber+"/cmd/down";
pubMqttClient.publish(1,true,topic, JSONUtil.toJsonStr(cmd)); pubMqttClient.publish(0,true,topic, JSONUtil.toJsonStr(cmd));
return AjaxResult.success(); return AjaxResult.success();
}catch (Exception e){ }catch (Exception e){
return AjaxResult.error("下发指令失败！"); return AjaxResult.error("下发指令失败！");