xm
2020-07-31 ecba45c93391066bc30c7bd602c3a7683fbb99a7
ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayLogic.cs
@@ -82,7 +82,7 @@
            GatewayResourse.AppOldSelectGatewayId = string.Empty;
            //从文件中获取上一次选择的网关id
            byte[] data = Global.ReadFileByDirectory(DirNameResourse.LocalMemoryDirectory, DirNameResourse.AppOldSelectGatewayFile);
            byte[] data = HdlFileLogic.Current.ReadFileByteContent(DirNameResourse.AppOldSelectGatewayFile);
            if (data != null)
            {
                string strvalue = System.Text.Encoding.UTF8.GetString(data);
@@ -118,7 +118,7 @@
            }
            List<string> listBackupGwId = new List<string>();
            var fileData = Global.ReadFileByDirectory(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile);
            var fileData = HdlFileLogic.Current.ReadFileByteContent(DirNameResourse.BackupGatewayIdFile);
            if (fileData != null)
            {
                //新增:虽然概率低,但是确实发生了。如果有网络时,App重新绑定记录的网关失败的话
@@ -149,26 +149,10 @@
                //删除网关文件
                this.DeleteGatewayFile(gatewayId);
            }
            //LOG输出
            if (listDelete.Count > 0)
            //如果网关都没了的话,把场景全部删了
            if (listDelete.Count > 0 && this.GetAllLocalGateway().Count == 0)
            {
                string msg = "本地拥有的网关:";
                foreach (var gatewayId in this.dicGateway.Keys)
                {
                    msg += gatewayId + ",";
                }
                msg += "\r\n被删除的网关:";
                foreach (var gatewayId in listDelete)
                {
                    msg += gatewayId + ",";
                }
                msg += "\r\n此时云端返回当前账号所绑定有的网关:";
                foreach (var gatewayId in result.Keys)
                {
                    msg += gatewayId + ",";
                }
                var bytes = System.Text.Encoding.UTF8.GetBytes(msg);
                Common.Global.WriteFileByBytesByHomeId("GatewayDeleteLog.txt", bytes);
                HdlSceneLogic.Current.DeleteAllLocalScene();
            }
        }
@@ -241,6 +225,9 @@
            {
                return false;
            }
            //添加网关的话,强制主页刷新
            UserView.UserPage.Instance.RefreshAllForm = true;
            return true;
        }
@@ -276,18 +263,7 @@
                return -1;
            }
            //获取网关的信息
            var result = await zbGateway.GetZbGwInfoAsync();
            //检测网关返回的共通错误状态码
            string error = HdlCheckLogic.Current.CheckCommonErrorCode(result);
            if (error != null)
            {
                if (mode == ShowErrorMode.YES)
                {
                    this.ShowTipMsg(error);
                }
                return -1;
            }
            var result = this.GetGatewayInfo(zbGateway, true, mode);
            if (result == null)
            {
                if (mode == ShowErrorMode.YES)
@@ -299,32 +275,24 @@
                return -1;
            }
            if (result.getGwData == null)
            {
                if (mode == ShowErrorMode.YES)
                {
                    //获取网关信息失败
                    string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayInfoFail);
                    this.ShowTipMsg(msg);
                }
                return -1;
            }
            //设置住宅ID到网关
            bool flage2 = await this.SetHomeIdToGateway(zbGateway, Common.Config.Instance.HomeId, mode);
            if (flage2 == false)
            if (result.HomeId != Common.Config.Instance.HomeId)
            {
                if (mode == ShowErrorMode.YES)
                bool flage2 = await this.SetHomeIdToGateway(zbGateway, Common.Config.Instance.HomeId, mode);
                if (flage2 == false)
                {
                    //向网关设置住宅ID失败
                    string msg = Language.StringByID(R.MyInternationalizationString.uSetHomeIdToGatewayFail);
                    this.ShowTipMsg(msg);
                    if (mode == ShowErrorMode.YES)
                    {
                        //向网关设置住宅ID失败
                        string msg = Language.StringByID(R.MyInternationalizationString.uSetHomeIdToGatewayFail);
                        this.ShowTipMsg(msg);
                    }
                    return -1;
                }
                return -1;
            }
            //更新云端数据库
            int flage1 = await this.SetGatewayIdToDataBase(zbGateway);
            int flage1 = this.SetGatewayIdToDataBase(zbGateway);
            //异常也不鸟它,0是特殊含义
            if (flage1 == 0)
            {
@@ -350,9 +318,9 @@
            //刷新的是缓存,不刷新真实物理网关
            this.dicGateway[gwID].GatewayOnlineFlage = zbGateway.GatewayOnlineFlage;
            //将网关的数据设置到本地缓存中
            this.SetGatewayDataToLocalMemmory(this.dicGateway[gwID], result.getGwData);
            this.SetGatewayDataToLocalMemmory(this.dicGateway[gwID], result);
            //顺便这个变量也设置一下
            this.SetGatewayDataToLocalMemmory(zbGateway, result.getGwData, false);
            this.SetGatewayDataToLocalMemmory(zbGateway, result, false);
            if (isEsist == false)
            {
@@ -396,7 +364,7 @@
        /// </summary>
        /// <param name="zbGateway">网关对象</param>
        /// <returns></returns>
        private async Task<int> SetGatewayIdToDataBase(ZbGateway zbGateway)
        private int SetGatewayIdToDataBase(ZbGateway zbGateway)
        {
            //调用接口,绑定网关(即使失败,也返回true往下走)
            var bindGateway = new BindGatewayPra();
@@ -404,10 +372,8 @@
            //获取控制主人账号的Token
            bindGateway.LoginAccessToken = UserCenterLogic.GetConnectMainToken();
            //不显示已经被绑定过的信息,NotSetAgain:假如断网时,不二次发送
            List<string> listNotShow = new List<string>() { "NotSetAgain" };
            var result = await UserCenterLogic.GetResultCodeByRequestHttps("App/BindGatewayToHome", true, bindGateway, listNotShow);
            if (result == "Error" || result == "ErrorEx")
            var result = UserCenterLogic.GetResultCodeByRequestHttps("App/BindGatewayToHome", true, bindGateway, new List<string> { "NotCheck" });
            if (result == "Error")
            {
                return -1;
            }
@@ -479,7 +445,7 @@
            }
            //更新云端数据库
            int flage1 = await this.SetGatewayIdToDataBase(zbGateway);
            int flage1 = this.SetGatewayIdToDataBase(zbGateway);
            //异常也不鸟它,0是特殊含义
            if (flage1 == 0)
            {
@@ -507,16 +473,20 @@
            await Task.Delay(8000);
            //获取网关的信息
            var result = await zbGateway.GetZbGwInfoAsync();
            //检测网关返回的共通错误状态码
            string error = HdlCheckLogic.Current.CheckCommonErrorCode(result);
            if (error != null)
            ZbGatewayData.GetGwData result = null;
            int count = 5;
            while (count >= 0)
            {
                this.ShowTipMsg(error);
                return -1;
                result = this.GetGatewayInfo(zbGateway, true, ShowErrorMode.NO);
                if (result != null)
                {
                    break;
                }
                count--;
                //最多再等20秒
                await Task.Delay(4000);
            }
            if (result == null || result.getGwData == null)
            if (result == null)
            {
                //获取网关信息失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayInfoFail);
@@ -538,15 +508,19 @@
            //刷新的是缓存,不刷新真实物理网关
            this.dicGateway[gwID].GatewayOnlineFlage = zbGateway.GatewayOnlineFlage;
            //将网关的数据设置到本地缓存中
            this.SetGatewayDataToLocalMemmory(this.dicGateway[gwID], result.getGwData);
            this.SetGatewayDataToLocalMemmory(this.dicGateway[gwID], result);
            //顺便这个变量也设置一下
            this.SetGatewayDataToLocalMemmory(zbGateway, result.getGwData, false);
            this.SetGatewayDataToLocalMemmory(zbGateway, result, false);
            if (isEsist == false)
            {
                //添加备份
                HdlAutoBackupLogic.AddOrEditorFile(this.dicGateway[gwID].FilePath);
            }
            //添加网关的话,强制主页刷新
            UserView.UserPage.Instance.RefreshAllForm = true;
            return 1;
        }
@@ -559,42 +533,30 @@
        /// </summary>
        /// <param name="zbGateway">网关对象</param>
        /// <param name="gatewayName">网关名</param>
        public async Task<bool> ReName(ZbGateway zbGateway, string gatewayName)
        public bool ReName(ZbGateway zbGateway, string gatewayName)
        {
            ZbGateway realWay = null;
            if (this.GetRealGateway(ref realWay, zbGateway) == false)
            //只取32个byte
            var bytes = new byte[32];
            var reamarkGwBytes = System.Text.Encoding.UTF8.GetBytes(gatewayName);
            System.Array.Copy(reamarkGwBytes, 0, bytes, 0, 32 < reamarkGwBytes.Length ? 32 : reamarkGwBytes.Length);
            gatewayName = System.Text.Encoding.UTF8.GetString(bytes);
            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 91 } };
            var data = new Newtonsoft.Json.Linq.JObject { { "GwName", gatewayName } };
            jObject.Add("Data", data);
            var result = this.SendJobjectDataToGateway(zbGateway, "GwReName", jObject.ToString(), "GwReName_Respon");
            if (result.ErrorMsg != null)
            {
                //获取网关对象失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayTagartFail);
                this.ShowErrorMsg(msg);
                this.ShowTipMsg(result.ErrorMsg);
                return false;
            }
            var result = await realWay.GwReNameAsync(gatewayName);
            //检测网关返回的共通错误状态码
            string error = HdlCheckLogic.Current.CheckCommonErrorCode(result);
            if (error != null)
            {
                this.ShowErrorMsg(error);
                return false;
            }
            if (result == null)
            if (result.ErrorMsgDiv == 0)
            {
                //网关名称修改失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGatewayReNameFail);
                this.ShowErrorMsg(msg);
                return false;
            }
            //网关修改失败
            if (result.gwReNameData == null)
            {
                //网关名称修改失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGatewayReNameFail);
                this.ShowErrorMsg(msg);
                //网关回复超时
                msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                this.ShowTipMsg(msg);
                return false;
            }
@@ -620,19 +582,18 @@
        public async Task<bool> DoSwitchGateway(string gatewayId)
        {
            var zbGateway = this.GetLocalGateway(gatewayId);
            if (this.CheckGatewayOnlineByFlag(zbGateway) == true)
            //重新获取在线网关的信息
            var result = await this.GetOnlineGatewayInfo(gatewayId);
            if (result == false)
            {
                //重新获取在线网关的信息
                var result = await this.GetOnlineGatewayInfo(gatewayId);
                if (result == false)
                {
                    return false;
                }
                return false;
            }
            //切换网关,保存缓存
            this.SaveGatewayIdToLocation(gatewayId);
            //切换网关的话,主页需要重新刷新
            UserView.UserPage.Instance.RefreshForm = true;
            UserView.UserPage.Instance.RefreshAllForm = true;
            return true;
        }
@@ -677,7 +638,7 @@
            if (getGatewayInfo == true)
            {
                //获取网关信息
                var info = await this.GetGatewayNewInfoAsync(realWay);
                var info = this.GetGatewayInfo(realWay, false);
                if (info == null)
                {
                    //关闭进度条
@@ -687,7 +648,7 @@
            }
            //获取全部设备
            int result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay);
            int result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay, false);
            //关闭进度条
            ProgressBar.Close();
            if (result == -1)
@@ -704,8 +665,7 @@
        public void SaveGatewayIdToLocation(string gatewayId)
        {
            GatewayResourse.AppOldSelectGatewayId = gatewayId;
            byte[] data = System.Text.Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(GatewayResourse.AppOldSelectGatewayId));
            Global.WriteFileToDirectoryByBytes(DirNameResourse.LocalMemoryDirectory, DirNameResourse.AppOldSelectGatewayFile, data);
            HdlFileLogic.Current.SaveFileContent(DirNameResourse.AppOldSelectGatewayFile, GatewayResourse.AppOldSelectGatewayId);
        }
        #endregion
@@ -729,24 +689,15 @@
        public async Task<bool> DeleteGateway(string zbGatewayID)
        {
            ZbGateway realWay = null;
            bool hadReal = this.GetRealGateway(ref realWay, zbGatewayID);
            //暂不支持分享
            if (hadReal == true && realWay.GatewayOnlineFlage == true)
            this.GetRealGateway(ref realWay, zbGatewayID);
            //清空网关的住宅ID 网关解绑失败  不理它,因为网关可以按按键强制搜索得到
            if (realWay != null)
            {
                //清空网关的住宅ID
                bool result = await this.SetHomeIdToGateway(realWay, string.Empty, ShowErrorMode.YES);
                if (result == false)
                {
                    //网关解绑失败  不理它,因为网关可以按按键强制搜索得到
                    string msg = Language.StringByID(R.MyInternationalizationString.uGatewayUnBindFail);
                    //this.ShowErrorMsg(msg);
                    //return false;
                }
                await this.SetHomeIdToGateway(realWay, string.Empty, ShowErrorMode.NO);
            }
            //删除云端的网关
            await this.DeleteDataBaseGateway(zbGatewayID);
            this.DeleteDataBaseGateway(zbGatewayID);
            //删除网关文件
            this.DeleteGatewayFile(zbGatewayID);
@@ -754,7 +705,10 @@
            //移除
            ZbGateway.GateWayList.RemoveAll((obj) => obj.GwId == zbGatewayID);
            //断开mqtt连接
            realWay.DisConnectLocalMqttClient("GD");
            if (realWay != null)
            {
                realWay.DisConnectLocalMqttClient("GD");
            }
            return true;
        }
@@ -995,7 +949,7 @@
        public List<string> GetAllGatewayFile()
        {
            List<string> list = new List<string>();
            List<string> listFile = Global.FileListByHomeId();
            List<string> listFile = HdlFileLogic.Current.GetRootPathListFile();
            foreach (string file in listFile)
            {
                //只获取网关设备
@@ -1317,10 +1271,11 @@
        /// 获取网关加特效的名称
        /// </summary>
        /// <param name="zbGateway"></param>
        /// <param name="mode"></param>
        /// <returns></returns>
        public string GetGatewayName(ZbGateway zbGateway, GetNameMode mode = GetNameMode.SpecialGateway)
        public string GetGatewayName(ZbGateway zbGateway)
        {
            if (zbGateway == null) { return string.Empty; }
            string gwId = zbGateway.GwId;
            if (this.dicGateway.ContainsKey(gwId) == false)
            {
@@ -1334,14 +1289,10 @@
                return name;
            }
            if (mode == GetNameMode.SpecialGateway)
            var nameContent = LocalDevice.Current.GetDeviceModelIdNameInfo(localWay.LinuxImageType.ToString());
            if (nameContent != null)
            {
                string keyName = Common.LocalDevice.deviceModelIdName + localWay.LinuxImageType;
                if (LocalDevice.Current.dicDeviceAllNameID.ContainsKey(keyName) == true)
                {
                    //没有名称时,则使用R文件里面设置的默认设备名称
                    return Language.StringByID(LocalDevice.Current.dicDeviceAllNameID[keyName] + 20000);
                }
                return nameContent.A备注名字;
            }
            return string.Empty;
@@ -1378,19 +1329,18 @@
                //如果这个网关没有信息,则从新获取
                if (zbGateway.LinuxImageType != -1)
                {
                    string keyName = Common.LocalDevice.deviceModelIdName + zbGateway.LinuxImageType;
                    if (Common.LocalDevice.Current.dicDeviceAllNameID.ContainsKey(keyName) == true)
                    var nameContent = LocalDevice.Current.GetDeviceModelIdNameInfo(zbGateway.LinuxImageType.ToString());
                    if (nameContent != null)
                    {
                        //使用R文件里面设置的东西
                        button.TextID = LocalDevice.Current.dicDeviceAllNameID[keyName];
                        button.Text = nameContent.A官方名字;
                    }
                }
                else
                {
                    //给一个线程去获取它的镜像类型
                    HdlThreadLogic.Current.RunThread(async () =>
                    HdlThreadLogic.Current.RunThread(() =>
                    {
                        var result = await this.GetGatewayNewInfoAsync(zbGateway, ShowErrorMode.NO);
                        var result = this.GetGatewayInfo(zbGateway, false, ShowErrorMode.NO);
                        if (result != null)
                        {
                            //将网关的数据设置到本地缓存中
@@ -1398,11 +1348,10 @@
                            HdlThreadLogic.Current.RunMain(() =>
                            {
                                string keyName = Common.LocalDevice.deviceModelIdName + zbGateway.LinuxImageType;
                                if (Common.LocalDevice.Current.dicDeviceAllNameID.ContainsKey(keyName) == true)
                                var nameContent = LocalDevice.Current.GetDeviceModelIdNameInfo(zbGateway.LinuxImageType.ToString());
                                if (nameContent != null)
                                {
                                    //使用R文件里面设置的东西
                                    button.TextID = LocalDevice.Current.dicDeviceAllNameID[keyName];
                                    button.Text = nameContent.A官方名字;
                                }
                            });
                        }
@@ -1411,11 +1360,10 @@
            }
            else
            {
                string keyName = Common.LocalDevice.deviceModelIdName + this.dicGateway[gwId].LinuxImageType;
                if (Common.LocalDevice.Current.dicDeviceAllNameID.ContainsKey(keyName) == true)
                var nameContent = LocalDevice.Current.GetDeviceModelIdNameInfo(zbGateway.LinuxImageType.ToString());
                if (nameContent != null)
                {
                    //使用R文件里面设置的东西
                    button.TextID = Common.LocalDevice.Current.dicDeviceAllNameID[keyName];
                    button.Text = nameContent.A官方名字;
                }
            }
        }
@@ -1428,34 +1376,16 @@
        /// 获取网关信息(版本信息,镜像类型,基本信息等。只刷新本地网关的缓存)
        /// </summary>
        /// <param name="zbGateway"></param>
        /// <param name="useLocalConnect">是否强制使用本地连接发送</param>
        /// <param name="mode"></param>
        /// <returns></returns>
        public async Task<ZbGatewayData.GetGwData> GetGatewayNewInfoAsync(ZbGateway zbGateway, ShowErrorMode mode = ShowErrorMode.YES)
        public ZbGatewayData.GetGwData GetGatewayInfo(ZbGateway zbGateway, bool useLocalConnect, ShowErrorMode mode = ShowErrorMode.YES)
        {
            ZbGateway realWay = null;
            if (this.GetRealGateway(ref realWay, zbGateway) == false)
            {
                if (mode == ShowErrorMode.YES)
                {
                    string msg = Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg);
                    this.ShowTipMsg(msg);
                }
                return null;
            }
            //获取网关版本信息
            var imageTypeResult = await realWay.GetZbGwInfoAsync();
            //检测网关返回的共通错误状态码
            string error = HdlCheckLogic.Current.CheckCommonErrorCode(imageTypeResult);
            if (error != null)
            {
                if (mode == ShowErrorMode.YES)
                {
                    this.ShowTipMsg(error);
                }
                return null;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 95 } };
            var result = this.SendJobjectDataToGateway(zbGateway, "GetZbGwInfo", jObject.ToString(), "GetZbGwInfo_Respon", 5, useLocalConnect);
            if (imageTypeResult == null || imageTypeResult.getGwData == null)
            if (result.ErrorMsgDiv != 1)
            {
                if (mode == ShowErrorMode.YES)
                {
@@ -1467,42 +1397,19 @@
                }
                return null;
            }
            var getGwInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGatewayData.GetGwData>(result.ReceiptData);
            string gwID = zbGateway.GwId;
            if (this.dicGateway.ContainsKey(gwID) == true)
            {
                //刷新缓存
                ZbGateway localWay = this.dicGateway[gwID];
                //将网关的数据设置到本地缓存中
                this.SetGatewayDataToLocalMemmory(localWay, imageTypeResult.getGwData);
                this.SetGatewayDataToLocalMemmory(localWay, getGwInfo);
            }
            //顺便这个变量也设置一下
            this.SetGatewayDataToLocalMemmory(zbGateway, imageTypeResult.getGwData, false);
            this.SetGatewayDataToLocalMemmory(zbGateway, getGwInfo, false);
            return imageTypeResult.getGwData;
        }
        /// <summary>
        /// 获取网关信息,非异步,会等待(版本信息,镜像类型,基本信息等。只刷新本地网关的缓存)
        /// </summary>
        /// <param name="zbGateway"></param>
        /// <param name="mode"></param>
        /// <returns></returns>
        public ZbGatewayData.GetGwData GetGatewayNewInfo(ZbGateway zbGateway, ShowErrorMode mode = ShowErrorMode.YES)
        {
            bool bolBreak = false;
            ZbGatewayData.GetGwData result = null;
            HdlThreadLogic.Current.RunThread(async () =>
            {
                result = await this.GetGatewayNewInfoAsync(zbGateway, mode);
                bolBreak = true;
            });
            while (bolBreak == false)
            {
                System.Threading.Thread.Sleep(500);
            }
            return result;
            return getGwInfo;
        }
        /// <summary>
@@ -1525,6 +1432,7 @@
            localWay.CoordinatorFirmwareVersion = data.ZbFWVersion;
            localWay.CoordinatorImageId = data.ZbImageType;
            localWay.DriveCodeList = data.DriveCodeList;
            localWay.GwVersionDate = data.AppVersion;
            if (saveFile == true)
            {
                localWay.ReSave();
@@ -1563,11 +1471,11 @@
        /// <summary>
        /// 变更网关房间
        /// </summary>
        /// <param name="zbGateway">网关对象</param>
        /// <param name="gwId">网关Id</param>
        /// <param name="roomId">房间ID</param>
        public void ChangedGatewayRoom(ZbGateway zbGateway, string roomId)
        public void ChangedGatewayRoom(string gwId, string roomId)
        {
            var localGateway = this.GetLocalGateway(zbGateway.GwId);
            var localGateway = this.GetLocalGateway(gwId);
            if (localGateway != null)
            {
                localGateway.RoomId = roomId;
@@ -1609,10 +1517,10 @@
        /// <param name="zbGateway">网关对象</param>
        /// <param name="mode">错误时,是否显示错误</param>
        /// <returns></returns>
        public async Task<List<FirmwareVersionInfo>> GetGatewayAllNewVersion(ZbGateway zbGateway, ShowErrorMode mode = ShowErrorMode.YES)
        public List<FirmwareVersionInfo> GetGatewayAllNewVersion(ZbGateway zbGateway, ShowErrorMode mode = ShowErrorMode.YES)
        {
            //获取网关版本信息
            var result = await HdlGatewayLogic.Current.GetGatewayNewInfoAsync(zbGateway, mode);
            var result = this.GetGatewayInfo(zbGateway, false, mode);
            if (result == null)
            {
                return null;
@@ -1629,10 +1537,14 @@
                localWay.LinuxHardVersion.ToString(),
                localWay.LinuxImageType.ToString());
            //添加协调器的升级固件(成不成功都无所谓)
            flage = HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.Coordinator,
                localWay.CoordinatorHardVersion.ToString(),
                localWay.CoordinatorImageId.ToString());
            //添加协调器的升级固件(成不成功都无所谓) 必须能够联网才行
            if (flage == 1)
            {
                //没网的时候不再处理
                HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.Coordinator,
                    localWay.CoordinatorHardVersion.ToString(),
                    localWay.CoordinatorImageId.ToString());
            }
            //网关的版本
            var gatewayFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.Linux,
@@ -1656,10 +1568,13 @@
                //虚拟驱动号
                foreach (var data in localWay.DriveCodeList)
                {
                    //添加虚拟驱动的升级固件(成不成功都无所谓)
                    flage = HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.VirtualDevice,
                        data.DriveHwVersion.ToString(),
                        data.DriveImageType.ToString());
                    //添加虚拟驱动的升级固件(成不成功都无所谓) 必须能够联网才行
                    if (flage == 1)
                    {
                        HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.VirtualDevice,
                           data.DriveHwVersion.ToString(),
                           data.DriveImageType.ToString());
                    }
                    //虚拟驱动
                    var virtualFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.VirtualDevice,
@@ -1753,9 +1668,9 @@
                else
                {
                    //给一个线程去获取它的镜像类型
                    HdlThreadLogic.Current.RunThread(async () =>
                    HdlThreadLogic.Current.RunThread(() =>
                    {
                        var result = await this.GetGatewayNewInfoAsync(zbGateway, ShowErrorMode.NO);
                        var result = this.GetGatewayInfo(zbGateway, true, ShowErrorMode.NO);
                        if (result != null)
                        {
                            //将网关的数据设置到本地缓存中
@@ -1791,9 +1706,9 @@
                else
                {
                    //给一个线程去获取它的镜像类型
                    HdlThreadLogic.Current.RunThread(async () =>
                    HdlThreadLogic.Current.RunThread(() =>
                    {
                        var result = await this.GetGatewayNewInfoAsync(zbGateway, ShowErrorMode.NO);
                        var result = this.GetGatewayInfo(zbGateway, true, ShowErrorMode.NO);
                        if (result != null)
                        {
                            //将网关的数据设置到本地缓存中
@@ -1885,9 +1800,9 @@
            }
            bool canBreak = false;
            HdlThreadLogic.Current.RunThread(async () =>
            HdlThreadLogic.Current.RunThread(() =>
            {
                List<string> list = new List<string>() { "NotSetAgain", "NotCheck" };
                List<string> list = new List<string>() { "NotCheck" };
                //设置访问接口的参数
                var pra = new GetGatewayPra();
@@ -1896,7 +1811,7 @@
                //获取控制主人账号的Token
                pra.ReqDto.LoginAccessToken = UserCenterLogic.GetConnectMainToken();
                var result = await UserCenterLogic.GetResponseDataByRequestHttps("App/GetSingleHomeGatewayPagger", true, pra, list);
                var result = UserCenterLogic.GetResponseDataByRequestHttps("App/GetSingleHomeGatewayPagger", true, pra, list);
                if (string.IsNullOrEmpty(result) == true)
                {
                    canBreak = true;
@@ -2019,16 +1934,16 @@
        /// 解绑云端绑定的网关
        /// </summary>
        /// <param name="strWayId"></param>
        public async Task<bool> DeleteDataBaseGateway(string strWayId)
        public bool DeleteDataBaseGateway(string strWayId)
        {
            var Pra = new DeleteGatewayPra();
            Pra.BindGateways.Add(strWayId);
            //获取控制主人账号的Token
            Pra.LoginAccessToken = UserCenterLogic.GetConnectMainToken();
            List<string> listNotShowError = new List<string>() { "NoExist", "NoBind", "NoRecord", "NotSetAgain" };
            List<string> listNotShowError = new List<string>() { "NoExist", "NoBind", "NoRecord", "NotCheck" };
            bool result = await UserCenterLogic.GetResultStatuByRequestHttps("App/ReleaseGatewayToHome", true, Pra, listNotShowError);
            bool result = UserCenterLogic.GetResultStatuByRequestHttps("App/ReleaseGatewayToHome", true, Pra, listNotShowError);
            if (result == false)
            {
                return false;
@@ -2052,9 +1967,7 @@
                listBackupGwId.Add(strId);
                //备份
                var strData = Newtonsoft.Json.JsonConvert.SerializeObject(listBackupGwId);
                var byteData = System.Text.Encoding.UTF8.GetBytes(strData);
                Global.WriteFileToDirectoryByBytes(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile, byteData);
                HdlFileLogic.Current.SaveFileContent(DirNameResourse.BackupGatewayIdFile, listBackupGwId);
            }
        }
@@ -2063,9 +1976,9 @@
        /// </summary>
        public void ResetComandToBindBackupGateway()
        {
            HdlThreadLogic.Current.RunThread(async () =>
            HdlThreadLogic.Current.RunThread(() =>
            {
                var fileData = Global.ReadFileByDirectory(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile);
                var fileData = HdlFileLogic.Current.ReadFileByteContent(DirNameResourse.BackupGatewayIdFile);
                if (fileData == null)
                {
                    return;
@@ -2074,8 +1987,6 @@
                var listTempId = new List<string>();
                listTempId.AddRange(this.listBackupGwId);
                //不显示已经被绑定过的信息,NotSetAgain:假如断网时,不二次发送
                List<string> listNotShow = new List<string>() { "NotSetAgain" };
                //调用接口,绑定网关
                var bindGateway = new BindGatewayPra();
                //获取控制主人账号的Token
@@ -2085,12 +1996,12 @@
                {
                    bindGateway.BindGateways.Clear();
                    bindGateway.BindGateways.Add(gwId);
                    var result = await UserCenterLogic.GetResultCodeByRequestHttps("App/BindGatewayToHome", true, bindGateway, listNotShow);
                    var result = UserCenterLogic.GetResultCodeByRequestHttps("App/BindGatewayToHome", true, bindGateway, new List<string> { "NotCheck" });
                    if (result == "Success")
                    {
                        this.listBackupGwId.Remove(gwId);
                    }
                    if (result == "Error" || result == "ErrorEx")
                    if (result == "Error")
                    {
                        break;
                    }
@@ -2099,7 +2010,7 @@
                if (this.listBackupGwId.Count == 0)
                {
                    //如果没有了内容,则删除文件
                    string file = UserCenterLogic.CombinePath(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile);
                    string file = DirNameResourse.BackupGatewayIdFile;
                    if (System.IO.File.Exists(file) == true)
                    {
                        System.IO.File.Delete(file);
@@ -2108,9 +2019,7 @@
                else
                {
                    //备份
                    var strData = Newtonsoft.Json.JsonConvert.SerializeObject(listBackupGwId);
                    var byteData = System.Text.Encoding.UTF8.GetBytes(strData);
                    Global.WriteFileToDirectoryByBytes(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile, byteData);
                    HdlFileLogic.Current.SaveFileContent(DirNameResourse.BackupGatewayIdFile, listBackupGwId);
                }
            });
        }
@@ -2127,8 +2036,9 @@
        /// <param name="sendData">需要发送的数据  JObject.ToString()的东西</param>
        /// <param name="receiptTopic">指定接收哪个主题</param>
        /// <param name="waitTime">超时时间(秒)</param>
        /// <param name="useLocalConnect">是否强制使用本地连接发送</param>
        /// <returns>网关返回的数据</returns>
        public ReceiptGatewayResult SendJobjectDataToGateway(ZbGateway gateway, string sendTopic, string sendData, string receiptTopic, int waitTime = 5)
        public ReceiptGatewayResult SendJobjectDataToGateway(ZbGateway gateway, string sendTopic, string sendData, string receiptTopic, int waitTime = 5, bool useLocalConnect = false)
        {
            var reResult = new ReceiptGatewayResult();
@@ -2165,7 +2075,14 @@
            };
            myGateway.Actions += receiptAction;
            //发送数据
            myGateway.Send(sendTopic, sendData);
            if (useLocalConnect == false)
            {
                myGateway.Send(sendTopic, sendData);
            }
            else
            {
                myGateway.SendLocation(sendTopic, System.Text.Encoding.UTF8.GetBytes(sendData));
            }
            //超时时间
            int TimeOut = 0;