Administrator
/
FenXiNspJavaMain
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加mqt的查询发送延迟

This commit is contained in:
zhangyue 2026-08-17 11:53:52 +08:00
parent 2366d521be
commit b35c9e2038
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java
View File

@ -749,6 +749,8 @@ public class IotCommonP3ServiceImpl {
QueryCmd queryCmd = LhIotUtil.ConstructCmd(batch); QueryCmd queryCmd = LhIotUtil.ConstructCmd(batch);
String cmdStr = JSONObject.toJSONString(queryCmd); String cmdStr = JSONObject.toJSONString(queryCmd);
mqttService.sendMessage(deploy.getDeviceIotUrl(), cmdStr); mqttService.sendMessage(deploy.getDeviceIotUrl(), cmdStr);
//增加延迟，发送太快会导致客户端忽略
Thread.sleep(2000);
log.error("===========当前批次指令========={}============", batch); log.error("===========当前批次指令========={}============", batch);
} }