blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
mac
2023-12-29 27d994f4375f604ba7f49a5ba600882884d73126 
 app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java


@@ -1,40 +1,41 @@


package com.hdl.photovoltaic.ui;




import androidx.annotation.NonNull;


import androidx.annotation.Nullable;


import androidx.appcompat.content.res.AppCompatResources;


import androidx.core.app.ActivityCompat;




import android.Manifest;


import android.content.ComponentName;


import android.content.Intent;


import android.content.ServiceConnection;


import android.content.IntentFilter;


import android.content.UriPermission;


import android.content.pm.PackageManager;


import android.os.Bundle;


import android.os.IBinder;


import android.os.Process;


import android.text.TextUtils;


import android.util.Log;


import android.view.View;




import com.google.gson.Gson;


import com.google.gson.reflect.TypeToken;


import com.hdl.linkpm.sdk.core.exception.HDLException;


import com.hdl.linkpm.sdk.home.type.HomeType;


import com.hdl.linkpm.sdk.ota.bean.CloudGatewayDriversBean;


import com.hdl.linkpm.sdk.utils.HDLMD5Utils;


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.HdlFileLogic;


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.ui.bean.OidBean;


import com.hdl.photovoltaic.uni.HDLUniMP;


import com.hdl.photovoltaic.utils.AppManagerUtils;


import com.hdl.photovoltaic.utils.PermissionUtils;


@@ -47,12 +48,12 @@


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;




import java.lang.reflect.Type;


import java.util.List;




import okhttp3.ResponseBody;






/**


@@ -67,6 +68,8 @@




    private int backPressTimes;




    private NetworkChangeReceiver networkChangeReceiver;






    @Override


    public Object getContentView() {


@@ -78,16 +81,27 @@


    public void onBindView(Bundle savedInstanceState) {


        setNotificationBarBackgroundColor(CustomColor.blue);


        //初始化


        initView();


        this.initView();


        //初始化界面监听器


        initEvent();


        this.initEvent();


        //注册监听


        registerAllTopicsListener();


        this.registerAllTopicsListener();


        //初始化mqtt客户端


        initMqttClient();


        this.initMqttClient();


        //监听网络状态变化


        this.networkMonitoring();




//        dddd();




    }




    /**


     * 监听网络状态变化


     */


    private void networkMonitoring() {


        IntentFilter intentFilter = new IntentFilter();


        intentFilter.addAction("android.net.conn.CONNECTIVITY_CHANGE");


        networkChangeReceiver = new NetworkChangeReceiver();


        registerReceiver(networkChangeReceiver, intentFilter);


    }




    private void initEvent() {


@@ -96,6 +110,7 @@


            public void onClick(View v) {


                currentFragmentIndex = 1;


                bottomViewChangeOfStyle();


                postEventBus(HomepageTitleTabSwitch.powerstation);


            }


        });


        viewBinding.myMessageBottomIl2.clickTv.setOnClickListener(new View.OnClickListener() {


@@ -103,6 +118,8 @@


            public void onClick(View v) {


                currentFragmentIndex = 2;


                bottomViewChangeOfStyle();


                postEventBus(HomepageTitleTabSwitch.message);




            }


        });


        viewBinding.myMeBottomIl3.clickTv.setOnClickListener(new View.OnClickListener() {


@@ -110,6 +127,7 @@


            public void onClick(View v) {


                currentFragmentIndex = 3;


                bottomViewChangeOfStyle();


                postEventBus(HomepageTitleTabSwitch.me);


            }


        });




@@ -122,11 +140,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();


@@ -167,6 +187,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});


@@ -227,7 +258,7 @@


                    if (response.getTopic() == null) {


                        return;


                    }


                    HdlLogLogic.print("监听到的数据===" + new Gson().toJson(response), false);


                    HdlLogLogic.print("监听到Modbus数据--->" + new Gson().toJson(response), false);


//                    if (response.getTopic().endsWith("custom/native/inverter/up")) {


                    HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean();


                    uniCallBackBaseBean.setType(response.getTopic());


@@ -245,11 +276,34 @@


                        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);


                    } else if (linkResponse.getTopic().endsWith("/custom/device/list/upload")) {


                        //逆变器有新oid通知主题


                        if (linkResponse.getData() == null) {


                            HdlLogLogic.print("逆变器有新oid通知--->数据为空", false);


                            return;


                        }


                        try {


                            Gson gson = new Gson();


                            Type typeOfT = new TypeToken<List<OidBean>>() {


                            }.getType();


                            String json = gson.toJson(linkResponse.getData());


                            List<OidBean> oidList = gson.fromJson(json, typeOfT);


                            //增量增加add


                            HdlDeviceLogic.getInstance().updateOidAdd(UserConfigManage.getInstance().getHomeId(), oidList, null);


                        } catch (Exception ignored) {


                        }






                    }


                }


            }


        };


        HDLLinkLocalSdk.getInstance().registerAllTopicsListener(allTopicsListener);


        }




        ;


        HDLLinkLocalSdk.getInstance().




                registerAllTopicsListener(allTopicsListener);


    }




    /**


@@ -266,7 +320,7 @@




            @Override


            public void onFailure(HDLException e) {


                HdlLogLogic.print("读取mqtt远程信息失败===" + e.getMessage(), e.getCode(), true);


                HdlLogLogic.print("读取mqtt远程信息失败--->" + e.getMessage(), e.getCode(), true);


            }


        });


    }


@@ -288,7 +342,7 @@


                return;


            }


            int index = -1;


            List<GatewayBean> list = HdlDeviceLogic.getInstance().getCurrentHomeGatewayList();


            List<GatewayBean> list = HdlDeviceLogic.getInstance().getCurrentHomeGatewayList(UserConfigManage.getInstance().getHomeId());


            for (int i = 0; i < list.size(); i++) {


                GatewayBean gatewayBean = list.get(i);


                if (gatewayBean.getGatewayId().equals(topics[2])) {


@@ -316,20 +370,45 @@


                });


            }


        } else if (event.getTopic().contains(HdlOtaLogic.localDownloadProgress)) {


            //下载云端驱动或者固件文件,自己计算进度条上报到uni那边


            //下载云端驱动或者固件文件到本地,自己计算进度条上报到uni那边


            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("进度:" + ((HdlOtaLogic.Progress) event.getData()).step + "", false);


            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的ssid需要位置权限的


            HdlLogLogic.print("监听网络状态--->" + event.getData().toString() + "(" + event.getType() + ")", true);


            //第一次启动App,以及切换网络的时候更新


            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();


                            }


                        });


                    }


                });


            }


        }


    }










    /**


     * 点击返回键的事件


     * 物理按键返回事件


     */


    @Override


    public void onBackPressed() {


@@ -356,78 +435,6 @@


            }


        }


        super.onBackPressed();


    }






    private void dddd() {


//        String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName("036F6C1B", "V01.01.02");


//        String data = HdlFileLogic.getInstance().readFile(drivePathFileName);


//        String md5 = HDLMD5Utils.encodeMD5(data);//网关驱动需要


//        Log.e("", md5);


//        HdlOtaLogic.getInstance().getDeviceDriverDownloadFile("http://192.168.16.135:49152/storage/emulated/0/Android/data/com.hdl.photovoltaic/files/Documents/upgrade/drive/036F6C1B_V01.01.02.zip", new CloudCallBeak<ResponseBody>() {


//            @Override


//            public void onSuccess(ResponseBody responseBody) {


//


//                HdlOtaLogic.getInstance().disposeDownLoadFile(drivePathFileName, responseBody, md5);


//


////                //本地升级驱动文件路径


////


////                String data = HdlFileLogic.getInstance().readFile(drivePathFileName);


////                String md5 = HDLMD5Utils.encodeMD5(data);//网关驱动需要


//            }


//


//            @Override


//            public void onFailure(HDLException e) {


//


//            }


//        });






//        HdlOtaLogic.getInstance().getNewGatewayDrivers("036F6C1B", "A000", new CloudCallBeak<CloudGatewayDriversBean>() {


//            @Override


//            public void onSuccess(CloudGatewayDriversBean obj) {


//


//            }


//


//            @Override


//            public void onFailure(HDLException e) {


//


//            }


//        });






//        dowlao();


        HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {


            @Override


            public void onServiceConnected(ComponentName name, IBinder service) {




            }




            @Override


            public void onServiceDisconnected(ComponentName name) {




            }


        });




    }




    void dowlao() {




        HdlOtaLogic.getInstance().getDeviceUpgradeDownloadFile("http://hdl-hz-test.oss-cn-hangzhou.aliyuncs.com/20/2023/11/1834a1d0-d2a7-4b6f-9877-6f2722e9b7bc.hdlipk_sec", new CloudCallBeak<ResponseBody>() {


            @Override


            public void onSuccess(ResponseBody responseBody) {


                String drivePathFileName = HdlFileLogic.getInstance().getDrivePathFileName("036F6C1B", "V01.01.02");


                HdlOtaLogic.getInstance().disposeDownLoadFile(drivePathFileName, responseBody, "84cd8e62d4311c90508313f0e5965dbb", HdlOtaLogic.driver_type);




//                HdlFileLogic.getInstance().writeFile(drivePathFileName, bytes);//写入新文件


                HdlLogLogic.print("写入新驱动文件到内存成功.", false);


            }




            @Override


            public void onFailure(HDLException e) {


                HdlLogLogic.print("下载驱动文件到内存失败.", false);


            }


        });


    }