| | |
|---|
| | | new System.Threading.Thread(async () => { |
|---|
| | | while (true) |
|---|
| | | { |
|---|
| | | if (!UserInfo.Current.IsLogin) |
|---|
| | | { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | try |
|---|
| | | { |
|---|
| | | System.Threading.Thread.Sleep(2000); |
|---|
| | |
|---|
| | | |
|---|
| | | await StartCloudMqtt(); |
|---|
| | | await SubscribeTopics(); |
|---|
| | | |
|---|
| | | } |
|---|
| | | catch { } |
|---|
| | | } |
|---|
| | |
|---|
| | | //SetGatewayOnlineResetCheck(); |
|---|
| | | //var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, mqttEncryptKey); |
|---|
| | | //bus数据解析 |
|---|
| | | var packet = new Packet(); |
|---|
| | | var packet = new Packet(e.ApplicationMessage.Payload.Length); |
|---|
| | | |
|---|
| | | if (!string.IsNullOrEmpty(DB_ResidenceData.Instance.HomeGateway.aesKey)) |
|---|
| | | { |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | MqttInfoConfig.Current.mMqttInfo = mqttInfoRequestResult_Obj; |
|---|
| | | await MQTTConnectAsync(); |
|---|
| | | //await MQTTConnectAsync(); |
|---|
| | | //1.判断是否绑定了网关，获取网关远程连接的加密KEY |
|---|
| | | //if (DB_ResidenceData.Instance.CheckWhetherGatewayIsBound()) |
|---|
| | | { |
|---|
