派生自 ~xm/HomeApp
ZigbeeApp/Shared/Phone/ZigBee/Device/ZbGateway.cs
@@ -60,6 +60,12 @@ /// <value><c>true</c> if is remote; otherwise, <c>false</c>.</value> public static bool IsRemote; /// <summary> /// 是否拥有远程连接的权限 /// </summary> [Newtonsoft.Json.JsonIgnore] public static bool AllowRemoteCtrl = true; /// <summary> /// 网关保存路径 /// </summary> @@ -95,7 +101,7 @@ } } #region variable #region variable /// <summary> /// 远程连接成功时的时间 /// </summary> @@ -218,6 +224,7 @@ /// <para>第一个参数：如果为 DDevice/IsGetEpointInfo:有新设备加入zigbee网络反馈</para>设备请求APP获取升级数据 /// <para>第一个参数：如果为 Device/DeviceJoinZbNet:获取新设备所有端点信息是否成功反馈</para> /// <para>第一个参数：如果为 DeviceRequestAcUpdateData: 设备请求空调发升级数据</para> /// "已经通知");//已经通知"); /// </summary> [Newtonsoft.Json.JsonIgnore] public Action<string, object> ReportAction; @@ -603,7 +610,8 @@ var jObject = new JObject { { "Cluster_ID", 0 }, { "Command", 82 } }; 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 { } @@ -3177,7 +3185,7 @@ .WithTcpServer(brokerName, 1883) .WithKeepAlivePeriod(TimeSpan.FromSeconds(20)) .WithCleanSession() .WithCommunicationTimeout(TimeSpan.FromSeconds(4)) //.WithCommunicationTimeout(TimeSpan.FromSeconds(10)) .WithCredentials("", "") .Build(); await localMqttClient.ConnectAsync(options, CancellationToken.None); @@ -3228,6 +3236,11 @@ /// <returns></returns> static async System.Threading.Tasks.Task initGateWayBaseInfomation() { if (AllowRemoteCtrl == false) { //没有远程连接的权限 return; } string loginToken = Config.Instance.Token; if (Config.Instance.Home.IsOthreShare == true) { @@ -3270,11 +3283,13 @@ var statuCode = jobject["StateCode"].ToString(); if (statuCode != "Success") { //Log出力 Shared.Phone.UserCenter.HdlLogLogic.Current.WriteLog(-1, "接口访问失败★：App/GetSingleHomeGatewayPagger " + statuCode); //序列化对象 var requestJson = Newtonsoft.Json.JsonConvert.SerializeObject(pra2); Shared.Phone.UserCenter.HdlLogLogic.Current.WriteLog(-1, "参数：\r\n" + requestJson); //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"]; @@ -3310,7 +3325,7 @@ /// 远程MqttClient /// </summary> public static IMqttClient RemoteMqttClient= new MqttFactory().CreateMqttClient(); static bool remoteIsConnected; static bool remoteIsConnected; private int IsLogin = 0; [Newtonsoft.Json.JsonIgnore] static Action actionTemp; @@ -3322,10 +3337,12 @@ /// <param name="brokerName">Broker name.</param> public static async System.Threading.Tasks.Task StartRemoteMqtt() { if (remoteMqttIsConnecting || !Shared.Common.Config.Instance.IsLogin || Shared.Common.Config.Instance.HomeId == "" || remoteIsConnected) //追加：没有远程连接的权限 if (AllowRemoteCtrl == false || remoteMqttIsConnecting || !Shared.Common.Config.Instance.IsLogin || Shared.Common.Config.Instance.HomeId == "" || remoteIsConnected) { return; } @@ -3358,7 +3375,7 @@ { DebugPrintLog($"远程连接断开"); await DisConnectRemoteMqttClient("StartRemoteMqtt.DisconnectedHandler"); await StartRemoteMqtt(); //await StartRemoteMqtt(); }); } if (RemoteMqttClient.ConnectedHandler == null) @@ -3366,6 +3383,18 @@ 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.ConnEmqClientId + "/Push/NotifySqueeze"); await initGateWayBaseInfomation(); Shared.Phone.UserCenter.HdlGatewayLogic.Current.CheckGatewayByConnectChanged(Shared.Phone.UserCenter.GatewayConnectMode.Remote); //没有主网关时主动读取，获取主网关信息 @@ -3411,24 +3440,44 @@ try { var jsonData = new Dictionary<string, object> { ["RequestVersion"] = "RequestVersion", ["RequestSource"] = 0, ["LoginAccessToken"] = Config.Instance.Token, ["RequestProtocolType"] = 0 }; var bytes = System.Text.Encoding.UTF8.GetBytes(Newtonsoft.Json.JsonConvert.SerializeObject(jsonData)); var result = await CommonPage.Instance.DoRequestZigbeeHttpsInterface("https://global.hdlcontrol.com/HangZhouHdlCloudApi/EmqMqtt/GetConnMqttInfo", bytes, Config.Instance.Token); //{ //"ResponseVersion": "RequestVersion1", //"StateCode": "Success", //"ErrorInfo": null, //"ResponseData": { < !--如下信息只能使用一次，即便你连接失败!-- > // "ConnEmqDomainPort": "tcp://developer.hdlcontrol.com:1883", // "ConnEmqClientId": "ZigbeeClientTcp_33094de8-34ba-4e38-93c2-ac8da16d0e68_Zigbee", // "ConnEmqUserName": "33094de8-34ba-4e38-93c2-ac8da16d0e68", // "ConnEmqPwd": "4a265b65-d6cc-4a" //} //} 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 }; 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 }; 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; } var responseData = jobject["ResponseData"]; if (responseData != null) { @@ -3436,6 +3485,8 @@ 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]; @@ -3447,7 +3498,7 @@ .WithCredentials(connEmqUserName, connEmqPwd) .WithKeepAlivePeriod(TimeSpan.FromSeconds(20)) .WithCleanSession() .WithCommunicationTimeout(TimeSpan.FromSeconds(6)) //.WithCommunicationTimeout(TimeSpan.FromSeconds(10)) .Build(); await DisConnectRemoteMqttClient("StartRemoteMqtt"); await RemoteMqttClient.ConnectAsync(options, CancellationToken.None); @@ -3481,7 +3532,8 @@ { localIsConnected = false; DebugPrintLog($"Local主动断开_{s}"); await localMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None); //await localMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None); await localMqttClient.DisconnectAsync(); } } catch (Exception ex) @@ -3501,10 +3553,11 @@ { remoteIsConnected = false; DebugPrintLog($"Remote主动断开_{s}"); await RemoteMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None); //await RemoteMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None); await RemoteMqttClient.DisconnectAsync(); } } catch(Exception e) { catch(Exception e) { DebugPrintLog($"Remote断开通讯连接出异常:{e.Message}"); } } @@ -3601,9 +3654,7 @@ //文件流不用加密 if (topic != "FileTransfer/SendFile") { topic = ZigBee.Common.SecuritySet.AesEncrypt(System.Text.Encoding.UTF8.GetBytes(topic), Password); topic = topic.Replace("/", "[[$-MQTT_TILT_SYMBOL_REPLACE-$]]").Replace("+", "[[$-MQTT_PLUS_SYMBOL_REPLACE-$]]"); message = System.Text.Encoding.UTF8.GetBytes(SecuritySet.AesEncrypt(message, password)); message = SecuritySet.AesEncryptBytes(message, password); } } if (localIsConnected) @@ -3614,10 +3665,12 @@ } catch(Exception e) { DebugPrintLog($"Local主动断开_{e.Message}"); await DisConnectLocalMqttClient(e.Message); await StartLocalMqtt("ReConnect"); if (localIsConnected) { DebugPrintLog($"局域网——二次发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_当前网关{CurrentGateWayId} 是否加密:{IsEncry}"); await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain }); } } @@ -3644,8 +3697,58 @@ return; } 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) { try { if (Shared.Common.Config.Instance.HomeId == "") { return; } DebugPrintLog($"局域网——发送到网关的主题:{topic}_发送到网关的数据:{System.Text.Encoding.UTF8.GetString(message)}_当前网关{CurrentGateWayId} 是否加密:{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)}_当前网关{CurrentGateWayId} 是否加密:{IsEncry}"); await localMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topic, Payload = message, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Retain = retain }); } } } } catch (Exception ex) { DebugPrintLog($"Send:{ex.Message}"); } } [Serializable] public class CloudTimeResponse @@ -3664,8 +3767,7 @@ { try { var topic = e.ApplicationMessage.Topic.TrimStart('/'); topic = topic.Replace("[[$-MQTT_TILT_SYMBOL_REPLACE-$]]", "/").Replace("[[$-MQTT_PLUS_SYMBOL_REPLACE-$]]", "+"); var topic = e.ApplicationMessage.Topic.TrimStart('/'); var payload = e.ApplicationMessage.Payload; var message = string.Empty; @@ -3680,7 +3782,7 @@ { return; } if (topics[2]== "NotifyGateWayInfoChagne") { if (topics[2]== "NotifyGateWayInfoChange") { initGateWayBaseInfomation(); return; } @@ -3727,39 +3829,36 @@ { try { var topic = e.ApplicationMessage.Topic; topic = topic.Replace("[[$-MQTT_TILT_SYMBOL_REPLACE-$]]", "/").Replace("[[$-MQTT_PLUS_SYMBOL_REPLACE-$]]", "+"); var message = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload); var topic = e.ApplicationMessage.Topic; 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)); } } #if DEBUG DebugPrintLog($"网关返回的主题:{topic}_网关返回的负载:{message}_{System.DateTime.Now.ToString()}"); #endif ReceiveMessage(topic, message, e.ApplicationMessage.Payload); else { payloadString = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload); } DebugPrintLog($"网关返回的主题:{topic}_网关返回的负载:{payloadString}"); ReceiveMessage(topic, payloadString, e.ApplicationMessage.Payload); } catch (Exception ex) { #if DEBUG DebugPrintLog($"接收网关数据异常:{ex.Message}"); #endif } } @@ -3790,7 +3889,10 @@ epoint = topic.Split('/')[3]; cluID = topic.Split('/')[4]; attrId = topic.Split('/')[5]; } } //全局接收网关推送的的逻辑(为了执行速度,尽可能的别加耗时的操作) Shared.Phone.UserCenter.HdlGatewayReceiveLogic.Current.GatewayOverallMsgReceive(gatewayID, topic, reportStatus, message); var gwa = GateWayList.Find(obj => obj.getGatewayBaseInfo.gwID == gatewayID); if (gwa == null) @@ -3822,9 +3924,6 @@ { jobject = Newtonsoft.Json.Linq.JObject.Parse(message); } //全局接收网关推送的的逻辑(为了执行速度,尽可能的别加耗时的操作) Shared.Phone.UserCenter.HdlGatewayReceiveLogic.Current.GatewayOverallMsgReceive(gatewayID, topic, reportStatus, jobject); #region 远程,主网关上报通知 if (IsRemote) @@ -4268,22 +4367,18 @@ #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<ClientDataPassthroughResponseData>(jobject["Data"].ToString()); if (clientDataPassthrough != null) { DebugPrintLog("DeviceRequestAcUpdateData"); gwa.ReportAction("DeviceRequestAcUpdateData", clientDataPassthrough); } } } #endregion DebugPrintLog("网关返回数据通知"); } catch (Exception ex) {
