From 87cd5df70918e6ba1af849c5f026d3719bfdb1ac Mon Sep 17 00:00:00 2001
From: wjc <1243177876@qq.com>
Date: 星期三, 09 四月 2025 09:06:29 +0800
Subject: [PATCH] Merge branch '1.5.2' into dev

---
 app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java |   36 ++++++++++++++++++++++++++++++++----
 1 files changed, 32 insertions(+), 4 deletions(-)

diff --git a/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java b/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java
index f5eb2c4..ff46904 100644
--- a/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java
+++ b/app/src/main/java/com/hdl/photovoltaic/other/HdlDeviceLogic.java
@@ -39,6 +39,7 @@
 import java.lang.reflect.Type;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
@@ -291,7 +292,8 @@
      * @param whetherToAdd true琛ㄧず鐢ㄥ閲�,false琛ㄧず鐢ㄥ叏閲�
      */
     public void uploadOidDataToCloud(String homeId, List<GatewayBean> list, boolean whetherToAdd, CloudCallBeak<Boolean> callBeak) {
-        if (list == null || list.size() == 0) {
+
+        if (list == null || list.isEmpty()) {
             return;
         }
         if (whetherToAdd) {
@@ -346,7 +348,7 @@
                         }
                         newOidList.addAll(oidBeanList);
                         if (atomicInteger.get() == list.size()) {
-                            if (newOidList.size() == 0) {
+                            if (newOidList.isEmpty()) {
                                 return;
                             }
 //                        //澧為噺娣诲姞oid
@@ -381,7 +383,7 @@
                     public void onError(HDLLinkException e) {
                         atomicInteger.set(atomicInteger.get() + 1);
                         if (atomicInteger.get() == list.size()) {
-                            if (newOidList.size() == 0) {
+                            if (newOidList.isEmpty()) {
                                 HdlLogLogic.print("鑾峰彇閫嗗彉鍣╫id鍒楄〃澶辫触---浣忓畢id:" + homeId + "---mac:" + gatewayBean.getDevice_mac() + "-->" + e.getMsg() + "(" + e.getCode() + ")", true);
                                 return;
                             }
@@ -624,6 +626,10 @@
      * @param cloudCallBeak 鍥炶皟update
      */
     public void fullUpdateOid(String homeId, List<OidBean> oidList, CloudCallBeak<Boolean> cloudCallBeak) {
+        if (!UserConfigManage.getInstance().getHomeId().equals(homeId)) {
+            HdlLogLogic.print("涓婁紶oid鍒楄〃鍒颁簯绔け璐�---褰撳墠浣忓畢id:" + UserConfigManage.getInstance().getHomeId() + "---涓婁紶浣忓畢id:" + homeId, true);
+            return;
+        }
         if (oidList == null || oidList.size() == 0) {
             HdlLogLogic.print("oid鍒楄〃涓虹┖锛屾棤娉曞叏閲忔洿鏂皁id鍒颁簯绔�---", true);
             return;
@@ -679,6 +685,10 @@
      * @param cloudCallBeak 鍥炶皟update
      */
     public void updateOidAdd(String homeId, List<OidBean> oidList, CloudCallBeak<Boolean> cloudCallBeak) {
+        if (!UserConfigManage.getInstance().getHomeId().equals(homeId)) {
+            HdlLogLogic.print("涓婁紶oid鍒楄〃鍒颁簯绔け璐�---褰撳墠浣忓畢id:" + UserConfigManage.getInstance().getHomeId() + "---涓婁紶浣忓畢id:" + homeId, true);
+            return;
+        }
         if (oidList == null || oidList.size() == 0) {
             HdlLogLogic.print("oid鍒楄〃涓虹┖锛屾棤娉曞閲忔坊鍔爋id鍒颁簯绔�---", true);
             return;
@@ -1132,7 +1142,7 @@
                                 List<String> removeSidList = new ArrayList<>();
                                 for (int j = 0; j < HDLLinkLocalGateway.getInstance().getGatewayList().size(); j++) {
                                     GatewayBean gatewayBean = HDLLinkLocalGateway.getInstance().getGatewayList().get(j);
-                                    if (gatewayBean.getSpk().equals(INVERTER_DEVICE_SPK)) {
+                                    if (!isLoadCenterSpk(gatewayBean.getSpk())) {
                                         //涓嶆槸璐熻浇涓績鐨剆pk涓嶅仛澶勭悊锛�
                                         continue;
                                     }
@@ -1348,6 +1358,16 @@
         if (gatewayBean != null) {
             HDLLinkLocalGateway.getInstance().getGatewayList().remove(gatewayBean);
         }
+    }
+
+    /**
+     * 鍒ゆ柇spk鏄惁鏄礋杞戒腑蹇�
+     *
+     * @param spk spk
+     * @return 鐪�=true锛屽惁鍒欒繑鍥瀎alse
+     */
+    private boolean isLoadCenterSpk(String spk) {
+        return Objects.equals(spk, LC_SPK);
     }
 
     /**
@@ -1721,6 +1741,9 @@
         gatewayBean.setDevice_name(cloudInverterDeviceBean.getName());//璁惧鍚嶇О
         gatewayBean.setGatewayType(cloudInverterDeviceBean.getSpk());//璁剧疆spk
         gatewayBean.setLocalEncrypt(true);
+        //绂荤綉閫嗗彉鍣�
+        gatewayBean.setOgMaster(cloudInverterDeviceBean.isOgMaster());
+        //閫嗗彉鍣�
         gatewayBean.setMaster(GatewayMasterType.MasterTrue);//榛樿閮芥槸涓婚�嗗彉鍣�(浠ュ悗鏀寔浠庨�嗗彉鍣ㄨ鏇存敼)
         gatewayBean.setSystemStatusDesc(cloudInverterDeviceBean.getSystemStatusDesc());//璁惧鐘舵��
         gatewayBean.setHwVersion(cloudInverterDeviceBean.getHwVersion());//杞欢鐗堟湰鍙�
@@ -1749,6 +1772,7 @@
         List<String> spks = new ArrayList<>();
         spks.add(INVERTER_DEVICE_SPK);
         spks.add(LC_SPK);
+        spks.add(OFF_INVERTER_OG_SPK);
         return spks;
     }
 
@@ -1772,4 +1796,8 @@
      * 璐熻浇涓績spk
      */
     public final String LC_SPK = "energy.hdl_lc";
+    /**
+     * 绂荤嚎閫嗗彉鍣╯pk
+     */
+    public final String OFF_INVERTER_OG_SPK = "energy.inverter_og";
 }

--
Gitblit v1.8.0