From c13cb54d0b9f9b2c73f213b6cdb163f462fd64c7 Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期五, 13 十月 2023 18:17:59 +0800
Subject: [PATCH] 2023年10月13日18:17:52

---
 app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java |   89 ++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 88 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..65c5431 100644
--- a/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java
+++ b/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java
@@ -6,19 +6,45 @@
 import android.Manifest;
 import android.content.pm.PackageManager;
 import android.os.Bundle;
+import android.text.TextUtils;
+import android.util.Log;
 import android.view.View;
 
 import com.google.gson.Gson;
+import com.hdl.linkpm.sdk.core.callback.IResponseCallBack;
+import com.hdl.linkpm.sdk.core.exception.HDLException;
+import com.hdl.linkpm.sdk.device.HDLLinkPMDevice;
+import com.hdl.linkpm.sdk.device.bean.GatewayCloudBean;
+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.CloudInverterDeviceBean;
+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 com.hdl.sdk.link.gateway.HDLLinkLocalGateway;
+
+import org.greenrobot.eventbus.Subscribe;
+import org.greenrobot.eventbus.ThreadMode;
+
+import java.util.ArrayList;
+import java.util.List;
+
 
 /**
  * 鎴戠殑鐢电珯鐣岄潰
@@ -46,6 +72,10 @@
         initEvent();
         //娉ㄥ唽鐩戝惉
         registerAllTopicsListener();
+        //鍒濆鍖杕qtt瀹㈡埛绔�
+        initMqttClient();
+
+
     }
 
     private void initEvent() {
@@ -85,7 +115,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 +226,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璁㈤槄锛屽姞瑙ｅ瘑浼氱敤鍒拌鍙傛暟;
+                        HDLLinkConfig.getInstance().setAesKey(deviceRemoteInfo.getSecret());//璁剧疆mqtt閫氳绉橀挜搴�
+                    }
+                }
+
+                @Override
+                public void onFailure(HDLException e) {
+
+                }
+            });
+        }
+
+
+    }
+
 
 }
\ No newline at end of file

--
Gitblit v1.8.0