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