新版本

黄学彪

2020-09-18 c7df85937f73fb347ee0b19e9c052d2d00a6df6c

 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();

            }

        }

@@ -194,6 +178,10 @@
                    //将网关的数据设置到本地缓存中

                    this.SetGatewayDataToLocalMemmory(gateway, result);

                }

                if (gateway.HomeId == string.Empty)

                {

                    gateway.HomeId = Config.Instance.Home.Id;

                }

                return gateway;

            }

            catch (Exception ex)

@@ -212,7 +200,7 @@
        /// </summary>
        /// <param name="zbGateway">网关</param>
        /// <param name="mode">是否显示错误</param>
        public async Task<bool> AddNewGateway(ZbGateway zbGateway, ShowErrorMode mode)
        public bool AddNewGateway(ZbGateway zbGateway, ShowErrorMode mode)
        {

            //设置网关的经纬度

            bool falge = this.SetGatewaySite(zbGateway, Common.Config.Instance.Home.Longitude, Common.Config.Instance.Home.Latitude, ShowErrorMode.NO);
@@ -221,7 +209,7 @@
                return falge;

            }
            //执行添加网关到内存
            var result = await this.DoAddGatewayToMemory(zbGateway, mode);
            var result = this.DoAddGatewayToMemory(zbGateway, mode);
            //前的网关绑定在了当前账号下的不同住宅里面

            if (result == 0)

            {

@@ -241,6 +229,9 @@
            {

                return false;

            }
            //添加网关的话,强制主页刷新
            UserView.UserPage.Instance.RefreshAllForm = true;

            return true;
        }



@@ -263,7 +254,7 @@
        /// <param name="zbGateway">网关对象</param>

        /// <param name="mode">是否显示错误</param>

        /// <returns></returns>

        private async Task<int> DoAddGatewayToMemory(ZbGateway zbGateway, ShowErrorMode mode)

        private int DoAddGatewayToMemory(ZbGateway zbGateway, ShowErrorMode mode)

        {

            if (zbGateway == null)

            {

@@ -276,18 +267,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 +279,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);

            if (flage2 == false)

            if (result.HomeId != Common.Config.Instance.HomeId)

            {

                if (mode == ShowErrorMode.YES)

                bool flage2 = 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)

            {

@@ -333,12 +305,12 @@
            if (flage1 == -1)

            {

                //备份失败的网关ID

                HdlGatewayLogic.Current.BackupGatewayIdOnNotNetwork(zbGateway);

                this.BackupGatewayIdOnNotNetwork(zbGateway);

            }



            //是否已经存在

            string gwID = zbGateway.GwId;

            bool isEsist = HdlGatewayLogic.Current.IsGatewayExist(zbGateway);
            bool isEsist = this.IsGatewayExist(zbGateway);
            if (isEsist == false)

            {

                //新建一个虚拟的网关出来

@@ -350,9 +322,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)

            {

@@ -369,14 +341,42 @@
        /// <param name="zbGateway"></param>

        /// <param name="HomeId"></param>

        /// <returns></returns>
        public async Task<bool> SetHomeIdToGateway(ZbGateway zbGateway, string HomeId)

        public bool SetHomeIdToGateway(ZbGateway zbGateway, string HomeId, ShowErrorMode mode)

        {

            var info = await zbGateway.GwSetHomeIdAsync(HomeId);

            if (info != null && info.gwSetHomeIdData != null)

            //账号ID

            string accountId = string.Empty;

            if (HomeId != string.Empty)

            {

                return true;

                if (UserCenterResourse.UserInfo.AuthorityNo == 1)

                {

                    //主账号

                    accountId = Config.Instance.Guid;

                }

                else

                {

                    accountId = Config.Instance.Home.MainUserDistributedMark;

                }

            }

            return false;

            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 82 } };

            var data = new Newtonsoft.Json.Linq.JObject { { "HomeId", HomeId }, { "AccountId", accountId } };

            jObject.Add("Data", data);

            //住宅ID的设置,固定使用局域网,不存在远程的说法

            var result = this.SendJobjectDataToGateway(zbGateway, "GwSetHomeId", jObject.ToString(), "GwSetHomeId_Respon", 5, true);

            if (result.ErrorMsgDiv == -1)

            {

                if (mode == ShowErrorMode.YES)

                {

                    //错误:网关对象丢失

                    string msg = Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg);

                    this.ShowTipMsg(msg);

                }

                return false;

            }

            if (result.ErrorMsgDiv == 0)

            {

                return false;

            }

            return true;

        }



        /// <summary>

@@ -384,7 +384,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();

@@ -392,10 +392,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" }, false);
            if (result == "Error")

            {

                return -1;

            }
@@ -440,7 +438,7 @@
        /// </summary>
        /// <param name="zbGateway">网关</param>
        /// <param name="btnMsg">消息控件</param>
        public async Task<int> ReBindNewGateway(ZbGateway zbGateway, NormalViewControl btnMsg = null)
        public int ReBindNewGateway(ZbGateway zbGateway, NormalViewControl btnMsg = null)
        {

            if (zbGateway == null)

            {

@@ -457,7 +455,7 @@
            }



            //设置住宅ID到网关

            bool flage2 = await this.SetHomeIdToGateway(zbGateway, Common.Config.Instance.HomeId);

            bool flage2 = this.SetHomeIdToGateway(zbGateway, Common.Config.Instance.HomeId, ShowErrorMode.YES);

            if (flage2 == false)

            {

                //向网关设置住宅ID失败

@@ -467,7 +465,7 @@
            }



            //更新云端数据库

            int flage1 = await this.SetGatewayIdToDataBase(zbGateway);

            int flage1 = this.SetGatewayIdToDataBase(zbGateway);

            //异常也不鸟它,0是特殊含义

            if (flage1 == 0)

            {

@@ -492,19 +490,23 @@
                    btnMsg.TextID = R.MyInternationalizationString.uGatewayDataIsChangingPleaseWhait;

                });

            }

            await Task.Delay(8000);

            System.Threading.Thread.Sleep(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秒

                System.Threading.Thread.Sleep(4000);

            }



            if (result == null || result.getGwData == null)

            if (result == null)

            {

                //获取网关信息失败

                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayInfoFail);

@@ -526,15 +528,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;
        }

@@ -547,42 +553,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;
            }



@@ -605,22 +599,19 @@
        /// 执行切换网关操作

        /// </summary>

        /// <param name="gatewayId"></param>

        public async Task<bool> DoSwitchGateway(string gatewayId)

        public bool DoSwitchGateway(string gatewayId)

        {

            var zbGateway = this.GetLocalGateway(gatewayId);

            if (this.CheckGatewayOnlineByFlag(zbGateway) == true)

            //重新获取在线网关的信息

            var result = 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;

        }

@@ -630,7 +621,7 @@
        /// </summary>

        /// <param name="gatewayId"></param>

        /// <returns></returns>

        private async Task<bool> GetOnlineGatewayInfo(string gatewayId)

        private bool GetOnlineGatewayInfo(string gatewayId)

        {

            //显示进度条

            ProgressBar.Show();

@@ -643,7 +634,7 @@
                //重新设置住宅ID(这个应该是不经过APP,直接把网关恢复了出厂设置)

                if (this.HomeIdIsEmpty(realWay.HomeId) == true)

                {

                    int result2 = await this.ReBindNewGateway(realWay);

                    int result2 = this.ReBindNewGateway(realWay);

                    if (result2 == 0)

                    {

                        //出现未知错误,请稍后再试

@@ -665,7 +656,7 @@
            if (getGatewayInfo == true)

            {

                //获取网关信息

                var info = await this.GetGatewayNewInfoAsync(realWay);

                var info = this.GetGatewayInfo(realWay, false);

                if (info == null)

                {

                    //关闭进度条

@@ -673,9 +664,14 @@
                    return false;

                }

            }

            //刷新全部场景

            if (this.IsMainGateway(realWay) == 1)

            {

                HdlSceneLogic.Current.RefreshSceneUIList(false);

            }



            //获取全部设备

            int result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay);

            int result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay, false);

            //关闭进度条

            ProgressBar.Close();

            if (result == -1)

@@ -692,8 +688,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
@@ -703,38 +698,19 @@
        /// <summary>
        /// 删除网关，包括云端和本地(失败时不会显示信息，并且会返回true)
        /// </summary>
        /// <param name="zbGateway"></param>
        public async Task<bool> DeleteGateway(ZbGateway zbGateway)
        {
            //移除本地网关信息
            return await this.DeleteGateway(zbGateway.GwId);
        }

        /// <summary>
        /// 删除网关，包括云端和本地(失败时不会显示信息，并且会返回true)
        /// </summary>
        /// <param name="zbGatewayID"></param>
        public async Task<bool> DeleteGateway(string zbGatewayID)
        public 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);

                if (result == false)

                {

                    //网关解绑失败  不理它,因为网关可以按按键强制搜索得到

                    string msg = Language.StringByID(R.MyInternationalizationString.uGatewayUnBindFail);

                    //this.ShowErrorMsg(msg);

                    //return false;

                }

                this.SetHomeIdToGateway(realWay, string.Empty, ShowErrorMode.NO);

            }



            //删除云端的网关

            await this.DeleteDataBaseGateway(zbGatewayID);

            this.DeleteDataBaseGateway(zbGatewayID);



            //删除网关文件
            this.DeleteGatewayFile(zbGatewayID);
@@ -742,7 +718,10 @@
            //移除
            ZbGateway.GateWayList.RemoveAll((obj) => obj.GwId == zbGatewayID);
            //断开mqtt连接
            realWay.DisConnectLocalMqttClient("GD");
            if (realWay != null)

            {

                realWay.DisConnectLocalMqttClient("GD");

            }

            return true;
        }

@@ -983,7 +962,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)

            {

                //只获取网关设备

@@ -1305,10 +1284,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)

            {

@@ -1322,14 +1302,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;

@@ -1366,19 +1342,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)

                        {

                            //将网关的数据设置到本地缓存中

@@ -1386,11 +1361,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官方名字;

                                }

                            });

                        }

@@ -1399,11 +1373,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官方名字;

                }

            }

        }

@@ -1416,34 +1389,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)

                {

@@ -1455,42 +1410,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>

@@ -1513,6 +1445,7 @@
            localWay.CoordinatorFirmwareVersion = data.ZbFWVersion;

            localWay.CoordinatorImageId = data.ZbImageType;

            localWay.DriveCodeList = data.DriveCodeList;

            localWay.GwVersionDate = data.AppVersion;

            if (saveFile == true)

            {

                localWay.ReSave();

@@ -1551,11 +1484,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;

@@ -1567,24 +1500,39 @@


        #endregion



        #region ■ 清空真实网关列表___________________

        #region ■ 清空真实网关链接___________________



        /// <summary>

        /// 清空全部的真实物理网关对象

        /// 清空全部的真实物理网关的链接

        /// </summary>

        public void ClearAllRealGateway()

        /// <param name="roadGateway">是否加载本地的网关对象到真实列表中</param>

        public void ClearAllRealGatewayConection(bool roadGateway)

        {

            //因为那一瞬间，有可能mqtt会加回来,所以先加缓存

            var list = new List<ZbGateway>();

            list.AddRange(ZbGateway.GateWayList);

            //然后清空掉

            ZbGateway.GateWayList.Clear();

            //最后再断开mqtt连接

            for (int i = 0; i < list.Count; i++)

            //断开mqtt连接(即使保存在内存当中也没问题,因为如果广播不到,则它不会建立链接)

            for (int i = 0; i < ZbGateway.GateWayList.Count; i++)

            {

                list[i].DisConnectLocalMqttClient("G");

                ZbGateway.GateWayList[i].DisConnectLocalMqttClient("G");

            }

            list.Clear();

            //加载本地网关对象

            if (roadGateway == true)

            {

                List<string> listFile = this.GetAllGatewayFile();

                //反序列化添加到缓存

                foreach (string file in listFile)

                {

                    //从文件中反序列化出网关对象

                    var gateway = this.GetGatewayFromFile(file);

                    if (gateway == null)

                    {

                        continue;

                    }

                    var tempWay = ZbGateway.GateWayList.Find(obj => (obj != null) && (obj.GwId == gateway.GwId));
                    if (tempWay == null)
                    {
                        ZbGateway.GateWayList.Add(gateway);
                    }

                }

            }

        }



        #endregion

@@ -1597,10 +1545,15 @@
        /// <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)

        {

            //如果是展示模板,或者是虚拟住宅的话,没有什么新版本的说法

            if (Common.Config.Instance.Home.IsVirtually == true || Common.Config.Instance.Home.IsShowTemplate == true)

            {

                return new List<FirmwareVersionInfo> { null, null, null };

            }

            //获取网关版本信息

            var result = await HdlGatewayLogic.Current.GetGatewayNewInfoAsync(zbGateway, mode);

            var result = this.GetGatewayInfo(zbGateway, false, mode);

            if (result == null)

            {

                return null;

@@ -1617,10 +1570,14 @@
                localWay.LinuxHardVersion.ToString(),

                localWay.LinuxImageType.ToString());



            //添加协调器的升级固件(成不成功都无所谓)

            flage = HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.Coordinator,

                localWay.CoordinatorHardVersion.ToString(),

                localWay.CoordinatorImageId.ToString());

            //添加协调器的升级固件(成不成功都无所谓) 必须能够联网才行

            if (flage == 1)

            {

                //没网的时候不再处理

                HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.A协调器,

                    localWay.CoordinatorHardVersion.ToString(),

                    localWay.CoordinatorImageId.ToString());

            }



            //网关的版本

            var gatewayFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.Linux,

@@ -1629,7 +1586,7 @@
                localWay.LinuxFirmwareVersion);



            //协调器版本

            var coordinatorFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.Coordinator,

            var coordinatorFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.A协调器,

                localWay.CoordinatorHardVersion.ToString(),

                localWay.CoordinatorImageId.ToString(),

                localWay.CoordinatorFirmwareVersion);

@@ -1644,13 +1601,16 @@
                //虚拟驱动号

                foreach (var data in localWay.DriveCodeList)

                {

                    //添加虚拟驱动的升级固件(成不成功都无所谓)

                    flage = HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.VirtualDevice,

                        data.DriveHwVersion.ToString(),

                        data.DriveImageType.ToString());

                    //添加虚拟驱动的升级固件(成不成功都无所谓) 必须能够联网才行

                    if (flage == 1)

                    {

                        HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.A虚拟驱动,

                           data.DriveHwVersion.ToString(),

                           data.DriveImageType.ToString());

                    }



                    //虚拟驱动

                    var virtualFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.VirtualDevice,

                    var virtualFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.A虚拟驱动,

                        data.DriveHwVersion.ToString(),

                        data.DriveImageType.ToString(),

                        data.DriveFwVersion);

@@ -1677,6 +1637,13 @@
        /// <returns></returns>

        public List<ZbGatewayData.DriveCodeObj> GetListVDDriveCode(ZbGateway zbGateway)

        {

            //如果是展示模板,或者是虚拟住宅的话,直接取缓存

            if (Common.Config.Instance.Home.IsVirtually == true || Common.Config.Instance.Home.IsShowTemplate == true)

            {

                //取本地对象

                var localgw = this.GetLocalGateway(zbGateway.GwId);

                return localgw != null ? zbGateway.DriveCodeList : zbGateway.DriveCodeList;

            }

            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 505 } };

            var result = this.SendJobjectDataToGateway(zbGateway, "VirtualDrive/CatDriveCode", jObject.ToString(), "VirtualDrive/CatDriveCode_Respon");

            if (result.ErrorMsg != null)

@@ -1712,12 +1679,16 @@
        /// <returns></returns>

        public int IsMainGateway(string waiID)

        {

            ZbGateway zbGateway = null;

            if (this.GetRealGateway(ref zbGateway, waiID) == false)

            var realWay = ZbGateway.GateWayList.Find((obj) =>

            {

                return obj.GwId == waiID;

            });

            //虚拟网关也返回 0

            if (realWay == null || realWay.IsVirtual == true)

            {

                return 0;

            }

            return zbGateway.IsMainGateWay == true ? 1 : 2;

            return realWay.IsMainGateWay == true ? 1 : 2;

        }



        #endregion

@@ -1741,9 +1712,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)

                        {

                            //将网关的数据设置到本地缓存中

@@ -1779,9 +1750,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)

                        {

                            //将网关的数据设置到本地缓存中

@@ -1873,9 +1844,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();

@@ -1884,7 +1855,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, false);

                if (string.IsNullOrEmpty(result) == true)

                {

                    canBreak = true;

@@ -1940,6 +1911,11 @@
                    this.ShowTipMsg(msg);

                }

                return false;

            }

            if (((decimal)Longitude) == 0 && ((decimal)Latitude) == 0)

            {

                //没有配置过经纬度

                return true;

            }



            int result = -1;

@@ -2007,16 +1983,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, false);

            if (result == false)

            {

                return false;

@@ -2040,9 +2016,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);

            }

        }



@@ -2051,9 +2025,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;

@@ -2062,8 +2036,6 @@
                var listTempId = new List<string>();

                listTempId.AddRange(this.listBackupGwId);



                //不显示已经被绑定过的信息,NotSetAgain:假如断网时,不二次发送

                List<string> listNotShow = new List<string>() { "NotSetAgain" };

                //调用接口，绑定网关

                var bindGateway = new BindGatewayPra();

                //获取控制主人账号的Token

@@ -2073,12 +2045,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" }, false);

                    if (result == "Success")

                    {

                        this.listBackupGwId.Remove(gwId);

                    }

                    if (result == "Error" || result == "ErrorEx")

                    if (result == "Error")

                    {

                        break;

                    }

@@ -2087,7 +2059,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);

@@ -2096,9 +2068,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);

                }

            });

        }

@@ -2115,8 +2085,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();



@@ -2153,7 +2124,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;