From 936fb552a30c05fc7a60c20f47bf6fccbc2dc1c1 Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期三, 27 十二月 2023 16:17:23 +0800
Subject: [PATCH] 备份一下代码

---
 app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java |  246 +++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 198 insertions(+), 48 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 263a352..e02daf2 100644
--- a/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java
+++ b/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java
@@ -2,10 +2,14 @@
 
 import androidx.annotation.NonNull;
 import androidx.appcompat.content.res.AppCompatResources;
+import androidx.core.app.ActivityCompat;
 
 import android.Manifest;
+import android.content.IntentFilter;
 import android.content.pm.PackageManager;
 import android.os.Bundle;
+import android.os.Process;
+import android.text.TextUtils;
 import android.view.View;
 
 import com.google.gson.Gson;
@@ -14,24 +18,34 @@
 import com.hdl.photovoltaic.R;
 import com.hdl.photovoltaic.base.CustomBaseActivity;
 import com.hdl.photovoltaic.bean.MqttInfo;
+import com.hdl.photovoltaic.broadcast.NetworkChangeReceiver;
+import com.hdl.photovoltaic.config.ConstantManage;
 import com.hdl.photovoltaic.config.UserConfigManage;
 import com.hdl.photovoltaic.databinding.ActivityMyPowerStationBinding;
+import com.hdl.photovoltaic.enums.HomepageTitleTabSwitch;
+import com.hdl.photovoltaic.enums.NetworkType;
 import com.hdl.photovoltaic.listener.CloudCallBeak;
+import com.hdl.photovoltaic.other.HdlCommonLogic;
 import com.hdl.photovoltaic.other.HdlDeviceLogic;
 import com.hdl.photovoltaic.other.HdlLogLogic;
 import com.hdl.photovoltaic.other.HdlMqttLogic;
+import com.hdl.photovoltaic.other.HdlOtaLogic;
+import com.hdl.photovoltaic.other.HdlThreadLogic;
 import com.hdl.photovoltaic.other.HdlUniLogic;
 import com.hdl.photovoltaic.ui.bean.DeviceRemoteInfo;
 import com.hdl.photovoltaic.uni.HDLUniMP;
+import com.hdl.photovoltaic.utils.AppManagerUtils;
 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.LinkResponse;
 import com.hdl.sdk.link.core.bean.ModbusResponse;
-import com.hdl.sdk.link.core.bean.eventbus.EventNotifyRefreshGatewayAesKeyInfo;
+import com.hdl.sdk.link.core.bean.eventbus.BaseEventBus;
 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.EventBus;
 import org.greenrobot.eventbus.Subscribe;
 import org.greenrobot.eventbus.ThreadMode;
 
@@ -48,6 +62,10 @@
     private int currentFragmentIndex = 1;
     private EventListener allTopicsListener;
 
+    private int backPressTimes;
+
+    private NetworkChangeReceiver networkChangeReceiver;
+
 
     @Override
     public Object getContentView() {
@@ -57,17 +75,40 @@
 
     @Override
     public void onBindView(Bundle savedInstanceState) {
-
+        setNotificationBarBackgroundColor(CustomColor.blue);
         //鍒濆鍖�
-        initView();
+        this.initView();
         //鍒濆鍖栫晫闈㈢洃鍚櫒
-        initEvent();
+        this.initEvent();
         //娉ㄥ唽鐩戝惉
-        registerAllTopicsListener();
+        this.registerAllTopicsListener();
         //鍒濆鍖杕qtt瀹㈡埛绔�
-        initMqttClient();
+        this.initMqttClient();
+        //鐩戝惉缃戠粶鐘舵�佸彉鍖�
+        this.networkMonitoring();
 
+//        HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {
+//            @Override
+//            public void onServiceConnected(ComponentName name, IBinder service) {
+//
+//            }
+//
+//            @Override
+//            public void onServiceDisconnected(ComponentName name) {
+//
+//            }
+//        });
 
+    }
+
+    /**
+     * 鐩戝惉缃戠粶鐘舵�佸彉鍖�
+     */
+    private void networkMonitoring() {
+        IntentFilter intentFilter = new IntentFilter();
+        intentFilter.addAction("android.net.conn.CONNECTIVITY_CHANGE");
+        networkChangeReceiver = new NetworkChangeReceiver();
+        registerReceiver(networkChangeReceiver, intentFilter);
     }
 
     private void initEvent() {
@@ -76,6 +117,7 @@
             public void onClick(View v) {
                 currentFragmentIndex = 1;
                 bottomViewChangeOfStyle();
+                postEventBus(HomepageTitleTabSwitch.powerstation);
             }
         });
         viewBinding.myMessageBottomIl2.clickTv.setOnClickListener(new View.OnClickListener() {
@@ -83,6 +125,8 @@
             public void onClick(View v) {
                 currentFragmentIndex = 2;
                 bottomViewChangeOfStyle();
+                postEventBus(HomepageTitleTabSwitch.message);
+
             }
         });
         viewBinding.myMeBottomIl3.clickTv.setOnClickListener(new View.OnClickListener() {
@@ -90,6 +134,7 @@
             public void onClick(View v) {
                 currentFragmentIndex = 3;
                 bottomViewChangeOfStyle();
+                postEventBus(HomepageTitleTabSwitch.me);
             }
         });
 
@@ -102,11 +147,13 @@
         HdlUniLogic.getInstance().checkRemoveOtherUniMPEventCallBack();
         //绉婚櫎鐩戝惉
         HDLLinkLocalSdk.getInstance().removeAllTopicsListener(allTopicsListener);
+        //绉婚櫎鐩戝惉缃戠粶鐘舵�佸彉鍖�
+        unregisterReceiver(networkChangeReceiver);
 
     }
 
     private void initView() {
-        viewBinding.myPowerStationBottomIl1.titleTv.setText(R.string.power_station);
+        viewBinding.myPowerStationBottomIl1.titleTv.setText("棣栭〉");//
         viewBinding.myMessageBottomIl2.titleTv.setText(R.string.message);
         viewBinding.myMeBottomIl3.titleTv.setText(R.string.power_station_me);
         this.bottomViewChangeOfStyle();
@@ -115,9 +162,9 @@
 
     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));
@@ -125,9 +172,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));
@@ -135,9 +182,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));
@@ -147,6 +194,17 @@
         }
     }
 
+    /**
+     * 鍙戝竷鐐瑰嚮浜嬩欢
+     *
+     * @param tabSwitch -
+     */
+    private void postEventBus(HomepageTitleTabSwitch tabSwitch) {
+        BaseEventBus baseEventBus = new BaseEventBus();
+        baseEventBus.setTopic(ConstantManage.homepage_title_tab_switch);
+        baseEventBus.setType(tabSwitch.toString());
+        EventBus.getDefault().post(baseEventBus);
+    }
 
     public void requestPermissions() {
         String[] ary = PermissionUtils.checkPermission(_mActivity, new String[]{Manifest.permission.ACCESS_FINE_LOCATION});
@@ -199,12 +257,15 @@
             @Override
             public void onMessage(Object msg) {
 
+                if (msg == null) {
+                    return;
+                }
                 if (msg instanceof ModbusResponse) {
                     ModbusResponse response = (ModbusResponse) msg;
                     if (response.getTopic() == null) {
                         return;
                     }
-                    HdlLogLogic.print("鐩戝惉鍒扮殑鏁版嵁===========" + new Gson().toJson(response));
+                    HdlLogLogic.print("鐩戝惉鍒扮殑鏁版嵁--->" + new Gson().toJson(response), false);
 //                    if (response.getTopic().endsWith("custom/native/inverter/up")) {
                     HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();
                     uniCallBackBaseBean.setType(response.getTopic());
@@ -212,6 +273,18 @@
                     HdlUniLogic.getInstance().sendUni(HDLUniMP.UNI_EVENT_NOTIFICATION_DEVICE_MODEL, uniCallBackBaseBean);
 //                    }
 
+                } else if (msg instanceof LinkResponse) {
+                    LinkResponse linkResponse = (LinkResponse) msg;
+                    if (linkResponse.getTopic() == null) {
+                        return;
+                    }
+                    if (linkResponse.getTopic().endsWith("/ota/device/progress/up")) {
+                        HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();
+                        uniCallBackBaseBean.setType(linkResponse.getTopic());
+                        uniCallBackBaseBean.setData(linkResponse.getData());
+                        HdlUniLogic.getInstance().sendUni(HDLUniMP.UNI_EVENT_REPLY_OTA_MODEL, uniCallBackBaseBean);
+                        HdlLogLogic.print(linkResponse.getTopic() + new Gson().toJson(linkResponse.getData()), true);
+                    }
                 }
             }
         };
@@ -232,48 +305,125 @@
 
             @Override
             public void onFailure(HDLException e) {
-                HdlLogLogic.print("璇诲彇mqtt杩滅▼淇℃伅澶辫触", e.getMessage(), e.getCode());
+                HdlLogLogic.print("璇诲彇mqtt杩滅▼淇℃伅澶辫触--->" + e.getMessage(), e.getCode(), true);
             }
         });
     }
 
     @Subscribe(threadMode = ThreadMode.MAIN)
-    public void onEventMessage(EventNotifyRefreshGatewayAesKeyInfo event) {
-        //缃戝叧鏇存柊mqtt绉橀挜鏇存柊閫氱煡
+    public void onEventMessage(BaseEventBus event) {
+
         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 (TextUtils.isEmpty(event.getTopic())) {
+            return;
+        }
+        //缃戝叧鏇存柊mqtt绉橀挜鏇存柊閫氱煡
+        if (event.getTopic().contains("/custom/mqtt/secret/change")) {
+            String[] topics = event.getTopic().split("/");
+            //涓婚涓嶇鍚堣鍒欎笉澶勭悊
+            if (topics.length < 3) {
+                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(topics[2])) {
+                    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) {
+
+                    }
+                });
+            }
+        } else if (event.getTopic().contains(HdlOtaLogic.localDownloadProgress)) {
+            //涓嬭浇浜戠椹卞姩鎴栬�呭浐浠舵枃浠跺埌鏈湴,鑷繁璁$畻杩涘害鏉′笂鎶ュ埌uni閭h竟
+            HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();
+            uniCallBackBaseBean.setType(event.getType());
+            uniCallBackBaseBean.setData(event.getData());
+            HdlUniLogic.getInstance().sendUni(HDLUniMP.UNI_EVENT_REPLY_OTA_MODEL, uniCallBackBaseBean);
+            HdlLogLogic.print(event.getTopic() + new Gson().toJson(event.getData()), true);
+        } else if (event.getTopic().contains(ConstantManage.network_change_post)) {
+//            String wifi_ssid = WifiUtils.getInstance().getCurrentConnectWifiSsid();//鑾峰彇WiFi鐨剆sid闇�瑕佷綅缃潈闄愮殑
+            HdlLogLogic.print("鐩戝惉缃戠粶鐘舵��--->" + event.getData().toString() + "(" + event.getType() + ")", true);
+            //绗竴娆″惎鍔ˋpp,浠ュ強鍒囨崲缃戠粶鐨勬椂鍊欐洿鏂�
+            if (TextUtils.isEmpty(UserConfigManage.getInstance().getHomeId())) {
+                return;
+            }
+            if (!event.getType().equals(NetworkType.no_network.toString())) {
+//                AppManagerUtils.getAppManager().showLoading();
+                HdlThreadLogic.runSubThread(new Runnable() {
+                    @Override
+                    public void run() {
+                        HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(UserConfigManage.getInstance().getHomeId(), new CloudCallBeak<List<GatewayBean>>() {
+                            @Override
+                            public void onSuccess(List<GatewayBean> obj) {
+//                                AppManagerUtils.getAppManager().hideLoading();
+
+                            }
+
+                            @Override
+                            public void onFailure(HDLException e) {
+//                                AppManagerUtils.getAppManager().hideLoading();
+                            }
+                        });
+                    }
+                });
             }
         }
-        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) {
-
-                }
-            });
-        }
-
-
     }
 
 
+    /**
+     * 鐗╃悊鎸夐敭杩斿洖浜嬩欢
+     */
+    @Override
+    public void onBackPressed() {
+        if (AppManagerUtils.getAppManager().getActivitySize() <= 1) {
+            if (backPressTimes == 0) {
+                HdlThreadLogic.toast(_mActivity, R.string.kill_app);
+                backPressTimes = 1;
+                new Thread() {
+                    @Override
+                    public void run() {
+                        try {
+                            Thread.sleep(2000);
+                        } catch (InterruptedException e) {
+                            e.printStackTrace();
+                        } finally {
+                            backPressTimes = 0;
+                        }
+                    }
+                }.start();
+                return;
+            } else {
+                AppManagerUtils.getAppManager().finishAllActivity();
+                Process.killProcess(Process.myPid());
+            }
+        }
+        super.onBackPressed();
+    }
+
+
+
+
+
 }
\ No newline at end of file

--
Gitblit v1.8.0