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

统一类名

This commit is contained in:
zy 2025-12-20 15:52:29 +08:00
parent 3e3ded66ee
commit 1cdf314f0e
2 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -333,19 +333,6 @@ public class SurvIotVirtualDeviceServiceImpl extends ServiceImpl<SurvIotVirtualD
} else {
log.error("==================未能识别功能码，错误信息：{}：主题：{}===================", res != null ? res.getErrorMsg() : "", ident);
}
//如果是心跳，更新设备的时间
String infoStr = new String(payload);
log.error("========{}==========更新心跳：{}===================", infoStr, ident);
if ("www.usr.cn".equals(infoStr)) {
//查询网络模块
List<SurvIotVirtualDeviceModule> modules = getModulesByIdent(ident);
if (!modules.isEmpty()) {
List<String> deviceId = modules.stream().map(SurvIotVirtualDeviceModule::getDeviceId).collect(Collectors.toList());
List<SurvIotVirtualDevice> devices = lambdaQuery().in(SurvIotVirtualDevice::getId, deviceId).list();
List<String> deploys = devices.stream().map(SurvIotVirtualDevice::getIotId).collect(Collectors.toList());
deviceDeployService.refreshLastSyncTimeByDeployCode(deploys);
}
}
}catch (Exception e){
e.printStackTrace();
log.error("处理厂家mqtt报文失败，"+e.getMessage());

2
zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/mqtt/MqttConfig.java
View File

@ -29,7 +29,7 @@ public class MqttConfig {
@Value("${mqtt.password}")
public String password;
// @Value("${mqtt.clientId}")
public String clientId = "jppApp-" + UUID.fastUUID().toString().replaceAll("-","").substring(0,5);
public String clientId = "fxApp-" + UUID.fastUUID().toString().replaceAll("-","").substring(0,5);
@Value("${mqtt.timeout}")
public int timeOut;
@Value("${mqtt.keepalive}")