From 1ce2d1a724a9ee6b36ef8d7c3c3797ada1ce25da Mon Sep 17 00:00:00 2001
From: zhangyue <82248909@qq.com>
Date: Mon, 17 Aug 2026 11:55:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0mqt=E7=9A=84=E6=9F=A5?=
 =?UTF-8?q?=E8=AF=A2=E5=8F=91=E9=80=81=E5=BB=B6=E8=BF=9F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../appmana/controller/SurvDeviceDeployController.java    | 2 +-
 .../appmana/service/impl/IotCommonP3ServiceImpl.java      | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/SurvDeviceDeployController.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/SurvDeviceDeployController.java
index 0b3d3b8..a69ffd0 100644
--- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/SurvDeviceDeployController.java
+++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/appmana/controller/SurvDeviceDeployController.java
@@ -441,7 +441,7 @@ public class SurvDeviceDeployController extends JeecgController<SurvDeviceDeploy
 					 List<String> fianlVariables = variables.stream()
 							 .distinct()
 							 .collect(Collectors.toList());
-					 boolean b = p3Service.sendMqttDeviceQuery(deploy, fianlVariables);
+					 p3Service.sendMqttDeviceQuery(deploy, fianlVariables);
 				 }
 				 break;
 			 default:
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 9fd9ffd..19bafa9 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
@@ -22,6 +22,7 @@ import org.jeecg.modules.appmana.utils.Iotutils;
 import org.jeecg.modules.mqtt.service.MqttService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDate;
@@ -32,6 +33,7 @@ import java.time.temporal.TemporalAdjusters;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
 
 @Service
 @Slf4j
@@ -733,9 +735,8 @@ public class IotCommonP3ServiceImpl {
         }
         return true;
     }
-
-    public boolean sendMqttDeviceQuery(SurvDeviceDeploy deploy, List<String> variables) {
-        boolean result = true;
+    @Async
+    public void sendMqttDeviceQuery(SurvDeviceDeploy deploy, List<String> variables) {
         try{
             log.error("===========预发送指令========={}============", variables.size());
             if (deploy != null && variables != null && !variables.isEmpty()) {
@@ -760,6 +761,5 @@ public class IotCommonP3ServiceImpl {
             //抛出未注入时的报错
             e.printStackTrace();
         }
-        return result;
     }
 }