Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微调

Browse Source
This commit is contained in:
xy
2024-08-20 16:47:17 +08:00
parent a0e5394f11
commit e1db9ffb1a
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
iot-access/access-boot/src/main/java/com/njcn/access/handler/MqttMessageHandler.java
View File

@@ -352,6 +352,10 @@ public class MqttMessageHandler {
} }
//询问设备软件信息 //询问设备软件信息
askDevData(nDid,version,1,mid); askDevData(nDid,version,1,mid);
//更新治理监测点信息和设备容量
askDevData(nDid,version,2,(res.getMid()+1));
//更新电网侧、负载侧监测点信息
askDevData(nDid,version,3,(res.getMid()+1));
} else { } else {
log.info(AccessResponseEnum.ACCESS_RESPONSE_ERROR.getMessage()); log.info(AccessResponseEnum.ACCESS_RESPONSE_ERROR.getMessage());
logDto.setResult(0); logDto.setResult(0);
@@ -383,7 +387,7 @@ public class MqttMessageHandler {
} }
equipmentFeignClient.updateSoftInfo(nDid,csSoftInfoPo.getId()); equipmentFeignClient.updateSoftInfo(nDid,csSoftInfoPo.getId());
//询问设备容量信息 //询问设备容量信息
askDevData(nDid,version,2,(res.getMid()+1)); //askDevData(nDid,version,2,(res.getMid()+1));
} catch (ParseException e) { } catch (ParseException e) {
e.printStackTrace(); e.printStackTrace();
} }
@@ -416,7 +420,7 @@ public class MqttMessageHandler {
//3.更新设备模块个数 //3.更新设备模块个数
equipmentFeignClient.updateModuleNumber(nDid,(devInfo.size()-1)); equipmentFeignClient.updateModuleNumber(nDid,(devInfo.size()-1));
//4.询问监测点pt/ct信息 //4.询问监测点pt/ct信息
askDevData(nDid,version,3,(res.getMid()+1)); //askDevData(nDid,version,3,(res.getMid()+1));
} else if (Objects.equals(res.getDid(),2)) { } else if (Objects.equals(res.getDid(),2)) {
logDto.setOperate(nDid + "更新电网侧、负载侧监测点信息"); logDto.setOperate(nDid + "更新电网侧、负载侧监测点信息");
//1.更新电网侧、负载侧监测点相关信息 //1.更新电网侧、负载侧监测点相关信息