| | |
|---|
| | | Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.RegionID}/app/thing/property/send", |
|---|
| | | QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce |
|---|
| | | }; |
|---|
| | | //设备入网上报主题(目前只有红外宝) |
|---|
| | | var topicFilterPush3 = new MqttTopicFilter() |
|---|
| | | { |
|---|
| | | Topic = $"/user/{DB_ResidenceData.Instance.CurrentRegion.RegionID}/app/thing/topo/found", |
|---|
| | | QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce |
|---|
| | | }; |
|---|
| | | |
|---|
| | | Utlis.WriteLine("开始订阅！"); |
|---|
| | | var result = await RemoteMqttClient.SubscribeAsync(new MqttTopicFilter[] { topicFilterPush2, topicAlinkStatus }); |
|---|
| | | var result = await RemoteMqttClient.SubscribeAsync(new MqttTopicFilter[] { topicFilterPush2, topicAlinkStatus, topicFilterPush3 }); |
|---|
| | | if (result.Items[0].ResultCode == MQTTnet.Client.Subscribing.MqttClientSubscribeResultCode.GrantedQoS0) |
|---|
| | | { |
|---|
| | | isSubscribeSuccess = true; |
|---|
| | |
|---|
| | | { |
|---|
| | | var bytes = Securitys.EncryptionService.AesDecryptPayload(e.ApplicationMessage.Payload, tuyaEncryptKey); |
|---|
| | | var revString = Encoding.UTF8.GetString(bytes); |
|---|
| | | Control.Ins.UpdataFunctionStatus(revString, null); |
|---|
| | | Control.Ins.UpdataFunctionStatus(revString, null,true); |
|---|
| | | } |
|---|
| | | //一端口数据解析 |
|---|
| | | else |
|---|
