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:55:57 +08:00
parent b35c9e2038
commit 1ce2d1a724
2 changed files with 5 additions and 5 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/controller/SurvDeviceDeployController.java
View File

@ -441,7 +441,7 @@ public class SurvDeviceDeployController extends JeecgController<SurvDeviceDeploy
List<String> fianlVariables = variables.stream() List<String> fianlVariables = variables.stream()
.distinct() .distinct()
.collect(Collectors.toList()); .collect(Collectors.toList());
boolean b = p3Service.sendMqttDeviceQuery(deploy, fianlVariables); p3Service.sendMqttDeviceQuery(deploy, fianlVariables);
} }
break; break;
default: default:

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

@ -22,6 +22,7 @@ import org.jeecg.modules.appmana.utils.Iotutils;
import org.jeecg.modules.mqtt.service.MqttService; import org.jeecg.modules.mqtt.service.MqttService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy; import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.time.LocalDate; import java.time.LocalDate;
@ -32,6 +33,7 @@ import java.time.temporal.TemporalAdjusters;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.CompletableFuture;
@Service @Service
@Slf4j @Slf4j
@ -733,9 +735,8 @@ public class IotCommonP3ServiceImpl {
} }
return true; return true;
} }
@Async
public boolean sendMqttDeviceQuery(SurvDeviceDeploy deploy, List<String> variables) { public void sendMqttDeviceQuery(SurvDeviceDeploy deploy, List<String> variables) {
boolean result = true;
try{ try{
log.error("===========预发送指令========={}============", variables.size()); log.error("===========预发送指令========={}============", variables.size());
if (deploy != null && variables != null && !variables.isEmpty()) { if (deploy != null && variables != null && !variables.isEmpty()) {
@ -760,6 +761,5 @@ public class IotCommonP3ServiceImpl {
//抛出未注入时的报错 //抛出未注入时的报错
e.printStackTrace(); e.printStackTrace();
} }
return result;
} }
} }