2023年12月21日21:17:08

mac

2023-12-21 78dbac2e8e7ad58d9e5d6a025de0d6fc58f69146

 app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java

@@ -4,9 +4,13 @@
import androidx.appcompat.content.res.AppCompatResources;

import android.Manifest;
import android.content.ComponentName;
import android.content.ServiceConnection;
import android.content.pm.PackageManager;
import android.os.Bundle;
import android.os.IBinder;
import android.os.Process;
import android.text.TextUtils;
import android.view.View;

import com.google.gson.Gson;
@@ -15,12 +19,15 @@
import com.hdl.photovoltaic.R;
import com.hdl.photovoltaic.base.CustomBaseActivity;
import com.hdl.photovoltaic.bean.MqttInfo;
import com.hdl.photovoltaic.config.ConstantManage;
import com.hdl.photovoltaic.config.UserConfigManage;
import com.hdl.photovoltaic.databinding.ActivityMyPowerStationBinding;
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;
@@ -29,12 +36,14 @@
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;

@@ -62,7 +71,7 @@

    @Override
    public void onBindView(Bundle savedInstanceState) {

        setNotificationBarBackgroundColor(CustomColor.blue);
        //初始化
        initView();
        //初始化界面监听器
@@ -72,6 +81,17 @@
        //初始化mqtt客户端
        initMqttClient();

//        HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {
//            @Override
//            public void onServiceConnected(ComponentName name, IBinder service) {
//
//            }
//
//            @Override
//            public void onServiceDisconnected(ComponentName name) {
//
//            }
//        });

    }

@@ -81,6 +101,7 @@
            public void onClick(View v) {
                currentFragmentIndex = 1;
                bottomViewChangeOfStyle();
                postEventBus(HdlCommonLogic.HomepageTitleTabSwitch.powerstation);
            }
        });
        viewBinding.myMessageBottomIl2.clickTv.setOnClickListener(new View.OnClickListener() {
@@ -88,6 +109,7 @@
            public void onClick(View v) {
                currentFragmentIndex = 2;
                bottomViewChangeOfStyle();
                postEventBus(HdlCommonLogic.HomepageTitleTabSwitch.message);
            }
        });
        viewBinding.myMeBottomIl3.clickTv.setOnClickListener(new View.OnClickListener() {
@@ -95,6 +117,7 @@
            public void onClick(View v) {
                currentFragmentIndex = 3;
                bottomViewChangeOfStyle();
                postEventBus(HdlCommonLogic.HomepageTitleTabSwitch.me);
            }
        });

@@ -111,7 +134,7 @@
    }

    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();
@@ -152,6 +175,17 @@
        }
    }

    /**
     * 发布点击事件
     *
     * @param tabSwitch -
     */
    private void postEventBus(HdlCommonLogic.HomepageTitleTabSwitch tabSwitch) {
        BaseEventBus baseEventBus = new BaseEventBus();
        baseEventBus.setTopic(ConstantManage.homepage_title_tab_switch);
        baseEventBus.setType(tabSwitch + "");
        EventBus.getDefault().post(baseEventBus);
    }

    public void requestPermissions() {
        String[] ary = PermissionUtils.checkPermission(_mActivity, new String[]{Manifest.permission.ACCESS_FINE_LOCATION});
@@ -204,12 +238,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),false);
                    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());
@@ -217,6 +254,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);
                    }
                }
            }
        };
@@ -237,47 +286,63 @@

            @Override
            public void onFailure(HDLException e) {
                HdlLogLogic.print("读取mqtt远程信息失败==="+e.getMessage(), e.getCode(),true);
                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;
            }
        }
        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通讯秘钥库
            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订阅，加解密会用到该参数;
                            HDLLinkConfig.getInstance().setAesKey(deviceRemoteInfo.getSecret());//设置mqtt通讯秘钥库
                        }
                    }
                }

                @Override
                public void onFailure(HDLException e) {
                    @Override
                    public void onFailure(HDLException e) {

                }
            });
                    }
                });
            }
        } else if (event.getTopic().contains(HdlOtaLogic.localDownloadProgress)) {
            //下载云端驱动或者固件文件到本地,自己计算进度条上报到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(event.getTopic() + new Gson().toJson(event.getData()), true);
        }


    }


@@ -311,4 +376,5 @@
        super.onBackPressed();
    }


}