code-image-backup-public/fastbee
1
0
Fork 0
mirror of https://gitee.com/beecue/fastbee.git synced 2025-12-17 16:36:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

设备状态同步改进

Browse Source
This commit is contained in:
kerwincui
2022-07-04 18:23:03 +08:00
parent c629033690
commit b3ed268175
4 changed files with 26 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
springboot/wumei-iot/src/main/java/com/ruoyi/iot/mqtt/EmqxService.java
View File

@@ -274,7 +274,7 @@ public class EmqxService {
// 1-未激活，2-禁用，3-在线，4-离线
if(device.getStatus()==3){
device.setStatus(4);
deviceService.updateDevice(device);
deviceService.updateDeviceStatus(device);
// 发布设备信息
publishInfo(device.getProductId(),device.getSerialNumber());
}

9
springboot/wumei-iot/src/main/java/com/ruoyi/iot/service/IDeviceService.java
View File

@@ -141,12 +141,19 @@ public interface IDeviceService
public AjaxResult updateDevice(Device device);
/**
* 更新设备状态
* 更新设备状态和定位
* @param device 设备
* @return 结果
*/
public int updateDeviceStatusAndLocation(Device device,String ipAddress);
/**
* 更新设备状态
* @param device 设备
* @return 结果
*/
public int updateDeviceStatus(Device device);
/**
* 上报设备信息
* @param device 设备

19
springboot/wumei-iot/src/main/java/com/ruoyi/iot/service/impl/DeviceServiceImpl.java
View File

@@ -533,15 +533,6 @@ public class DeviceServiceImpl implements IDeviceService {
SysUser user = getLoginUser().getUser();
device.setNetworkIp(user.getLoginIp());
setLocation(user.getLoginIp(),device);
// if(device.getLongitude()==null || device.getLongitude().equals("")){
// device.setLongitude(BigDecimal.valueOf(116.23-(Math.random()*15)));
// }
// if(device.getLatitude()==null || device.getLatitude().equals("")){
// device.setLatitude(BigDecimal.valueOf(39.54-(Math.random()*15)));
// }
// if(device.getNetworkAddress()==null || device.getNetworkAddress().equals("")){
// device.setNetworkAddress("中国");
// }
deviceMapper.insertDevice(device);
// 添加设备用户
@@ -783,6 +774,16 @@ public class DeviceServiceImpl implements IDeviceService {
return result;
}
/**
*
* @param device 设备状态
* @return 结果
*/
@Override
public int updateDeviceStatus(Device device) {
return deviceMapper.updateDeviceStatus(device);
}
/**
* 根据IP获取地址
* @param ip

10
springboot/wumei-iot/src/main/java/com/ruoyi/iot/service/impl/ToolServiceImpl.java
View File

@@ -224,9 +224,13 @@ public class ToolServiceImpl implements IToolService
}
String mqttPassword = passwordArray[0];
String authCode = passwordArray.length == 2 ? passwordArray[1] : "";
// 验证用户名和密码
if ((!mqttConfig.getusername().equals(mqttModel.getUserName())) || (!mqttConfig.getpassword().equals(mqttPassword))) {
return returnUnauthorized(mqttModel, "设备简单认证，mqtt账号和密码与认证服务器配置不匹配");
// 验证用户名
if (!mqttModel.getUserName().equals(productModel.getMqttAccount())) {
return returnUnauthorized(mqttModel, "设备简单认证，设备mqtt用户名错误");
}
// 验证密码
if (!mqttPassword.equals(productModel.getMqttPassword())) {
return returnUnauthorized(mqttModel, "设备简单认证，设备mqtt密码错误");
}
// 验证授权码
if (productModel.getIsAuthorize() == 1) {