~wjc/HomeApp.git

			@@ -3,15 +3,16 @@
			using System.Net;
			using System.Net.Sockets;
			using System.Text;

			using Shared.Common;
			using ZigBee.Device;
			using static ZigBee.Device.ZbGateway;


			namespace ZigBee.Common
			{
			public static class Application
			{
			static bool isInited;
			public static bool isInited;
			static bool isEncry;
			/// <summary>
			/// 是否正在搜索网关
			@@ -21,6 +22,10 @@
			/// 新发现的网关通知
			/// </summary>
			public static Action<ZigBee.Device.ZbGateway> NewGateWayAction;
			/// <summary>
			/// 上一次的住宅ID
			/// </summary>
			private static string oldHomeID = string.Empty;

			public static void Init()
			{
			@@ -29,11 +34,11 @@
			return;
			}
			isInited = true;

			new System.Threading.Thread(async () =>
			{
			var gateWayList = new List<ZbGateway> { };
			var searchCount = 2;
			var oldHomeID = string.Empty;
			var searchCount = 6;
			var broadBytes = new byte[44];// byteHomeId[0] ,//H
			broadBytes[0] = 0xfe;
			broadBytes[1] = 0x29;
			@@ -48,7 +53,9 @@
			try
			{
			if (string.IsNullOrEmpty(Shared.Common.Config.Instance.HomeId))
			{
			{
			//住宅ID为空只有一种可能就是退出了登录，这里的上一次住宅ID要清空
			oldHomeID = "?";
			System.Threading.Thread.Sleep(1000);
			continue;
			}
			@@ -57,13 +64,13 @@
			{
			//因为那一瞬间，有可能mqtt会加回来,所以先加缓存
			var list = new List<ZbGateway>();
			list.AddRange(GateWayList);
			list.AddRange(ZbGateway.GateWayList);
			//然后清空掉
			GateWayList.Clear();
			ZbGateway.GateWayList.Clear();
			//最后再断开mqtt连接
			for (int i = 0; i < list.Count; i++)
			{
			list[i].DisConnect("1");
			list[i].DisConnectLocalMqttClient("1");
			}
			list.Clear();
			oldHomeID = Shared.Common.Config.Instance.HomeId;
			@@ -88,43 +95,48 @@
			}
			}

			var broadcastIpAddress = new Shared.Net.NetWiFi().BroadcastIpAddress;

			//网关通讯处理

			if (0 < gateWayList.Count)
			{
			searchCount = 2;
			gateWayList.Clear();
			var aa = GateWayList;

			//关闭远程服务器
			if (RemoteMqttClient!=null&& RemoteMqttClient.IsConnected==true)
			{
			await RemoteMqttClient?.DisconnectAsync();
			System.Console .WriteLine ($"收到网关远程连接主动断开_{System.DateTime.Now.ToString()}");
			}
			}
			else
			var broadcastIpAddress = new Shared.Net.NetWiFi().BroadcastIpAddress;


			if (Shared.Application.IsWifi)
			{
			if (searchCount <= 0)
			if (0 < gateWayList.Count)
			{
			//远程通讯连接，连接云端服务器
			await StartCloudMqtt();
			}
			}
			searchCount = 6;
			ZbGateway.IsRemote = false;
			}
			else
			{
			if (searchCount < 0)
			{
			ZbGateway.IsRemote = true;
			}
			}
			}
			else
			{
			ZbGateway.IsRemote = true;
			for (int i = 0; i < ZbGateway.GateWayList.Count; i++)
			{
			ZbGateway.GateWayList[i].DisConnectLocalMqttClient("1");
			}
			}

			searchCount--;

			//每0.5秒广播发现一次网关，共2s
			int count = 4;
			#region 1秒搜索一次网关
			//每0.5秒广播发现一次网关，共1s
			int count = 2;
			new System.Threading.Thread(() =>
			{
			{
			gateWayList.Clear();
			while (0 < count--)
			{
			try
			{
			//点对点发送(先发一条已有的点播，回复几率高一点）
			for (int i = 0; i < gateWayList.Count;i++){
			for (int i = 0; i < gateWayList.Count; i++)
			{
			FindGateWaySocket.BeginSend(new System.Net.IPEndPoint(System.Net.IPAddress.Parse(gateWayList[i].getGatewayBaseInfo.IpAddress), 7624), broadBytes);
			}
			//广播发送
			@@ -133,10 +145,7 @@
			FindGateWaySocket.BeginSend(new System.Net.IPEndPoint(broadcastIpAddress, 7624), broadBytes);
			}
			}
			catch (Exception e)
			{
			System.Console.WriteLine("===" + e.Message);
			}
			catch { }
			System.Threading.Thread.Sleep(500);
			}
			})
			@@ -171,7 +180,6 @@
			var pubKeyLengthByte1 = bytes[49 + gwNameLength + 1 + gwIdLength + 2];
			int pubKeyLength = ((pubKeyLengthByte1 & 0xff) << 8 \| (pubKeyLengthByte0 & 0xff));
			var pubKey = Encoding.UTF8.GetString(bytes, 49 + gwNameLength + 1 + gwIdLength + 2 + 1, pubKeyLength);

			var zbGateWay = new ZbGateway
			{
			getGatewayBaseInfo = new ZbGateway.GatewayBaseInfo
			@@ -192,25 +200,25 @@
			//网关匹配当前住宅中到网关
			if (Shared.Common.Config.Instance.HomeId == homeID)
			{
			gateWayList.Add(zbGateWay);
			gateWayList.Add(zbGateWay);
			}
			//UI界面正在搜索，不必配当前住宅到到网关此时也通讯
			else if (IsSearchingGateway)
			{
			gateWayList.Add(zbGateWay);
			gateWayList.Add(zbGateWay);
			}
			//网关中到住宅ID为空此时也通讯
			else if (homeID == string.Empty)
			{
			gateWayList.Add(zbGateWay);
			gateWayList.Add(zbGateWay);
			}
			}
			//网关列表存储处理
			var gateWay = GateWayList.Find(obj => obj.getGatewayBaseInfo != null && obj.getGatewayBaseInfo.gwID == zbGateWay.getGatewayBaseInfo.gwID);
			var gateWay = ZbGateway.GateWayList.Find(obj => obj.getGatewayBaseInfo != null && obj.getGatewayBaseInfo.gwID == zbGateWay.getGatewayBaseInfo.gwID);
			if (gateWay == null)
			{
			await zbGateWay.StartLocalMqtt(ipAddress);
			GateWayList.Add(zbGateWay);
			ZbGateway.GateWayList.Add(zbGateWay);
			await zbGateWay.StartLocalMqtt(ipAddress);
			NewGateWayAction?.Invoke(zbGateWay);
			}
			else
			@@ -220,11 +228,11 @@
			gateWay.GatewayOnlineFlage = true;
			if (gateWay.getGatewayBaseInfo.IpAddress != ipAddress)
			{
			gateWay.DisConnect("2");
			GateWayList.Remove(gateWay);
			await gateWay.DisConnectLocalMqttClient("2");
			ZbGateway.GateWayList.Remove(gateWay);
			gateWay = zbGateWay;
			await zbGateWay.StartLocalMqtt(ipAddress);
			GateWayList.Add(gateWay);
			ZbGateway.GateWayList.Add(gateWay);
			await zbGateWay.StartLocalMqtt(ipAddress);
			}
			else
			{
			@@ -232,15 +240,15 @@
			gateWay.getGatewayBaseInfo.Time = time;
			gateWay.getGatewayBaseInfo.GwName = gwName;
			gateWay.getGatewayBaseInfo.HomeId = homeID;
			await gateWay.StartLocalMqtt(ipAddress);
			await gateWay.StartLocalMqtt(ipAddress);
			}

			//主网关设置
			if (isMainGateWay && oldHomeID == gateWay.getGatewayBaseInfo.HomeId)
			{
			for (int i = 0; i < GateWayList.Count; i++)
			for (int i = 0; i < ZbGateway.GateWayList.Count; i++)
			{
			var gw = GateWayList[i];
			var gw = ZbGateway.GateWayList[i];
			//网关ID不是当前的网关，则把网关列表中其他网关标记为不是主网关
			if (gw.getGatewayBaseInfo.gwID != id && oldHomeID == gw.getGatewayBaseInfo.HomeId)
			{
			@@ -251,21 +259,14 @@
			gateWay.getGatewayBaseInfo.IsMainGateWay = true;
			}
			}

			}
			}
			catch (Exception ex)
			{
			var mess = ex.Message;
			}
			catch { }
			}
			#endregion
			}
			catch (Exception ex)
			{
			var mess = ex.Message;
			}
			catch { }
			System.Threading.Thread.Sleep(500);

			}
			})
			{ IsBackground = true }.Start();
			@@ -277,12 +278,14 @@
			{
			try
			{
			//定时检测远程连接情况
			await ZbGateway.StartRemoteMqtt();
			if (!ZbGateway.IsRemote)
			{
			System.Threading.Thread.Sleep(500);
			continue;
			}
			var gateWayList = GateWayList.FindAll(obj => obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId);
			var gateWayList = ZbGateway.GateWayList.FindAll(obj => obj.getGatewayBaseInfo.HomeId == Shared.Common.Config.Instance.HomeId);

			if (gateWayList.Count == 1)
			{
			@@ -290,28 +293,33 @@
			}
			else
			{
			for (int i = 0; i < gateWayList.Count; i++)
			if (gateWayList.Find((obj) => obj.getGatewayBaseInfo.IsMainGateWay) == null)
			{
			var gateWay = gateWayList[i];
			var info = await gateWay.GetZbGwInfoAsync();
			if (info == null \|\| info.getGwData == null)
			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;
			}
			break;
			continue;
			}
			if (info.getGwData.IsDominant == 1)
			{
			for (int j = 0; j < gateWayList.Count; j++)
			{
			if (gateWayList[i].getGatewayBaseInfo.gwID == info.getGwData.GwId)
			{
			gateWayList[i].getGatewayBaseInfo.IsMainGateWay = true;
			}
			else
			{
			gateWayList[i].getGatewayBaseInfo.IsMainGateWay = false;
			}
			}
			break;
			}
			}
			}
			}
			if (gateWayList.Find(obj => obj.getGatewayBaseInfo.IsMainGateWay == true) != null)
			{
			break;
			}
			}
			catch { }
			@@ -321,6 +329,14 @@
			{ IsBackground = true }.Start();
			}

			/// <summary>
			/// 重新搜索,注意：调用该方法,则促使全部网关的mqtt全部断开,然后重新搜索(可能会有1秒延迟)
			/// </summary>
			public static void ReSearch()
			{
			//为了那么多少万分之一的几率,这里设置成别的另一类的值
			oldHomeID = "**";
			}

			/// <summary>
			/// 接收处理UDP数据包