| | |
| | | // //Utlis.WriteLine ("回复Topic={0}", topic); |
| | | // //if (topic == $"/BusGateWayToClient/{MqttInfoConfig.Instance.CurRemoteMACInfo.clientId}/Push/NotifySqueeze") { |
| | | |
| | | // // var mMes = CommonPage.MyEncodingUTF8.GetString (e.ApplicationMessage.Payload); |
| | | // // var mMes = System.Text.Encoding.UTF8.GetString (e.ApplicationMessage.Payload); |
| | | // // //收到挤下线主题 |
| | | // // ReceiveNotifySqueezeAsync (mMes); |
| | | // //} else |
| | | |
| | | // if (topic == $"/BusGateWayToClient/{MainPage.LoginUser.ID}" + PushNotifySqueeze) |
| | | // { |
| | | // var mMes = CommonPage.MyEncodingUTF8.GetString(e.ApplicationMessage.Payload); |
| | | // var mMes = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload); |
| | | // //新挤下线主题方案 收到挤下线主题 |
| | | // ReceiveNotifySqueezeAsync(mMes); |
| | | // } |
| | |
| | | // else if (topic == $"/BusGateWayToClient/{MqttInfoConfig.Instance.CurRemoteMACInfo.macMark}/Common/CheckGateway") |
| | | // { |
| | | |
| | | // var ss = CommonPage.MyEncodingUTF8.GetString(e.ApplicationMessage.Payload); |
| | | // var ss = System.Text.Encoding.UTF8.GetString(e.ApplicationMessage.Payload); |
| | | // ReceiveCheckGateway(ss); |
| | | // } |
| | | // else |
| | |
| | | // break; |
| | | // case 4://发布新方案的挤下线主题 |
| | | // topicName = $"/BusGateWayToClient/{MainPage.LoginUser.ID}" + PushNotifySqueeze; |
| | | // //message = CommonPage.MyEncodingUTF8.GetBytes (PushSignStr); |
| | | // //message = System.Text.Encoding.UTF8.GetBytes (PushSignStr); |
| | | // await RemoteMqttClient.PublishAsync(new MqttApplicationMessage { Topic = topicName, Payload = message, Retain = false, QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce }); |
| | | // break; |
| | | // } |