From 0f91b37f7711481b9671409d0de08873d77060eb Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期三, 20 十二月 2023 17:24:31 +0800
Subject: [PATCH] 2023年12月20日17:24:20

---
 app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java |  340 ++++++++++++++++++++++++++++++++++++--------------------
 1 files changed, 216 insertions(+), 124 deletions(-)

diff --git a/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java b/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java
index cdf638f..1a0c645 100644
--- a/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java
+++ b/app/src/main/java/com/hdl/photovoltaic/other/HdlUniLogic.java
@@ -305,9 +305,9 @@
                     break;
                 }
             }
-            HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�===澶х被->" + topic + "\r\n" + data, false);
+            HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�===澶х被->" + topic + "\r\n" + data, true);
         } catch (Exception e) {
-            HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�===" + e.getMessage(), false);
+            HdlLogLogic.print("uni===鍘熺敓鎺ユ敹uni鍙戞潵鐨勬暟鎹�===" + e.getMessage(), true);
         }
 
     }
@@ -465,7 +465,14 @@
                 } else {
                     HdlFileLogic.getInstance().deleteFile(firmwarePathFileName);//涓嬭浇澶辫触锛屽垹闄や笉瀹屾暣鍥轰欢鏂囦欢;
                 }
-                HdlLogLogic.print("鍐欏叆鏂板浐浠舵枃浠跺埌鍐呭瓨鎴愬姛.", true);
+
+                if (isBoolean) {
+                    HdlLogLogic.print("鍐欏叆鏂板浐浠舵枃浠跺埌鍐呭瓨鎴愬姛.", true);
+                    uniCallbackData(null, 0, "鍐欏叆鏂伴┍鍔ㄦ枃浠跺埌鍐呭瓨鎴愬姛", callback);
+                } else {
+                    HdlLogLogic.print("鐢ㄦ埛鍙栨秷涓嬭浇鍥轰欢鍗囩骇鏂囦欢.", true);
+                    uniCallbackData(null, -2, "鐢ㄦ埛鍙栨秷涓嬭浇椹卞姩鍗囩骇鏂囦欢", callback);
+                }
             }
 
             @Override
@@ -490,68 +497,74 @@
         String module = "FW#" + imageId;
 
         //鍗囩骇鏈湴浼樺厛->浜戠鍗囩骇
-        boolean isLocalConnect = HdlDeviceLogic.getInstance().isLocalConnect(deviceMac);
-        if (isLocalConnect) {
-            //鏈湴
-            //1,寤虹珛鏈湴鏈嶅姟锛�
-            //2,鍛婅瘔缃戝叧鎵嬫満ip鍜岀鍙o紱
-            //瀹炰緥鍖� 鑾峰彇ip 鍦板潃
-            if (HdlOtaLogic.getInstance().mServiceStart) {
-                HdlOtaLogic.getInstance().unLocalService();
-            }
-            HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {
-                @Override
-                public void onServiceConnected(ComponentName name, IBinder service) {
-                    //鏈湴鍗囩骇鍥轰欢鏂囦欢璺緞
-                    String firmwarePathFileName = HdlFileLogic.getInstance().getFirmwarePathFileName(oid, imageId, version);
-                    byte[] data = HdlFileLogic.getInstance().readFileByte(firmwarePathFileName);
-                    if (data == null || data.length == 0) {
-                        uniCallbackData(null, -2, "鏈湴鎵句笉鍒板崌绾у浐浠舵枃浠�,璇蜂笅杞藉ソ鍥轰欢鏂囦欢,鍐嶉噸鏂板崌绾�.", callback);
-                        return;
-                    }
-                    String md5 = HDLMD5Utils.encodeMD5(data);//缃戝叧鍥轰欢闇�瑕�
-                    //鍗囩骇鍥轰欢鏂囦欢鍦板潃
-                    String upgradeFileLocalPathUrl = "http://" + AppManagerUtils.getAppManager().getIPAddress(HDLApp.getInstance()) + ":" + MyNanoHttpServer.HTTP_PORT + firmwarePathFileName;
-                    //閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�绛変俊鎭�
-                    HdlOtaLogic.getInstance().pushUpgradePacketInfo(deviceMac, oid, module, version, data.length + "", upgradeFileLocalPathUrl, md5, new LinkCallBack<String>() {
+        HdlDeviceLogic.getInstance().isLocalConnect(deviceMac, new CloudCallBeak<Boolean>() {
+            @Override
+            public void onSuccess(Boolean b) {
+                if (b) {
+                    //鏈湴
+                    //1,寤虹珛鏈湴鏈嶅姟锛�
+                    //2,鍛婅瘔缃戝叧鎵嬫満ip鍜岀鍙o紱
+                    //瀹炰緥鍖� 鑾峰彇ip 鍦板潃
+                    HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {
                         @Override
-                        public void onSuccess(String obj) {
-                            HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�鎴愬姛.", true);
+                        public void onServiceConnected(ComponentName name, IBinder service) {
+                            //鏈湴鍗囩骇鍥轰欢鏂囦欢璺緞
+                            String firmwarePathFileName = HdlFileLogic.getInstance().getFirmwarePathFileName(oid, imageId, version);
+                            byte[] data = HdlFileLogic.getInstance().readFileByte(firmwarePathFileName);
+                            if (data == null || data.length == 0) {
+                                uniCallbackData(null, -2, "鏈湴鎵句笉鍒板崌绾у浐浠舵枃浠�,璇蜂笅杞藉ソ鍥轰欢鏂囦欢,鍐嶉噸鏂板崌绾�.", callback);
+                                return;
+                            }
+                            String md5 = HDLMD5Utils.encodeMD5(data);//缃戝叧鍥轰欢闇�瑕�
+                            //鍗囩骇鍥轰欢鏂囦欢鍦板潃
+                            String upgradeFileLocalPathUrl = "http://" + AppManagerUtils.getAppManager().getIPAddress(HDLApp.getInstance()) + ":" + MyNanoHttpServer.HTTP_PORT + firmwarePathFileName;
+                            //閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�绛変俊鎭�
+                            HdlOtaLogic.getInstance().pushUpgradePacketInfo(deviceMac, oid, module, version, data.length + "", upgradeFileLocalPathUrl, md5, new LinkCallBack<String>() {
+                                @Override
+                                public void onSuccess(String obj) {
+                                    HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�鎴愬姛.", true);
+                                }
+
+                                @Override
+                                public void onError(HDLLinkException e) {
+                                    HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇.", true);
+                                    uniCallbackData(null, -2, "閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇,", callback);
+                                }
+                            });
                         }
 
                         @Override
-                        public void onError(HDLLinkException e) {
-                            HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇.", true);
-                            uniCallbackData(null, -2, "閫氱煡缁欑綉鍏冲崌绾у浐浠舵枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇,", callback);
+                        public void onServiceDisconnected(ComponentName name) {
+                            uniCallbackData(null, -2, "鏈湴鏈嶅姟鏈夊紓甯稿け璐�,鏃犳硶鍗囩骇,", callback);
                         }
                     });
-                }
-
-                @Override
-                public void onServiceDisconnected(ComponentName name) {
-                    uniCallbackData(null, -2, "鏈湴鏈嶅姟鏈夊紓甯稿け璐�,鏃犳硶鍗囩骇,", callback);
-                }
-            });
-
-        } else {
-            //杩滅▼鍗囩骇闇�瑕佹娴嬪湪閫嗗彉鍣ㄦ湁娌℃湁杩炴帴涓婁簯
-            HdlDeviceLogic.getInstance().checkInverterConnectedCloud(deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
-                @Override
-                public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
-                    //1锛氳繛鎺ヤ腑,2锛氭晠闅�,3锛氳繍琛�,4锛氱绾�,6:閫嗗彉鍣ㄨ繛涓嶄笂浜�(鑷畾涔�)
-                    if (cloudInverterDeviceBean == null) {
-                        uniCallbackData(null, 6, HDLApp.getInstance().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
-                        return;
-                    }
-                    if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
-                        uniCallbackData(null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getString(R.string.ota_not_cloud_upgrade_fails), callback);
-                        return;
-                    }
-                    //4:杩愯
-                    HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
+                } else {
+                    //杩滅▼鍗囩骇闇�瑕佹娴嬪湪閫嗗彉鍣ㄦ湁娌℃湁杩炴帴涓婁簯
+                    HdlDeviceLogic.getInstance().checkInverterConnectedCloud(deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
                         @Override
-                        public void onSuccess(Boolean obj) {
-                            uniCallbackData(obj, callback);
+                        public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
+                            //1锛氳繛鎺ヤ腑,2锛氭晠闅�,3锛氳繍琛�,4锛氱绾�,6:閫嗗彉鍣ㄨ繛涓嶄笂浜�(鑷畾涔�)
+                            if (cloudInverterDeviceBean == null) {
+                                uniCallbackData(null, 6, HDLApp.getInstance().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
+                                return;
+                            }
+                            if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
+                                uniCallbackData(null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getString(R.string.ota_not_cloud_upgrade_fails), callback);
+                                return;
+                            }
+                            //4:杩愯
+                            HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
+                                @Override
+                                public void onSuccess(Boolean obj) {
+                                    uniCallbackData(obj, callback);
+                                }
+
+                                @Override
+                                public void onFailure(HDLException e) {
+                                    uniCallbackData(null, e.getCode(), e.getMsg(), callback);
+                                }
+                            });
+
                         }
 
                         @Override
@@ -559,16 +572,47 @@
                             uniCallbackData(null, e.getCode(), e.getMsg(), callback);
                         }
                     });
-
                 }
+            }
 
-                @Override
-                public void onFailure(HDLException e) {
-                    uniCallbackData(null, e.getCode(), e.getMsg(), callback);
-                }
-            });
+            @Override
+            public void onFailure(HDLException e) {
+                //杩滅▼鍗囩骇闇�瑕佹娴嬪湪閫嗗彉鍣ㄦ湁娌℃湁杩炴帴涓婁簯
+                HdlDeviceLogic.getInstance().checkInverterConnectedCloud(deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
+                    @Override
+                    public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
+                        //1锛氳繛鎺ヤ腑,2锛氭晠闅�,3锛氳繍琛�,4锛氱绾�,6:閫嗗彉鍣ㄨ繛涓嶄笂浜�(鑷畾涔�)
+                        if (cloudInverterDeviceBean == null) {
+                            uniCallbackData(null, 6, HDLApp.getInstance().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
+                            return;
+                        }
+                        if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
+                            uniCallbackData(null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getString(R.string.ota_not_cloud_upgrade_fails), callback);
+                            return;
+                        }
+                        //4:杩愯
+                        HdlOtaLogic.getInstance().upgradeDeviceFirmware(deviceOidId, firmwareVersionId, new CloudCallBeak<Boolean>() {
+                            @Override
+                            public void onSuccess(Boolean obj) {
+                                uniCallbackData(obj, callback);
+                            }
 
-        }
+                            @Override
+                            public void onFailure(HDLException e) {
+                                uniCallbackData(null, e.getCode(), e.getMsg(), callback);
+                            }
+                        });
+
+                    }
+
+                    @Override
+                    public void onFailure(HDLException e) {
+                        uniCallbackData(null, e.getCode(), e.getMsg(), callback);
+                    }
+                });
+            }
+        });
+
     }
 
     /**
@@ -666,7 +710,13 @@
                 } else {
                     HdlFileLogic.getInstance().deleteFile(drivePathFileName);//涓嬭浇澶辫触锛屽垹闄や笉瀹屾暣椹卞姩鏂囦欢;
                 }
-                HdlLogLogic.print("鍐欏叆鏂伴┍鍔ㄦ枃浠跺埌鍐呭瓨鎴愬姛.", true);
+                if (isBoolean) {
+                    HdlLogLogic.print("鍐欏叆鏂伴┍鍔ㄦ枃浠跺埌鍐呭瓨鎴愬姛.", true);
+                    uniCallbackData(null, 0, "鍐欏叆鏂伴┍鍔ㄦ枃浠跺埌鍐呭瓨鎴愬姛", callback);
+                } else {
+                    HdlLogLogic.print("鐢ㄦ埛鍙栨秷涓嬭浇椹卞姩鍗囩骇鏂囦欢.", true);
+                    uniCallbackData(null, -2, "鐢ㄦ埛鍙栨秷涓嬭浇椹卞姩鍗囩骇鏂囦欢", callback);
+                }
             }
 
             @Override
@@ -690,64 +740,74 @@
         String imageId = getKeyValue("imageId", getKeyValue("data", data));//鍥轰欢闀滃儚id
         String module = driverCode + "#" + imageId;
         //鍗囩骇鏈湴浼樺厛->浜戠鍗囩骇
-        boolean isLocalConnect = HdlDeviceLogic.getInstance().isLocalConnect(deviceMac);
-        if (isLocalConnect) {
-            //鏈湴
-            //1,寤虹珛鏈湴鏈嶅姟锛�
-            // 2锛屽憡璇夌綉鍏虫墜鏈篿p鍜岀鍙o紱
-            //瀹炰緥鍖� 鑾峰彇ip 鍦板潃
-            HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {
-                @Override
-                public void onServiceConnected(ComponentName name, IBinder service) {
-                    //鏈湴鍗囩骇椹卞姩鏂囦欢璺緞
-                    String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, version);
-                    byte[] data = HdlFileLogic.getInstance().readFileByte(drivePathFileName);
-                    if (data == null || data.length == 0) {
-                        uniCallbackData(null, -2, "鏈湴鎵句笉鍒板崌绾ч┍鍔ㄦ枃浠�,璇蜂笅杞藉ソ椹卞姩鏂囦欢,鍐嶉噸鏂板崌绾�.", callback);
-                        return;
-                    }
-                    String md5 = HDLMD5Utils.encodeMD5(data);//缃戝叧椹卞姩闇�瑕�
-                    //鍗囩骇椹卞姩鏂囦欢鍦板潃
-                    String upgradeFileLocalPathUrl = "http://" + AppManagerUtils.getAppManager().getIPAddress(HDLApp.getInstance()) + ":" + MyNanoHttpServer.HTTP_PORT + drivePathFileName;
-                    //閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�绛変俊鎭�
-                    HdlOtaLogic.getInstance().pushUpgradePacketInfo(deviceMac, deviceOid, module, version, data.length + "", upgradeFileLocalPathUrl, md5, new LinkCallBack<String>() {
+        HdlDeviceLogic.getInstance().isLocalConnect(deviceMac, new CloudCallBeak<Boolean>() {
+            @Override
+            public void onSuccess(Boolean b) {
+                if (b) {
+                    //鏈湴
+                    //1,寤虹珛鏈湴鏈嶅姟锛�
+                    // 2锛屽憡璇夌綉鍏虫墜鏈篿p鍜岀鍙o紱
+                    //瀹炰緥鍖� 鑾峰彇ip 鍦板潃
+                    HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {
                         @Override
-                        public void onSuccess(String obj) {
-                            HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�鎴愬姛.", true);
+                        public void onServiceConnected(ComponentName name, IBinder service) {
+                            //鏈湴鍗囩骇椹卞姩鏂囦欢璺緞
+                            String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName(driverCode, version);
+                            byte[] data = HdlFileLogic.getInstance().readFileByte(drivePathFileName);
+                            if (data == null || data.length == 0) {
+                                uniCallbackData(null, -2, "鏈湴鎵句笉鍒板崌绾ч┍鍔ㄦ枃浠�,璇蜂笅杞藉ソ椹卞姩鏂囦欢,鍐嶉噸鏂板崌绾�.", callback);
+                                return;
+                            }
+                            String md5 = HDLMD5Utils.encodeMD5(data);//缃戝叧椹卞姩闇�瑕�
+                            //鍗囩骇椹卞姩鏂囦欢鍦板潃
+                            String upgradeFileLocalPathUrl = "http://" + AppManagerUtils.getAppManager().getIPAddress(HDLApp.getInstance()) + ":" + MyNanoHttpServer.HTTP_PORT + drivePathFileName;
+                            //閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�绛変俊鎭�
+                            HdlOtaLogic.getInstance().pushUpgradePacketInfo(deviceMac, deviceOid, module, version, data.length + "", upgradeFileLocalPathUrl, md5, new LinkCallBack<String>() {
+                                @Override
+                                public void onSuccess(String obj) {
+                                    HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�鎴愬姛.", true);
+                                }
+
+                                @Override
+                                public void onError(HDLLinkException e) {
+                                    HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇.", true);
+                                    uniCallbackData(null, -2, "閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇,", callback);
+                                }
+                            });
                         }
 
                         @Override
-                        public void onError(HDLLinkException e) {
-                            HdlLogLogic.print("閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇.", true);
-                            uniCallbackData(null, -2, "閫氱煡缁欑綉鍏冲崌绾ч┍鍔ㄦ枃浠跺湴鍧�澶辫触,鏃犳硶鍗囩骇,", callback);
+                        public void onServiceDisconnected(ComponentName name) {
+                            uniCallbackData(null, -2, "鏈湴鏈嶅姟鏈夊紓甯稿け璐�,鏃犳硶鍗囩骇,", callback);
                         }
                     });
-                }
-
-                @Override
-                public void onServiceDisconnected(ComponentName name) {
-                    uniCallbackData(null, -2, "鏈湴鏈嶅姟鏈夊紓甯稿け璐�,鏃犳硶鍗囩骇,", callback);
-                }
-            });
-        } else {
-            //杩滅▼鍗囩骇闇�瑕併�愭娴嬨�戝湪閫嗗彉鍣ㄦ湁娌℃湁杩炴帴涓婁簯
-            HdlDeviceLogic.getInstance().checkInverterConnectedCloud(deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
-                @Override
-                public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
-                    //1锛氳繛鎺ヤ腑,2锛氭晠闅�,3锛氳繍琛�,4锛氱绾�,6:閫嗗彉鍣ㄨ繛涓嶄笂浜�(鑷畾涔�)
-                    if (cloudInverterDeviceBean == null) {
-                        uniCallbackData(null, 6, HDLApp.getInstance().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
-                        return;
-                    }
-                    if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
-                        uniCallbackData(null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getString(R.string.ota_not_cloud_upgrade_fails), callback);
-                        return;
-                    }
-                    //4:杩愯
-                    HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
+                } else {
+                    //杩滅▼鍗囩骇闇�瑕併�愭娴嬨�戝湪閫嗗彉鍣ㄦ湁娌℃湁杩炴帴涓婁簯
+                    HdlDeviceLogic.getInstance().checkInverterConnectedCloud(deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
                         @Override
-                        public void onSuccess(Boolean obj) {
-                            uniCallbackData(obj, callback);
+                        public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
+                            //1锛氳繛鎺ヤ腑,2锛氭晠闅�,3锛氳繍琛�,4锛氱绾�,6:閫嗗彉鍣ㄨ繛涓嶄笂浜�(鑷畾涔�)
+                            if (cloudInverterDeviceBean == null) {
+                                uniCallbackData(null, 6, HDLApp.getInstance().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
+                                return;
+                            }
+                            if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
+                                uniCallbackData(null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getString(R.string.ota_not_cloud_upgrade_fails), callback);
+                                return;
+                            }
+                            //4:杩愯
+                            HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
+                                @Override
+                                public void onSuccess(Boolean obj) {
+                                    uniCallbackData(obj, callback);
+                                }
+
+                                @Override
+                                public void onFailure(HDLException e) {
+                                    uniCallbackData(null, e.getCode(), e.getMsg(), callback);
+                                }
+                            });
+
                         }
 
                         @Override
@@ -755,16 +815,47 @@
                             uniCallbackData(null, e.getCode(), e.getMsg(), callback);
                         }
                     });
-
                 }
+            }
 
-                @Override
-                public void onFailure(HDLException e) {
-                    uniCallbackData(null, e.getCode(), e.getMsg(), callback);
-                }
-            });
+            @Override
+            public void onFailure(HDLException e) {
+                //杩滅▼鍗囩骇闇�瑕併�愭娴嬨�戝湪閫嗗彉鍣ㄦ湁娌℃湁杩炴帴涓婁簯
+                HdlDeviceLogic.getInstance().checkInverterConnectedCloud(deviceMac, new CloudCallBeak<CloudInverterDeviceBean>() {
+                    @Override
+                    public void onSuccess(CloudInverterDeviceBean cloudInverterDeviceBean) {
+                        //1锛氳繛鎺ヤ腑,2锛氭晠闅�,3锛氳繍琛�,4锛氱绾�,6:閫嗗彉鍣ㄨ繛涓嶄笂浜�(鑷畾涔�)
+                        if (cloudInverterDeviceBean == null) {
+                            uniCallbackData(null, 6, HDLApp.getInstance().getString(R.string.ota_binding_cloud_upgrade_fails), callback);
+                            return;
+                        }
+                        if (cloudInverterDeviceBean.getDeviceStatus() != 3) {
+                            uniCallbackData(null, cloudInverterDeviceBean.getDeviceStatus(), HDLApp.getInstance().getString(R.string.ota_not_cloud_upgrade_fails), callback);
+                            return;
+                        }
+                        //4:杩愯
+                        HdlOtaLogic.getInstance().upgradeGatewayDriver(deviceOid, driverVersionId, new CloudCallBeak<Boolean>() {
+                            @Override
+                            public void onSuccess(Boolean obj) {
+                                uniCallbackData(obj, callback);
+                            }
 
-        }
+                            @Override
+                            public void onFailure(HDLException e) {
+                                uniCallbackData(null, e.getCode(), e.getMsg(), callback);
+                            }
+                        });
+
+                    }
+
+                    @Override
+                    public void onFailure(HDLException e) {
+                        uniCallbackData(null, e.getCode(), e.getMsg(), callback);
+                    }
+                });
+            }
+        });
+
     }
 
     /**
@@ -772,6 +863,7 @@
      */
     private void uniCancelDownloadingUpgradeFile(Object data, DCUniMPJSCallback callback) {
         HdlOtaLogic.getInstance().stopDownloadUpgradeFile();
+        uniCallbackData(null, 0, "鍙栨秷涓嬭浇鎴愬姛.", callback);
     }
 
     /**

--
Gitblit v1.8.0