gxc
2020-02-28 66a9965c44ecc32a6696abca876ab9d1cd091584
ZigbeeApp/Shared/Phone/UserCenter/CommonBase/Logic/HdlGatewayLogic.cs
@@ -117,10 +117,20 @@
            {
                return;
            }
            List<string> listBackupGwId = new List<string>();
            var fileData = Global.ReadFileByDirectory(DirNameResourse.LocalMemoryDirectory, DirNameResourse.BackupGatewayIdFile);
            if (fileData != null)
            {
                //新增:虽然概率低,但是确实发生了。如果有网络时,App重新绑定记录的网关失败的话
                //不应该删除它
                listBackupGwId = JsonConvert.DeserializeObject<List<string>>(System.Text.Encoding.UTF8.GetString(fileData));
            }
            List<string> listDelete = new List<string>();
            foreach (var gatewayId in this.dicGateway.Keys)
            {
                if (result.ContainsKey(gatewayId) == false)
                if (result.ContainsKey(gatewayId) == false && listBackupGwId.Contains(gatewayId) == false)
                {
                    //本地存在云端不存在的网关,则删除
                    listDelete.Add(gatewayId);
@@ -132,8 +142,10 @@
                List<CommonDevice> list = Common.LocalDevice.Current.GetDeviceByGatewayID(gatewayId);
                foreach (var device in list)
                {
                    //删除设备,不删除房间信息
                    Common.LocalDevice.Current.DeleteMemmoryDevice(device, false);
                    //删除一般设备
                    Common.LocalDevice.Current.DeleteMemmoryDevice(device, true);
                    //删除Ota设备
                    Common.LocalDevice.Current.DeleteMemmoryOtaDevice(device.DeviceAddr);
                }
                //删除网关文件
                this.DeleteGatewayFile(gatewayId);
@@ -168,10 +180,18 @@
        /// <returns></returns>
        private ZbGateway GetGatewayFromFile(string file)
        {
            byte[] filebyte = Global.ReadFileByHomeId(file);
            string strvalue = System.Text.Encoding.UTF8.GetString(filebyte);
            var gateway = JsonConvert.DeserializeObject<ZbGateway>(strvalue);
            return gateway;
            try
            {
                byte[] filebyte = Global.ReadFileByHomeId(file);
                string strvalue = System.Text.Encoding.UTF8.GetString(filebyte);
                var gateway = JsonConvert.DeserializeObject<ZbGateway>(strvalue);
                return gateway;
            }
            catch (Exception ex)
            {
                HdlLogLogic.Current.WriteLog(ex);
                return null;
            }
        }
        #endregion
@@ -202,11 +222,13 @@
                }
                return false;
            }
            if (result != 1)
            if (result == -1)
            {
                return false;
            }
            return true;
            //设置网关的经纬度
            bool falge = this.SetGatewaySite(zbGateway, Common.Config.Instance.Home.Longitude, Common.Config.Instance.Home.Latitude);
            return falge;
        }
        /// <summary>
@@ -405,6 +427,7 @@
        /// 重新绑定网关(1:正常  -1:异常  0:当前的网关绑定在了当前账号下的不同住宅里面)
        /// </summary>
        /// <param name="zbGateway">网关</param>
        /// <param name="btnMsg">消息控件</param>
        public async Task<int> ReBindNewGateway(ZbGateway zbGateway, NormalViewControl btnMsg = null)
        {
            if (zbGateway == null)
@@ -412,6 +435,12 @@
                //错误:网关对象丢失
                string msg = Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg);
                this.ShowTipMsg(msg);
                return -1;
            }
            //设置网关的经纬度
            bool falge = this.SetGatewaySite(zbGateway, Common.Config.Instance.Home.Longitude, Common.Config.Instance.Home.Latitude);
            if (falge == false)
            {
                return -1;
            }
@@ -451,7 +480,7 @@
                    btnMsg.TextID = R.MyInternationalizationString.uGatewayDataIsChangingPleaseWhait;
                });
            }
            await System.Threading.Tasks.Task.Delay(8000);
            await Task.Delay(8000);
            //获取网关的信息
            var result = await zbGateway.GetZbGwInfoAsync();
@@ -463,15 +492,7 @@
                return -1;
            }
            if (result == null)
            {
                //获取网关信息失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayInfoFail);
                this.ShowTipMsg(msg);
                return -1;
            }
            if (result.getGwData == null)
            if (result == null || result.getGwData == null)
            {
                //获取网关信息失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayInfoFail);
@@ -639,10 +660,10 @@
            }
            //获取全部设备
            bool result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay);
            int result = LocalDevice.Current.SetDeviceToMemmoryByGateway(realWay);
            //关闭进度条
            ProgressBar.Close();
            if (result == false)
            if (result == -1)
            {
                return false;
            }
@@ -691,15 +712,15 @@
                bool result = await this.SetHomeIdToGateway(realWay, string.Empty);
                if (result == false)
                {
                    //网关解绑失败
                    //网关解绑失败  不理它,因为网关可以按按键强制搜索得到
                    string msg = Language.StringByID(R.MyInternationalizationString.uGatewayUnBindFail);
                    this.ShowErrorMsg(msg);
                    return false;
                    //this.ShowErrorMsg(msg);
                    //return false;
                }
            }
            //删除云端的网关
            await Phone.UserCenter.HdlGatewayLogic.Current.DeleteDataBaseGateway(zbGatewayID);
            await this.DeleteDataBaseGateway(zbGatewayID);
            //删除网关文件
            this.DeleteGatewayFile(zbGatewayID);
@@ -707,7 +728,7 @@
            //移除
            ZbGateway.GateWayList.RemoveAll((obj) => this.GetGatewayId(obj) == zbGatewayID);
            //断开mqtt连接
            realWay.DisConnect("GD");
            realWay.DisConnectLocalMqttClient("GD");
            return true;
        }
@@ -740,6 +761,8 @@
            {
                //删除设备文件
                Common.LocalDevice.Current.DeleteMemmoryDevice(device, true);
                //删除Ota设备
                Common.LocalDevice.Current.DeleteMemmoryOtaDevice(device.DeviceAddr);
            }
            //如果是主网关
            if (this.IsMainGateway(zbGatewayID) == 1)
@@ -1043,14 +1066,14 @@
                this.ShowTipMsg(Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg));
                return -1;
            }
            ChannelIdInfo data = null;
            int data = -1;
            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/" + "ZbGw/GetChannel_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    data = Newtonsoft.Json.JsonConvert.DeserializeObject<ChannelIdInfo>(jobject["Data"].ToString());
                    data = Convert.ToInt32(jobject["Data"]["Channel"].ToString());
                }
            };
            realWay.Actions += action;
@@ -1059,34 +1082,22 @@
            realWay.Send("ZbGw/GetChannel", jObject.ToString());
            int TimeOut = 0;
            while (data == null && TimeOut < 30)
            while (data == -1 && TimeOut < 30)
            {
                System.Threading.Thread.Sleep(100);
                TimeOut++;
            }
            realWay.Actions -= action;
            if (data == null)
            if (data == -1)
            {
                //获取协调器信道失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayChannelIdFail);
                msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                this.ShowTipMsg(msg);
                return -1;
            }
            return data.Channel;
        }
        /// <summary>
        /// 网关信道信息
        /// </summary>
        private class ChannelIdInfo
        {
            /// <summary>
            /// 网关信道
            /// </summary>
            public int Channel = -1;
            return data;
        }
        #endregion
@@ -1107,14 +1118,14 @@
                this.ShowTipMsg(Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg));
                return null;
            }
            CoordinatorMacInfo data = null;
            string data = null;
            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/" + "ZbGw/GetMac_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    data = Newtonsoft.Json.JsonConvert.DeserializeObject<CoordinatorMacInfo>(jobject["Data"].ToString());
                    data = jobject["Data"]["MacAddr"].ToString();
                }
            };
            realWay.Actions += action;
@@ -1136,21 +1147,9 @@
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayCoordinatorMacFail);
                msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                this.ShowTipMsg(msg);
                return null;
            }
            return data.MacAddr;
        }
        /// <summary>
        /// 网关协调器Mac信息
        /// </summary>
        private class CoordinatorMacInfo
        {
            /// <summary>
            /// 调器Mac
            /// </summary>
            public string MacAddr = string.Empty;
            return data;
        }
        #endregion
@@ -1171,14 +1170,14 @@
                this.ShowTipMsg(Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg));
                return -1;
            }
            PanIdInfo data = null;
            int panId = -1;
            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/" + "ZbGw/GetPanId_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    data = Newtonsoft.Json.JsonConvert.DeserializeObject<PanIdInfo>(jobject["Data"].ToString());
                    panId = Convert.ToInt32(jobject["Data"]["PANID"].ToString());
                }
            };
            realWay.Actions += action;
@@ -1187,34 +1186,128 @@
            realWay.Send("ZbGw/GetPanId", jObject.ToString());
            int TimeOut = 0;
            while (data == null && TimeOut < 30)
            while (panId == -1 && TimeOut < 30)
            {
                System.Threading.Thread.Sleep(100);
                TimeOut++;
            }
            realWay.Actions -= action;
            if (data == null)
            if (panId == -1)
            {
                //获取协调器PanID失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayPanIDFail);
                msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                this.ShowTipMsg(msg);
                return -1;
            }
            return data.PANID;
            return panId;
        }
        #endregion
        #region ■ 网关自动备份设置___________________
        /// <summary>
        /// 获取网关自动备份设置(-1:异常 0:关闭 1:打开)
        /// </summary>
        /// <param name="zbGateway"></param>
        /// <returns></returns>
        public int GetGatewayAutoBackupStatu(ZbGateway zbGateway)
        {
            ZbGateway realWay = null;
            if (this.GetRealGateway(ref realWay, zbGateway) == false)
            {
                //错误:网关对象丢失
                this.ShowTipMsg(Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg));
                return -1;
            }
            int statu = -1;
            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/GatewayAutoBackup_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    statu = Convert.ToInt32(jobject["Data"]["AutoBackupStatus"].ToString());
                }
            };
            realWay.Actions += action;
            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 6205 } };
            var data = new Newtonsoft.Json.Linq.JObject { { "AutoBackup", 1 } };
            jObject.Add("Data", data);
            realWay.Send("GatewayAutoBackup", jObject.ToString());
            int TimeOut = 0;
            while (statu == -1 && TimeOut < 60)
            {
                System.Threading.Thread.Sleep(100);
                TimeOut++;
            }
            realWay.Actions -= action;
            if (statu == -1)
            {
                //获取网关自动备份设置失败
                string msg = Language.StringByID(R.MyInternationalizationString.uGetGatewayAutoBackupStatuFail);
                msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                this.ShowTipMsg(msg);
            }
            return statu;
        }
        /// <summary>
        /// 网关PanId信息
        /// 设置网关自动备份设置
        /// </summary>
        private class PanIdInfo
        /// <param name="zbGateway"></param>
        /// <param name="statu"></param>
        /// <returns></returns>
        public bool SetGatewayAutoBackupStatu(ZbGateway zbGateway, bool statu)
        {
            /// <summary>
            /// PanId
            /// </summary>
            public int PANID = -1;
            ZbGateway realWay = null;
            if (this.GetRealGateway(ref realWay, zbGateway) == false)
            {
                //错误:网关对象丢失
                this.ShowTipMsg(Language.StringByID(R.MyInternationalizationString.uErrorGatewayLostMsg));
                return false;
            }
            int result = -1;
            Action<string, string> action = (topic, message) =>
            {
                var gatewayID = topic.Split('/')[0];
                if (topic == gatewayID + "/GatewayAutoBackup_Respon")
                {
                    var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
                    result = Convert.ToInt32(jobject["Data"]["AutoBackupStatus"].ToString());
                }
            };
            realWay.Actions += action;
            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 6205 } };
            var data = new Newtonsoft.Json.Linq.JObject { { "AutoBackup", statu == true ? 2 : 3 } };
            jObject.Add("Data", data);
            realWay.Send("GatewayAutoBackup", jObject.ToString());
            int TimeOut = 0;
            while (result == -1 && TimeOut < 60)
            {
                System.Threading.Thread.Sleep(100);
                TimeOut++;
            }
            realWay.Actions -= action;
            if (result == -1)
            {
                //设置网关自动备份失败
                string msg = Language.StringByID(R.MyInternationalizationString.uSetGatewayAutoBackupStatuFail);
                msg = UserCenterLogic.CombineGatewayTimeOutMsg(msg, null, "回复超时");
                this.ShowTipMsg(msg);
                return false;
            }
            return true;
        }
        #endregion
@@ -1486,7 +1579,7 @@
            //最后再断开mqtt连接
            for (int i = 0; i < list.Count; i++)
            {
                list[i].DisConnect("G");
                list[i].DisConnectLocalMqttClient("G");
            }
            list.Clear();
        }
@@ -1760,51 +1853,15 @@
                return;
            }
            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 85 } };
            realWay.Send("GwLinuxLocate_Respon", jObject.ToString());
        }
        #endregion
        #region ■ 一般方法___________________________
        /// <summary>
        /// 弹出网关不在线的
        /// </summary>
        private void ShowGatewayNotOnlineMsg()
        {
            Application.RunOnMainThread(() =>
            if (this.IsGatewayExist(zbGateway) == true)
            {
                //网关连接失败,请确认网络
                string msg = Language.StringByID(R.MyInternationalizationString.uGatewayIsNotLinkAndCheckNetwork);
                var control = new ShowMsgControl(ShowMsgType.Tip, msg);
                control.Show();
            });
        }
        /// <summary>
        /// 显示错误信息窗口
        /// </summary>
        /// <param name="msg"></param>
        private void ShowErrorMsg(string msg)
        {
            Application.RunOnMainThread(() =>
                realWay.Send("GwLinuxLocate_Respon", jObject.ToString());
            }
            else
            {
                var contr = new ShowMsgControl(ShowMsgType.Error, msg);
                contr.Show();
            });
        }
        /// <summary>
        /// 显示Tip信息窗口
        /// </summary>
        /// <param name="msg"></param>
        private void ShowTipMsg(string msg)
        {
            Application.RunOnMainThread(() =>
            {
                var contr = new ShowMsgControl(ShowMsgType.Tip, msg);
                contr.Show();
            });
                //如果这个网关还没有绑定的话,则强制使用本地连接
                realWay.SendLocation("GwLinuxLocate_Respon", System.Text.Encoding.UTF8.GetBytes(jObject.ToString()));
            }
        }
        #endregion
@@ -2010,17 +2067,19 @@
            {
                return;
            }
            //获取当前接受在线状态推送的界面
            var listForm = new List<CommonFormBase>();
            listForm.AddRange(UserCenterResourse.listGatewayOnlinePushForm);
            if (listForm.Count > 0)
            //保存当前激活的界面ID
            var listId = new List<string>();
            listId.AddRange(UserCenterResourse.listActionFormId);
            for (int i = 0; i < listId.Count; i++)
            {
                for (int i = 0; i < listChange.Count; i++)
                if (UserCenterResourse.DicActionForm.ContainsKey(listId[i]) == false)
                {
                    foreach (var form in listForm)
                    {
                        form?.GatewayOnlinePush(listChange[i], listChangeStatu[i]);
                    }
                    continue;
                }
                //网关在线推送
                for (int j = 0; j < listChange.Count; j++)
                {
                    UserCenterResourse.DicActionForm[listId[i]]?.GatewayOnlinePush(listChange[j], listChangeStatu[j]);
                }
            }
        }
@@ -2091,7 +2150,7 @@
            bool canBreak = false;
            HdlThreadLogic.Current.RunThread(async () =>
            {
                List<string> list = new List<string>() { "NotSetAgain" };
                List<string> list = new List<string>() { "NotSetAgain", "NotCheck" };
                //设置访问接口的参数
                var pra = new GetGatewayPra();
@@ -2175,7 +2234,15 @@
            var jObject = new Newtonsoft.Json.Linq.JObject { { "Cluster_ID", 0 }, { "Command", 2013 } };
            var data = new Newtonsoft.Json.Linq.JObject { { "Longitude", intLongitude }, { "Latitude", intLatitude } };
            jObject.Add("Data", data);
            realWay.Send("Logic/SetSite", jObject.ToString());
            if (this.IsGatewayExist(gateway) == true)
            {
                realWay.Send("Logic/SetSite", jObject.ToString());
            }
            else
            {
                //如果这个网关还没有绑定的话,则强制使用本地连接
                realWay.SendLocation("Logic/SetSite", System.Text.Encoding.UTF8.GetBytes(jObject.ToString()));
            }
            int TimeOut = 0;
            while (result == -1 && TimeOut < 30)
@@ -2215,7 +2282,7 @@
            //获取控制主人账号的Token
            Pra.LoginAccessToken = UserCenterLogic.GetConnectMainToken();
            List<string> listNotShowError = new List<string>() { "NoExist", "NoBind", "NoRecord" };
            List<string> listNotShowError = new List<string>() { "NoExist", "NoBind", "NoRecord", "NotSetAgain" };
            bool result = await UserCenterLogic.GetResultStatuByRequestHttps("App/ReleaseGatewayToHome", true, Pra, listNotShowError);
            if (result == false)
@@ -2484,7 +2551,7 @@
            else if (backType == GatewayBackupEnum.APir灯光配置)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.ConfigureParamates>(System.Text.Encoding.UTF8.GetString(byteData));
                result = await HdlDevicePirSensorLogic.Current.SetPirSensorLightSettion((IASZone)device, recoverData);
                result = await HdlDevicePirSensorLogic.Current.SetPirSensorSettion((IASZone)device, recoverData);
            }
            else if (backType == GatewayBackupEnum.A干接点颜色调节)
            {
@@ -2506,10 +2573,10 @@
                int level = Convert.ToInt32(recoverData["level"]);
                result = await HdlDevicePanelLogic.Current.SetDeviceEnergyConservationMode((Panel)device, modeEnable, modeTime, level);
            }
            else if (backType == GatewayBackupEnum.A干接点私有属性)
            else if (backType == GatewayBackupEnum.A干接点第三级别私有属性)
            {
                var recoverData = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(System.Text.Encoding.UTF8.GetString(byteData));
                result = await HdlDevicePanelLogic.Current.EditorDryContactFunction((Panel)device, recoverData);
                result = await HdlDevicePanelLogic.Current.EditorDryContactThirdFunction((Panel)device, recoverData);
            }
            else if (backType == GatewayBackupEnum.A窗帘方向)
            {
@@ -2574,5 +2641,49 @@
        }
        #endregion
        #region ■ 一般方法___________________________
        /// <summary>
        /// 弹出网关不在线的
        /// </summary>
        private void ShowGatewayNotOnlineMsg()
        {
            Application.RunOnMainThread(() =>
            {
                //网关连接失败,请确认网络
                string msg = Language.StringByID(R.MyInternationalizationString.uGatewayIsNotLinkAndCheckNetwork);
                var control = new ShowMsgControl(ShowMsgType.Tip, msg);
                control.Show();
            });
        }
        /// <summary>
        /// 显示错误信息窗口
        /// </summary>
        /// <param name="msg"></param>
        private void ShowErrorMsg(string msg)
        {
            Application.RunOnMainThread(() =>
            {
                var contr = new ShowMsgControl(ShowMsgType.Error, msg);
                contr.Show();
            });
        }
        /// <summary>
        /// 显示Tip信息窗口
        /// </summary>
        /// <param name="msg"></param>
        private void ShowTipMsg(string msg)
        {
            Application.RunOnMainThread(() =>
            {
                var contr = new ShowMsgControl(ShowMsgType.Tip, msg);
                contr.Show();
            });
        }
        #endregion
    }
}