//using System;
|
//using MQTTnet.Client;
|
//using System.Threading.Tasks;
|
//using Shared;
|
//using MQTTnet;
|
//using System.Text;
|
//using HDL_ON.Entity;
|
|
//namespace HDL_ON.DAL.Mqtt
|
//{
|
// public static class Mqtt_Cloud
|
// {
|
// static string mqttEncryptKey = "";
|
// static string checkGatewayTopicBase64 = "";
|
// static RemoteMACInfo CurRemoteMACInfo = null;
|
|
// /// <summary>
|
// /// 手机标识
|
// /// </summary>
|
// static Guid currentGuid = Guid.NewGuid();
|
|
// /// <summary>
|
// /// 外网的MQTT是否正在连接
|
// /// </summary>
|
// /// <summary>
|
// /// 远程MqttClient
|
// /// </summary>
|
// /// <summary>
|
// /// 远程MqttClient
|
// /// </summary>
|
// public static IMqttClient RemoteMqttClient = new MqttFactory().CreateMqttClient();
|
|
// static bool thisShowTip = true;
|
// //static string mqttRequestParToken="";
|
// /// <summary>
|
// /// 推送标识
|
// /// </summary>
|
// static string PushSignStr = System.DateTime.Now.Ticks.ToString();
|
|
// /// <summary>
|
// /// 断开远程Mqtt的链接
|
// /// </summary>
|
// public static async Task DisConnectRemoteMqttClient(string s = "")
|
// {
|
// try
|
// {
|
// if (remoteIsConnected)
|
// {
|
// remoteIsConnected = false;
|
// MainPage.Log($"Remote主动断开_{s}");
|
// //await RemoteMqttClient.DisconnectAsync(new MQTTnet.Client.Disconnecting.MqttClientDisconnectOptions { }, CancellationToken.None);
|
// await RemoteMqttClient.DisconnectAsync();
|
// }
|
// }
|
// catch (Exception e)
|
// {
|
// System.Console.WriteLine($"Remote断开通讯连接出异常:{e.Message}");
|
// }
|
// }
|
// static DateTime dateTime = DateTime.MinValue;
|
// /// <summary>
|
// /// 外网的MQTT是否正在连接
|
// /// </summary>
|
// static bool remoteMqttIsConnecting;
|
// static bool remoteIsConnected;
|
|
// static Mqtt_Cloud()
|
// {
|
// InitMqtt();
|
// }
|
|
// public static bool IsInitMqtt = false;
|
|
// static void InitMqtt()
|
// {
|
// new System.Threading.Thread(async () => {
|
// while (true)
|
// {
|
// try
|
// {
|
// System.Threading.Thread.Sleep(1000);
|
// if (!MainPage.IsRemote) continue;
|
|
// await StartCloudMqtt();
|
// await SubscribeTopics();
|
// }
|
// catch { }
|
// }
|
// })
|
// { IsBackground = true }.Start();
|
// }
|
|
// static bool isSubscribeSuccess;
|
// static async Task SubscribeTopics()
|
// {
|
// if (remoteIsConnected && !isSubscribeSuccess)
|
// {
|
// try
|
// {
|
// var topicFilter1 = new TopicFilter { QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Topic = $"/BusGateWayToClient/{CurRemoteMACInfo.macMark}/NotifyBusGateWayInfoChange" };
|
// var topicFilter2 = new TopicFilter { QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce, Topic = $"/BusGateWayToClient/{CurRemoteMACInfo.macMark}/Common/#" };
|
// var topicFilter3 = new TopicFilter { QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.ExactlyOnce, Topic = $"/BusGateWayToClient/{CurRemoteMACInfo.clientId}/Push/NotifySqueeze" };
|
// var result = await RemoteMqttClient.SubscribeAsync(new TopicFilter[] { topicFilter1, topicFilter2, topicFilter3 });
|
// if (result.Items[0].ResultCode == MQTTnet.Client.Subscribing.MqttClientSubscribeResultCode.GrantedQoS2)
|
// {
|
// isSubscribeSuccess = true;
|
// }
|
// }
|
// catch { }
|
// }
|
// }
|
// /// <summary>
|
// /// 启动远程Mqtt
|
// /// </summary>
|
// public static async Task StartCloudMqtt()
|
// {
|
// //追加：没有远程连接的权限
|
// if (remoteMqttIsConnecting
|
// || remoteIsConnected || ! UserInfo.Current.IsLogin)
|
// {
|
// return;
|
// }
|
|
// await Task.Factory.StartNew(async () => {
|
// //try {
|
// lock (RemoteMqttClient)
|
// {
|
// //表示后面将进行连接
|
// remoteMqttIsConnecting = true;
|
|
// #region 初始化远程Mqtt
|
// //(3)当[连接云端的Mqtt成功后]或者[以及后面App通过云端Mqtt转发数据给网关成功后],处理接收到云端数据包响应时在mqttServerClient_ApplicationMessageReceived这个方法处理
|
// if (RemoteMqttClient.ApplicationMessageReceivedHandler == null)
|
// {
|
// RemoteMqttClient.UseApplicationMessageReceivedHandler((e) => {
|
// try
|
// {
|
// var topic = e.ApplicationMessage.Topic;
|
// //Console.WriteLine ("回复Topic={0}", topic);
|
// if (topic == $"/BusGateWayToClient/{CurRemoteMACInfo.clientId}/Push/NotifySqueeze")
|
// {
|
// var mMes = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
|
// //收到挤下线主题
|
// ReceiveNotifySqueezeAsync(mMes);
|
// }
|
// else if (topic == $"/BusGateWayToClient/{CurRemoteMACInfo.macMark}/NotifyBusGateWayInfoChange")
|
// {
|
// //网关上线，需要更新aeskey
|
// //收到网关上线消息主题
|
// //ReceiveNotifyBusGateWayInfoChange();
|
// }
|
// else if (topic == $"/BusGateWayToClient/{CurRemoteMACInfo.macMark}/Common/CheckGateway")
|
// {
|
// var ss = Encoding.UTF8.GetString(e.ApplicationMessage.Payload);
|
// ReceiveCheckGateway(ss);
|
// }
|
// else
|
// {
|
// var packet = new Packet();
|
|
// if (!string.IsNullOrEmpty(mqttEncryptKey))
|
// {
|
// packet.Bytes = Shared.Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, mqttEncryptKey);
|
// }
|
// else
|
// {
|
// packet.Bytes = e.ApplicationMessage.Payload;
|
// }
|
// packet.Manager();
|
// }
|
// }
|
// catch { }
|
// });
|
// }
|
|
// if (RemoteMqttClient.DisconnectedHandler == null)
|
// {
|
// RemoteMqttClient.UseDisconnectedHandler(async (e) => {
|
// System.Console.WriteLine($"远程连接断开");
|
// isSubscribeSuccess = false;
|
// await DisConnectRemoteMqttClient("StartRemoteMqtt.DisconnectedHandler");
|
// if (MainPage.IsRemote)
|
// {
|
// Application.RunOnMainThread(() => {
|
// //远程连接成功
|
// });
|
// }
|
// });
|
// }
|
// if (RemoteMqttClient.ConnectedHandler == null)
|
// {
|
// RemoteMqttClient.UseConnectedHandler(async (e) => {
|
// System.Console.WriteLine($"远程连接成功");
|
// MainPage.IsRemote = true;
|
// Application.RunOnMainThread(() => {
|
// //远程连接成功
|
// MainPage.IsRemote = true;
|
// });
|
// //刷新状态
|
// if (CurRemoteMACInfo != null)
|
// {
|
// if (CurRemoteMACInfo.isValid == "InValid")
|
// {
|
// //远程失败
|
// MainPage.IsRemote = false;
|
// }
|
// else
|
// {
|
// MqttRemoteSend(new byte[] { 0 }, 3);
|
// }
|
// }
|
// });
|
// }
|
// #endregion
|
// }
|
|
// try
|
// {
|
|
// //--第一步：获取mqtt链接参数 提交MAC 服务器自动判断是否为新网关，返回是否需要自动切换远程连接的服务器
|
// var mqttInfoRequestPar = new RemoteRequestParameters()
|
// {
|
// PlatformStr = "ON",
|
// LoginAccessToken = UserInfo.Current.loginTokenString,
|
// RequestVersion = MainPage.VersionString,
|
// RequestProtocolType = 0,
|
// RequestSource = 1,
|
// HdlGatewayGatewayType = 0,
|
// PublishPayloadJsonStr = PushSignStr,
|
// Mac = HDL_ON.Entity.DB_ResidenceData.residenceData.residenceGatewayMAC,
|
// };
|
// var jsonString = Newtonsoft.Json.JsonConvert.SerializeObject(mqttInfoRequestPar);
|
// var mqttInfoRequestResult = new HDL_ON.DAL.Server.HttpServerRequest().RequestMqttInfo(jsonString);
|
|
// if (mqttInfoRequestResult != null && mqttInfoRequestResult.ResponseData != null)
|
// {
|
// try
|
// {
|
// var mqttInfoRequestResult_Obj = Newtonsoft.Json.JsonConvert.DeserializeObject<MqttInfo>(mqttInfoRequestResult.ResponseData.ToString());
|
|
// if (mqttInfoRequestResult_Obj != null)
|
// {
|
// string url = mqttInfoRequestResult_Obj.connEmqDomainPort;
|
// string clientId = mqttInfoRequestResult_Obj.connEmqClientId;
|
// string username = mqttInfoRequestResult_Obj.connEmqUserName;
|
// string passwordRemote = mqttInfoRequestResult_Obj.connEmqPwd;
|
// if (mqttInfoRequestResult_Obj.AccountAllGateways != null && mqttInfoRequestResult_Obj.AccountAllGateways.Count > 0)
|
// {
|
// //----第二步找出是否存在匹配当前住宅的mac，存在再进行远程。
|
// foreach (var curRegionMac in DB_ResidenceData.residenceData.residecenInfo.homeGateways)
|
// {
|
// CurRemoteMACInfo = mqttInfoRequestResult_Obj.AccountAllGateways.Find((obj) => obj.mac == curRegionMac.GatewayUniqueId);
|
// if (CurRemoteMACInfo != null)
|
// {
|
// break;
|
// }
|
// }
|
// if (CurRemoteMACInfo != null)
|
// {
|
// CurRemoteMACInfo.LoginAccessToken = UserInfo.Current.loginTokenString;
|
// CurRemoteMACInfo.clientId = clientId;
|
// mqttEncryptKey = CurRemoteMACInfo.isNewBusproGateway ? CurRemoteMACInfo.aesKey : "";
|
|
// var options1 = new MQTTnet.Client.Options.MqttClientOptionsBuilder()
|
// .WithClientId(clientId)
|
// .WithTcpServer(url.Split(':')[1].Substring("//".Length), int.Parse(url.Split(':')[2]))
|
// .WithCredentials(username, passwordRemote)
|
// .WithCleanSession()
|
// .WithCommunicationTimeout(new TimeSpan(0, 0, 20))
|
// .Build();
|
|
// await DisConnectRemoteMqttClient("StartRemoteMqtt");
|
// await RemoteMqttClient.ConnectAsync(options1);
|
// remoteIsConnected = true;
|
// IsDisConnectingWithSendCatch = false;
|
|
// }
|
// }
|
|
// }
|
// }
|
// catch { }
|
// }
|
|
// }
|
// catch (Exception e)
|
// {
|
|
// }
|
// finally
|
// {
|
// //最终要释放连接状态
|
// remoteMqttIsConnecting = false;
|
// }
|
|
// });
|
// }
|
|
|
|
// ///// <summary>
|
// ///// 收到网关上线消息
|
// ///// </summary>
|
// //static void ReceiveNotifyBusGateWayInfoChange()
|
// //{
|
// // var gatewayListUrl = @"https://developer.hdlcontrol.com/Center/Center/GetGatewayPagger"; //App、Buspro软件登录后获取网关列表 http 请求
|
// // var gatewayListRequestPar = new RemoteRequestParameters() { Mac = CurRemoteMACInfo.mac, LoginAccessToken = UserInfo.Current.loginTokenString, RequestVersion = "RequestVersion1", RequestProtocolType = 0, RequestSource = 1 };
|
// // var gatewayListRequestResult = MainPage.RequestHttps("", Newtonsoft.Json.JsonConvert.SerializeObject(gatewayListRequestPar), false, false, gatewayListUrl);
|
// // var gatewayListRequestResult_Obj = Newtonsoft.Json.JsonConvert.DeserializeObject<MqttRemoteInfo>(gatewayListRequestResult.ResponseData.ToString());
|
// // if (gatewayListRequestResult_Obj != null && gatewayListRequestResult_Obj.pageData.Count > 0)
|
// // {
|
// // CurRemoteMACInfo.aesKey = gatewayListRequestResult_Obj.pageData[0].aesKey;
|
// // mqttEncryptKey = CurRemoteMACInfo.isNewBusproGateway ? CurRemoteMACInfo.aesKey : "";
|
// // }
|
// //}
|
|
// /// <summary>
|
// /// 收到挤下线推送
|
// /// </summary>
|
// static void ReceiveNotifySqueezeAsync(string mMes)
|
// {
|
// if (mMes == PushSignStr) return;//是自己的登录推送不处理
|
// //断开远程连接
|
// MainPage.IsRemote = false;
|
// if (! UserInfo.Current.IsLogin)
|
// {
|
// return;
|
// }
|
// UserInfo.Current.lastTime = DateTime.MinValue;
|
// UserInfo.Current.SaveUserInfo();
|
|
// string oldRegionRootPath = FileUtils.CreateRegionBackup(DB_ResidenceData.residenceData.CurReginID.ToString());
|
// new System.Threading.Thread(() =>
|
// {
|
// try
|
// {
|
// var backuplist = FileUtils.ReadFiles();
|
// FileUtils.DeleteRegionFiles(oldRegionRootPath);
|
// //移动文件
|
// foreach (var fileName in backuplist)
|
// {
|
// System.IO.FileInfo fileInfo = new System.IO.FileInfo(FileUtils.RootPath + fileName);
|
// if (fileName == "headImage.png")
|
// {
|
// continue;
|
// }
|
// if (fileInfo.Exists)
|
// {
|
// fileInfo.MoveTo(oldRegionRootPath + fileName);
|
// MainPage.Log("move file : " + fileName);
|
// }
|
// }
|
// //删除本地文件
|
// foreach (var fileName in backuplist)
|
// {
|
// if (fileName == "headImage.png")
|
// {
|
// continue;
|
// }
|
// FileUtils.DeleteFile(fileName);
|
// }
|
// }
|
// catch (Exception ex)
|
// {
|
// MainPage.Log(ex.Message);
|
// }
|
// finally
|
// {
|
// }
|
// })
|
// { IsBackground = true }.Start();
|
|
|
// //删除推送数据
|
// DisConnectRemoteMqttClient("挤下线");
|
// Application.RunOnMainThread(() =>
|
// {
|
// MainPage.GoLoginPage( UserInfo.Current);
|
// });
|
// }
|
|
// /// <summary>
|
// /// 收到CheckGateway主题
|
// /// </summary>
|
// static void ReceiveCheckGateway(string mMes)
|
// {
|
// var obj = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponsePack>(mMes);
|
// if (obj == null)
|
// {
|
// return;
|
// }
|
// switch (obj.StateCode)
|
// {
|
// case "HDLUdpDataForwardServerMqttClientNoOnLine":
|
// case "NoOnline":
|
// case "NetworkAnomaly"://不在线
|
// Application.RunOnMainThread(() =>
|
// {
|
// new HDL_ON.UI.PublicAssmebly().TipMsgAutoClose(Language.StringByID(StringId.RemoteFailedGatewayOffline), true);
|
// });
|
// break;
|
// case "NoRecord"://MAC不正确
|
// Application.RunOnMainThread(() => {
|
// new HDL_ON.UI.PublicAssmebly().TipMsgAutoClose(Language.StringByID(StringId.MACError), true);
|
// });
|
// break;
|
// case "Success":
|
// break;
|
// default:
|
// Application.RunOnMainThread(() => {
|
// new HDL_ON.UI.PublicAssmebly().TipMsgAutoClose(Language.StringByID(StringId.LinkLoser), true);
|
// });
|
// break;
|
// }
|
|
// }
|
|
// /// <summary>
|
// ///
|
// /// </summary>
|
// /// <param name="message">附加数据包</param>
|
// /// <param name="optionType">操作类型：0=网关控制；1=订阅网关数据;2=订阅网关上线数据</param>
|
// /// <returns></returns>
|
// public static async Task MqttRemoteSend(byte[] message, int optionType = 0)
|
// {
|
// try
|
// {
|
// string topicName;
|
// switch (optionType)
|
// {
|
// case 0:
|
// topicName = $"/ClientToBusGateWay/{CurRemoteMACInfo.macMark}/Common/ON";
|
// if (!string.IsNullOrEmpty(mqttEncryptKey))
|
// {
|
// message = Shared.Securitys.EncryptionService.AesEncryptPayload(message, mqttEncryptKey);
|
// }
|
// await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicName, Payload = message, Retain = false, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce });
|
// break;
|
// case 3:
|
// topicName = $"/ClientToBusGateWay/{CurRemoteMACInfo.macMark}/Common/CheckGateway";
|
// Console.WriteLine("CheckGateway");
|
// await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicName, Retain = false, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce });
|
// break;
|
// }
|
// }
|
// catch (Exception e)
|
// {
|
// //System.Console.WriteLine ($"============>Mqtt MqttRemoteSend catch");
|
// if (!IsDisConnectingWithSendCatch)
|
// {
|
// IsDisConnectingWithSendCatch = true;
|
// await DisConnectRemoteMqttClient("SendCatch");
|
// }
|
// }
|
// }
|
// /// <summary>
|
// /// SendCatch 后执行一次断开操作
|
// /// </summary>
|
// static bool IsDisConnectingWithSendCatch = false;
|
|
// }
|
//}
|
