From 1aba7557e091d2220337b27c79c7cd50e7c0478f Mon Sep 17 00:00:00 2001 From: zhangyue <82248909@qq.com> Date: Wed, 27 May 2026 16:20:05 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=86=E6=89=B9=E6=AC=A1=E5=8F=91=E9=80=81mq?= =?UTF-8?q?tt=E6=8C=87=E4=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/IotCommonP3ServiceImpl.java | 21 ++++++++++++++++--- 1 file changed, 18 insertions(+), 3 deletions(-) diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java index c248a84..232d9f6 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/service/impl/IotCommonP3ServiceImpl.java @@ -739,9 +739,24 @@ public class IotCommonP3ServiceImpl { try{ log.error("===========预发送指令========={}============", variables.size()); if (deploy != null && variables != null && !variables.isEmpty()) { - QueryCmd queryCmd = LhIotUtil.ConstructCmd(variables); - String cmdStr = JSONObject.toJSONString(queryCmd); - mqttService.sendMessage(deploy.getDeviceIotUrl(), cmdStr); + if(variables.size()>10){ + //如果超过十个分多次，十个一组 + int batchSize = 10; + for (int i = 0; i < variables.size(); i += batchSize) { + int end = Math.min(i + batchSize, variables.size()); + List batch = variables.subList(i, end); + + // 处理这一批数据 + QueryCmd queryCmd = LhIotUtil.ConstructCmd(batch); + String cmdStr = JSONObject.toJSONString(queryCmd); + mqttService.sendMessage(deploy.getDeviceIotUrl(), cmdStr); + + log.error("===========当前批次指令========={}============", batch); + } + + } + + } }catch (Exception e){ //抛出未注入时的报错