From e1db9ffb1a5bd076dcb057295277232bad4eb285 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Tue, 20 Aug 2024 16:47:17 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/njcn/access/handler/MqttMessageHandler.java  | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

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.更新电网侧、负载侧监测点相关信息