From c7c07eaa32ca7b137b1ac028d17beee0ebcf9a0b Mon Sep 17 00:00:00 2001 From: mac <user@users-MacBook-Pro.local> Date: 星期二, 26 三月 2024 15:22:15 +0800 Subject: [PATCH] 2024年03月26日15:22:09 --- app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java | 30 ++++++++++++++++-------------- 1 files changed, 16 insertions(+), 14 deletions(-) diff --git a/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java b/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java index db93bb2..1ee7d7c 100644 --- a/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java +++ b/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java @@ -92,7 +92,7 @@ this.initMqttClient(); //涓婁紶鏋佸厜娉ㄥ唽ID鍒颁簯绔� this.pushTokens(); -// //鐐瑰嚮鏋佸厜閫氱煡鏍忔秷鎭繘鏉� + //鐐瑰嚮鏋佸厜閫氱煡鏍忔秷鎭繘鏉� this.clickJpushNotificationMessage(); //鍒濆鍖栨潈闄� this.requestPermissions(); @@ -109,6 +109,7 @@ //鐐瑰嚮鏋佸厜閫氱煡鏍忔秷鎭繘鏉� // this.clickJpushNotificationMessage(); } + /** * 涓婁紶鏋佸厜娉ㄥ唽ID鍒颁簯绔� @@ -395,21 +396,22 @@ * 鍒濆鍖杕qtt瀹㈡埛绔� */ public void initMqttClient() { - - HdlMqttLogic.getInstance().getMqttRemoteInfo(HomeType.A, new CloudCallBeak<MqttInfo>() { - @Override - public void onSuccess(MqttInfo info) { - if (info != null) { - MqttRecvClient.getInstance().setConnectParam(info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord()); - MqttRecvClient.getInstance().connect(); + if (!MqttRecvClient.getInstance().isInit()) { + HdlMqttLogic.getInstance().getMqttRemoteInfo(HomeType.A, new CloudCallBeak<MqttInfo>() { + @Override + public void onSuccess(MqttInfo info) { + if (info != null) { + MqttRecvClient.getInstance().setConnectParam(info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord()); + MqttRecvClient.getInstance().connect(); + } } - } - @Override - public void onFailure(HDLException e) { - HdlLogLogic.print("璇诲彇mqtt杩滅▼淇℃伅澶辫触--->" + e.getMessage(), e.getCode(), true); - } - }); + @Override + public void onFailure(HDLException e) { + HdlLogLogic.print("璇诲彇mqtt杩滅▼淇℃伅澶辫触--->" + e.getMessage(), e.getCode(), true); + } + }); + } } @Subscribe(threadMode = ThreadMode.MAIN) -- Gitblit v1.8.0