| | |
| | | { |
| | | MqttInfoConfig.Current.IfGetMqttInfoSuccess = false; |
| | | } |
| | | Control.Ins.GatewayOnline_Cloud = Control.Ins.GatewayOnline_Local = false; |
| | | //Control.Ins.GatewayOnline_Cloud = Control.Ins.GatewayOnline_Local = false; |
| | | await DisConnectRemoteMqttClient(s); |
| | | } |
| | | |
| | |
| | | new System.Threading.Thread(async () => { |
| | | while (true) |
| | | { |
| | | if (!UserInfo.Current.IsLogin) |
| | | { |
| | | return; |
| | | } |
| | | try |
| | | { |
| | | System.Threading.Thread.Sleep(2000); |
| | |
| | | { |
| | | var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey); |
| | | var revString = Encoding.UTF8.GetString(bytes); |
| | | MainPage.Log($"mqtt 状态更新:{revString}"); |
| | | //MainPage.Log($"mqtt 状态更新:{revString}"); |
| | | Control.Ins.UpdataFunctionStatus(revString, null, true); |
| | | //Control.Ins.MsgInfoList.Add($"mqtt 状态更新:{revString}"); |
| | | //Control.Ins.MsgInfoList.Add(revString + "\r\n"); |