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

分批次发送mqtt指令

This commit is contained in:
zhangyue 2026-05-27 16:24:15 +08:00
parent 1aba7557e0
commit 467486355b
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -739,7 +739,6 @@ public class IotCommonP3ServiceImpl {
try{ try{
log.error("===========预发送指令========={}============", variables.size()); log.error("===========预发送指令========={}============", variables.size());
if (deploy != null && variables != null && !variables.isEmpty()) { if (deploy != null && variables != null && !variables.isEmpty()) {
if(variables.size()>10){
//如果超过十个分多次，十个一组 //如果超过十个分多次，十个一组
int batchSize = 10; int batchSize = 10;
for (int i = 0; i < variables.size(); i += batchSize) { for (int i = 0; i < variables.size(); i += batchSize) {
@ -754,9 +753,6 @@ public class IotCommonP3ServiceImpl {
log.error("===========当前批次指令========={}============", batch); log.error("===========当前批次指令========={}============", batch);
} }
}
} }
}catch (Exception e){ }catch (Exception e){
//抛出未注入时的报错 //抛出未注入时的报错