| | |
| | | setNotificationBarBackgroundColor(CustomColor.white); |
| | | setStatusBarTextColor(); |
| | | //C端启动App自动打开小程序电站详情界面 |
| | | // startAppAutomaticallyOpenUni(); |
| | | startAppAutomaticallyOpenUni(); |
| | | //注册监听 |
| | | this.registerAllTopicsListener(); |
| | | //初始化mqtt客户端 |
| | |
| | | } |
| | | |
| | | @Override |
| | | protected void onCreate(@Nullable Bundle savedInstanceState) { |
| | | super.onCreate(savedInstanceState); |
| | | setTheme(R.style.NoAnimationTheme); |
| | | } |
| | | |
| | | @Override |
| | | protected void onResume() { |
| | | super.onResume(); |
| | | //启动页与mainActivity样式一样,这样启动页和mainActivity看上去是一个界面,目的是为了mainActivity遮住下一页; |
| | | // AppManagerUtils.getAppManager().finishActivity(StartActivity.class); |
| | | this.portConflictDialog(); |
| | | startAppAutomaticallyOpenUni(); |
| | | // this.portConflictDialog(); |
| | | } |
| | | |
| | | public void startAppAutomaticallyOpenUni() { |
| | | //低于安卓14版本 |
| | | if (android.os.Build.VERSION.SDK_INT < 34) { |
| | | startAppAutomaticallyOpenUni(false); |
| | | } else { |
| | | new Thread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | SystemClock.sleep(10); |
| | | runOnUiThread(new Runnable() { |
| | | @Override |
| | | public void run() { |
| | | 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(); |
| | | } |
| | | } |
| | | }); |
| | | } |
| | | }).start(); |
| | | } |
| | | |
| | | @Subscribe(threadMode = ThreadMode.MAIN) |
| | |
| | | if (TextUtils.isEmpty(event.getTopic())) { |
| | | return; |
| | | } |
| | | //网关更新mqtt秘钥更新通知 |
| | | //网关mqtt秘钥更新通知 |
| | | if (event.getTopic().contains("/custom/mqtt/secret/change")) { |
| | | String[] topics = event.getTopic().split("/"); |
| | | //主题不符合规则不处理 |
| | |
| | | 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) { |
| | |
| | | */ |
| | | private void startAppAutomaticallyOpenUni(boolean delay) { |
| | | |
| | | if(delay) { |
| | | if (delay) { |
| | | SystemClock.sleep(2000); |
| | | } |
| | | List<HouseIdBean> HouseIdList = HdlResidenceLogic.getInstance().getHouseIdList(); |
| | |
| | | * 初始化mqtt客户端 |
| | | */ |
| | | public void initMqttClient() { |
| | | if (MqttRecvClient.getInstance().isConnected()) { |
| | | //检查断开连接 |
| | | MqttRecvClient.getInstance().reConnect(); |
| | | } |
| | | if (!MqttRecvClient.getInstance().isInit()) { |
| | | HdlMqttLogic.getInstance().getMqttRemoteInfo(HomeType.A, new CloudCallBeak<MqttInfo>() { |
| | | @Override |
| | | public void onSuccess(MqttInfo info) { |
| | | if (info != null) { |
| | | MqttRecvClient.getInstance().setConnectParam(info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord(),null); |
| | | MqttRecvClient.getInstance().setConnectParam(info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord()); |
| | | MqttRecvClient.getInstance().connect(); |
| | | } |
| | | } |