~wjc/HDLPhotovoltaicDebugAPP.git

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

			import android.Manifest;
			import android.content.Intent;
			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;
			@@ -14,19 +16,18 @@
			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.HDLApp;
			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.internet.HttpServer.MyNanoHttpServer;
			import com.hdl.photovoltaic.internet.HttpServer.MyNanoHttpService;
			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;
			@@ -42,6 +43,7 @@
			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;

			@@ -69,6 +71,7 @@

			@Override
			public void onBindView(Bundle savedInstanceState) {
			setNotificationBarBackgroundColor(CustomColor.blue);
			//初始化
			initView();
			//初始化界面监听器
			@@ -78,12 +81,17 @@
			//初始化mqtt客户端
			initMqttClient();

			String path = HdlFileLogic.getInstance().getDriveRootPath() + "/036F6C1B.zip";
			MyNanoHttpServer.getInstance(AppManagerUtils.getAppManager().getIPAddress(HDLApp.getInstance()));
			//MyNanoHttpServer.getInstance("127.0.0.1");
			Intent intentServer = new Intent();
			intentServer.setClass(HDLApp.getInstance(), MyNanoHttpService.class);
			startService(intentServer);
			// HdlOtaLogic.getInstance().startLocalService(new ServiceConnection() {
			// @Override
			// public void onServiceConnected(ComponentName name, IBinder service) {
			//
			// }
			//
			// @Override
			// public void onServiceDisconnected(ComponentName name) {
			//
			// }
			// });

			}

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

			@@ -123,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();
			@@ -164,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});
			@@ -242,6 +264,7 @@
			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);
			}
			}
			}
			@@ -270,48 +293,56 @@

			@Subscribe(threadMode = ThreadMode.MAIN)
			public void onEventMessage(BaseEventBus event) {
			//网关更新mqtt秘钥更新通知

			if (event == null) {
			return;
			}
			if (TextUtils.isEmpty(event.getTopic())) {
			return;
			}
			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;
			//网关更新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);
			}


			}


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


			}