| | |
| | | /// </summary> |
| | | public static async Task StartCloudMqtt() |
| | | { |
| | | if (OnAppConfig.Instance.internetStatus == 0) |
| | | if (MainPage.InternetStatus == 0) |
| | | { |
| | | return; |
| | | } |
| | |
| | | else |
| | | { |
| | | SetGatewayOnlineResetCheck(); |
| | | Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, DB_ResidenceData.residenceData.HomeGateway.aesKey); |
| | | var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, DB_ResidenceData.residenceData.HomeGateway.aesKey); |
| | | |
| | | //bus数据解析 |
| | | if (DB_ResidenceData.residenceData.GatewayType == 0) |
| | | { |
| | |
| | | else |
| | | { |
| | | //A协议数据处理 |
| | | var revString = Encoding.UTF8.GetString(e.ApplicationMessage.Payload); |
| | | var revString = Encoding.UTF8.GetString(bytes); |
| | | Control.Ins.UpdataFunctionStatus(revString); |
| | | } |
| | | } |
| | |
| | | if (RemoteMqttClient.ConnectedHandler == null) |
| | | { |
| | | RemoteMqttClient.UseConnectedHandler(async (e) => { |
| | | Control.Ins.GatewayOnline = true; |
| | | IfNeedReadAllDeviceStatus = true; |
| | | Utlis.WriteLine($"============>Mqtt远程连接成功"); |
| | | SendPushSignOut(); |