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