| | |
|---|
| | | try |
|---|
| | | { |
|---|
| | | var topic = e.ApplicationMessage.Topic; |
|---|
| | | //MainPage.Log($"收到mqtt主题:{topic}"); |
|---|
| | | MainPage.Log($"收到mqtt主题:{topic}"); |
|---|
| | | //一端口主题处理 |
|---|
| | | if (DB_ResidenceData.Instance.GatewayType == 0 && !DB_ResidenceData.Instance.CheckWhetherGatewayIdIsNull()) |
|---|
| | | { |
|---|
| | |
|---|
| | | else if (topic == $"/user/{DB_ResidenceData.Instance.CurrentRegion.id}/app/thing/event/appHomeRefresh/up") |
|---|
| | | { |
|---|
| | | MainPage.Log("住宅数据刷新通知"); |
|---|
| | | System.Threading.Thread.Sleep(2000); |
|---|
| | | new HttpServerRequest().GetHomePager(); |
|---|
| | | } |
|---|
| | | //appRoomRefresh：房间数据刷新通知 |
|---|
| | |
|---|
| | | } |
|---|
| | | catch (Exception ex) |
|---|
| | | { |
|---|
| | | Utlis.WriteLine($"error:" + ex.Message); |
|---|
| | | Utlis.WriteLine($"mqtt连接异常 error:" + ex.Message); |
|---|
| | | //mqtt连接异常，清空本地mqtt信息，可能需要重新获取：wxr |
|---|
| | | MqttInfoConfig.Current.Refresh(); |
|---|
| | | } |
|---|
| | |
|---|
| | | static void ReceiveNotifySqueezeAsync(string mMes) |
|---|
| | | { |
|---|
| | | #if DEBUG |
|---|
| | | return; |
|---|
| | | //return; |
|---|
| | | #endif |
|---|
| | | if (mMes == PushSignStr) return;//是自己的登录推送不处理//或者当前不是远程链接状态 |
|---|
| | | //测试账号，不挤下线 |
|---|
