From 6e418105015e0ca91fe2240bb4a3584fd165ddd7 Mon Sep 17 00:00:00 2001 From: mac <user@users-MacBook-Pro.local> Date: 星期二, 10 十月 2023 17:28:23 +0800 Subject: [PATCH] 2023年10月10日17:28:19 --- app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java | 32 +++++++++++++++++++++++++++++++- 1 files changed, 31 insertions(+), 1 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 491be13..e66f382 100644 --- a/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java +++ b/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java @@ -9,16 +9,23 @@ import android.view.View; import com.google.gson.Gson; +import com.hdl.linkpm.sdk.core.exception.HDLException; +import com.hdl.linkpm.sdk.home.type.HomeType; import com.hdl.photovoltaic.R; import com.hdl.photovoltaic.base.CustomBaseActivity; +import com.hdl.photovoltaic.bean.MqttInfo; import com.hdl.photovoltaic.databinding.ActivityMyPowerStationBinding; +import com.hdl.photovoltaic.listener.CloudCallBeak; import com.hdl.photovoltaic.other.HdlLogLogic; +import com.hdl.photovoltaic.other.HdlMqttLogic; import com.hdl.photovoltaic.other.HdlUniLogic; import com.hdl.photovoltaic.uni.HDLUniMP; import com.hdl.photovoltaic.utils.PermissionUtils; import com.hdl.sdk.link.HDLLinkLocalSdk; import com.hdl.sdk.link.common.event.EventListener; import com.hdl.sdk.link.core.bean.ModbusResponse; +import com.hdl.sdk.link.core.utils.mqtt.MqttRecvClient; + /** * 鎴戠殑鐢电珯鐣岄潰 @@ -46,6 +53,10 @@ initEvent(); //娉ㄥ唽鐩戝惉 registerAllTopicsListener(); + //鍒濆鍖杕qtt瀹㈡埛绔� + initMqttClient(); + + } private void initEvent() { @@ -85,7 +96,7 @@ private void initView() { viewBinding.myPowerStationBottomIl1.titleTv.setText(R.string.my_power_station_title); - viewBinding.myMessageBottomIl2.titleTv.setText(R.string.message_娑堟伅); + viewBinding.myMessageBottomIl2.titleTv.setText(R.string.message); viewBinding.myMeBottomIl3.titleTv.setText(R.string.my_power_station_me); this.bottomViewChangeOfStyle(); @@ -196,5 +207,24 @@ HDLLinkLocalSdk.getInstance().registerAllTopicsListener(allTopicsListener); } + /** + * 鍒濆鍖杕qtt瀹㈡埛绔� + */ + public void initMqttClient() { + HdlMqttLogic.getInstance().getMqttRemoteInfo(HomeType.A, new CloudCallBeak<MqttInfo>() { + @Override + public void onSuccess(MqttInfo info) { + if (info != null) { + MqttRecvClient.init(_mActivity, info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord()); + } + } + + @Override + public void onFailure(HDLException e) { + HdlLogLogic.print("璇诲彇mqtt杩滅▼淇℃伅澶辫触", e.getMessage(), e.getCode()); + } + }); + } + } \ No newline at end of file -- Gitblit v1.8.0