From a8e0bddc9903d854808e9526600128e95560faa3 Mon Sep 17 00:00:00 2001 From: mac <user@users-MacBook-Pro.local> Date: 星期一, 30 十月 2023 18:21:25 +0800 Subject: [PATCH] 2023年10月30日18:21:12 --- app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java | 105 ++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 92 insertions(+), 13 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..03ca70c 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,34 @@ 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.config.UserConfigManage; import com.hdl.photovoltaic.databinding.ActivityMyPowerStationBinding; +import com.hdl.photovoltaic.listener.CloudCallBeak; +import com.hdl.photovoltaic.other.HdlDeviceLogic; import com.hdl.photovoltaic.other.HdlLogLogic; +import com.hdl.photovoltaic.other.HdlMqttLogic; import com.hdl.photovoltaic.other.HdlUniLogic; +import com.hdl.photovoltaic.ui.bean.DeviceRemoteInfo; 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.bean.eventbus.EventNotifyRefreshGatewayAesKeyInfo; +import com.hdl.sdk.link.core.bean.gateway.GatewayBean; +import com.hdl.sdk.link.core.config.HDLLinkConfig; +import com.hdl.sdk.link.core.utils.mqtt.MqttRecvClient; + +import org.greenrobot.eventbus.Subscribe; +import org.greenrobot.eventbus.ThreadMode; + +import java.util.List; + /** * 鎴戠殑鐢电珯鐣岄潰 @@ -39,13 +57,17 @@ @Override public void onBindView(Bundle savedInstanceState) { - getWindow().setStatusBarColor(getColor(R.color.text_245EC3)); + //鍒濆鍖� initView(); //鍒濆鍖栫晫闈㈢洃鍚櫒 initEvent(); //娉ㄥ唽鐩戝惉 registerAllTopicsListener(); + //鍒濆鍖杕qtt瀹㈡埛绔� + initMqttClient(); + + } private void initEvent() { @@ -84,18 +106,18 @@ } private void initView() { - viewBinding.myPowerStationBottomIl1.titleTv.setText(R.string.my_power_station_title); - viewBinding.myMessageBottomIl2.titleTv.setText(R.string.message_娑堟伅); - viewBinding.myMeBottomIl3.titleTv.setText(R.string.my_power_station_me); + viewBinding.myPowerStationBottomIl1.titleTv.setText(R.string.power_station); + viewBinding.myMessageBottomIl2.titleTv.setText(R.string.message); + viewBinding.myMeBottomIl3.titleTv.setText(R.string.power_station_me); this.bottomViewChangeOfStyle(); } private void bottomViewChangeOfStyle() { if (this.currentFragmentIndex == 1) { - viewBinding.myPowerStationFcv1.setVisibility(View.VISIBLE); - viewBinding.myMessageFcv2.setVisibility(View.GONE); - viewBinding.myMeFcv3.setVisibility(View.GONE); + viewBinding.myPowerStationFcv1.setVisibility(View.VISIBLE);//鏄剧ず鐢电珯鐣岄潰 + viewBinding.myMessageFcv2.setVisibility(View.GONE);//闅愯棌娑堟伅鐣岄潰 + viewBinding.myMeFcv3.setVisibility(View.GONE);//闅愯棌鎴戠殑鐣岄潰 viewBinding.myPowerStationBottomIl1.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.selectedpowerstation)); viewBinding.myPowerStationBottomIl1.titleTv.setTextColor(getColor(R.color.text_90000000)); viewBinding.myMessageBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.message_unselected)); @@ -103,9 +125,9 @@ viewBinding.myMeBottomIl3.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedme)); viewBinding.myMeBottomIl3.titleTv.setTextColor(getColor(R.color.text_65000000)); } else if (this.currentFragmentIndex == 2) { - viewBinding.myPowerStationFcv1.setVisibility(View.GONE); - viewBinding.myMessageFcv2.setVisibility(View.VISIBLE); - viewBinding.myMeFcv3.setVisibility(View.GONE); + viewBinding.myPowerStationFcv1.setVisibility(View.GONE);//闅愯棌鐢电珯鐣岄潰 + viewBinding.myMessageFcv2.setVisibility(View.VISIBLE);//鏄剧ず娑堟伅鐣岄潰 + viewBinding.myMeFcv3.setVisibility(View.GONE);//闅愯棌鎴戠殑鐣岄潰 viewBinding.myPowerStationBottomIl1.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedpowerstation)); viewBinding.myPowerStationBottomIl1.titleTv.setTextColor(getColor(R.color.text_65000000)); viewBinding.myMessageBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.message_select)); @@ -113,9 +135,9 @@ viewBinding.myMeBottomIl3.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedme)); viewBinding.myMeBottomIl3.titleTv.setTextColor(getColor(R.color.text_65000000)); } else if (this.currentFragmentIndex == 3) { - viewBinding.myPowerStationFcv1.setVisibility(View.GONE); - viewBinding.myMessageFcv2.setVisibility(View.GONE); - viewBinding.myMeFcv3.setVisibility(View.VISIBLE); + viewBinding.myPowerStationFcv1.setVisibility(View.GONE);//闅愯棌鐢电珯鐣岄潰 + viewBinding.myMessageFcv2.setVisibility(View.GONE);//闅愯棌娑堟伅鐣岄潰 + viewBinding.myMeFcv3.setVisibility(View.VISIBLE);//鏄剧ず鎴戠殑鐣岄潰 viewBinding.myPowerStationBottomIl1.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedpowerstation)); viewBinding.myPowerStationBottomIl1.titleTv.setTextColor(getColor(R.color.text_65000000)); viewBinding.myMessageBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.message_unselected)); @@ -196,5 +218,62 @@ 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()); + } + }); + } + + @Subscribe(threadMode = ThreadMode.MAIN) + public void onEventMessage(EventNotifyRefreshGatewayAesKeyInfo event) { + //缃戝叧鏇存柊mqtt绉橀挜鏇存柊閫氱煡 + if (event == null) { + return; + } + int index = -1; + List<GatewayBean> list = HdlDeviceLogic.getInstance().getCurrentHomeGatewayList(); + for (int i = 0; i < list.size(); i++) { + GatewayBean gatewayBean = list.get(i); + if (gatewayBean.getGatewayId().equals(event.getGatewayId())) { + index = i; + break; + } + } + if (index > -1) { + GatewayBean gatewayBean = list.get(index); + HdlDeviceLogic.getInstance().getDeviceRemoteInfo(UserConfigManage.getInstance().getHomeId(), gatewayBean.getSpk(), gatewayBean.getDevice_mac(), new CloudCallBeak<DeviceRemoteInfo>() { + @Override + public void onSuccess(DeviceRemoteInfo deviceRemoteInfo) { + if (deviceRemoteInfo != null) { + //鏇存柊mqtt閫氳鐨勬柊绉橀挜 + gatewayBean.setAesKey(deviceRemoteInfo.getSecret()); + //鐢ㄤ箣鍓嶇殑搴�,搴曞眰mqtt璁㈤槄锛屽姞瑙e瘑浼氱敤鍒拌鍙傛暟; + HDLLinkConfig.getInstance().setAesKey(deviceRemoteInfo.getSecret());//璁剧疆mqtt閫氳绉橀挜搴� + } + } + + @Override + public void onFailure(HDLException e) { + + } + }); + } + + + } + } \ No newline at end of file -- Gitblit v1.8.0