| | |
| | | System.Threading.Thread.Sleep (200); |
| | | if (!CommonPage.IsRemote) continue; |
| | | |
| | | if (Control.IsEnterBackground) continue; |
| | | |
| | | await StartCloudMqtt (); |
| | | await CheckingSubscribeTopics (); |
| | | } catch { } |
| | |
| | | } catch (Exception ex) { |
| | | //Utlis.WriteLine ($"============>Mqtt 远程连接通讯连接出异常:{ex.Message}"); |
| | | |
| | | MainPage.LoadingSetText ("Connect error, trying to reconnect."); |
| | | MainPage.LoadingTipShow ("Connect error, trying to reconnect."); |
| | | |
| | | if (IfDEBUG) { |
| | | MainPage.ShowAlertOnMainThread ("error: " + ex.Message); |
| | |
| | | //最终要释放连接状态 |
| | | remoteMqttIsConnecting = false; |
| | | |
| | | MainPage.LoadingHide (); |
| | | MainPage.LoadingTipHide (); |
| | | |
| | | //MainPage.LoadingHide (); |
| | | } |
| | | }); |
| | | } |
| | |
| | | } else { |
| | | //Utlis.WriteLine ("============>Mqtt CurRemoteMACInfo null"); |
| | | |
| | | MainPage.LoadingSetText ("Please wait, failed to get gateway parameters."); |
| | | MainPage.LoadingTipShow ("Please wait, failed to get gateway parameters."); |
| | | } |
| | | } |
| | | |
| | | } else { |
| | | //Utlis.WriteLine ("============>Mqtt mqttInfoRequestResult_Obj null"); |
| | | |
| | | MainPage.LoadingSetText ("Please wait, failed to get user parameters."); |
| | | //MainPage.LoadingSetText ("Please wait, failed to get parameters."); |
| | | MainPage.LoadingTipShow ("Please wait, failed to get user parameters."); |
| | | //MainPage.LoadingTipShow ("Please wait, failed to get parameters."); |
| | | } |
| | | } catch { |
| | | |
| | |
| | | } else { |
| | | //Utlis.WriteLine ("============>Mqtt GetInfo 失败"); |
| | | MainPage.AddTip ("Please wait, failed to get parameters."); |
| | | //MainPage.LoadingSetText ("Please wait, failed to get parameters."); |
| | | //MainPage.LoadingTipShow ("Please wait, failed to get parameters."); |
| | | } |
| | | |
| | | } |
| | |
| | | //--第二步:获取当前住分享宅网关信息并连接MQTT |
| | | await GetSingleHomeGatewayPaggerAndMQTTConnectAsync (); |
| | | } else { |
| | | MainPage.LoadingSetText ("Please wait, failed to get user parameters."); |
| | | MainPage.LoadingTipShow ("Please wait, failed to get user parameters."); |
| | | } |
| | | } |
| | | } |
| | |
| | | //获取参数成功,开始连接... |
| | | //MainPage.AddTip ("Successfully obtained parameters, starting to connect..."); |
| | | |
| | | MainPage.LoadingStart ("Please wait, connecting remotely..."); |
| | | MainPage.LoadingTipShow ("Please wait, connecting remotely..."); |
| | | |
| | | //try { |
| | | // var url = mMqttInfo.connEmqDomainPort; |
| | |
| | | remoteIsConnected = true; |
| | | IsDisConnectingWithSendCatch = false; |
| | | |
| | | MainPage.LoadingSetText ("Remote connection succeeded."); |
| | | MainPage.LoadingTipShow ("Remote connection succeeded."); |
| | | |
| | | //MainPage.AddTip ("Connection succeeded!"); |
| | | //await MqttRemoteSend (new byte [] { 0 }, 1); |
| | |
| | | //options1 异常提示 |
| | | //Console.WriteLine ("Connect error: " + ex.Message); |
| | | |
| | | MainPage.LoadingSetText ("Connect error."); |
| | | MainPage.LoadingTipShow ("Connect error."); |
| | | |
| | | if (IfDEBUG) { |
| | | MainPage.ShowAlertOnMainThread ("Connect error: " + ex.Message); |
| | |
| | | bNeedStartTip = false; |
| | | if (CommonPage.IsRemote) { |
| | | //MainPage.AddTip ("Getting remote connection parameters..."); |
| | | MainPage.LoadingStart ("Please wait, getting connection parameters..."); |
| | | MainPage.LoadingTipShow ("Please wait, getting connection parameters..."); |
| | | } |
| | | } |
| | | } |
| | |
| | | CurRemoteMACInfo.aesKey = mGatewayRes.AesKey; |
| | | mqttEncryptKey = CurRemoteMACInfo.aesKey; |
| | | } else { |
| | | MainPage.LoadingSetText ("Please wait, failed to get gateway parameters."); |
| | | MainPage.LoadingTipShow ("Please wait, failed to get gateway parameters."); |
| | | } |
| | | |
| | | } |