~wjc/HDLPhotovoltaicDebugAPP.git

			@@ -5,6 +5,7 @@
			import android.os.Process;
			import android.os.SystemClock;
			import android.text.TextUtils;
			import android.util.Log;


			import com.google.gson.Gson;
			@@ -18,8 +19,10 @@
			import com.hdl.photovoltaic.config.ConstantManage;
			import com.hdl.photovoltaic.config.UserConfigManage;
			import com.hdl.photovoltaic.databinding.ActivityCpowerStationBinding;
			import com.hdl.photovoltaic.enums.LowerTagType;
			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;
			@@ -33,8 +36,6 @@
			import com.hdl.photovoltaic.uni.HDLUniMP;
			import com.hdl.photovoltaic.uni.HDLUniMPSDKManager;
			import com.hdl.photovoltaic.utils.AppManagerUtils;
			import com.hdl.photovoltaic.widget.ConfirmationCancelDialog;
			import com.hdl.photovoltaic.widget.ConfirmationTipDialog;
			import com.hdl.sdk.link.HDLLinkLocalSdk;
			import com.hdl.sdk.link.common.event.EventListener;
			import com.hdl.sdk.link.core.bean.LinkResponse;
			@@ -42,13 +43,16 @@
			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.connect.HDLUdpConnect;
			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.ArrayList;
			import java.util.Arrays;
			import java.util.Collections;
			import java.util.List;

			import cn.jpush.android.api.JPushInterface;
			@@ -87,7 +91,28 @@
			protected void onResume() {
			super.onResume();
			//启动页与mainActivity样式一样，这样启动页和mainActivity看上去是一个界面，目的是为了mainActivity遮住下一页；
			AppManagerUtils.getAppManager().finishActivity(StartActivity.class);
			// AppManagerUtils.getAppManager().finishActivity(StartActivity.class);
			// this.portConflictDialog();
			}

			public void startAppAutomaticallyOpenUni() {
			new Thread(new Runnable() {
			@Override
			public void run() {
			SystemClock.sleep(10);
			runOnUiThread(new Runnable() {
			@Override
			public void run() {
			//低于安卓14版本
			if (android.os.Build.VERSION.SDK_INT < 34) {
			startAppAutomaticallyOpenUni(false);
			} else {
			startAppAutomaticallyOpenUni(true);
			}
			}
			});
			}
			}).start();
			}

			@Subscribe(threadMode = ThreadMode.MAIN)
			@@ -99,7 +124,7 @@
			if (TextUtils.isEmpty(event.getTopic())) {
			return;
			}
			//网关更新mqtt秘钥更新通知
			//网关mqtt秘钥更新通知
			if (event.getTopic().contains("/custom/mqtt/secret/change")) {
			String[] topics = event.getTopic().split("/");
			//主题不符合规则不处理
			@@ -155,6 +180,9 @@
			HdlThreadLogic.runSubThread(new Runnable() {
			@Override
			public void run() {
			//防止app启动的时候没有网络(app也登录不了),导致获取不了mqtt远程连接信息;
			initMqttClient();

			HdlDeviceLogic.getInstance().getCurrentHomeLocalAndCloudGatewayList(UserConfigManage.getInstance().getHomeId(), new CloudCallBeak<List<GatewayBean>>() {
			@Override
			public void onSuccess(List<GatewayBean> obj) {
			@@ -172,14 +200,36 @@
			} else if (event.getTopic().contains(HDLUniMP.UNI_EVENT_REPLY_OTHER_MODEL) && event.getType().contains(HDLUniMP.UNI_EVENT_REPLY_OTHER_BACK)) {
			//物理按键返回事件(包括左滑移除事件)
			killProcessApp();
			} else if (HDLUniMP.UNI_EVENT_REPLY_DEVICE_LIST.equals(event.getType())) {
			if (MqttRecvClient.getInstance() != null) {
			MqttRecvClient.getInstance().removeAllTopic();
			}
			String homeId = event.getData().toString();
			//进去住宅详情uni读取逆变器列表成功后通知
			for (int i = 0; i < HdlDeviceLogic.getInstance().getCurrentHomeGatewayList(homeId).size(); i++) {
			String gatewayId = HdlDeviceLogic.getInstance().getCurrentHomeGatewayList(homeId).get(i).getGatewayId();
			//字符串是自己按规则拼接的,里面注册主题时会解析字符串,只拿getGatewayId()值;
			String topic = "/user/" + gatewayId + "/#";
			//进去住宅详情开始订阅主题
			MqttRecvClient.getInstance().checkAndsubscribeAllTopics(topic);//订阅【逆变器】消息

			}
			String topicHome = "/user/" + homeId + "/#";
			MqttRecvClient.getInstance().checkAndsubscribeAllTopics(topicHome);//订阅【电站】消息


			}
			}


			/**
			* C端启动App自动打开小程序电站详情界面
			*/
			private void startAppAutomaticallyOpenUni() {
			private void startAppAutomaticallyOpenUni(boolean delay) {

			if (delay) {
			SystemClock.sleep(2000);
			}
			List<HouseIdBean> HouseIdList = HdlResidenceLogic.getInstance().getHouseIdList();
			if (HouseIdList.size() == 0) {
			String path = HDLUniMP.UNI_EVENT_OPEN_HOME_Null_C;
			@@ -197,8 +247,6 @@
			String path = HDLUniMP.UNI_EVENT_OPEN_HOME_DETAILS_C + "?homeId=" + houseIdBean.getHomeId() + "&homeName=" + houseIdBean.getHomeName() + "&powerStationStatus=" + houseIdBean.getPowerStationStatus();
			HdlUniLogic.getInstance().openUniMP(path, null);
			}


			}

			// /**
			@@ -309,6 +357,10 @@
			* 初始化mqtt客户端
			*/
			public void initMqttClient() {
			//检查断开状态
			if (!MqttRecvClient.getInstance().isConnected()) {
			MqttRecvClient.getInstance().reConnect();
			}
			if (!MqttRecvClient.getInstance().isInit()) {
			HdlMqttLogic.getInstance().getMqttRemoteInfo(HomeType.A, new CloudCallBeak<MqttInfo>() {
			@Override
			@@ -396,4 +448,4 @@
			}


			}
			}