黄学彪
2020-11-19 9ef48d7b2da7c408b53f73be0f6eef3cbac1c84a
ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayLogic.cs
@@ -178,6 +178,10 @@
                    //将网关的数据设置到本地缓存中
                    this.SetGatewayDataToLocalMemmory(gateway, result);
                }
                if (gateway.HomeId == string.Empty)
                {
                    gateway.HomeId = Config.Instance.Home.Id;
                }
                return gateway;
            }
            catch (Exception ex)
@@ -196,16 +200,21 @@
        /// </summary>
        /// <param name="zbGateway">网关</param>
        /// <param name="mode">是否显示错误</param>
        public bool AddNewGateway(ZbGateway zbGateway, ShowErrorMode mode)
        /// <param name="logMode">是否写Log</param>
        public bool AddNewGateway(ZbGateway zbGateway, ShowErrorMode mode, WriteLogMode logMode = WriteLogMode.NO)
        {
            //设置网关的经纬度
            bool falge = this.SetGatewaySite(zbGateway, Common.Config.Instance.Home.Longitude, Common.Config.Instance.Home.Latitude, ShowErrorMode.NO);
            if (falge == false)
            {
                if (logMode == WriteLogMode.YES)
                {
                    HdlLogLogic.Current.WriteLog(-1, zbGateway.GwIP + " 设置经纬度失败");
                }
                return falge;
            }
            //执行添加网关到内存
            var result = this.DoAddGatewayToMemory(zbGateway, mode);
            var result = this.DoAddGatewayToMemory(zbGateway, mode, logMode);
            //前的网关绑定在了当前账号下的不同住宅里面
            if (result == 0)
            {
@@ -219,6 +228,10 @@
                    }
                    this.ShowTipMsg(msg);
                }
                if (logMode == WriteLogMode.YES)
                {
                    HdlLogLogic.Current.WriteLog(-1, zbGateway.GwIP + " 网关绑定在了当前账号下的不同住宅里面,云端不给绑定");
                }
                return false;
            }
            if (result == -1)
@@ -228,6 +241,20 @@
            //添加网关的话,强制主页刷新
            UserView.UserPage.Instance.RefreshAllForm = true;
            if (Config.Instance.Home.TemplateMode == 2)
            {
                //如果这个类型的网关只有一个模板,则自动匹配
                var dicName = TemplateData.TemplateCommonLogic.Current.GetGatewayCanSelectTemplateName(zbGateway);
                if (dicName.Count == 1)
                {
                    foreach (var tempId in dicName.Keys)
                    {
                        TemplateData.TemplateCommonLogic.Current.AddGatewayTemplateSelect(zbGateway.GwId, tempId);
                        break;
                    }
                }
            }
            return true;
        }
@@ -249,8 +276,9 @@
        /// </summary>
        /// <param name="zbGateway">网关对象</param>
        /// <param name="mode">是否显示错误</param>
        /// <param name="logMode">是否写Log</param>
        /// <returns></returns>
        private int DoAddGatewayToMemory(ZbGateway zbGateway, ShowErrorMode mode)
        private int DoAddGatewayToMemory(ZbGateway zbGateway, ShowErrorMode mode, WriteLogMode logMode = WriteLogMode.NO)
        {
            if (zbGateway == null)
            {
@@ -272,6 +300,10 @@
                    string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayInfoFail);
                    this.ShowTipMsg(msg);
                }
                if (logMode == WriteLogMode.YES)
                {
                    HdlLogLogic.Current.WriteLog(-1, zbGateway.GwIP + " 获取网关信息失败");
                }
                return -1;
            }
@@ -286,6 +318,10 @@
                        //向网关设置住宅ID失败
                        string msg = Language.StringByID(R.MyInternationalizationString.uSetHomeIdToGatewayFail);
                        this.ShowTipMsg(msg);
                    }
                    if (logMode == WriteLogMode.YES)
                    {
                        HdlLogLogic.Current.WriteLog(-1, zbGateway.GwIP + " 向网关设置住宅ID失败");
                    }
                    return -1;
                }
@@ -316,7 +352,7 @@
            }
            //刷新的是缓存,不刷新真实物理网关
            this.dicGateway[gwID].GatewayOnlineFlage = zbGateway.GatewayOnlineFlage;
            this.dicGateway[gwID].OnlineTime = DateTime.Now;
            //将网关的数据设置到本地缓存中
            this.SetGatewayDataToLocalMemmory(this.dicGateway[gwID], result);
            //顺便这个变量也设置一下
@@ -357,7 +393,7 @@
            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);
            var result = this.SendJobjectDataToGateway(zbGateway.GwId, "GwSetHomeId", jObject.ToString(), "GwSetHomeId_Respon", 5, true);
            if (result.ErrorMsgDiv == -1)
            {
                if (mode == ShowErrorMode.YES)
@@ -522,7 +558,7 @@
            }
            //刷新的是缓存,不刷新真实物理网关
            this.dicGateway[gwID].GatewayOnlineFlage = zbGateway.GatewayOnlineFlage;
            this.dicGateway[gwID].OnlineTime = DateTime.Now;
            //将网关的数据设置到本地缓存中
            this.SetGatewayDataToLocalMemmory(this.dicGateway[gwID], result);
            //顺便这个变量也设置一下
@@ -536,6 +572,20 @@
            //添加网关的话,强制主页刷新
            UserView.UserPage.Instance.RefreshAllForm = true;
            if (Config.Instance.Home.TemplateMode == 2)
            {
                //如果这个类型的网关只有一个模板,则自动匹配
                var dicName = TemplateData.TemplateCommonLogic.Current.GetGatewayCanSelectTemplateName(zbGateway);
                if (dicName.Count == 1)
                {
                    foreach (var tempId in dicName.Keys)
                    {
                        TemplateData.TemplateCommonLogic.Current.AddGatewayTemplateSelect(zbGateway.GwId, tempId);
                        break;
                    }
                }
            }
            return 1;
        }
@@ -560,7 +610,7 @@
            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");
            var result = this.SendJobjectDataToGateway(zbGateway.GwId, "GwReName", jObject.ToString(), "GwReName_Respon");
            if (result.ErrorMsg != null)
            {
                this.ShowTipMsg(result.ErrorMsg);
@@ -667,7 +717,7 @@
            }
            //获取全部设备
            int result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay, false);
            int result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay.GwId, false);
            //关闭进度条
            ProgressBar.Close();
            if (result == -1)
@@ -716,7 +766,7 @@
            //断开mqtt连接
            if (realWay != null)
            {
                realWay.DisConnectLocalMqttClient("GD");
                realWay.CloseLocalConnectionOnForce();
            }
            return true;
@@ -796,29 +846,14 @@
                    //虚拟物理网关
                    listRealWay.Add(listGateway[i]);
                }
                //标识指定网关为不在线
                listRealWay[i].GatewayOnlineFlage = false;
            }
            //这是第一道坎,强制检查WIFI:等待2秒(因为wifi的时候,它会自动去刷新flage)
            System.Threading.Thread.Sleep(2000);
            //检查是否拥有网关存在于WIFi下
            if (this.CheckHadGatewayInWifi(listRealWay) == false)
            {
                //第二道坎:在远程的情况下刷新网关的在线状态
                this.RefreshGatewayOnlineOnRemode(listRealWay);
            }
            //刷新缓存的在线标识
            foreach (var zbway in listRealWay)
            {
                string gwID = zbway.GwId;
                if (this.dicGateway.ContainsKey(gwID) == false)
                {
                    continue;
                }
                this.dicGateway[gwID].GatewayOnlineFlage = zbway.GatewayOnlineFlage;
            }
            //wifi情况下,由Application自己刷新标识
        }
        /// <summary>
@@ -830,8 +865,8 @@
        {
            foreach (var zbway in listGateway)
            {
                //是否存在网关存在于WIFI下
                if (zbway.GatewayOnlineFlage == true)
                //如果广播得到网关,则会刷新OnlineTime,如果与当前时间相差少于指定秒数,则判断为存在网关存在于WIFI下
                if ((DateTime.Now - zbway.OnlineTime).TotalSeconds <= ZigBee.Common.Application.SendTime * 2)
                {
                    return true;
                }
@@ -847,7 +882,7 @@
        private void RefreshGatewayOnlineOnRemode(List<ZbGateway> listGateway)
        {
            //获取云端上面的网关
            Dictionary<string, GatewayResult> dicDbGateway = HdlGatewayLogic.Current.GetGateWayListFromDataBase();
            Dictionary<string, GatewayResult> dicDbGateway = this.GetGateWayListFromDataBase();
            if (dicDbGateway == null)
            {
                return;
@@ -859,19 +894,20 @@
                    continue;
                }
                string strId = way.GwId;
                if (dicDbGateway.ContainsKey(strId) == true) //如果云端上面有这个网关
                if (dicDbGateway.ContainsKey(strId) == true
                    && dicDbGateway[strId].MqttOnlineStatus == true) //如果云端上面有这个网关
                {
                    way.GatewayOnlineFlage = dicDbGateway[strId].MqttOnlineStatus;
                    way.OnlineTime = DateTime.Now;
                }
            }
        }
        /// <summary>
        /// 根据某种标识判断指定网关是否在线
        /// 根据本地缓存判断指定网关是否在线
        /// </summary>
        /// <param name="zbGateway"></param>
        /// <returns></returns>
        public bool CheckGatewayOnlineByFlag(ZbGateway zbGateway)
        public bool CheckGatewayOnlineByMemory(ZbGateway zbGateway)
        {
            if (zbGateway == null)
            {
@@ -881,10 +917,42 @@
            string gwID = zbGateway.GwId;
            if (this.dicGateway.ContainsKey(gwID) == true)
            {
                return this.dicGateway[gwID].GatewayOnlineFlage;
                return this.CheckGatewayOnlineByFlage(dicGateway[gwID]);
            }
            return zbGateway.GatewayOnlineFlage;
            return this.CheckGatewayOnlineByFlage(zbGateway);
        }
        /// <summary>
        /// 刷新网关的在线时间点
        /// </summary>
        /// <param name="i_gatewayId">网关ID</param>
        public void RefreshGatewayOnlineTime(string i_gatewayId)
        {
            try
            {
                if (this.dicGateway.ContainsKey(i_gatewayId) == true)
                {
                    this.dicGateway[i_gatewayId].OnlineTime = DateTime.Now;
                }
            }
            catch { }
        }
        /// <summary>
        /// 根据指定标识,判断网关是否在线
        /// </summary>
        /// <param name="zbGateway"></param>
        /// <returns></returns>
        private bool CheckGatewayOnlineByFlage(ZbGateway zbGateway)
        {
            if (this.nowGwConnectMode == GatewayConnectMode.Remote)
            {
                //远程每20秒检测一次
                return (DateTime.Now - zbGateway.OnlineTime).TotalSeconds <= 40;
            }
            //如果广播得到网关,则会刷新OnlineTime,如果与当前时间相差少于10秒,则判断为在线
            return (DateTime.Now - zbGateway.OnlineTime).TotalSeconds <= 15;
        }
        #endregion
@@ -1392,7 +1460,7 @@
        {
            //获取网关版本信息
            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 95 } };
            var result = this.SendJobjectDataToGateway(zbGateway, "GetZbGwInfo", jObject.ToString(), "GetZbGwInfo_Respon", 5, useLocalConnect);
            var result = this.SendJobjectDataToGateway(zbGateway.GwId, "GetZbGwInfo", jObject.ToString(), "GetZbGwInfo_Respon", 5, useLocalConnect);
            if (result.ErrorMsgDiv != 1)
            {
@@ -1434,6 +1502,7 @@
            localWay.GwSerialNum = data.GWSN;
            localWay.IsMainGateWay = data.IsDominant == 1 ? true : false;
            localWay.GwIP = data.GwIP;
            localWay.GwMac = data.GwMac;
            localWay.LinuxImageType = data.LinuxImageType;
            localWay.LinuxHardVersion = data.LinuxHWVersion;
            localWay.LinuxFirmwareVersion = data.LinuxFWVersion;
@@ -1442,55 +1511,11 @@
            localWay.CoordinatorImageId = data.ZbImageType;
            localWay.DriveCodeList = data.DriveCodeList;
            localWay.GwVersionDate = data.AppVersion;
            localWay.OnlineTime = DateTime.Now;
            if (saveFile == true)
            {
                localWay.ReSave();
            }
        }
        #endregion
        #region ■ 网关房间相关_______________________
        /// <summary>
        /// 获取网关所在的房间
        /// </summary>
        /// <param name="zbGateway">网关对象</param>
        /// <returns></returns>
        public Room GetRoomByGateway(ZbGateway zbGateway)
        {
            return this.GetRoomByGateway(zbGateway.GwId);
        }
        /// <summary>
        /// 获取网关所在的房间
        /// </summary>
        /// <param name="gatewayId">网关ID</param>
        /// <returns></returns>
        public Room GetRoomByGateway(string gatewayId)
        {
            var localGateway = this.GetLocalGateway(gatewayId);
            if (localGateway == null)
            {
                return null;
            }
            return HdlRoomLogic.Current.GetRoomById(localGateway.RoomId);
        }
        /// <summary>
        /// 变更网关房间
        /// </summary>
        /// <param name="gwId">网关Id</param>
        /// <param name="roomId">房间ID</param>
        public void ChangedGatewayRoom(string gwId, string roomId)
        {
            var localGateway = this.GetLocalGateway(gwId);
            if (localGateway != null)
            {
                localGateway.RoomId = roomId;
                localGateway.ReSave();
                //添加备份
                HdlAutoBackupLogic.AddOrEditorFile(localGateway.FilePath);
            }
        }
@@ -1507,7 +1532,7 @@
            //断开mqtt连接(即使保存在内存当中也没问题,因为如果广播不到,则它不会建立链接)
            for (int i = 0; i < ZbGateway.GateWayList.Count; i++)
            {
                ZbGateway.GateWayList[i].DisConnectLocalMqttClient("G");
                ZbGateway.GateWayList[i].CloseLocalConnectionOnForce();
            }
            //加载本地网关对象
            if (roadGateway == true)
@@ -1570,7 +1595,7 @@
            if (flage == 1)
            {
                //没网的时候不再处理
                HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.Coordinator,
                HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.A协调器,
                    localWay.CoordinatorHardVersion.ToString(),
                    localWay.CoordinatorImageId.ToString());
            }
@@ -1582,7 +1607,7 @@
                localWay.LinuxFirmwareVersion);
            //协调器版本
            var coordinatorFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.Coordinator,
            var coordinatorFirmware = HdlFirmwareUpdateLogic.GetFirmwareMostVersionInfo(FirmwareLevelType.A协调器,
                localWay.CoordinatorHardVersion.ToString(),
                localWay.CoordinatorImageId.ToString(),
                localWay.CoordinatorFirmwareVersion);
@@ -1600,13 +1625,13 @@
                    //添加虚拟驱动的升级固件(成不成功都无所谓) 必须能够联网才行
                    if (flage == 1)
                    {
                        HdlFirmwareUpdateLogic.AddFirmwareVersionInfo(FirmwareLevelType.VirtualDevice,
                        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);
@@ -1641,7 +1666,7 @@
                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");
            var result = this.SendJobjectDataToGateway(zbGateway.GwId, "VirtualDrive/CatDriveCode", jObject.ToString(), "VirtualDrive/CatDriveCode_Respon");
            if (result.ErrorMsg != null)
            {
                this.ShowTipMsg(result.ErrorMsg);
@@ -2019,54 +2044,53 @@
        /// <summary>
        /// 重新发送命令去绑定断网情况下备份的网关
        /// </summary>
        public void ResetComandToBindBackupGateway()
        public bool ResetComandToBindBackupGateway()
        {
            HdlThreadLogic.Current.RunThread(() =>
            var fileData = HdlFileLogic.Current.ReadFileByteContent(DirNameResourse.BackupGatewayIdFile);
            if (fileData == null)
            {
                var fileData = HdlFileLogic.Current.ReadFileByteContent(DirNameResourse.BackupGatewayIdFile);
                if (fileData == null)
                {
                    return;
                }
                this.listBackupGwId = Newtonsoft.Json.JsonConvert.DeserializeObject<List<string>>(System.Text.Encoding.UTF8.GetString(fileData));
                var listTempId = new List<string>();
                listTempId.AddRange(this.listBackupGwId);
                return true;
            }
            this.listBackupGwId = Newtonsoft.Json.JsonConvert.DeserializeObject<List<string>>(System.Text.Encoding.UTF8.GetString(fileData));
            var listTempId = new List<string>();
            listTempId.AddRange(this.listBackupGwId);
                //调用接口,绑定网关
                var bindGateway = new BindGatewayPra();
                //获取控制主人账号的Token
                bindGateway.LoginAccessToken = UserCenterLogic.GetConnectMainToken();
            //调用接口,绑定网关
            var bindGateway = new BindGatewayPra();
            //获取控制主人账号的Token
            bindGateway.LoginAccessToken = UserCenterLogic.GetConnectMainToken();
                foreach (var gwId in listTempId)
            foreach (var gwId in listTempId)
            {
                bindGateway.BindGateways.Clear();
                bindGateway.BindGateways.Add(gwId);
                var result = UserCenterLogic.GetResultCodeByRequestHttps("App/BindGatewayToHome", true, bindGateway, new List<string> { "NotCheck" }, false);
                if (result == "Success")
                {
                    bindGateway.BindGateways.Clear();
                    bindGateway.BindGateways.Add(gwId);
                    var result = UserCenterLogic.GetResultCodeByRequestHttps("App/BindGatewayToHome", true, bindGateway, new List<string> { "NotCheck" }, false);
                    if (result == "Success")
                    {
                        this.listBackupGwId.Remove(gwId);
                    }
                    if (result == "Error")
                    {
                        break;
                    }
                    this.listBackupGwId.Remove(gwId);
                }
                if (result == "Error")
                {
                    break;
                }
            }
                if (this.listBackupGwId.Count == 0)
            if (this.listBackupGwId.Count == 0)
            {
                //如果没有了内容,则删除文件
                string file = DirNameResourse.BackupGatewayIdFile;
                if (System.IO.File.Exists(file) == true)
                {
                    //如果没有了内容,则删除文件
                    string file = DirNameResourse.BackupGatewayIdFile;
                    if (System.IO.File.Exists(file) == true)
                    {
                        System.IO.File.Delete(file);
                    }
                    System.IO.File.Delete(file);
                }
                else
                {
                    //备份
                    HdlFileLogic.Current.SaveFileContent(DirNameResourse.BackupGatewayIdFile, listBackupGwId);
                }
            });
                return true;
            }
            else
            {
                //备份
                HdlFileLogic.Current.SaveFileContent(DirNameResourse.BackupGatewayIdFile, listBackupGwId);
                return false;
            }
        }
        #endregion
@@ -2083,26 +2107,16 @@
        /// <param name="waitTime">超时时间(秒)</param>
        /// <param name="useLocalConnect">是否强制使用本地连接发送</param>
        /// <returns>网关返回的数据</returns>
        public ReceiptGatewayResult SendJobjectDataToGateway(ZbGateway gateway, string sendTopic, string sendData, string receiptTopic, int waitTime = 5, bool useLocalConnect = false)
        public ReceiptGatewayResult SendJobjectDataToGateway(string gatewayId, string sendTopic, string sendData, string receiptTopic, int waitTime = 5, bool useLocalConnect = false)
        {
            var reResult = new ReceiptGatewayResult();
            ZbGateway myGateway = null;
            if (this.GetRealGateway(ref myGateway, gateway) == false)
            {
                //获取网关对象失败
                reResult.ErrorMsg = Language.StringByID(R.MyInternationalizationString.uGetGatewayTagartFail);
                reResult.ErrorMsgDiv = -1;
                return reResult;
            }
            //网关ID
            string gatewayID = gateway.GwId;
            //错误主题
            string errorTopic = gatewayID + "/" + "Error_Respon";
            string errorTopic = gatewayId + "/" + "Error_Respon";
            //检测对象的主题
            string checkTopic = gatewayID + "/" + receiptTopic;
            string checkTopic = gatewayId + "/" + receiptTopic;
            Action<string, string> receiptAction = (topic, message) =>
            HdlGatewayReceiveLogic.Current.AddGatewayReceiveEvent(gatewayId, (topic, message) =>
            {
                var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
@@ -2117,17 +2131,10 @@
                {
                    reResult.ReceiptData = jobject["Data"].ToString();
                }
            };
            myGateway.Actions += receiptAction;
            });
            //发送数据
            if (useLocalConnect == false)
            {
                myGateway.Send(sendTopic, sendData);
            }
            else
            {
                myGateway.SendLocation(sendTopic, System.Text.Encoding.UTF8.GetBytes(sendData));
            }
            this.SendJobjectData(gatewayId, sendTopic, sendData, useLocalConnect);
            //超时时间
            int TimeOut = 0;
@@ -2138,14 +2145,53 @@
                System.Threading.Thread.Sleep(50);
                TimeOut++;
            }
            myGateway.Actions -= receiptAction;
            receiptAction = null;
            //移除网关监听事件
            HdlGatewayReceiveLogic.Current.RemoveGatewayReceiveEvent();
            if (reResult.ReceiptData == null)
            {
                reResult.ErrorMsgDiv = 0;
            }
            return reResult;
        }
        /// <summary>
        /// 单纯执行发送json数据到网关
        /// </summary>
        /// <param name="i_gatewayId">网关id</param>
        /// <param name="topic">主题</param>
        /// <param name="sendData">发送的json数据</param>
        /// <param name="useLocalConnect">是否强制使用本地连接发送</param>
        public void SendJobjectData(string i_gatewayId, string topic, string sendData, bool useLocalConnect = false)
        {
            ZbGateway realWay = null;
            for (int i = 0; i < ZbGateway.GateWayList.Count; i++)
            {
                //寻找真实物理网关对象
                if (ZbGateway.GateWayList[i].GwId == i_gatewayId)
                {
                    realWay = ZbGateway.GateWayList[i];
                    break;
                }
            }
            if (realWay == null)
            {
                //如果网关对象丢失了,则创建个新的
                realWay = new ZbGateway { IsVirtual = true, };
                realWay.GwId = i_gatewayId;
                realWay.HomeId = Config.Instance.HomeId;
                ZbGateway.GateWayList.Add(realWay);
            }
            if (useLocalConnect == false)
            {
                realWay.Send(topic, System.Text.Encoding.UTF8.GetBytes(sendData));
            }
            else
            {
                //强制使用本地连接
                realWay.SendLocation(topic, System.Text.Encoding.UTF8.GetBytes(sendData));
            }
        }
        #endregion
@@ -2197,8 +2243,8 @@
                    }
                    else if (this.nowGwConnectMode == GatewayConnectMode.WIFI)
                    {
                        //局域网每5秒检测一次
                        if (waitCount < 5) { continue; }
                        //局域网每8秒检测一次
                        if (waitCount < 8) { continue; }
                    }
                    waitCount = 0;
@@ -2231,27 +2277,18 @@
        private void CheckGatewayStatuByWIFI(Dictionary<string, bool> dicOldOnline)
        {
            //从网关获取全部的网关
            List<ZbGateway> list = this.GetAllGatewayFromGateway();
            foreach (var way in list)
            {
                //将标识置为false
                way.GatewayOnlineFlage = false;
            }
            //等个2秒
            System.Threading.Thread.Sleep(2000);
            List<ZbGateway> list = this.GetAllLocalGateway();
            //2020.05.25追加:此住宅是否拥有网关在线
            var hadGwOnline = false;
            foreach (var way in list)
            {
                if (dicOldOnline.ContainsKey(way.GwId) == true)
                if (dicOldOnline.ContainsKey(way.GwId) == true
                    && this.CheckGatewayOnlineByFlage(way) == true)
                {
                    if (way.GatewayOnlineFlage == true)
                    {
                        //有一个网关在线,即在线
                        hadGwOnline = true;
                        break;
                    }
                    //有一个网关在线,即在线
                    hadGwOnline = true;
                    break;
                }
            }
@@ -2261,7 +2298,8 @@
                if (dicOldOnline.ContainsKey(gwId) == true)
                {
                    //网关也不多,直接推送吧
                    this.PushGatewayOnlineStatuToForm(gwId, way.GatewayOnlineFlage, hadGwOnline);
                    bool online = this.CheckGatewayOnlineByFlage(way);
                    this.PushGatewayOnlineStatuToForm(gwId, online, hadGwOnline);
                }
                else
                {
@@ -2277,7 +2315,7 @@
        private void CheckGatewayStatuByRemote(Dictionary<string, bool> dicOldOnline)
        {
            //获取云端上面的网关
            Dictionary<string, GatewayResult> dicDbGateway = HdlGatewayLogic.Current.GetGateWayListFromDataBase();
            Dictionary<string, GatewayResult> dicDbGateway = this.GetGateWayListFromDataBase();
            if (dicDbGateway == null)
            {
                //如果网络不通,则也往下走
@@ -2333,7 +2371,7 @@
                foreach (var zbway in this.dicGateway.Values)
                {
                    //获取前回的在线状态
                    dicOldOnline[zbway.GwId] = zbway.GatewayOnlineFlage;
                    dicOldOnline[zbway.GwId] = this.CheckGatewayOnlineByFlage(zbway);
                }
                return dicOldOnline;
            }
@@ -2362,7 +2400,10 @@
                    if (zbway != null)
                    {
                        //切换住宅时,这个东西有可能是null
                        zbway.GatewayOnlineFlage = online;
                        if (online == true)
                        {
                            zbway.OnlineTime = DateTime.Now;
                        }
                        UserCenterResourse.DicActionForm[formId]?.GatewayOnlinePush(zbway, online, hadGwOnline);
                    }
                }