~wjc/HomeApp.git

			@@ -8,10 +8,11 @@
			using System.Net.Sockets;
			using System.Net;
			using Newtonsoft.Json.Linq;
			using MQTTnet.Core.Client;
			using MQTTnet;
			using Shared.Common;
			using Shared.Phone.UserView;
			using MQTTnet.Client;
			using System.Threading.Tasks;

			namespace ZigBee.Device
			{
			@@ -21,12 +22,7 @@
			[System.Serializable]
			public class ZbGateway : ZbGatewayData
			{
			public ZbGateway()
			{
			this.Type = DeviceType.ZbGateway;
			}

			#region 网关特殊信息处理
			#region 一堆变量
			/// <summary>
			/// 主网关
			/// </summary>
			@@ -35,53 +31,60 @@
			{
			get
			{
			return GateWayList.Find((obj) => { return obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId && obj.getGatewayBaseInfo.IsMainGateWay; });
			return GateWayList.Find((obj) => { return obj.HomeId == Shared.Common.Config.Instance.HomeId && obj.IsMainGateWay; });
			}
			}

			/// <summary>
			/// 主网关
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public bool IsMainGateWay
			{
			get
			{
			return getGatewayBaseInfo != null && getGatewayBaseInfo.IsMainGateWay;
			}
			}

			/// <summary>
			/// 远程网关
			/// 是否使用远程连接模式
			/// </summary>
			/// <value><c>true</c> if is remote; otherwise, <c>false</c>.</value>
			public static bool IsRemote
			{
			get
			{
			return ZigBee.Device.ZbGateway.RemoteMqttClient != null && ZigBee.Device.ZbGateway.RemoteMqttClient.IsConnected;
			}
			}
			public static bool IsRemote;

			/// <summary>
			/// 是否拥有远程连接的权限
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public static bool AllowRemoteCtrl = true;

			/// <summary>
			/// 网关保存路径
			/// </summary>
			/// <value>The file path.</value>
			[Newtonsoft.Json.JsonIgnore]
			public override string FilePath
			public string FilePath
			{
			get
			{
			var deviceType = Type.ToString();
			var fileName = "Gateway_" + deviceType + "_" + this.getGatewayBaseInfo?.gwID;
			var fileName = "Gateway_" + DeviceType.ZbGateway.ToString() + "_" + this.GwId;
			return fileName;
			}
			}

			/// <summary>
			/// 等待从网关接收数据的时间
			/// </summary>
			/// <value>The wait receive data time.</value>
			[Newtonsoft.Json.JsonIgnore]
			public int WaitReceiveDataTime
			{
			get
			{
			if (Device.ZbGateway.RemoteMqttClient != null && Device.ZbGateway.RemoteMqttClient.IsConnected)
			{
			return 10000;
			}
			else
			{
			return 3000;
			}
			}
			}

			/// <summary>
			/// 局域网加密密码
			/// </summary>
			string password;
			private string password;
			/// <summary>
			/// 局域网加密密钥
			/// </summary>
			@@ -98,27 +101,6 @@
			}
			}

			#region variable
			/// <summary>
			/// 远程连接成功时的时间
			/// </summary>
			public static DateTime LoginRemoteDateTime = DateTime.Now;

			/// <summary>
			/// 同步到远程的当前时间戳
			/// </summary>Re
			public static ulong CurrentTimeStamp
			{
			get
			{
			return RemoteTimeStamp + (ulong)(DateTime.Now - LoginRemoteDateTime).TotalSeconds;
			}
			}

			/// <summary>
			/// 远程连接成功时的时间戳
			/// </summary>
			public static ulong RemoteTimeStamp;
			/// <summary>
			/// 网关是否加密
			/// </summary>
			@@ -135,71 +117,6 @@
			[Newtonsoft.Json.JsonIgnore]
			public static List<ZbGateway> GateWayList = new List<ZbGateway>();

			//当前网关中的设备列表
			[Newtonsoft.Json.JsonIgnore]
			public List<CommonDevice> DeviceList = new List<CommonDevice>();

			/// <summary>
			/// 所有网关中的设备列表
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public List<CommonDevice> AllGatewayDeviceList = new List<CommonDevice>();

			/// <summary>
			/// 网关中场景列表
			/// 一个场景中包含所有信息，包括场景设备信息
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public static List<Scene.GetSceneAllInfo> AllSceneList = new List<Scene.GetSceneAllInfo>();

			/// <summary>
			/// 网关中场景的设备列表
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public List<Scene.GetSceneDeviceListInfo> SceneDeviceList = new List<Scene.GetSceneDeviceListInfo>();

			/// <summary>
			/// 网关中逻辑列表
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public static List<Logic.GetLogicInfoResponseData> LogicList = new List<Logic.GetLogicInfoResponseData>();

			/// <summary>
			/// 网关中hdl私有按键绑定列表
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public List<HDLbutton> HdlButtonList = new List<HDLbutton>();

			//网关中新的设备列表
			[Newtonsoft.Json.JsonIgnore]
			public List<CommonDevice> ListNewDeviceInfoData = new List<CommonDevice>();

			/// <summary>
			/// 私有按键信息列表
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public System.Collections.Generic.Dictionary<string, HDLbutton> hdlButtonInfoList = new Dictionary<string, HDLbutton>();

			/// <summary>
			/// 传感器信息列表
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public System.Collections.Generic.Dictionary<string, Scene.TaskListInfo> sceneTaskInfoList = new Dictionary<string, Scene.TaskListInfo>();

			#region action variable
			/// <summary>
			/// 接收数据后回调
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			Action<object> action;
			/// <summary>
			/// 设置数据回调
			/// </summary>
			public void SetAction(Action<object> action, int timeOut = 1000)
			{
			this.action = action;
			}

			/// <summary>
			/// 网关推送数据
			/// <para>第一个参数：如果为 DeviceInComingRespon:设备新上报</para>
			@@ -214,24 +131,15 @@
			/// <para>第一个参数：如果为 ZoneTriggerReport:防区被触发时报告</para>
			/// <para>第一个参数：如果为 LogicExecuteReport:逻辑被调用反馈</para>
			/// <para>第一个参数：如果为 TimingWillArrive:时间点条件推迟执行</para>
			/// para>第一个参数：如果为 ModeTriggerReport:模式安防动作被最终激活时发送报警信息</para>
			/// <para>第一个参数：如果为 ModeTriggerReport:模式安防动作被最终激活时发送报警信息</para>
			/// <para>第一个参数：如果为 EnOrWithdrawSucceedReport:通过外部方式布防撤防成功时报告息</para>
			/// <para>第一个参数：如果为 PushTargetInfoReport:胁迫密码撤防时短信推送</para>
			/// <para>第一个参数：如果为 DeviceDefaultAck:节点设备默认反馈</para>
			/// <para>第一个参数：如果为 DDevice/IsGetEpointInfo:有新设备加入zigbee网络反馈</para>设备请求APP获取升级数据
			/// <para>第一个参数：如果为 Device/DeviceJoinZbNet:获取新设备所有端点信息是否成功反馈</para>
			/// <para>第一个参数：如果为 DeviceRequestAcUpdateData: 设备请求空调发升级数据</para>
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public Action<string, object> ReportAction;
			/// <summary>
			/// 云端通讯错误数据上报
			///<para>"ForwardGatewayNoOnLine", "当前操作的网关不在线"</para>
			///<para>"AppTimeOut", "从云端获取数据超时，请重新获取"</para>
			///<para>"AppNoLogin", "登录过期，请重新登录"</para>
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public Action<string, string> CloudErrorAction;

			/// <summary>
			/// 网关文件流内容通知
			@@ -250,8 +158,7 @@
			/// </summary>
			[Newtonsoft.Json.JsonIgnore]
			public Action<string, string> Actions;
			#endregion
			#endregion

			#endregion

			#region 网关API
			@@ -272,8 +179,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -281,24 +187,21 @@
			}
			else
			{
			d = new GetGwVersionAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new GetGwVersionAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "GetZbGwVersionRespon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			gatewayTemp.getGwVersion = Newtonsoft.Json.JsonConvert.DeserializeObject<GetGwVersionData>(jobject["Data"].ToString());
			var getGwVersion = Newtonsoft.Json.JsonConvert.DeserializeObject<GetGwVersionData>(jobject["Data"].ToString());

			if (gatewayTemp.getGwVersion == null)
			if (getGwVersion == null)
			{
			d = new GetGwVersionAllData { errorMessageBase = "网关错误回复，且数据是空" };
			}
			else
			{
			d = new GetGwVersionAllData { getGwVersion = gatewayTemp.getGwVersion };
			AppVersion = gatewayTemp.getGwVersion.AppVersion;
			ZigbeeVersion = gatewayTemp.getGwVersion.ZigbeeVersion;
			d = new GetGwVersionAllData { getGwVersion = getGwVersion };
			//Save();
			DebugPrintLog($"UI收到通知后的主题_{topic}");
			}
			@@ -350,16 +253,15 @@
			if (topic == gatewayID + "/" + "GetZbGwInfo_Respon")
			{
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			gatewayTemp.getGwInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<GetGwData>(jobject["Data"].ToString());
			var getGwInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<GetGwData>(jobject["Data"].ToString());

			if (gatewayTemp.getGwInfo == null)
			if (getGwInfo == null)
			{
			data = new GetGwAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			data = new GetGwAllData { getGwData = gatewayTemp.getGwInfo };
			data = new GetGwAllData { getGwData = getGwInfo };
			DebugPrintLog($"UI收到通知后的主题_{topic}");
			}
			}
			@@ -404,8 +306,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -413,13 +314,12 @@
			}
			else
			{
			d = new GetMacResponData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new GetMacResponData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbGw/GetMac_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<MacAddrData>(jobject["Data"].ToString());

			if (tempData == null)
			@@ -474,8 +374,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -483,22 +382,21 @@
			}
			else
			{
			d = new GwReNameAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new GwReNameAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "GwReName_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			gatewayTemp.gwRename = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GwReNameData>(jobject["Data"].ToString());
			var gwRename = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GwReNameData>(jobject["Data"].ToString());

			if (gatewayTemp.gwRename == null)
			if (gwRename == null)
			{
			d = new GwReNameAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new GwReNameAllData { gwReNameData = gatewayTemp.gwRename };
			d = new GwReNameAllData { gwReNameData = gwRename };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			}
			@@ -557,8 +455,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -566,21 +463,20 @@
			}
			else
			{
			d = new GwSetHomeIdAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new GwSetHomeIdAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "GwSetHomeId_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			gatewayTemp.gwSetHomeId = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GwSetHomeIdData>(jobject["Data"].ToString());
			if (gatewayTemp.gwSetHomeId == null)
			var gwSetHomeId = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GwSetHomeIdData>(jobject["Data"].ToString());
			if (gwSetHomeId == null)
			{
			d = new GwSetHomeIdAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new GwSetHomeIdAllData { gwSetHomeIdData = gatewayTemp.gwSetHomeId };
			d = new GwSetHomeIdAllData { gwSetHomeIdData = gwSetHomeId };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			}
			@@ -589,10 +485,25 @@
			DebugPrintLog("GwReName_Actions 启动" + System.DateTime.Now.ToString());
			try
			{
			//账号ID
			string accountId = string.Empty;
			if (homeId != string.Empty)
			{
			if (Shared.Phone.UserCenter.UserCenterResourse.UserInfo.AuthorityNo == 1)
			{
			//主账号
			accountId = Config.Instance.Guid;
			}
			else
			{
			accountId = Config.Instance.Home.MainUserDistributedMark;
			}
			}
			var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 82 } };
			var data = new JObject { { "HomeId", homeId } };
			var data = new JObject { { "HomeId", homeId }, { "AccountId", accountId } };
			jObject.Add("Data", data);
			Send("GwSetHomeId", jObject.ToString());
			//住宅ID的设置,固定使用局域网,不存在远程的说法
			SendLocation("GwSetHomeId", System.Text.Encoding.UTF8.GetBytes(jObject.ToString()));
			}
			catch { }

			@@ -619,498 +530,6 @@
			}
			#endregion

			#region 获取已入网设备信息
			/// <summary>
			/// 获取网关设备信息(注意，这个接口会被去掉）
			/// </summary>
			public async System.Threading.Tasks.Task<List<CommonDevice>> GetGwDeviceList()
			{
			DeviceList.Clear();
			return await System.Threading.Tasks.Task.Run((Func<System.Threading.Tasks.Task<List<CommonDevice>>>)(async () =>
			{
			var dateTime = DateTime.Now;
			bool canBreak = false;
			Action<string, string> action = (topic, message) =>
			{
			var gatewayID = topic.Split('/')[0];
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);

			if (topic == gatewayID + "/" + "DeviceInfoRespon")
			{
			dateTime = DateTime.Now;
			var totalNum = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["TotalNum"].ToString());
			if (totalNum == 0)
			{
			canBreak = true;
			return;
			}
			var deviceID = jobject.Value<int>("Device_ID");
			switch ((DeviceType)(deviceID))
			{
			//case DeviceType.DimmableLight:
			// var dimmableLight = new DimmableLight() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			// dimmableLight.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<DimmableLight.DeviceInfoData>(jobject["Data"].ToString());
			// if (dimmableLight.DeviceInfo == null)
			// {
			// return;
			// }
			// var light = DeviceList.Find(obj => obj.DeviceID == dimmableLight.DeviceID && obj.DeviceAddr == dimmableLight.DeviceAddr && obj.DeviceEpoint == dimmableLight.DeviceEpoint);
			// if (light == null)
			// {
			// DeviceList.Add(dimmableLight);
			// dimmableLight.DeviceName = dimmableLight.DeviceInfo.MacName;
			// dimmableLight.DeviceEpointName = dimmableLight.DeviceInfo.DeviceName;
			// dimmableLight.ImgVersion = dimmableLight.DeviceInfo.ImgVersion;
			// dimmableLight.HwVersion = dimmableLight.DeviceInfo.HwVersion;
			// dimmableLight.IsOnline = dimmableLight.DeviceInfo.IsOnline;
			// dimmableLight.DriveCode = dimmableLight.DeviceInfo.DriveCode;
			// dimmableLight.ImgTypeId = dimmableLight.DeviceInfo.ImgTypeId;
			// dimmableLight.IasDeviceType = dimmableLight.DeviceInfo.DeviceType;
			// dimmableLight.Profile = dimmableLight.DeviceInfo.Profile;
			// dimmableLight.InClusterList = dimmableLight.DeviceInfo.InClusterList;
			// dimmableLight.OutClusterList = dimmableLight.DeviceInfo.OutClusterList;
			// dimmableLight.AttributeStatus = dimmableLight.DeviceInfo.AttributeStatus;
			// //dimmableLight.Save();
			// }
			// else
			// {
			// light.DeviceInfo = dimmableLight.DeviceInfo;
			// light.DeviceName = dimmableLight.DeviceInfo.MacName;
			// light.DeviceEpointName = dimmableLight.DeviceInfo.DeviceName;
			// light.ImgVersion = dimmableLight.DeviceInfo.ImgVersion;
			// light.HwVersion = dimmableLight.DeviceInfo.HwVersion;
			// light.IsOnline = dimmableLight.DeviceInfo.IsOnline;
			// light.DriveCode = dimmableLight.DeviceInfo.DriveCode;
			// light.ImgTypeId = dimmableLight.DeviceInfo.ImgTypeId;
			// light.IasDeviceType = dimmableLight.DeviceInfo.DeviceType;
			// light.Profile = dimmableLight.DeviceInfo.Profile;
			// light.InClusterList = dimmableLight.DeviceInfo.InClusterList;
			// light.OutClusterList = dimmableLight.DeviceInfo.OutClusterList;
			// light.AttributeStatus = dimmableLight.DeviceInfo.AttributeStatus;
			// //dimmableLight.ReSave();
			// }
			// DebugPrintLog($"UI收到通知后的主题_{ topic}");

			// break;
			//case DeviceType.OnOffSwitch:
			// var panel = new Panel() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			// panel.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<Panel.DeviceInfoData>(jobject["Data"].ToString());
			// if (panel.DeviceInfo == null)
			// {
			// return;
			// }
			// var panelInfo = DeviceList.Find(obj => obj.DeviceID == panel.DeviceID && obj.DeviceAddr == panel.DeviceAddr && obj.DeviceEpoint == panel.DeviceEpoint);
			// if (panelInfo == null)
			// {
			// DeviceList.Add(panel);
			// panel.DeviceName = panel.DeviceInfo.MacName;
			// panel.DeviceEpointName = panel.DeviceInfo.DeviceName;
			// panel.ImgTypeId = panel.DeviceInfo.ImgTypeId;
			// panel.ImgVersion = panel.DeviceInfo.ImgVersion;
			// panel.HwVersion = panel.DeviceInfo.HwVersion;
			// panel.IasDeviceType = panel.DeviceInfo.DeviceType;
			// panel.IsOnline = panel.DeviceInfo.IsOnline;
			// panel.DriveCode = panel.DeviceInfo.DriveCode;
			// panel.Profile = panel.DeviceInfo.Profile;
			// panel.InClusterList = panel.DeviceInfo.InClusterList;
			// panel.OutClusterList = panel.DeviceInfo.OutClusterList;
			// panel.AttributeStatus = panel.DeviceInfo.AttributeStatus;
			// //panel.Save();
			// }
			// else
			// {
			// panelInfo.DeviceInfo = panel.DeviceInfo;
			// panelInfo.DeviceName = panel.DeviceInfo.MacName;
			// panelInfo.DeviceEpointName = panel.DeviceInfo.DeviceName;
			// panelInfo.ImgVersion = panel.DeviceInfo.ImgVersion;
			// panelInfo.HwVersion = panel.DeviceInfo.HwVersion;
			// panelInfo.IsOnline = panel.DeviceInfo.IsOnline;
			// panelInfo.DriveCode = panel.DeviceInfo.DriveCode;
			// panelInfo.IasDeviceType = panel.DeviceInfo.DeviceType;
			// panelInfo.Profile = panel.DeviceInfo.Profile;
			// panelInfo.ImgTypeId = panel.DeviceInfo.ImgTypeId;
			// panelInfo.InClusterList = panel.DeviceInfo.InClusterList;
			// panelInfo.OutClusterList = panel.DeviceInfo.OutClusterList;
			// panelInfo.AttributeStatus = panel.DeviceInfo.AttributeStatus;
			// //panel.ReSave();
			// }
			// DebugPrintLog($"UI收到通知后的主题_{ topic}");

			// break;
			//case DeviceType.OnOffOutput:
			// var toggleLight = new ToggleLight() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			// toggleLight.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ToggleLight.DeviceInfoData>(jobject["Data"].ToString());
			// if (toggleLight.DeviceInfo == null)
			// {
			// return;
			// }
			// var toggleLightInfo = DeviceList.Find(obj => obj.DeviceID == toggleLight.DeviceID && obj.DeviceAddr == toggleLight.DeviceAddr && obj.DeviceEpoint == toggleLight.DeviceEpoint);
			// if (toggleLightInfo == null)
			// {
			// DeviceList.Add(toggleLight);
			// toggleLight.DeviceName = toggleLight.DeviceInfo.MacName;
			// toggleLight.DeviceEpointName = toggleLight.DeviceInfo.DeviceName;
			// toggleLight.ImgVersion = toggleLight.DeviceInfo.ImgVersion;
			// toggleLight.HwVersion = toggleLight.DeviceInfo.HwVersion;
			// toggleLight.IsOnline = toggleLight.DeviceInfo.IsOnline;
			// toggleLight.DriveCode = toggleLight.DeviceInfo.DriveCode;
			// toggleLight.IasDeviceType = toggleLight.DeviceInfo.DeviceType;
			// toggleLight.Profile = toggleLight.DeviceInfo.Profile;
			// toggleLight.ImgTypeId = toggleLight.DeviceInfo.ImgTypeId;
			// toggleLight.InClusterList = toggleLight.DeviceInfo.InClusterList;
			// toggleLight.OutClusterList = toggleLight.DeviceInfo.OutClusterList;
			// toggleLight.AttributeStatus = toggleLight.DeviceInfo.AttributeStatus;
			// //toggleLight.Save();
			// }
			// else
			// {
			// toggleLightInfo.DeviceName = toggleLight.DeviceInfo.MacName;
			// toggleLightInfo.DeviceEpointName = toggleLight.DeviceInfo.DeviceName;
			// toggleLightInfo.ImgVersion = toggleLight.DeviceInfo.ImgVersion;
			// toggleLightInfo.HwVersion = toggleLight.DeviceInfo.HwVersion;
			// toggleLightInfo.IsOnline = toggleLight.DeviceInfo.IsOnline;
			// toggleLightInfo.DriveCode = toggleLight.DeviceInfo.DriveCode;
			// toggleLightInfo.IasDeviceType = toggleLight.DeviceInfo.DeviceType;
			// toggleLightInfo.Profile = toggleLight.DeviceInfo.Profile;
			// toggleLightInfo.ImgTypeId = toggleLight.DeviceInfo.ImgTypeId;
			// toggleLightInfo.InClusterList = toggleLight.DeviceInfo.InClusterList;
			// toggleLightInfo.OutClusterList = toggleLight.DeviceInfo.OutClusterList;
			// toggleLightInfo.AttributeStatus = toggleLight.DeviceInfo.AttributeStatus;
			// toggleLightInfo.DeviceInfo = toggleLight.DeviceInfo;
			// //toggleLightInfo.ReSave();
			// }
			// DebugPrintLog($"UI收到通知后的主题_{ topic}");

			// break;
			//case DeviceType.AirSwitch:
			// var airSwitch = new AirSwitch() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			// airSwitch.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<AirSwitch.DeviceInfoData>(jobject["Data"].ToString());
			// if (airSwitch.DeviceInfo == null)
			// {
			// return;
			// }
			// var airSwitchInfo = DeviceList.Find(obj => obj.DeviceID == airSwitch.DeviceID && obj.DeviceAddr == airSwitch.DeviceAddr && obj.DeviceEpoint == airSwitch.DeviceEpoint);
			// if (airSwitchInfo == null)
			// {
			// DeviceList.Add(airSwitch);
			// airSwitch.DeviceName = airSwitch.DeviceInfo.MacName;
			// airSwitch.DeviceEpointName = airSwitch.DeviceInfo.DeviceName;
			// airSwitch.ImgVersion = airSwitch.DeviceInfo.ImgVersion;
			// airSwitch.HwVersion = airSwitch.DeviceInfo.HwVersion;
			// airSwitch.IsOnline = airSwitch.DeviceInfo.IsOnline;
			// airSwitch.DriveCode = airSwitch.DeviceInfo.DriveCode;
			// airSwitch.IasDeviceType = airSwitch.DeviceInfo.DeviceType;
			// airSwitch.Profile = airSwitch.DeviceInfo.Profile;
			// airSwitch.ImgTypeId = airSwitch.DeviceInfo.ImgTypeId;
			// airSwitch.InClusterList = airSwitch.DeviceInfo.InClusterList;
			// airSwitch.OutClusterList = airSwitch.DeviceInfo.OutClusterList;
			// airSwitch.AttributeStatus = airSwitch.DeviceInfo.AttributeStatus;
			// //airSwitch.Save();
			// }
			// else
			// {
			// airSwitchInfo.DeviceName = airSwitch.DeviceInfo.MacName;
			// airSwitchInfo.DeviceEpointName = airSwitch.DeviceInfo.DeviceName;
			// airSwitchInfo.ImgVersion = airSwitch.DeviceInfo.ImgVersion;
			// airSwitchInfo.HwVersion = airSwitch.DeviceInfo.HwVersion;
			// airSwitchInfo.IsOnline = airSwitch.DeviceInfo.IsOnline;
			// airSwitchInfo.DriveCode = airSwitch.DeviceInfo.DriveCode;
			// airSwitchInfo.IasDeviceType = airSwitch.DeviceInfo.DeviceType;
			// airSwitchInfo.Profile = airSwitch.DeviceInfo.Profile;
			// airSwitchInfo.ImgTypeId = airSwitch.DeviceInfo.ImgTypeId;
			// airSwitchInfo.InClusterList = airSwitch.DeviceInfo.InClusterList;
			// airSwitchInfo.OutClusterList = airSwitch.DeviceInfo.OutClusterList;
			// airSwitchInfo.AttributeStatus = airSwitch.DeviceInfo.AttributeStatus;
			// airSwitchInfo.DeviceInfo = airSwitch.DeviceInfo;
			// // airSwitchInfo.ReSave();
			// }
			// DebugPrintLog($"UI收到通知后的主题_{ topic}");

			// break;
			//case DeviceType.WindowCoveringDevice:
			// var windowCovering = new Rollershade() { DeviceID = jobject.Value<int>((object)"Device_ID"), DeviceAddr = jobject.Value<string>((object)"DeviceAddr"), DeviceEpoint = jobject.Value<int>((object)"Epoint"), DataID = jobject.Value<int>((object)"Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			// windowCovering.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<Rollershade.DeviceInfoData>(jobject["Data"].ToString());
			// if (windowCovering.DeviceInfo == null)
			// {
			// return;
			// }
			// var wc = DeviceList.Find(obj => obj.DeviceID == windowCovering.DeviceID && obj.DeviceAddr == windowCovering.DeviceAddr && obj.DeviceEpoint == windowCovering.DeviceEpoint);
			// if (wc == null)
			// {
			// DeviceList.Add(windowCovering);
			// windowCovering.DeviceName = windowCovering.DeviceInfo.MacName;
			// windowCovering.DeviceEpointName = windowCovering.DeviceInfo.DeviceName;
			// windowCovering.ImgVersion = windowCovering.DeviceInfo.ImgVersion;
			// windowCovering.HwVersion = windowCovering.DeviceInfo.HwVersion;
			// windowCovering.IsOnline = windowCovering.DeviceInfo.IsOnline;
			// windowCovering.DriveCode = windowCovering.DeviceInfo.DriveCode;
			// windowCovering.IasDeviceType = windowCovering.DeviceInfo.DeviceType;
			// windowCovering.Profile = windowCovering.DeviceInfo.Profile;
			// windowCovering.ImgTypeId = windowCovering.DeviceInfo.ImgTypeId;
			// windowCovering.InClusterList = windowCovering.DeviceInfo.InClusterList;
			// windowCovering.OutClusterList = windowCovering.DeviceInfo.OutClusterList;
			// windowCovering.AttributeStatus = windowCovering.DeviceInfo.AttributeStatus;
			// //windowCovering.Save();
			// }
			// else
			// {
			// wc.DeviceName = windowCovering.DeviceInfo.MacName;
			// wc.DeviceEpointName = windowCovering.DeviceInfo.DeviceName;
			// wc.DeviceInfo = windowCovering.DeviceInfo;
			// wc.ImgVersion = windowCovering.DeviceInfo.ImgVersion;
			// wc.HwVersion = windowCovering.DeviceInfo.HwVersion;
			// wc.IsOnline = windowCovering.DeviceInfo.IsOnline;
			// wc.DriveCode = windowCovering.DeviceInfo.DriveCode;
			// wc.IasDeviceType = windowCovering.DeviceInfo.DeviceType;
			// wc.Profile = windowCovering.DeviceInfo.Profile;
			// wc.ImgTypeId = windowCovering.DeviceInfo.ImgTypeId;
			// wc.InClusterList = windowCovering.DeviceInfo.InClusterList;
			// wc.OutClusterList = windowCovering.DeviceInfo.OutClusterList;
			// wc.AttributeStatus = windowCovering.DeviceInfo.AttributeStatus;
			// // wc.ReSave();
			// }
			// DebugPrintLog($"UI收到通知后的主题_{ topic}");
			// break;
			//case DeviceType.IASZone:
			// var ias = new IASZone() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			// ias.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.DeviceInfoData>(jobject["Data"].ToString());
			// if (ias.DeviceInfo == null)
			// {
			// return;
			// }
			// var infoIAS = DeviceList.Find(obj => obj.DeviceID == ias.DeviceID && obj.DeviceAddr == ias.DeviceAddr && obj.DeviceEpoint == ias.DeviceEpoint);
			// if (infoIAS == null)
			// {
			// DeviceList.Add(ias);
			// ias.DeviceName = ias.DeviceInfo.MacName;
			// ias.DeviceEpointName = ias.DeviceInfo.DeviceName;
			// ias.ImgVersion = ias.DeviceInfo.ImgVersion;
			// ias.HwVersion = ias.DeviceInfo.HwVersion;
			// ias.IsOnline = ias.DeviceInfo.IsOnline;
			// ias.DriveCode = ias.DeviceInfo.DriveCode;
			// ias.IasDeviceType = ias.DeviceInfo.DeviceType;
			// ias.Profile = ias.DeviceInfo.Profile;
			// ias.ImgTypeId = ias.DeviceInfo.ImgTypeId;
			// ias.InClusterList = ias.DeviceInfo.InClusterList;
			// ias.OutClusterList = ias.DeviceInfo.OutClusterList;
			// ias.AttributeStatus = ias.DeviceInfo.AttributeStatus;
			// //ias.Save();
			// }
			// else
			// {
			// infoIAS.DeviceName = ias.DeviceInfo.MacName;
			// infoIAS.DeviceEpointName = ias.DeviceInfo.DeviceName;
			// infoIAS.DeviceEpointName = ias.DeviceInfo.DeviceName;
			// infoIAS.ImgVersion = ias.DeviceInfo.ImgVersion;
			// infoIAS.HwVersion = ias.DeviceInfo.HwVersion;
			// infoIAS.IsOnline = ias.DeviceInfo.IsOnline;
			// infoIAS.DriveCode = ias.DeviceInfo.DriveCode;
			// infoIAS.IasDeviceType = ias.DeviceInfo.DeviceType;
			// infoIAS.Profile = ias.DeviceInfo.Profile;
			// infoIAS.ImgTypeId = ias.DeviceInfo.ImgTypeId;
			// infoIAS.InClusterList = ias.DeviceInfo.InClusterList;
			// infoIAS.OutClusterList = ias.DeviceInfo.OutClusterList;
			// infoIAS.AttributeStatus = ias.DeviceInfo.AttributeStatus;
			// infoIAS.DeviceInfo = ias.DeviceInfo;
			// //ias.ReSave();
			// }
			// DebugPrintLog($"UI收到通知后的主题_{ topic}");
			// break;
			//case DeviceType.OtaDevice:
			//case DeviceType.OtaPanelDevice:
			//var ota = new OTADevice() { Time = jobject.Value<int>("Time"), DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			//ota.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceInfoData>(jobject["Data"].ToString());
			//if (ota.DeviceInfo == null)
			//{
			// return;
			//}
			//var infoOta = DeviceList.Find(obj => obj.DeviceID == ota.DeviceID && obj.DeviceAddr == ota.DeviceAddr && obj.DeviceEpoint == ota.DeviceEpoint);
			//if (infoOta == null)
			//{
			// DeviceList.Add(ota);
			// ota.DeviceName = ota.DeviceInfo.MacName;
			// ota.DeviceEpointName = ota.DeviceInfo.DeviceName;
			// ota.ImgVersion = ota.DeviceInfo.ImgVersion;
			// ota.HwVersion = ota.DeviceInfo.HwVersion;
			// ota.IsOnline = ota.DeviceInfo.IsOnline;
			// ota.DriveCode = ota.DeviceInfo.DriveCode;
			// ota.IasDeviceType = ota.DeviceInfo.DeviceType;
			// ota.Profile = ota.DeviceInfo.Profile;
			// ota.ImgTypeId = ota.DeviceInfo.ImgTypeId;
			// ota.InClusterList = ota.DeviceInfo.InClusterList;
			// ota.OutClusterList = ota.DeviceInfo.OutClusterList;
			// ota.AttributeStatus = ota.DeviceInfo.AttributeStatus;
			// //ota.Save();
			//}
			//else
			//{
			// infoOta.DeviceName = ota.DeviceInfo.MacName;
			// infoOta.DeviceEpointName = ota.DeviceInfo.DeviceName;
			// infoOta.DeviceEpointName = ota.DeviceInfo.DeviceName;
			// infoOta.ImgVersion = ota.DeviceInfo.ImgVersion;
			// infoOta.HwVersion = ota.DeviceInfo.HwVersion;
			// infoOta.IsOnline = ota.DeviceInfo.IsOnline;
			// infoOta.DriveCode = ota.DeviceInfo.DriveCode;
			// infoOta.IasDeviceType = ota.DeviceInfo.DeviceType;
			// infoOta.Profile = ota.DeviceInfo.Profile;
			// infoOta.ImgTypeId = ota.DeviceInfo.ImgTypeId;
			// infoOta.InClusterList = ota.DeviceInfo.InClusterList;
			// infoOta.OutClusterList = ota.DeviceInfo.OutClusterList;
			// infoOta.AttributeStatus = ota.DeviceInfo.AttributeStatus;
			// infoOta.DeviceInfo = ota.DeviceInfo;
			// //ota.ReSave();
			//}
			//DebugPrintLog($"UI收到通知后的主题_{ topic}");
			//break;
			//case DeviceType.Thermostat:
			//var thermostat = new ThermostatObj() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gateway.getGatewayBaseInfo.gwID };
			//thermostat.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ThermostatObj.DeviceInfoData>(jobject["Data"].ToString());
			//if (thermostat.DeviceInfo == null)
			//{
			// return;
			//}
			//var ther = gateway.DeviceList.Find(obj => obj.DeviceID == thermostat.DeviceID && obj.DeviceAddr == thermostat.DeviceAddr && obj.DeviceEpoint == thermostat.DeviceEpoint);
			//if (ther == null)
			//{
			// gateway.DeviceList.Add(thermostat);
			// thermostat.DeviceName = thermostat.DeviceInfo.DeviceName;
			// IO.LocalFileUtils.SaveDeviceInfo(thermostat, thermostat.DeviceEpoint.ToString());
			//}
			//else
			//{
			// ther.DeviceName = thermostat.DeviceInfo.DeviceName;
			// ther.DeviceInfo = thermostat.DeviceInfo;
			// ZigBee.IO.LocalFileUtils.SaveDeviceInfo(ther, ther.DeviceEpoint.ToString());
			//}
			//break;
			//case DeviceType.TemperatureSensor:
			//var temperatureSensor = new TemperatureSensor() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gateway.getGatewayBaseInfo.gwID };
			//temperatureSensor.DeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<TemperatureSensor.DeviceInfoData>(jobject["Data"].ToString());
			//if (temperatureSensor.DeviceInfo == null)
			//{
			// return;
			//}
			//var ts = gateway.DeviceList.Find(obj => obj.DeviceID == temperatureSensor.DeviceID && obj.DeviceAddr == temperatureSensor.DeviceAddr && obj.DeviceEpoint == temperatureSensor.DeviceEpoint);
			//if (ts == null)
			//{
			// gateway.DeviceList.Add(temperatureSensor);
			// temperatureSensor.DeviceName = temperatureSensor.DeviceInfo.DeviceName;
			// IO.LocalFileUtils.SaveDeviceInfo(temperatureSensor, temperatureSensor.DeviceEpoint.ToString());
			//}
			//else
			//{
			// ts.DeviceName = temperatureSensor.DeviceInfo.DeviceName;
			// ts.DeviceInfo = temperatureSensor.DeviceInfo;
			// IO.LocalFileUtils.SaveDeviceInfo(ts, ts.DeviceEpoint.ToString());
			//}
			//break;

			}
			}
			else if (topic == gatewayID + "/" + "DeviceInfoResponEnd")
			{
			canBreak = true;
			}
			};

			Actions += action;
			DebugPrintLog("DeviceInfo Actions 启动" + "_" + System.DateTime.Now.ToString());

			try
			{
			var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 93 } };
			Send("GetDeviceInfo", jObject.ToString());
			}
			catch { }

			while (canBreak == false && (DateTime.Now - dateTime).TotalMilliseconds < 6000)
			{
			await System.Threading.Tasks.Task.Delay(10);
			}

			Actions -= action;
			DebugPrintLog("DeviceInfo_Actions 退出" + System.DateTime.Now.ToString());
			return DeviceList;
			}));
			}
			#endregion

			#region 获取网关记录的设备属性状态
			/// <summary>
			///获取网关记录的设备属性状态
			/// </summary>
			public async System.Threading.Tasks.Task<GetStatusRecordAllInfo> GetStatusRecordAsync(string deviceAddr, int deviceEpoint)
			{
			return await System.Threading.Tasks.Task.Run(async () =>
			{
			GetStatusRecordAllInfo d = null;
			Action<string, string> action = (topic, message) =>
			{
			var gatewayID = topic.Split('/')[0];
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			d = new GetStatusRecordAllInfo { errorMessageBase = "网关错误回复，且数据是空" };
			}
			else
			{
			d = new GetStatusRecordAllInfo { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "GetStatusRecord_Respon")
			{
			var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			gatewayTemp.getStatusRecordInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GetStatusRecordInfo>(jobject["Data"].ToString());

			if (gatewayTemp.getStatusRecordInfo == null)
			{
			d = new GetStatusRecordAllInfo { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new GetStatusRecordAllInfo { getStatusRecordInfo = gatewayTemp.getStatusRecordInfo };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			}
			};
			Actions += action;
			DebugPrintLog("GetStatusRecord_Actions 启动" + System.DateTime.Now.ToString());
			try
			{
			var jObject = new JObject { { "DeviceAddr", deviceAddr }, { "Epoint", deviceEpoint }, { "Cluster_ID", 0 }, { "Command", 80 } };
			Send("GetStatusRecord", jObject.ToString());

			}
			catch { }

			var dateTime = DateTime.Now;
			while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
			{
			await System.Threading.Tasks.Task.Delay(10);
			if (d != null)
			{
			break;
			}
			}
			if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
			{
			d = new GetStatusRecordAllInfo { errorMessageBase = " 回复超时，请重新操作" };
			}
			Actions -= action;
			DebugPrintLog("GetStatusRecord_Actions 退出" + System.DateTime.Now.ToString());

			return d;
			});
			}
			#endregion

			#region 允许设备入网
			///<summary >
			/// 搜索新入网的设备（允许设备入网）
			@@ -1120,7 +539,6 @@
			{
			await System.Threading.Tasks.Task.Run(async () =>
			{
			CommonDevice commonDev = null;
			Action<string, string> action1 = (topic, message) => { };
			Actions += action1;
			var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 94 } };
			@@ -1175,8 +593,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1184,13 +601,12 @@
			}
			else
			{
			d = new GwLinuxResetResponData { errorMessageBase = ErrorMess(temp.Error) };
			d = new GwLinuxResetResponData { errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "GwLinuxReset_Respon")
			{
			var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"].ToString());

			if (result == null)
			@@ -1253,8 +669,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1262,13 +677,12 @@
			}
			else
			{
			d = new GwRebootResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new GwRebootResponAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "GwReboot_Respon")
			{
			var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"].ToString());

			if (result == null)
			@@ -1329,8 +743,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1338,22 +751,21 @@
			}
			else
			{
			d = new SaveNVFileResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new SaveNVFileResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbGwOperation/SaveNVFile_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.zbGwOperationSaveNVFileData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.SaveNVFileResponseData>(jobject["Data"].ToString());
			var zbGwOperationSaveNVFileData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.SaveNVFileResponseData>(jobject["Data"].ToString());

			if (gatewayTemp.zbGwOperationSaveNVFileData == null)
			if (zbGwOperationSaveNVFileData == null)
			{
			d = new SaveNVFileResponseAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new SaveNVFileResponseAllData { saveNVFileResponseData = gatewayTemp.zbGwOperationSaveNVFileData };
			d = new SaveNVFileResponseAllData { saveNVFileResponseData = zbGwOperationSaveNVFileData };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			}
			@@ -1407,8 +819,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1416,14 +827,13 @@
			}
			else
			{
			d = new RestoreNVAllDtta { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new RestoreNVAllDtta { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}


			if (topic == gatewayID + "/" + "ZbGwOperation/RestoreNV_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.RestoreNVDtta>(jobject["Data"].ToString());

			if (tempData == null)
			@@ -1487,21 +897,19 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());
			if (temp == null)
			{
			d = new GwGetChannelResponData { errorMessageBase = "网关错误回复，且数据是空" };
			}
			else
			{
			d = new GwGetChannelResponData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new GwGetChannelResponData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbGw/GetChannel_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			var channel = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Channel"].ToString());
			d = new GwGetChannelResponData { channel = channel };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			@@ -1555,8 +963,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1564,13 +971,12 @@
			}
			else
			{
			d = new ChangeChannelResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new ChangeChannelResponAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbGw/ChangeChannel_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			var tempInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<ChangeChannelResponData>(jobject["Data"].ToString());

			if (tempInfo == null)
			@@ -1649,8 +1055,11 @@
			/// </summary>
			public async System.Threading.Tasks.Task<Panel.PanelSwitchLevelInfo> ClientDataPassthroughBytesAsync(string deviceAddr, int devicePoint, long dataLength, byte[] passData)
			{
			var myDevice = Shared.Common.LocalDevice.Current.GetDevice(deviceAddr, devicePoint);

			Panel.PanelSwitchLevelInfo result = null;
			if (Gateway == null)

			if (myDevice.Gateway == null)
			{
			result = new Panel.PanelSwitchLevelInfo { errorMessageBase = "当前没有网关" };
			return result;
			@@ -1664,8 +1073,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = Gateway.getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1674,24 +1082,23 @@

			else
			{
			result = new Panel.PanelSwitchLevelInfo { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			result = new Panel.PanelSwitchLevelInfo { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbDataPassthrough")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<ClientDataPassthroughResponseData>(jobject["Data"].ToString());
			var clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ClientDataPassthroughResponseData>(jobject["Data"].ToString());

			if (gatewayTemp.clientDataPassthroughResponseData == null)
			if (clientDataPassthroughResponseData == null)
			{
			result = new Panel.PanelSwitchLevelInfo { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			if (gatewayTemp.clientDataPassthroughResponseData?.PassData != null)
			if (clientDataPassthroughResponseData?.PassData != null)
			{
			var data = gatewayTemp.clientDataPassthroughResponseData.PassData;
			var data = clientDataPassthroughResponseData.PassData;
			if (data.Length == 14)
			{
			var command = data[4].ToString() + data[5].ToString() + data[2].ToString() + data[3].ToString();
			@@ -1708,7 +1115,7 @@
			}
			};

			Gateway.Actions += action;
			myDevice.Gateway.Actions += action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 启动" + System.DateTime.Now.ToString());

			try
			@@ -1749,7 +1156,7 @@
			{
			result = new Panel.PanelSwitchLevelInfo { errorMessageBase = " 回复超时，请重新操作" };
			}
			Gateway.Actions -= action;
			myDevice.Gateway.Actions -= action;
			System.Console.WriteLine("ClientDataPassthrough_Actions 退出" + System.DateTime.Now.ToString());

			return result;
			@@ -1778,8 +1185,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1787,24 +1193,16 @@
			}
			else
			{
			d = new PassthroughAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new PassthroughAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbDataPassthrough")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<string>(jobject["Data"].ToString());

			if (gatewayTemp.getGwVersion == null)
			{
			d = new PassthroughAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new PassthroughAllData { passData = temp };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			d = new PassthroughAllData { passData = temp };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			};
			Actions += action;
			@@ -1857,8 +1255,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = this.getGatewayBaseInfo?.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1867,13 +1264,12 @@

			else
			{
			d = new LinuxUpgradeAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new LinuxUpgradeAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbGwOperation/LinuxUpgrade_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
			d = new LinuxUpgradeAllData { Result = result };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			@@ -1934,8 +1330,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -1944,22 +1339,21 @@

			else
			{
			d = new ZbGwOperationUpgradeAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new ZbGwOperationUpgradeAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "ZbGwOperation/Upgrade_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.zbGwOperationUpgradeData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ZbGwOperationUpgradeData>(jobject["Data"].ToString());
			zbGwOperationUpgradeData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ZbGwOperationUpgradeData>(jobject["Data"].ToString());

			if (gatewayTemp.zbGwOperationUpgradeData == null)
			if (zbGwOperationUpgradeData == null)
			{
			d = new ZbGwOperationUpgradeAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new ZbGwOperationUpgradeAllData { bGwOperationUpgradeData = gatewayTemp.zbGwOperationUpgradeData };
			d = new ZbGwOperationUpgradeAllData { bGwOperationUpgradeData = zbGwOperationUpgradeData };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			}
			@@ -2005,11 +1399,11 @@
			/// <returns>The file async.</returns>
			/// <param name="distributedMark">Distributed mark:固件唯一标识</param>
			/// <param name="imageName">Image name:固件版本</param>
			public async System.Threading.Tasks.Task<DownloadFileResponAllData> DownloadFileAsync(string distributedMark, string imageName)
			public async System.Threading.Tasks.Task<CommonDevice.DownloadFileResponAllData> DownloadFileAsync(string distributedMark, string imageName)
			{
			return await System.Threading.Tasks.Task.Run(async () =>
			{
			DownloadFileResponAllData d = null; ;
			CommonDevice.DownloadFileResponAllData d = null; ;
			Action<string, string> action = (topic, message) =>
			{
			var gatewayID = topic.Split('/')[0];
			@@ -2017,32 +1411,30 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			d = new DownloadFileResponAllData { errorMessageBase = "网关错误回复，且数据是空" };
			d = new CommonDevice.DownloadFileResponAllData { errorMessageBase = "网关错误回复，且数据是空" };
			}

			else
			{
			d = new DownloadFileResponAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new CommonDevice.DownloadFileResponAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "DownloadFile_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.downloadFileResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DownloadFileResponData>(jobject["Data"].ToString());
			var downloadFileResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.DownloadFileResponData>(jobject["Data"].ToString());

			if (gatewayTemp.downloadFileResponData == null)
			if (downloadFileResponData == null)
			{
			d = new DownloadFileResponAllData { errorMessageBase = "网关返回的数据为空" };
			d = new CommonDevice.DownloadFileResponAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new DownloadFileResponAllData { downloadFileResponData = gatewayTemp.downloadFileResponData };
			d = new CommonDevice.DownloadFileResponAllData { downloadFileResponData = downloadFileResponData };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			}
			@@ -2073,7 +1465,7 @@
			}
			if ((DateTime.Now - dateTime).TotalMilliseconds > 30 * 1000)
			{
			d = new DownloadFileResponAllData { errorMessageBase = " 回复超时，请重新操作" };
			d = new CommonDevice.DownloadFileResponAllData { errorMessageBase = " 回复超时，请重新操作" };

			}
			Actions -= action;
			@@ -2100,8 +1492,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2110,22 +1501,21 @@

			else
			{
			d = new CheckVDDriveCodeResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new CheckVDDriveCodeResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "VirtualDrive/CatDriveCode_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.vDriveDriveCodeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VDriveDriveCodeResponData>(jobject["Data"].ToString());
			var vDriveDriveCodeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VDriveDriveCodeResponData>(jobject["Data"].ToString());

			if (gatewayTemp.vDriveDriveCodeResponData == null)
			if (vDriveDriveCodeResponData == null)
			{
			d = new CheckVDDriveCodeResponseAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new CheckVDDriveCodeResponseAllData { vDriveDriveCodeResponData = gatewayTemp.vDriveDriveCodeResponData };
			d = new CheckVDDriveCodeResponseAllData { vDriveDriveCodeResponData = vDriveDriveCodeResponData };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			}
			}
			@@ -2180,8 +1570,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2190,22 +1579,21 @@

			else
			{
			d = new VirtualDriveUpgradeResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			d = new VirtualDriveUpgradeResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "VirtualDrive/Upgrade_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.virtualDriveUpgradeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VirtualDriveUpgradeResponData>(jobject["Data"].ToString());
			virtualDriveUpgradeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VirtualDriveUpgradeResponData>(jobject["Data"].ToString());

			if (gatewayTemp.virtualDriveUpgradeResponData == null)
			if (virtualDriveUpgradeResponData == null)
			{
			d = new VirtualDriveUpgradeResponseAllData { errorMessageBase = "网关返回的数据为空" };
			}
			else
			{
			d = new VirtualDriveUpgradeResponseAllData { virtualDriveUpgradeResponData = gatewayTemp.virtualDriveUpgradeResponData };
			d = new VirtualDriveUpgradeResponseAllData { virtualDriveUpgradeResponData = virtualDriveUpgradeResponData };
			DebugPrintLog($"UI收到通知后的主题_{topic}");
			}
			}
			@@ -2243,115 +1631,6 @@

			#endregion

			//#region 上传私有数据
			//private bool backupSuccess = false;
			/// <summary>
			/// 上传私有数据
			/// </summary>
			/// <returns>The data to gateway.</returns>
			/// <param name="fileName">File name.</param>
			/// <param name="dev">Dev.</param>
			//public async System.Threading.Tasks.Task<SendFileResponseAllData> BackupDataToGateway(string fileName, CommonDevice dev)
			//{
			// return await System.Threading.Tasks.Task.Run(async () =>
			// {
			// SendFileResponseAllData backUpStatus = null;
			// var file = await System.Threading.Tasks.Task.Factory.StartNew(() => Newtonsoft.Json.JsonConvert.SerializeObject(dev));
			// var data = System.Text.Encoding.UTF8.GetBytes(file);
			// //网关中创建存储数据的文件
			// var saveFileName = await dev.Gateway.CreateFileAsync(fileName);
			// if (saveFileName != null && saveFileName.Result == 0)
			// {
			// backupSuccess = false;
			// //上传数据到网关
			// var saveData = await dev.Gateway.SendFileAsync(data);
			// if (saveData != null)
			// {
			// backUpStatus = new SendFileResponseAllData { Result = saveData.Result };
			// }
			// }
			// var dateTime = DateTime.Now;
			// while ((DateTime.Now - dateTime).TotalMilliseconds < WaitReceiveDataTime)
			// {
			// await System.Threading.Tasks.Task.Delay(10);
			// if (backUpStatus != null)
			// {
			// break;
			// }
			// }
			// if ((DateTime.Now - dateTime).TotalMilliseconds > WaitReceiveDataTime)
			// {
			// backUpStatus = new SendFileResponseAllData { errorMessageBase = " 回复超时，请重新操作" };
			// };
			// return backUpStatus;
			// });
			//}

			/// <summary>
			/// 下载私有数据
			/// </summary>
			/// <returns>The data from gateway.</returns>
			/// <param name="fileName">File name.</param>
			/// <param name="dev">Dev.</param>
			//public async System.Threading.Tasks.Task<System.Collections.Generic.List<byte>> DownloadDataFromGateway(string fileName, CommonDevice dev)
			//{
			// return await System.Threading.Tasks.Task.Run(async () =>
			// {
			// byteSource.Clear();
			// System.Collections.Generic.List<byte> backUpData = null;
			// var dateTime = DateTime.Now;
			// //获取当前文件的具体信息
			// //var getFileSize = await currentKey.Gateway.GetCurrentFileInfoAsync(fileName);
			// //下载文件
			// var saveFileName = await dev.Gateway.SetDownloadFileAsync(fileName);
			// Action<string, byte[]> action = (topic, dataContent) =>
			// {
			// if (topic.Split('/')[0] + "/" + topic.Split('/')[1] + "/" + topic.Split('/')[2] == topic.Split('/')[0] + "/" + "FileTransfer/DownloadFile")
			// {
			// dateTime = DateTime.Now;
			// byte[] fileBytes = dataContent;
			// if (fileBytes[5] != 1)
			// {
			// if (fileBytes.Length == 2056)
			// {
			// var tempBytes = new byte[2048];
			// System.Array.Copy(fileBytes, 8, tempBytes, 0, 2048);
			// byteSource.AddRange(tempBytes);
			// }
			// else
			// {
			// var tempBytes = new byte[fileBytes.Length - 8];
			// System.Array.Copy(fileBytes, 8, tempBytes, 0, tempBytes.Length);
			// byteSource.AddRange(tempBytes);
			// }
			// }
			// else
			// {
			// var tempBytes = new byte[fileBytes.Length - 8];
			// System.Array.Copy(fileBytes, 8, tempBytes, 0, tempBytes.Length);
			// byteSource.AddRange(tempBytes);

			// if (byteSource != null )
			// {
			// backUpData = byteSource;
			// }
			// }

			// }
			// };
			// dev.Gateway.FileContentAction += action;

			// while ((DateTime.Now - dateTime).TotalMilliseconds < 2000)
			// {
			// await System.Threading.Tasks.Task.Delay(10);
			// }
			// dev.Gateway.FileContentAction -= action;
			// return byteSource;
			// });
			//}

			//#endregion

			#region 客户端上传文件到网关.
			/// <summary>
			/// 客户端上传文件到网关
			@@ -2372,8 +1651,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2381,13 +1659,12 @@
			}
			else
			{
			dataRes = new CreateFileResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			dataRes = new CreateFileResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "FileTransfer/CreateFile_Respon")
			{
			var security = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
			dataRes = new CreateFileResponseAllData { Result = result };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			@@ -2451,7 +1728,6 @@

			if (topic == gatewayID + "/FileTransfer/SendFile_Respon")
			{
			var gateway = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
			dataRes = new SendFileResponseAllData { Result = result };
			if (result == 0)
			@@ -2541,8 +1817,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2550,13 +1825,12 @@
			}
			else
			{
			dataRes = new FileTransferLsDiResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			dataRes = new FileTransferLsDiResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "FileTransfer/lsDir_Respon")
			{
			var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var resultlsDir = Newtonsoft.Json.JsonConvert.DeserializeObject<FileTransferLsDiResponseData>(jobject["Data"].ToString());
			if (resultlsDir != null)
			{
			@@ -2619,8 +1893,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2628,13 +1901,12 @@
			}
			else
			{
			dataRes = new FileTransferGetFileInfoResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			dataRes = new FileTransferGetFileInfoResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "FileTransfer/GetFileInfo_Respon")
			{
			var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var resultlsDir = Newtonsoft.Json.JsonConvert.DeserializeObject<FileTransferGetFileInfoResponseData>(jobject["Data"].ToString());
			if (resultlsDir != null)
			{
			@@ -2699,8 +1971,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2708,13 +1979,12 @@
			}
			else
			{
			dataRes = new SetDownloadFileResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			dataRes = new SetDownloadFileResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "FileTransfer/SetDownloadFile_Respon")
			{
			var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = CurrentGateWayId };
			var tempData = Newtonsoft.Json.JsonConvert.DeserializeObject<SetDownloadFileResponseData>(jobject["Data"].ToString());
			if (tempData != null)
			{
			@@ -2722,7 +1992,7 @@
			var tempDa = new SetDownloadFileResponseData();
			if (tempData.Result == 0)
			{
			ZbGateway.byteSource.Clear();
			this.byteSource.Clear();
			}
			tempDa.Result = tempData.Result;
			dataRes.setDownloadFileResponseData = tempDa;
			@@ -2770,7 +2040,7 @@
			#endregion

			#region 网关发送文件流到客户端
			static System.Collections.Generic.List<byte> byteSource = new System.Collections.Generic.List<byte>();
			private List<byte> byteSource = new List<byte>();
			///<summary >
			/// 下载文件中的数据
			/// </summary>
			@@ -2833,8 +2103,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2842,13 +2111,12 @@
			}
			else
			{
			dataRes = new DelFileOrDirResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			dataRes = new DelFileOrDirResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "FileTransfer/DelFileOrDir_Respon")
			{
			var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = CurrentGateWayId };
			var resultDelFileOrDir = Newtonsoft.Json.JsonConvert.DeserializeObject<DelFileOrDirResponseData>(jobject["Data"].ToString());
			if (resultDelFileOrDir != null)
			{
			@@ -2912,8 +2180,7 @@

			if (topic == gatewayID + "/" + "Error_Respon")
			{
			var gatewayTemp = new ZbGateway() { Time = jobject.Value<int>("Time"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = getGatewayBaseInfo.gwID };
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<ErrorResponData>(jobject["Data"].ToString());
			var temp = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ErrorResponData>(jobject["Data"].ToString());

			if (temp == null)
			{
			@@ -2921,13 +2188,12 @@
			}
			else
			{
			dataRes = new CreateDirResponseAllData { errorResponData = temp, errorMessageBase = ErrorMess(temp.Error) };
			dataRes = new CreateDirResponseAllData { errorResponData = temp, errorMessageBase = CommonDevice.ErrorMess(temp.Error) };
			}
			}

			if (topic == gatewayID + "/" + "FileTransfer/CreateDir_Respon")
			{
			var lsDir = new ZbGateway() { DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = CurrentGateWayId };
			var resultCreateDir = Newtonsoft.Json.JsonConvert.DeserializeObject<CreateDirResponseData>(jobject["Data"].ToString());
			if (resultCreateDir != null)
			{
			@@ -2988,7 +2254,6 @@
			if (topic == gatewayID + "/" + "SendAESKey_Respon")
			{
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			var result = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["Result"].ToString());
			sendKeyResponData = new SendKeyResponData { Result = result };
			DebugPrintLog($"UI收到通知后的主题_{ topic}");
			@@ -3033,23 +2298,7 @@
			/// <para>进入当前界面时要添加</para>
			/// <para>退出当前界面时要关闭</para>
			/// </summary>
			public static readonly System.Collections.Generic.List<IStatus> StatusList = new System.Collections.Generic.List<IStatus>();

			/// <summary>
			/// 设备状态更新
			/// </summary>
			/// <param name="commonDevice">Common device.</param>
			public static void UpdateDeviceStatus(CommonDevice commonDevice)
			{
			if (commonDevice == null)
			{
			return;
			}
			for (int i = 0; i < StatusList.Count; i++)
			{
			StatusList[i].Changed(commonDevice);
			}
			}
			public static readonly List<IStatus> StatusList = new List<IStatus>();

			/// <summary>
			/// 设备信息变化
			@@ -3077,260 +2326,438 @@
			/// <summary>
			/// 局域网的MQTT
			/// </summary>
			IMqttClient mqttClient;
			IMqttClient localMqttClient = new MqttFactory().CreateMqttClient();
			bool localMqttIsConnecting;
			[Newtonsoft.Json.JsonIgnore]
			public bool localIsConnected;
			/// <summary>
			/// 手机标识
			/// </summary>
			static Guid currentGuid = Guid.NewGuid();
			/// <summary>
			/// 局域网的MQTT是否正在连接
			/// </summary>
			object mqttIsConnecting = false.ToString();

			public async System.Threading.Tasks.Task SendAesKey()
			{
			if (PubKey != null)
			{
			IsEncry = false;
			var rsaString = ZigBee.Common.SecuritySet.RSAEncrypt(PubKey, Password);
			var resultVerityfy = await SendAesKeyAsync(rsaString);
			if (resultVerityfy == null)
			{
			resultVerityfy = await SendAesKeyAsync(rsaString);
			}

			if (resultVerityfy != null && resultVerityfy.Result == 0)
			{
			IsEncry = true;
			}
			}
			}

			public async System.Threading.Tasks.Task StartLocalMqtt(string brokerName)
			{
			{
			if (localMqttIsConnecting
			\|\| !Shared.Common.Config.Instance.IsLogin
			\|\| Shared.Common.Config.Instance.HomeId == ""
			\|\| localIsConnected)
			{
			return;
			}
			await System.Threading.Tasks.Task.Factory.StartNew(async () =>
			{
			try
			{
			lock (mqttIsConnecting)
			lock (localMqttClient)
			{
			if (mqttIsConnecting.ToString() == true.ToString() \|\| brokerName == null)
			{
			return;
			}
			mqttIsConnecting = true.ToString();
			//表示后面将进行连接
			localMqttIsConnecting = true;

			if (mqttClient == null)
			//(3)当[连接Mqtt成功后]或者[Mqtt转发数据给网关成功后],处理接收到数据包响应时在mqttClient_ApplicationMessageReceived这个方法处理
			if (localMqttClient.ApplicationMessageReceivedHandler == null)
			{
			//(2)创建Mqtt客户端
			mqttClient = new MqttClientFactory().CreateMqttClient();
			//(3)当[连接Mqtt成功后]或者[Mqtt转发数据给网关成功后],处理接收到数据包响应时在mqttClient_ApplicationMessageReceived这个方法处理
			mqttClient.ApplicationMessageReceived += (sender, e) =>
			{
			if (mqttClient == null \|\| !mqttClient.IsConnected)
			localMqttClient.UseApplicationMessageReceivedHandler((e) =>
			{
			return;
			}
			mqttClient_MqttMsgPublishReceived(sender, e);
			};
			mqttClient.Disconnected += (sender, e) =>
			{
			IsEncry = false;
			#if DEBUG
			DebugPrintLog($" 本地连接断开_网关IP:{brokerName}_网关是否加:{IsEncry}_{System.DateTime.Now.ToString()}");
			#endif
			};
			mqttClient.Connected += async (sender, e) =>
			if (!localMqttClient.IsConnected)
			{
			return;
			}
			mqttClient_MqttMsgPublishReceived(e);
			});
			}

			if (localMqttClient.DisconnectedHandler == null)
			{
			localMqttClient.UseDisconnectedHandler(async (e) =>
			{
			#if DEBUG
			DebugPrintLog($" 本地连接成功_网关IP:{brokerName}_网关是否加:{IsEncry}_当前密码:{Password}_{System.DateTime.Now.ToString()}");
			#endif
			DebugPrintLog($" 本地连接断开_网关IP:{brokerName}_网关是否加:{IsEncry}");
			await DisConnectLocalMqttClient("StartLocalMqtt.DisconnectedHandler");
			//await StartLocalMqtt("ReConnect");
			});
			}
			if (localMqttClient.ConnectedHandler == null)
			{
			localMqttClient.UseConnectedHandler(async (e) =>
			{
			DebugPrintLog($" 本地连接成功_网关IP:{brokerName}_网关是否加:{IsEncry}_当前密码:{Password}");
			IsRemote = false;
			});
			}

			if (PubKey != null)
			var dateTime = DateTime.Now;

			new System.Threading.Thread(async () =>
			{
			try
			{
			if (localMqttClient.Options == null)
			{
			var rsaString = ZigBee.Common.SecuritySet.RSAEncrypt(PubKey, Password);
			var resultVerityfy = await SendAesKeyAsync(rsaString);
			if (resultVerityfy == null)
			{
			resultVerityfy = await SendAesKeyAsync(rsaString);
			}
			if (resultVerityfy != null && resultVerityfy.Result == 0)
			{
			IsEncry = true;
			}
			var options = new MQTTnet.Client.Options.MqttClientOptionsBuilder()//MQTT连接参数填充
			.WithClientId(currentGuid.ToString())//客户端ID
			.WithTcpServer(brokerName, 1883)//TCP服务端 1883 ，即MQTT服务端
			.WithCredentials("", "")//"", "")//凭证帐号密码
			.WithCommunicationTimeout(new TimeSpan(0, 0, 60)) //重连超时时间，默认5s
			.WithKeepAlivePeriod(new TimeSpan(0, 0, 15)) //保持连接时间，默认5s，心跳包
			.Build();//
			await localMqttClient.ConnectAsync(options);
			}
			Shared.Phone.UserCenter.HdlGatewayLogic.Current.CheckGatewayByConnectChanged(Shared.Phone.UserCenter.GatewayConnectMode.WIFI);
			System.Console.WriteLine($"当前是网关Wi-Fi在通讯_{System.DateTime.Now.ToString()}");

			};
			}

			if (RemoteMqttClient != null && RemoteMqttClient.IsConnected == true)
			{
			RemoteMqttClient?.DisconnectAsync();
			System.Console.WriteLine($"收到局域网网关，远程连接主动断开_{System.DateTime.Now.ToString()}");
			RemoteMqttClient = null;
			}

			if (mqttClient.IsConnected)
			{
			return;
			}
			}
			//(1)连接到Mqtt客户端连接参数
			var connectCloudMqttClientOptions = new MqttClientTcpOptions
			{
			Server = brokerName, //ip地址
			ClientId = currentGuid.ToString(),
			CleanSession = true,// 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
			KeepAlivePeriod = new TimeSpan(0, 5, 0),//设置心跳时间（最大值，2^16-1 = 65535秒 = 18小时。最小值可以为0，表示客户端不断开。一般设为几分钟，比如微信心跳周期为300秒。）
			DefaultCommunicationTimeout = new TimeSpan(0, 0, 100),//设置超时时间
			};
			await mqttClient.ConnectAsync(connectCloudMqttClientOptions);
			else
			{
			await DisConnectLocalMqttClient("StartLocalMqtt");
			await localMqttClient.ReconnectAsync();
			}
			localIsConnected = true;
			await SendAesKey();
			}
			catch { }
			dateTime = DateTime.MinValue;
			})
			{ IsBackground = true }.Start();
			while (dateTime != DateTime.MinValue)
			{
			System.Threading.Thread.Sleep(100);
			}
			}
			}
			catch (Exception ex)
			{
			#if DEBUG
			DebugPrintLog($"局域网通讯连接出异常:{ex.Message}");
			#endif
			}
			finally
			{
			mqttIsConnecting = false.ToString();
			localMqttIsConnecting = false;
			}
			});
			}

			/// <summary>
			/// 当前有帐号下所有的网关列表及信息
			/// </summary>
			public static Dictionary<string, Shared.Phone.UserCenter.GatewayResult> GateWayBaseInfomations = new Dictionary<string, Shared.Phone.UserCenter.GatewayResult> { };
			/// <summary>
			/// 获取当前帐号所有的网关信息
			/// </summary>
			/// <returns></returns>
			static async System.Threading.Tasks.Task initGateWayBaseInfomation()
			{
			if (AllowRemoteCtrl == false)
			{
			//没有远程连接的权限
			return;
			}
			string loginToken = Config.Instance.Token;
			if (Config.Instance.Home.IsOthreShare == true)
			{
			//获取成员的特殊Token
			var pra = new
			{
			CommonPage.RequestVersion,
			LoginAccessToken = Config.Instance.Token,
			MainAccountId = Config.Instance.Home.MainUserDistributedMark,
			SharedHid = Config.Instance.Home.Id
			};

			var listNotShow = new List<string>() { "NotSetAgain" };
			var resultData = await Shared.Phone.UserCenter.UserCenterLogic.GetByteResponseDataByRequestHttps("App/GetSharedHomeApiControl", false, pra, listNotShow);
			if (resultData == null)
			{
			return;
			}
			var revertObj = Newtonsoft.Json.JsonConvert.DeserializeObject<Shared.Common.ResponseEntity.ResponsePack>(Encoding.UTF8.GetString(resultData));
			//分享链接
			var info = Newtonsoft.Json.JsonConvert.DeserializeObject<Shared.Phone.UserCenter.MemberAdministratorResult>(revertObj.ResponseData.ToString());
			loginToken = info.RequestToken;
			}

			try
			{
			//设置访问接口的参数
			var pra2 = new Shared.Phone.UserCenter.GetGatewayPra();
			pra2.IsOtherAccountCtrl = Config.Instance.Home.IsOthreShare;
			pra2.ReqDto.PageSetting.Page = 1;
			pra2.ReqDto.PageSetting.PageSize = 20;
			pra2.ReqDto.LoginAccessToken = loginToken;
			var bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(pra2));

			var result = await CommonPage.Instance.DoRequestZigbeeHttpsInterface("https://global.hdlcontrol.com/HangZhouHdlCloudApi/App/GetSingleHomeGatewayPagger", bytes, loginToken);
			if (result != null)
			{
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(Encoding.UTF8.GetString(result));

			var statuCode = jobject["StateCode"].ToString();
			if (statuCode != "Success")
			{
			//序列化对象
			var requestJson = Newtonsoft.Json.JsonConvert.SerializeObject(pra2);
			//Log出力
			string errorMsg = "接口访问失败★：App/GetSingleHomeGatewayPagger " + statuCode + "\r\n";
			errorMsg += "参数：\r\n" + requestJson;
			Shared.Phone.UserCenter.HdlLogLogic.Current.WriteLog(-1, errorMsg);
			return;
			}

			var responseData = jobject["ResponseData"];
			if (responseData != null)
			{
			if (responseData["PageData"] != null)
			{
			var list = JArray.Parse(responseData["PageData"].ToString());
			foreach (var v in list)
			{
			GateWayBaseInfomations[v["GatewayUniqueId"].ToString()] = new Shared.Phone.UserCenter.GatewayResult { AesKey = v["AesKey"].ToString(), MacMark = v["MacMark"].ToString(), MqttOnlineStatus = bool.Parse(v["MqttOnlineStatus"].ToString()) };
			//if (RemoteMqttClient.IsConnected)
			{
			await RemoteMqttClient.SubscribeAsync($"/ZigbeeGateWayToClient/{v["MacMark"].ToString()}/#", MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce);
			}
			}
			}
			}
			}
			}
			catch (Exception ex)
			{
			Shared.Phone.UserCenter.HdlLogLogic.Current.WriteLog(ex);
			}
			}

			/// <summary>
			/// 外网的MQTT是否正在连接
			/// </summary>
			static bool remoteMqttIsConnecting; static bool IsLoginAgain;
			static bool remoteMqttIsConnecting;

			/// <summary>
			/// 远程MqttClient
			/// </summary>
			public static IMqttClient RemoteMqttClient;
			private int IsLogin = 0;
			[Newtonsoft.Json.JsonIgnore]
			static Action actionTemp;
			public static IMqttClient RemoteMqttClient = new MqttFactory().CreateMqttClient();
			static bool remoteIsConnected;

			/// <summary>
			/// 启动远程Mqtt
			/// </summary>
			/// <returns>The start.</returns>
			/// <param name="brokerName">Broker name.</param>
			public static async System.Threading.Tasks.Task StartCloudMqtt()
			{
			public static async System.Threading.Tasks.Task StartRemoteMqtt()
			{
			//追加：没有远程连接的权限
			if (AllowRemoteCtrl == false
			\|\| remoteMqttIsConnecting
			\|\| !Shared.Common.Config.Instance.IsLogin
			\|\| Shared.Common.Config.Instance.HomeId == ""
			\|\| remoteIsConnected)
			{
			return;
			}
			await System.Threading.Tasks.Task.Factory.StartNew(async () =>
			{
			try
			{
			if (remoteMqttIsConnecting \|\| Shared.Common.Config.Instance.HomeId == "")
			lock (RemoteMqttClient)
			{
			return;
			}
			remoteMqttIsConnecting = true;
			//表示后面将进行连接
			remoteMqttIsConnecting = true;

			var url = Shared.Common.Config.Instance.ZigbeeMqttBrokerLoadSubDomain;//.Replace("6688","6689");
			if (string.IsNullOrEmpty(url) \|\| !url.StartsWith("tcp://") \|\| url.Split(':').Length != 3)
			{
			remoteMqttIsConnecting = false;
			return;
			}
			if (RemoteMqttClient == null)
			{
			//(2)创建Mqtt客户端
			RemoteMqttClient = new MqttClientFactory().CreateMqttClient();
			#region 初始化远程Mqtt
			//(3)当[连接云端的Mqtt成功后]或者[以及后面App通过云端Mqtt转发数据给网关成功后],处理接收到云端数据包响应时在mqttServerClient_ApplicationMessageReceived这个方法处理
			RemoteMqttClient.ApplicationMessageReceived += (sender, e) =>
			if (RemoteMqttClient.ApplicationMessageReceivedHandler == null)
			{
			if (RemoteMqttClient == null \|\| !RemoteMqttClient.IsConnected)
			{
			return;
			}
			mqttRemoteClient_MqttMsgPublishReceived(sender, e);
			};
			RemoteMqttClient.Disconnected += (sender, e) =>
			{
			#if DEBUG
			DebugPrintLog($"远程连接断开_{System.DateTime.Now.ToString()}");
			#endif
			};
			RemoteMqttClient.Connected += async (sender, e) =>
			{
			#if DEBUG
			DebugPrintLog($"远程连接成功_{System.DateTime.Now.ToString()}");
			#endif
			Shared.Phone.UserCenter.HdlGatewayLogic.Current.CheckGatewayByConnectChanged(Shared.Phone.UserCenter.GatewayConnectMode.Remote);
			//没有主网关时主动读取，获取主网关信息
			var gateWayList = GateWayList.FindAll(obj => obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId);
			if (gateWayList.Find(obj => obj.getGatewayBaseInfo.IsMainGateWay == true) == null)
			RemoteMqttClient.UseApplicationMessageReceivedHandler((e) =>
			{
			if (gateWayList.Count == 1)
			//这里是特殊的主题
			if (e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.ConnEmqClientId + "/Push/NotifySqueeze"//踢人下线
			\|\| e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Guid + "/Push/Deleted"//分享删除
			\|\| e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Guid + "/Push/DeletedShareData"//分享删除
			\|\| e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Guid + "/Push/Update"//成员权限变更
			\|\| e.ApplicationMessage.Topic == "/ZigbeeGateWayToClient/" + Config.Instance.Home.Id + "_" + Config.Instance.Guid + "/PrimaryUserDelYou")//子账号被删除
			{
			gateWayList[0].getGatewayBaseInfo.IsMainGateWay = true;
			mqttRemoteClient_MqttMsgPublishReceived(e);
			return;
			}
			else
			if (!RemoteMqttClient.IsConnected \|\| !IsRemote)
			{
			for (int i = 0; i < gateWayList.Count; i++)
			return;
			}
			mqttRemoteClient_MqttMsgPublishReceived(e);
			});
			}

			if (RemoteMqttClient.DisconnectedHandler == null)
			{
			RemoteMqttClient.UseDisconnectedHandler(async (e) =>
			{
			DebugPrintLog($"远程连接断开");
			await DisConnectRemoteMqttClient("StartRemoteMqtt.DisconnectedHandler");
			//await StartRemoteMqtt();
			});
			}
			if (RemoteMqttClient.ConnectedHandler == null)
			{
			RemoteMqttClient.UseConnectedHandler(async (e) =>
			{
			DebugPrintLog($"远程连接成功");

			if (Config.Instance.Home.IsOthreShare == true)
			{
			//订阅一个成员被删除的主题
			string myGuid = Config.Instance.Guid;
			await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + myGuid + "/Push/Deleted");
			//订阅一个分享数据已经变更的主题
			await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + myGuid + "/Push/DeletedShareData");
			//订阅一个子账号被删除的主题
			await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + Config.Instance.Home.Id + "_" + myGuid + "/PrimaryUserDelYou");
			//订阅一个成员权限已经变更的主题
			await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + myGuid + "/Push/Update");
			}
			//订阅一个挤下线的主题
			await RemoteMqttClient.SubscribeAsync("/ZigbeeGateWayToClient/" + Config.Instance.ConnEmqClientId + "/Push/NotifySqueeze");

			await initGateWayBaseInfomation();

			//没有主网关时主动读取，获取主网关信息
			var gateWayList = GateWayList.FindAll(obj => obj.HomeId == Shared.Common.Config.Instance.HomeId);
			if (gateWayList.Find(obj => obj.IsMainGateWay == true) == null)
			{
			if (gateWayList.Count == 1)
			{
			var gateWay = gateWayList[i];
			var info = await gateWay.GetZbGwInfoAsync();
			if (info == null \|\| info.getGwData == null)
			gateWayList[0].IsMainGateWay = true;
			}
			else
			{
			for (int i = 0; i < gateWayList.Count; i++)
			{
			continue;
			}
			if (info.getGwData.IsDominant == 1)
			{
			gateWay.getGatewayBaseInfo.IsMainGateWay = true;
			for (int j = i + 1; j < gateWayList.Count; j++)
			var gateWay = gateWayList[i];
			var info = await gateWay.GetZbGwInfoAsync();
			if (info == null \|\| info.getGwData == null)
			{
			gateWayList[j].getGatewayBaseInfo.IsMainGateWay = false;
			continue;
			}
			break;
			if (info.getGwData.IsDominant == 1)
			{
			for (int j = 0; j < gateWayList.Count; j++)
			{
			if (gateWayList[i].GwId == info.getGwData.GwId)
			{
			gateWayList[i].IsMainGateWay = true;
			}
			else
			{
			gateWayList[i].IsMainGateWay = false;
			}
			}
			break;
			}
			}
			}
			}
			}
			};
			}

			if (RemoteMqttClient.IsConnected)
			{
			//当网关的连接方式改变时,检测网关,然后显示特效(可重复调用)
			return;
			}
			for (int i = 0; i < GateWayList.Count; i++)
			{
			var gateWay = GateWayList[i];
			try
			{
			gateWay.IsVirtual = true;
			await gateWay.DisConnect("本地搜素不到网关，准备调用远程，关闭当前局域网中所有网关");
			});
			}
			catch { }
			}
			//断开后重新链接需要重新登录获取连接的密码
			var tempResult = await Shared.Phone.UserView.HomePage.Instance.LoginByPWDAsync(Shared.Common.Config.Instance.Account, Shared.Common.Config.Instance.Password);
			if (tempResult != 1)
			{
			#if DEBUG
			DebugPrintLog($"重新连接远程通讯失败，因为获取新的KEY失败");
			#endif
			return;
			#endregion
			}

			//还有种情况是同一个ID 有多个设备用这个id连接（会导致中断）
			string clientId = Shared.Common.Config.Instance.ConnectZigbeeMqttClientId;
			string username = Shared.Common.Config.Instance.ConnectGuid;
			string passwordRemote = Shared.Common.Config.Instance.ConnectZigbeeMqttBrokerPwd;
			//(1)连接到云端的Mqtt客户端连接参数
			var connectCloudMqttClientOptions = new MqttClientTcpOptions
			{
			Server = url.Split(':')[1].Substring("//".Length), //114.215.173.87 先写ip吧，这个地址可能后面会换成域名
			Port = int.Parse(url.Split(':')[2]),
			ClientId = clientId,
			UserName = username,//连接的用户名
			Password = passwordRemote,//连接的密码（App登录后获取到的连接云端Mqtt密码只能连接一次成功之后不能再使用相同的密码进行连接Mqtt否则会提示用户名密码失败，连接不上云端;）
			CleanSession = true,// 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
			KeepAlivePeriod = new TimeSpan(0, 5, 0),//设置心跳时间（最大值，2^16-1 = 65535秒 = 18小时。最小值可以为0，表示客户端不断开。一般设为几分钟，比如微信心跳周期为300秒。）
			DefaultCommunicationTimeout = new TimeSpan(0, 0, 100),//设置超时时间
			};
			//远程通讯连接，连接云端服务器
			if (RemoteMqttClient != null)
			try
			{
			await RemoteMqttClient.ConnectAsync(connectCloudMqttClientOptions);
			}
			byte[] result = null;
			if (Config.Instance.Home.IsOthreShare == false)
			{
			//主人
			var jsonData = new Dictionary<string, object>
			{
			["RequestVersion"] = CommonPage.RequestVersion,
			["RequestSource"] = 0,
			["LoginAccessToken"] = Config.Instance.Token,
			["RequestProtocolType"] = 0,
			["PlatformStr"] = "h",//这两个值如果不设置,则云端不发布主题
			["PublishPayloadJsonStr"] = "1"
			};
			var bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(jsonData));
			result = await CommonPage.Instance.DoRequestZigbeeHttpsInterface("https://global.hdlcontrol.com/HangZhouHdlCloudApi/EmqMqtt/GetConnMqttInfo", bytes, Config.Instance.Token);
			}
			else
			{
			//分享的
			var jsonData = new Dictionary<string, object>
			{
			["RequestVersion"] = CommonPage.RequestVersion,
			["RequestSource"] = 0,
			["LoginAccessToken"] = Config.Instance.Token,
			["RequestProtocolType"] = 0,
			["MainUserDistributedMark"] = Config.Instance.Home.MainUserDistributedMark,
			["HomeId"] = Config.Instance.Home.Id,
			["PlatformStr"] = "h",//这两个值如果不设置,则云端不发布主题
			["PublishPayloadJsonStr"] = "1"
			};
			var bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(jsonData));
			result = await CommonPage.Instance.DoRequestZigbeeHttpsInterface("https://global.hdlcontrol.com/HangZhouHdlCloudApi/EmqMqtt/ShareMemberConnMqttInfo", bytes, Config.Instance.Token);
			}
			if (result != null)
			{
			var jobject = Newtonsoft.Json.Linq.JObject.Parse(Encoding.UTF8.GetString(result));
			if (jobject["StateCode"].ToString() == "NotAllowRemoteCtrl")
			{
			//没有远程连接的权限
			AllowRemoteCtrl = false;
			return;
			}
			//虽然不知道对挤下线那一块有没有用,不过先这么弄
			await System.Threading.Tasks.Task.Delay(1500);

			var responseData = jobject["ResponseData"];
			if (responseData != null)
			{
			var connEmqDomainPort = responseData["ConnEmqDomainPort"]?.ToString();
			var connEmqClientId = responseData["ConnEmqClientId"]?.ToString();
			var connEmqUserName = responseData["ConnEmqUserName"]?.ToString();
			var connEmqPwd = responseData["ConnEmqPwd"]?.ToString();
			//记录起当前的客户端ID
			Config.Instance.ConnEmqClientId = connEmqClientId;

			var connEmqDomainPorts = connEmqDomainPort.Replace("//", "").Split(':');
			var domain = connEmqDomainPorts[1];
			var port = connEmqDomainPorts[2];

			var options = new MQTTnet.Client.Options.MqttClientOptionsBuilder()
			.WithClientId(connEmqClientId)
			.WithTcpServer(domain, int.Parse(port))
			.WithCredentials(connEmqUserName, connEmqPwd)
			.WithKeepAlivePeriod(TimeSpan.FromSeconds(20))
			.WithCleanSession()
			//.WithCommunicationTimeout(TimeSpan.FromSeconds(10))
			.Build();
			await DisConnectRemoteMqttClient("StartRemoteMqtt");
			await RemoteMqttClient.ConnectAsync(options, CancellationToken.None);

			remoteIsConnected = true;
			}
			}
			}
			catch { }
			finally
			{
			//最终要释放连接状态
			remoteMqttIsConnecting = false;
			}
			}
			catch (Exception ex)
			{
			#if DEBUG
			DebugPrintLog($"远程连接通讯连接出异常:{ex.Message}");
			#endif
			}
			finally
			{
			remoteMqttIsConnecting = false;
			}
			});
			}
			@@ -3338,26 +2765,48 @@
			/// <summary>
			/// 断开服务器连接
			/// </summary>
			public async System.Threading.Tasks.Task DisConnect(string s)
			public async System.Threading.Tasks.Task DisConnectLocalMqttClient(string s)
			{
			try
			{
			#if DEBUG
			DebugPrintLog($"主动断开_{System.DateTime.Now.ToString()}_{s}");
			#endif
			if (mqttClient != null && mqttClient.IsConnected == true)
			if (localIsConnected)
			{
			await mqttClient.DisconnectAsync();
			}
			localIsConnected = false;
			DebugPrintLog($"Local主动断开_{s}");
			//await localMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None);
			await localMqttClient.DisconnectAsync();
			}
			}
			catch (Exception ex)
			{
			#if DEBUG
			DebugPrintLog($"断开通讯连接出异常:{ex.Message}");
			#endif
			DebugPrintLog($"Local断开通讯连接出异常:{ex.Message}");
			}
			}

			/// <summary>
			/// 断开远程Mqtt的链接
			/// </summary>
			public static async System.Threading.Tasks.Task DisConnectRemoteMqttClient(string s = "")
			{
			try
			{
			if (remoteIsConnected)
			{
			remoteIsConnected = false;
			DebugPrintLog($"Remote主动断开_{s}");
			//await RemoteMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None);
			await RemoteMqttClient.DisconnectAsync();
			}
			}
			catch (Exception e)
			{
			DebugPrintLog($"Remote断开通讯连接出异常:{e.Message}");
			}
			}

			#endregion

			#region 数据发送

			/// <summary>
			/// 发送消息到服务器
			@@ -3385,32 +2834,38 @@
			/// <summary>
			/// 远程发送数据格式
			/// </summary>
			async System.Threading.Tasks.Task SendRemoteMsg(string topicName, byte[] message, MQTTnet.Core.Protocol.MqttQualityOfServiceLevel qosLevel = MQTTnet.Core.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, bool retain = false)
			async System.Threading.Tasks.Task SendRemoteMsg(string topicName, byte[] message, bool retain = false)
			{
			//(1)生成[用户名:密码]
			var userNameAndPwdStr = string.Concat(Shared.Common.Config.Instance.Guid, RemoteOperatorConsts.CAP_NUMBER, Shared.Common.Config.Instance.MD5PWD);
			DebugPrintLog($"userNameAndPwdStr：{userNameAndPwdStr} ");

			//(2)将(1)转成Base64字符串,生成格式[Base64(用户名:密码)]
			var userNameAndPwdStrBaseSexFour = Convert.ToBase64String(ZigBee.Common.CommonInfo.EncodingUTF8.GetBytes(userNameAndPwdStr));

			//(3)将(2)继续生成格式[Base64(用户名:密码):Timestamp]
			var userNameAndPwdStrBaseSexFourAndTimestamp = string.Concat(userNameAndPwdStrBaseSexFour, RemoteOperatorConsts.CAP_NUMBER, CurrentTimeStamp.ToString());

			//[Zigbee.Buspro]App/id(帐号Id)/Base64(DES[Base64(用户名:密码):Timestamp ]/网关唯一Id/转发给网关的主题/XX/XX
			//(4)生成上报主题，主题模式需要为 /ZigbeeApp/id(主子调试帐号Id)/Base64(DES[Base64(用户名:密码):Timestamp ]/网关唯一Id/topicName "000204022022" GateWayId 000204022022
			var reportTopic = string.Format("/{0}/{1}/{2}/{3}/{4}", RemoteOperatorConsts.ZIGBEE_APP_STARTS_WITH, Shared.Common.Config.Instance.Guid, userNameAndPwdStrBaseSexFourAndTimestamp, this.getGatewayBaseInfo?.gwID, topicName);
			var aa = System.Text.Encoding.UTF8.GetString(message);

			string topicEncStr = reportTopic;
			//文件流不用加密
			topicEncStr = ZigBee.Common.SecuritySet.AesEncrypt(System.Text.Encoding.UTF8.GetBytes(topicEncStr), Shared.Common.Config.Instance.MqttKey);
			topicEncStr = topicEncStr.Replace("/", "[[$-MQTT_TILT_SYMBOL_REPLACE-$]]").Replace("+", "[[$-MQTT_PLUS_SYMBOL_REPLACE-$]]");
			message = System.Text.Encoding.UTF8.GetBytes(SecuritySet.AesEncrypt(message, Shared.Common.Config.Instance.MqttKey));
			var bb = System.Text.Encoding.UTF8.GetString(message);

			//(6)构建Mqtt需要发布的数据包,发布给云端的MqttBroker
			await RemoteMqttClient.PublishAsync(new MQTTnet.Core.MqttApplicationMessage(topicEncStr, message, qosLevel, retain));
			try
			{
			if (this.GwId == string.Empty \|\| !GateWayBaseInfomations.ContainsKey(this.GwId))
			{
			return;
			}
			var gateWayBaseInfomation = GateWayBaseInfomations[this.GwId];
			message = SecuritySet.AesEncryptBytes(message, gateWayBaseInfomation.AesKey);
			var topicEncStr = $"/ClientToZigbeeGateWay/{gateWayBaseInfomation.MacMark}/Common/{topicName}";
			//(6)构建Mqtt需要发布的数据包,发布给云端的MqttBroker
			if (remoteIsConnected)
			{
			try
			{
			await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicEncStr, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce });
			}
			catch (Exception e)
			{
			await DisConnectRemoteMqttClient(e.Message);
			await StartRemoteMqtt();
			if (remoteIsConnected)
			{
			await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicEncStr, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce });
			}
			}
			}
			}
			catch
			{
			}
			}

			/// <summary>
			@@ -3419,9 +2874,8 @@
			/// <returns></returns>
			/// <param name="topic"></param>
			/// <param name="message"></param>
			/// <param name="qosLevel"></param>
			/// <param name="retain"></param>
			public async System.Threading.Tasks.Task Send(string topic, byte[] message, MQTTnet.Core.Protocol.MqttQualityOfServiceLevel qosLevel = MQTTnet.Core.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, bool retain = false)
			public async System.Threading.Tasks.Task Send(string topic, byte[] message, bool retain = false)
			{
			try
			{
			@@ -3432,46 +2886,44 @@

			if (IsRemote)
			{

			await SendRemoteMsg(topic, message, qosLevel, retain);
			#if DEBUG
			DebugPrintLog($"远程 ——发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_当前网关{CurrentGateWayId}_{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")
			#endif
			await SendRemoteMsg(topic, message, retain);
			DebugPrintLog($"远程——发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")
			}
			else
			{
			#if DEBUG
			DebugPrintLog($"局域网——发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_当前网关{CurrentGateWayId}_{System.DateTime.Now.ToString()}");
			#endif
			if (mqttClient == null \|\| !mqttClient.IsConnected)
			{
			await StartLocalMqtt(getGatewayBaseInfo.IpAddress);
			}

			DebugPrintLog($"局域网——发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_是否加密:{IsEncry}");

			if (IsEncry)
			{
			//文件流不用加密
			if (topic != "FileTransfer/SendFile")
			{
			topic = ZigBee.Common.SecuritySet.AesEncrypt(System.Text.Encoding.UTF8.GetBytes(topic), Password);
			message = System.Text.Encoding.UTF8.GetBytes(SecuritySet.AesEncrypt(message, password));
			DebugPrintLog($"局域网——发送到网关的主题（秘文）:{topic}_当前秘钥{Password}_发送到网关的数据（秘文）:{System.Text.Encoding.UTF8.GetString(message)}_当前网关{CurrentGateWayId}_{System.DateTime.Now.ToString()}");

			message = SecuritySet.AesEncryptBytes(message, password);
			}

			await mqttClient.PublishAsync(new MQTTnet.Core.MqttApplicationMessage(topic, message, qosLevel, retain));
			}
			else
			{
			await mqttClient.PublishAsync(new MQTTnet.Core.MqttApplicationMessage(topic, message, qosLevel, retain));
			}
			}
			if (localIsConnected)
			{
			try
			{
			await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
			}
			catch (Exception e)
			{
			DebugPrintLog($"Local主动断开_{e.Message}");
			await DisConnectLocalMqttClient(e.Message);
			await StartLocalMqtt("ReConnect");
			if (localIsConnected)
			{
			DebugPrintLog($"局域网——二次发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_是否加密:{IsEncry}");
			await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
			}
			}
			}
			}
			}
			catch (Exception ex)
			{
			#if DEBUG
			DebugPrintLog($"Send:{ex.Message}");
			#endif
			}
			}

			@@ -3481,125 +2933,130 @@
			/// <returns></returns>
			/// <param name="topic"></param>
			/// <param name="message"></param>
			/// <param name="qosLevel"></param>
			/// <param name="retain"></param>
			public async System.Threading.Tasks.Task Send(string topic, string message, MQTTnet.Core.Protocol.MqttQualityOfServiceLevel qosLevel = MQTTnet.Core.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, bool retain = false)
			public async System.Threading.Tasks.Task Send(string topic, string message, bool retain = false)
			{
			if (string.IsNullOrEmpty(message))
			{
			return;
			}
			await Send(topic, System.Text.Encoding.UTF8.GetBytes(message), qosLevel, retain);
			}


			[Serializable]
			public class CloudTimeResponse
			await Send(topic, System.Text.Encoding.UTF8.GetBytes(message), retain);
			}

			/// <summary>
			/// 强制指定使用本地局域网发送消息到服务器
			/// </summary>
			/// <returns></returns>
			/// <param name="topic"></param>
			/// <param name="message"></param>
			/// <param name="retain"></param>
			public async Task SendLocation(string topic, byte[] message, bool retain = false)
			{
			public string StateCode;
			public string Info;
			public string CloudTimestamp;
			try
			{
			if (Shared.Common.Config.Instance.HomeId == "")
			{
			return;
			}

			DebugPrintLog($"局域网——发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_是否加密:{IsEncry}");

			if (IsEncry)
			{
			//文件流不用加密
			if (topic != "FileTransfer/SendFile")
			{
			message = SecuritySet.AesEncryptBytes(message, password);
			}
			}
			if (localIsConnected)
			{
			try
			{
			await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
			}
			catch (Exception e)
			{
			DebugPrintLog($"Local主动断开_{e.Message}");
			await DisConnectLocalMqttClient(e.Message);
			await StartLocalMqtt("ReConnect");
			if (localIsConnected)
			{
			DebugPrintLog($"局域网——二次发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_是否加密:{IsEncry}");
			await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain });
			}
			}
			}
			}
			catch (Exception ex)
			{
			DebugPrintLog($"Send:{ex.Message}");
			}
			}

			#endregion

			#region 数据接收处理

			/// <summary>
			/// 接收远程数据处理
			/// </summary>
			/// <param name="sender">Sender.</param>
			/// <param name="e">E.</param>
			static void mqttRemoteClient_MqttMsgPublishReceived(object sender, MqttApplicationMessageReceivedEventArgs e)
			static void mqttRemoteClient_MqttMsgPublishReceived(MqttApplicationMessageReceivedEventArgs e)
			{
			try
			{
			var topic = e.ApplicationMessage.Topic.TrimStart('/');
			var payload = e.ApplicationMessage.Payload;

			var message = string.Empty;
			//你当前的IP及端口在云端不存在,请重新登录连接下!
			if (topic == "YouIpAndPortNoRecord")

			var topics = topic.Split("/");
			if (topics.Length < 3)
			{
			message = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
			}
			else if (topic == "BeingSqueezedOffline")
			{
			//云端中的当前连接被挤下线，需要通知app
			//全局接收网关推送的的逻辑(为了执行速度,尽可能的别加耗时的操作)
			message = "BeingSqueezedOffline";
			Shared.Phone.UserCenter.HdlGatewayReceiveLogic.GatewayOverallMsgReceive("", topic, null);
			DebugPrintLog($"被挤下线通知:{ topic}_远程返回的数据_{message}_{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")
			return;
			}
			//重新登录:帐号或者共享连接中的[子帐号分布式Id$Share$分布式住宅Id=XXX尚未登录,请重新登录后再连接后再进行发布操作,如果您当前是别人共享给你的连接,则请重新请求获取连接信息一下,再初始化连接再次发布远程控制即可!!
			else if (topic == "AppNoLogin")
			if (topics[0] != "ZigbeeGateWayToClient")
			{
			message = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
			return;
			}
			else
			if (topics[2] == "NotifyGateWayInfoChange")
			{
			topic = topic.Replace("[[$-MQTT_TILT_SYMBOL_REPLACE-$]]", "/");
			topic = topic.Replace("[[$-MQTT_PLUS_SYMBOL_REPLACE-$]]", "+");
			topic = ZigBee.Common.SecuritySet.AesDecrypt(System.Text.Encoding.UTF8.GetBytes(topic), Shared.Common.Config.Instance.MqttKey).TrimStart('/'); ;

			if (!message.EndsWith("}"))
			{
			message = ZigBee.Common.SecuritySet.AesDecrypt(e.ApplicationMessage.Payload, Shared.Common.Config.Instance.MqttKey);
			}
			initGateWayBaseInfomation();
			return;
			}
			#if DEBUG
			DebugPrintLog($"远程返回的主题:{ topic}_远程返回的数据_{message}_{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")
			#endif
			var cloudMqttResult = Newtonsoft.Json.JsonConvert.DeserializeObject<ZigBee.Common.CloudMqttResponsePack>(message);
			if (cloudMqttResult != null)
			if (topics[2] == "Common")
			{
			if (topic == "AppConnectMqttBrokerSuccess")
			var macMark = topics[1];
			topic = topic.Substring(topics[0].Length + topics[1].Length + topics[2].Length + 3);
			if (payload[0] == (byte)'{' && payload[payload.Length - 1] == (byte)'}')
			{
			RemoteTimeStamp = ulong.Parse(cloudMqttResult.CloudTimestamp);
			LoginRemoteDateTime = System.DateTime.Now;
			#if DEBUG
			DebugPrintLog($"远程返回主题:{topic}_当前时间戳:_+{CurrentTimeStamp} + _+{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff" // {System.DateTime.Now.ToString()}");
			#endif
			return;
			message = System.Text.Encoding.UTF8.GetString(payload);
			}
			else
			{
			switch (cloudMqttResult.StateCode)
			foreach (var key in GateWayBaseInfomations.Keys)
			{
			case "GatewayIdNoIsYou":
			message = cloudMqttResult.StateCode + ":" + cloudMqttResult.Info;
			#if DEBUG
			DebugPrintLog($"远程返回返回的提示内容:{message}_当前时间戳:_+{CurrentTimeStamp} + _+ {System.DateTime.Now.ToString()}");
			#endif
			return;
			case "AppTimeOut":
			RemoteTimeStamp = ulong.Parse(cloudMqttResult.CloudTimestamp);
			LoginRemoteDateTime = System.DateTime.Now;
			message = cloudMqttResult.StateCode + ":" + cloudMqttResult.Info;
			#if DEBUG
			DebugPrintLog($"远程返回返回的提示内容:{message}_当前时间戳:_+{CurrentTimeStamp} + _+ {System.DateTime.Now.ToString()}");
			#endif
			return;
			case "AppReportSuccess":
			RemoteTimeStamp = ulong.Parse(cloudMqttResult.CloudTimestamp);
			LoginRemoteDateTime = System.DateTime.Now;
			message = cloudMqttResult.StateCode + ":" + cloudMqttResult.Info;
			#if DEBUG
			DebugPrintLog($"远程返回返回的提示内容:{message}_当前时间戳:_+{CurrentTimeStamp} + _+ {System.DateTime.Now.ToString()}");
			#endif
			return;
			case "ForwardGatewayNoOnLine":
			message = cloudMqttResult.StateCode + ":" + cloudMqttResult.Info;
			#if DEBUG
			DebugPrintLog($"远程返回返回的提示内容:{message}_当前时间戳:_+{CurrentTimeStamp} + _+ {System.DateTime.Now.ToString()}");
			#endif
			return;
			var value = GateWayBaseInfomations[key];
			if (value.MacMark == macMark)
			{
			topic = $"{key}/{topic}";
			message = System.Text.Encoding.UTF8.GetString(ZigBee.Common.SecuritySet.AesDecryptBytes(e.ApplicationMessage.Payload, value.AesKey));
			break;
			}
			}
			}
			}

			ReceiveMessage(topic, message, e);
			DebugPrintLog($"远程返回的主题:{ topic}_远程返回的数据_{message}");//{System.DateTime.Now.ToString()}");// DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff")

			ReceiveMessage(topic, message, payload);
			}
			catch (Exception ex)
			{
			#if DEBUG
			DebugPrintLog($"接收云端数据异常:{ex.Message}");
			#endif
			DebugPrintLog($"接收云端数据异常:{ex.Message} ");
			}
			}

			@@ -3609,45 +3066,40 @@
			/// </summary>
			/// <param name="sender">Sender.</param>
			/// <param name="e">E.</param>
			void mqttClient_MqttMsgPublishReceived(object sender, MqttApplicationMessageReceivedEventArgs e)
			void mqttClient_MqttMsgPublishReceived(MqttApplicationMessageReceivedEventArgs e)
			{
			try
			{
			var topic = e.ApplicationMessage.Topic;
			var message = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
			string payloadString = "";

			if (IsEncry)
			{
			//主题
			topic = Common.SecuritySet.AesDecrypt(System.Text.Encoding.UTF8.GetBytes(topic), Password);
			//下载的字节流不需要解密
			if (topic.Split('/')[0] + "/" + topic.Split('/')[1] == topic.Split('/')[0] + "/" + "FileTransfer")
			{
			if (topic.Split('/')[2] != "DownloadFile")
			{
			message = Common.SecuritySet.AesDecrypt(e.ApplicationMessage.Payload, Password);
			payloadString = System.Text.Encoding.UTF8.GetString(Common.SecuritySet.AesDecryptBytes(e.ApplicationMessage.Payload, Password));
			}
			}
			else if (topic == topic.Split('/')[0] + "/" + "SendAESKey_Respon") { }//回复主题是秘文，数据是明文
			else
			{
			message = Common.SecuritySet.AesDecrypt(e.ApplicationMessage.Payload, Password);
			payloadString = System.Text.Encoding.UTF8.GetString(Common.SecuritySet.AesDecryptBytes(e.ApplicationMessage.Payload, Password));
			}
			}
			else
			{
			topic = e.ApplicationMessage.Topic;
			else
			{
			payloadString = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
			}
			#if DEBUG
			DebugPrintLog($"网关返回的主题:{topic}_网关返回的负载:{message}_{System.DateTime.Now.ToString()}");
			#endif
			ReceiveMessage(topic, message, e);
			DebugPrintLog($"网关返回的主题:{topic}_网关返回的负载:{payloadString}");
			ReceiveMessage(topic, payloadString, e.ApplicationMessage.Payload);
			}
			catch (Exception ex)
			{
			#if DEBUG
			DebugPrintLog($"接收网关数据异常:{ex.Message}");
			#endif
			}
			}

			@@ -3657,7 +3109,7 @@
			/// <param name="topic">Topic.</param>
			/// <param name="message">Message.</param>
			/// <param name="e">E.</param>
			static void ReceiveMessage(string topic, string message, MqttApplicationMessageReceivedEventArgs e)
			static void ReceiveMessage(string topic, string message, byte[] payload)
			{
			try
			{
			@@ -3678,9 +3130,12 @@
			epoint = topic.Split('/')[3];
			cluID = topic.Split('/')[4];
			attrId = topic.Split('/')[5];
			}
			}

			//全局接收网关推送的的逻辑(为了执行速度,尽可能的别加耗时的操作)
			Shared.Phone.UserCenter.HdlGatewayReceiveLogic.Current.GatewayOverallMsgReceive(gatewayID, topic, reportStatus, message);

			var gwa = ZigBee.Device.ZbGateway.GateWayList.Find(obj => obj.getGatewayBaseInfo.gwID == gatewayID);
			var gwa = GateWayList.Find(obj => obj.GwId == gatewayID);
			if (gwa == null)
			{
			return;
			@@ -3691,24 +3146,17 @@
			gwa?.Actions(topic, message);
			}

			if (gwa.GwResDataAction != null)
			{
			gwa.GwResDataAction(topic, message);
			}
			gwa.CurrentGateWayId = gatewayID;
			gwa.GwResDataAction?.Invoke(topic, message);

			Newtonsoft.Json.Linq.JObject jobject = new Newtonsoft.Json.Linq.JObject();
			var jobject = new Newtonsoft.Json.Linq.JObject();
			if (topic.Split('/')[0] + "/" + topic.Split('/')[1] == topic.Split('/')[0] + "/" + "FileTransfer")
			{
			if (topic.Split('/')[2] == "DownloadFile")
			{
			gwa.DownloadFileConfirmAsync(e.ApplicationMessage.Payload);
			message = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
			if (gwa.FileContentAction != null)
			{
			gwa.FileContentAction(topic, e.ApplicationMessage.Payload);
			}
			DebugPrintLog($"网关返回数据流_{message}_{System.DateTime.Now.ToString()}");
			gwa.DownloadFileConfirmAsync(payload);
			message = System.Text.Encoding.UTF8.GetString(payload);
			gwa.FileContentAction?.Invoke(topic, payload);
			DebugPrintLog($"网关返回数据流_{message}");
			return;
			}
			}
			@@ -3717,41 +3165,6 @@
			jobject = Newtonsoft.Json.Linq.JObject.Parse(message);
			}

			//全局接收网关推送的的逻辑(为了执行速度,尽可能的别加耗时的操作)
			Shared.Phone.UserCenter.HdlGatewayReceiveLogic.GatewayOverallMsgReceive(gatewayID, topic, jobject);

			#region 云端通知
			var cloudMqttResult = Newtonsoft.Json.JsonConvert.DeserializeObject<ZigBee.Common.CloudMqttResponsePack>(message);
			if (cloudMqttResult != null)
			{
			switch (cloudMqttResult.StateCode)
			{
			case "AppNoLogin":
			if (gwa.CloudErrorAction != null)
			{
			DebugPrintLog("AppNoLogin已经通知");
			gwa.CloudErrorAction("AppNoLogin", "登录过期，请重新登录");
			}
			//全局接收网关推送的的逻辑(为了执行速度,尽可能的别加耗时的操作)
			Shared.Phone.UserCenter.HdlGatewayReceiveLogic.GatewayOverallMsgReceive(gatewayID, "AppNoLogin", jobject);
			break;
			case "AppTimeOut":
			if (gwa.CloudErrorAction != null)
			{
			DebugPrintLog("AppTimeOut已经通知");
			gwa.CloudErrorAction("AppTimeOut", "从云端获取数据超时，请重新获取");
			}
			break;
			case "ForwardGatewayNoOnLine":
			if (gwa.CloudErrorAction != null)
			{
			DebugPrintLog("ForwardGatewayNoOnLine已经通知");
			gwa.CloudErrorAction("ForwardGatewayNoOnLine", "当前操作的网关不在线");
			}
			break;
			}
			}
			#endregion
			#region 远程,主网关上报通知
			if (IsRemote)
			{
			@@ -3760,18 +3173,16 @@
			var gwData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.GetGwData>(jobject["Data"].ToString());
			if (gwData != null)
			{
			var gwList = GateWayList.FindAll(obj => obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId);

			var gwList = GateWayList.FindAll(obj => obj.HomeId == Shared.Common.Config.Instance.HomeId);
			for (int i = 0; i < gwList.Count; i++)
			{
			var gwTemp = gwList[i];
			if (gwData.IsDominant == 1)
			{
			gwTemp.getGatewayBaseInfo.IsMainGateWay = true;
			for (int j = i + 1; j < gwList.Count; j++)
			{
			gwList[j].getGatewayBaseInfo.IsMainGateWay = false;
			}
			if (gwList[i].GwId == gatewayID)
			{
			gwList[i].IsMainGateWay = true;
			}
			else
			{
			gwList[i].IsMainGateWay = false;
			}
			}
			}
			@@ -3779,168 +3190,82 @@
			}

			#endregion
			#region 设备新上报
			//步骤1）网关告知客户端有新设备加入zigbee网络。
			if (topic == gatewayID + "/" + "Device/DeviceJoinZbNet_Respon")
			{
			var gatewayTemp = new ZbGateway() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			gatewayTemp.deviceDeviceJoinZbNetResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceDeviceJoinZbNetResponData>(jobject["Data"].ToString());
			if (gatewayTemp.deviceDeviceJoinZbNetResponData == null)
			{
			return;
			}
			//上报类型通知
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("Device/DeviceJoinZbNet已经通知");
			gatewayTemp.CurrentGateWayId = gatewayID;//这里的CurrentGateWayId是当前新new ZbGateway的值
			gwa.ReportAction("Device/DeviceJoinZbNet", gatewayTemp);
			}
			}
			//步骤2）网关告知客户端获取新设备所有端点信息是否成功
			if (topic == gatewayID + "/" + "Device/IsGetEpointInfo_Respon")
			{
			var gatewayTemp = new ZbGateway() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			gatewayTemp.deviceIsGetEpointInfoResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DeviceIsGetEpointInfoResponData>(jobject["Data"].ToString());
			if (gatewayTemp.deviceIsGetEpointInfoResponData == null)
			{
			return;
			}
			//上报类型通知
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("Device/IsGetEpointInfo已经通知");
			gatewayTemp.CurrentGateWayId = gatewayID;//这里的CurrentGateWayId是当前新new ZbGateway的值
			gwa.ReportAction("Device/IsGetEpointInfo", gatewayTemp);
			}
			}
			//步骤3）网关上报节点设备所有端点信息
			if (topic == gatewayID + "/" + "DeviceInComingRespon")
			{
			//新设备上报，重新发获取所有的设备
			var tempDevice = new CommonDevice() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			tempDevice.getNewDeviceInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.NewDeviceInfoData>(jobject["Data"].ToString());
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("DeviceInComingRespon已经通知");
			gwa.ReportAction("DeviceInComingRespon", tempDevice.getNewDeviceInfo);
			}
			UpdateDeviceInfo(tempDevice, "DeviceInComingRespon");
			UpdateDeviceStatus(gwa);
			}
			#endregion

			#region 设备在线状态更新反馈
			else if (topic == gatewayID + "/" + "OnlineStatusChange_Respon")
			{
			var tempDevice = new CommonDevice() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			tempDevice.IsOnline = Newtonsoft.Json.JsonConvert.DeserializeObject<int>(jobject["Data"]["IsOnline"].ToString());

			if (gwa.ReportAction != null)
			{
			DebugPrintLog("OnlineStatusChange已经通知");
			gwa.ReportAction("OnlineStatusChange", tempDevice);
			}
			var infoTempDevice = gwa.DeviceList.Find(obj => obj.DeviceID == tempDevice.DeviceID && obj.DeviceAddr == tempDevice.DeviceAddr);
			if (infoTempDevice == null)
			{
			gwa.DeviceList.Add(tempDevice);
			UpdateDeviceStatus(tempDevice);
			UpdateDeviceInfo(tempDevice, "OnlineStatusChange");
			}
			else
			{
			if (infoTempDevice.DeviceInfo != null)
			{
			infoTempDevice.DeviceInfo.IsOnline = infoTempDevice.IsOnline;
			}
			UpdateDeviceInfo(infoTempDevice, "OnlineStatusChange");
			UpdateDeviceStatus(infoTempDevice);
			}
			}
			#endregion
			#region 设备被删除上报
			else if (topic == gatewayID + "/" + "RemoveDeviceRespon")
			{
			var gatewayTemp = new ZbGateway() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			gatewayTemp.removeDeviceResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGateway.RemoveDeviceResponseData>(jobject["Data"].ToString());

			if (gatewayTemp.removeDeviceResponseData != null)
			{
			try
			{
			if (gatewayTemp.removeDeviceResponseData.Result == 0)
			{
			foreach (var delD in gatewayTemp.removeDeviceResponseData.DeviceList)
			{
			var tempDevice = new CommonDevice() { DeviceAddr = jobject.Value<string>("DeviceAddr"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			tempDevice.removeDeviceResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.RemoveDeviceResponseData>(jobject["Data"].ToString());
			if (tempDevice.removeDeviceResponseData == null)
			{
			return;
			}
			else
			{
			UpdateDeviceStatus(tempDevice);
			UpdateDeviceInfo(tempDevice, "RemoveDeviceRespon");
			if (tempDevice.removeDeviceResponseData.Result == 0)
			{
			var infoTempDevice = gwa.DeviceList.Find((CommonDevice obj) => obj.DeviceID == tempDevice.DeviceID && obj.DeviceAddr == tempDevice.DeviceAddr && obj.DeviceEpoint == tempDevice.DeviceEpoint);
			if (infoTempDevice != null)
			{
			gwa.DeviceList.Remove(infoTempDevice);
			}
			}
			}
			}
			}
			}
			catch { }
			}
			}
			//2020.05.11 删除

			#endregion

			#region 设备状态上报
			else if (topic == gatewayID + "/" + "DeviceStatusReport" + "/" + addr + "/" + epoint + "/" + cluID + "/" + attrId)
			if (topic == gatewayID + "/" + "DeviceStatusReport" + "/" + addr + "/" + epoint + "/" + cluID + "/" + attrId)
			{
			var deviceID = jobject.Value<int>("Device_ID");
			var deviceAddr = jobject.Value<string>("DeviceAddr");
			var tempEpoint = jobject.Value<int>("Epoint");
			var dataId = jobject.Value<int>("Data_ID");

			var tempDevice = new CommonDevice { DeviceID = deviceID, DeviceAddr = deviceAddr, DeviceEpoint = tempEpoint, DataID = dataId };
			var tempDevice = new CommonDevice { DeviceID = deviceID, DeviceAddr = deviceAddr, DeviceEpoint = tempEpoint };
			tempDevice.DeviceStatusReport = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.DeviceStatusReportData>(jobject["Data"].ToString());
			UpdateDeviceStatus(tempDevice);
			UpdateDeviceInfo(tempDevice, "DeviceStatusReport");
			}
			#endregion
			#region IAS安防信息上报
			else if (topic == gatewayID + "/" + "IASInfoReport")
			#region 门锁操作事件通知
			else if (topic == gatewayID + "/" + "DoorLock/DoorLockOperatingEventNotificationCommand")
			{
			var deviceID = jobject.Value<int>("Device_ID");
			switch ((DeviceType)(deviceID))
			{
			case DeviceType.IASZone:
			var ias = new IASZone() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			ias.iASInfo = Newtonsoft.Json.JsonConvert.DeserializeObject<IASZone.IASInfoData>(jobject["Data"].ToString());
			//上报类型通知，必需先调用，然后才有通知，否则是空不会通知的
			case DeviceType.DoorLock:
			var doorLock = new DoorLock() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), CurrentGateWayId = gwa.GwId };
			var OperatingEventNotificationDatad = Newtonsoft.Json.JsonConvert.DeserializeObject<ZigBee.Device.DoorLock.DoorLockOperatingEventNotificationCommand>(jobject["Data"].ToString());
			if (OperatingEventNotificationDatad != null)
			{
			doorLock.doorLockOperatingEventNotificationCommand = OperatingEventNotificationDatad;
			}
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("IASInfoReport已经通知");
			//ias.Save();
			gwa.ReportAction("IASInfoReport", ias.iASInfo);
			DebugPrintLog("DoorLockProgrammingEventNotificationCommand已经通知");
			gwa.ReportAction("DoorLockProgrammingEventNotificationCommand", doorLock);
			}

			UpdateDeviceStatus(ias);
			UpdateDeviceInfo(ias, "IASInfoReport");
			UpdateDeviceInfo(doorLock, "DoorLockProgrammingEventNotificationCommand");
			break;
			}
			}
			#endregion
			#region 门锁编程事件通知
			else if (topic == gatewayID + "/" + "DoorLock/DoorLockProgrammingEventNotificationCommand")
			{
			var deviceID = jobject.Value<int>("Device_ID");
			switch ((DeviceType)(deviceID))
			{
			case DeviceType.DoorLock:
			var doorLock = new DoorLock() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), CurrentGateWayId = gwa.GwId };
			var ProgrammingEventNotificationData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZigBee.Device.DoorLock.DoorLockProgrammingEventNotificationCommand>(jobject["Data"].ToString());
			if (ProgrammingEventNotificationData != null)
			{
			doorLock.doorLockProgrammingEventNotificationCommand = ProgrammingEventNotificationData;
			}
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("DoorLockProgrammingEventNotificationCommand已经通知");
			gwa.ReportAction("DoorLockProgrammingEventNotificationCommand", doorLock);
			}
			UpdateDeviceInfo(doorLock, "DoorLockProgrammingEventNotificationCommand");
			break;
			}
			}
			#endregion
			#region IAS安防信息上报

			//2020.05.11 删除

			#endregion
			#region 下载进度上报
			else if (topic == gatewayID + "/" + "DownloadFile_Progress")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.downloadFileProgressResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<DownloadFileProgressResponData>(jobject["Data"].ToString());
			if (gatewayTemp.downloadFileProgressResponData == null)
			gwa.downloadFileProgressResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.DownloadFileProgressResponData>(jobject["Data"].ToString());
			if (gwa.downloadFileProgressResponData == null)
			{
			return;
			}
			@@ -3948,15 +3273,13 @@
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("DownloadFileProgress");
			gatewayTemp.CurrentGateWayId = gatewayID;//这里的CurrentGateWayId是当前新new ZbGateway的值
			gwa.ReportAction("DownloadFileProgress", gatewayTemp);
			gwa.ReportAction("DownloadFileProgress", gwa);
			}
			}
			else if (topic == gatewayID + "/" + "ZbGwOperation/Upgrade_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.zbGwOperationUpgradeData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGwOperationUpgradeData>(jobject["Data"].ToString());
			if (gatewayTemp.zbGwOperationUpgradeData == null)
			gwa.zbGwOperationUpgradeData = Newtonsoft.Json.JsonConvert.DeserializeObject<ZbGwOperationUpgradeData>(jobject["Data"].ToString());
			if (gwa.zbGwOperationUpgradeData == null)
			{
			return;
			}
			@@ -3964,16 +3287,14 @@
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("协调器升级百分比");
			gatewayTemp.CurrentGateWayId = gatewayID;//这里的CurrentGateWayId是当前新new ZbGateway的值
			gwa.ReportAction("CordinatorUpgradePercent", gatewayTemp);
			gwa.ReportAction("CordinatorUpgradePercent", gwa);
			}
			}
			else if (topic == gatewayID + "/" + "OTA/Schedule_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.oTAScheduleResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<OTAScheduleResponData>(jobject["Data"].ToString());
			gwa.oTAScheduleResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.OTAScheduleResponData>(jobject["Data"].ToString());

			if (gatewayTemp.oTAScheduleResponData == null)
			if (gwa.oTAScheduleResponData == null)
			{
			return;
			}
			@@ -3982,16 +3303,14 @@
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("节点设备升级百分比");
			gatewayTemp.CurrentGateWayId = gatewayID;//这里的CurrentGateWayId是当前新new ZbGateway的值
			gwa.ReportAction("DeviceUpgradePercent", gatewayTemp);
			gwa.ReportAction("DeviceUpgradePercent", gwa);
			}
			}
			else if (topic == gatewayID + "/" + "VirtualDrive/Upgrade_Respon")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.virtualDriveUpgradeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VirtualDriveUpgradeResponData>(jobject["Data"].ToString());
			gwa.virtualDriveUpgradeResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<VirtualDriveUpgradeResponData>(jobject["Data"].ToString());

			if (gatewayTemp.virtualDriveUpgradeResponData == null)
			if (gwa.virtualDriveUpgradeResponData == null)
			{
			return;
			}
			@@ -3999,18 +3318,16 @@
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("虚拟驱动升级百分比");
			gatewayTemp.CurrentGateWayId = gatewayID;//这里的CurrentGateWayId是当前新new ZbGateway的值
			gwa.ReportAction("VirtualDriveUpgrade", gatewayTemp);
			gwa.ReportAction("VirtualDriveUpgrade", gwa);
			}
			}
			#endregion
			#region 重启网关系统
			else if (topic == gatewayID + "/" + "GwReboot_Respon")
			{
			var gatewayTemp = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID") };
			gatewayTemp.gwRebootResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<GwRebootResponData>(jobject["Data"].ToString());
			var gwRebootResponData = Newtonsoft.Json.JsonConvert.DeserializeObject<GwRebootResponData>(jobject["Data"].ToString());

			if (gatewayTemp.gwRebootResponData == null)
			if (gwRebootResponData == null)
			{
			return;
			}
			@@ -4018,15 +3335,14 @@
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("GwReboot_Respon已经通知");
			gatewayTemp.CurrentGateWayId = gatewayID;//这里的CurrentGateWayId是当前新new ZbGateway的值
			gwa.ReportAction("GwReboot_Respon", gatewayTemp);
			gwa.ReportAction("GwReboot_Respon", gwRebootResponData);
			}
			}
			#endregion
			#region 防区被触发时报告
			else if (topic == gatewayID + "/" + "Security/ZoneTriggerReport")
			{
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.GwId };
			ias.zoneTriggerReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.ZoneTriggerReportData>(jobject["Data"].ToString());

			if (ias.zoneTriggerReportData == null)
			@@ -4044,43 +3360,43 @@
			#region 逻辑被调用反馈
			else if (topic == gatewayID + "/" + "Logic/Execute_Respon")
			{
			var logic = new Logic() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
			logic.logicExecuteRespo = Newtonsoft.Json.JsonConvert.DeserializeObject<Logic.ExecuteResponse>(jobject["Data"].ToString());
			//var logic = new Logic() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.GwId };
			//logic.logicExecuteRespo = Newtonsoft.Json.JsonConvert.DeserializeObject<Logic.ExecuteResponse>(jobject["Data"].ToString());

			if (logic.logicExecuteRespo == null)
			{
			return;
			}
			//上报类型通知
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("LogicExecuteReport已经通知");
			gwa.ReportAction("LogicExecuteReport", logic.logicExecuteRespo);
			}
			//if (logic.logicExecuteRespo == null)
			//{
			// return;
			//}
			////上报类型通知
			//if (gwa.ReportAction != null)
			//{
			// DebugPrintLog("LogicExecuteReport已经通知");
			// gwa.ReportAction("LogicExecuteReport", logic.logicExecuteRespo);
			//}
			}
			#endregion
			#region 时间点条件推迟执行
			else if (topic == gatewayID + "/" + "Logic/TimingWillArrive")
			{
			var logic = new Logic() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
			logic.timingWillArriveData = Newtonsoft.Json.JsonConvert.DeserializeObject<Logic.TimingWillArriveData>(jobject["Data"].ToString());
			//var logic = new Logic() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.GwId };
			//logic.timingWillArriveData = Newtonsoft.Json.JsonConvert.DeserializeObject<Logic.TimingWillArriveData>(jobject["Data"].ToString());

			if (logic.timingWillArriveData == null)
			{
			return;
			}
			//上报类型通知
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("TimingWillArrive已经通知");
			gwa.ReportAction("TimingWillArrive", logic.timingWillArriveData);
			}
			//if (logic.timingWillArriveData == null)
			//{
			// return;
			//}
			////上报类型通知
			//if (gwa.ReportAction != null)
			//{
			// DebugPrintLog("TimingWillArrive已经通知");
			// gwa.ReportAction("TimingWillArrive", logic.timingWillArriveData);
			//}
			}
			#endregion
			#region 模式安防动作被最终激活时发送报警信息
			else if (topic == gatewayID + "/" + "Security/ModeTriggerReport")
			{
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.GwId };
			ias.modeTriggerReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.ModeTriggerReportData>(jobject["Data"].ToString());
			if (ias.modeTriggerReportData == null)
			{
			@@ -4097,7 +3413,7 @@
			#region 通过外部方式布防撤防成功时报告息
			else if (topic == gatewayID + "/" + "Security/EnOrWithdrawSucceedReport")
			{
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.GwId };
			ias.enOrWithdrawSucceedReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.EnOrWithdrawSucceedReportData>(jobject["Data"].ToString());
			if (ias.enOrWithdrawSucceedReportData == null)
			{
			@@ -4114,7 +3430,7 @@
			#region 胁迫密码撤防时短信推送
			else if (topic == gatewayID + "/" + "Security/PushTargetInfo")
			{
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.getGatewayBaseInfo.gwID };
			var ias = new Safeguard() { DataID = jobject.Value<int>("Data_ID"), GateWayId = gwa.GwId };
			ias.coercedPWDWithdrawReportData = Newtonsoft.Json.JsonConvert.DeserializeObject<Safeguard.CoercedPWDWithdrawReportData>(jobject["Data"].ToString());
			if (ias.coercedPWDWithdrawReportData == null)
			{
			@@ -4128,42 +3444,22 @@
			}
			}
			#endregion
			#region 节点设备默认反馈
			else if (topic == gatewayID + "/" + "DeviceDefaultAck")
			{
			var deviceDefaultAck = new ZbGateway() { DeviceID = jobject.Value<int>("Device_ID"), DeviceAddr = jobject.Value<string>("DeviceAddr"), DeviceEpoint = jobject.Value<int>("Epoint"), DataID = jobject.Value<int>("Data_ID"), CurrentGateWayId = gwa.getGatewayBaseInfo.gwID };
			if (deviceDefaultAck == null)
			{
			return;
			}
			//上报类型通知
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("DeviceDefaultAck");
			gwa.ReportAction("DeviceDefaultAck", deviceDefaultAck);
			}
			}
			#endregion

			#region 设备请求APP获取升级数据
			else if (topic == gatewayID + "/" + "ZbDataPassthrough")
			{
			var gatewayTemp = new ZbGateway() { DataID = jobject.Value<int>("Data_ID") };
			gatewayTemp.clientDataPassthroughResponseData = Newtonsoft.Json.JsonConvert.DeserializeObject<ClientDataPassthroughResponseData>(jobject["Data"].ToString());
			if (gatewayTemp.clientDataPassthroughResponseData == null)
			{
			return;
			}

			//上报类型通知
			if (gwa.ReportAction != null)
			{
			DebugPrintLog("DeviceRequestAcUpdateData");
			gwa.ReportAction("DeviceRequestAcUpdateData", gatewayTemp.clientDataPassthroughResponseData);
			{
			var clientDataPassthrough = Newtonsoft.Json.JsonConvert.DeserializeObject<CommonDevice.ClientDataPassthroughResponseData>(jobject["Data"].ToString());
			if (clientDataPassthrough != null)
			{
			DebugPrintLog("DeviceRequestAcUpdateData");
			gwa.ReportAction("DeviceRequestAcUpdateData", clientDataPassthrough);
			}
			}
			}
			#endregion
			DebugPrintLog("网关返回数据通知");
			}
			catch (Exception ex)
			{
			@@ -4171,5 +3467,40 @@
			}

			}

			#endregion

			#region 保存缓存

			/// <summary>
			/// 重新保存设备
			/// </summary>
			public void ReSave()
			{
			Global.WriteFileByBytesByHomeId(FilePath, System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(this)));
			}
			#endregion

			#region 调试打印

			/// <summary>
			/// 调试时打开打印信息，true:打印，false:不打印
			/// </summary>
			/// <param name="msg">Message.</param>
			/// <param name="flage">If set to <c>true</c> flage.</param>
			public static void DebugPrintLog(string msg, bool flage = true)
			{
			#if DEBUG
			if (flage == true)
			{
			//if (msg.Contains("DeviceStatusReport") == false)
			{
			System.Console.WriteLine(msg + " " + System.DateTime.Now.ToLongTimeString() + " " + System.DateTime.Now.Millisecond);
			}
			}
			#endif
			}

			#endregion
			}
			}