From d1ebb94e1a17b7c25d4fcf73d85345d92cc86b5c Mon Sep 17 00:00:00 2001 From: mac <user@users-MacBook-Pro.local> Date: 星期二, 02 一月 2024 18:41:34 +0800 Subject: [PATCH] 2024年01月02日18:41:32 --- app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java | 456 +++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 431 insertions(+), 25 deletions(-) diff --git a/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java b/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java index 4f6568f..a83b80e 100644 --- a/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java +++ b/app/src/main/java/com/hdl/photovoltaic/ui/MyPowerStationActivity.java @@ -1,23 +1,78 @@ 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.Intent; +import android.content.IntentFilter; +import android.content.UriPermission; import android.content.pm.PackageManager; import android.os.Bundle; +import android.os.Process; +import android.text.TextUtils; 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.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.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.BUserInfo; +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; +import com.hdl.photovoltaic.widget.ConfirmationCancelDialog; +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.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; + +import java.lang.reflect.Type; +import java.util.List; +/** + * 鎴戠殑鐢电珯鐣岄潰 + */ public class MyPowerStationActivity extends CustomBaseActivity { + private ActivityMyPowerStationBinding viewBinding; - private int currentFragmentIndex = 0; + private int currentFragmentIndex = 1; + private EventListener allTopicsListener; + + private int backPressTimes; + + private NetworkChangeReceiver networkChangeReceiver; @Override @@ -28,58 +83,409 @@ @Override public void onBindView(Bundle savedInstanceState) { - + setNotificationBarBackgroundColor(CustomColor.blue); //鍒濆鍖� - initView(); + this.initView(); //鍒濆鍖栫晫闈㈢洃鍚櫒 - initEvent(); + this.initEvent(); + //娉ㄥ唽鐩戝惉 + this.registerAllTopicsListener(); + //鍒濆鍖杕qtt瀹㈡埛绔� + this.initMqttClient(); + //鐩戝惉缃戠粶鐘舵�佸彉鍖� + this.networkMonitoring(); + //鐐瑰嚮鏋佸厜閫氱煡鏍忔秷鎭繘鏉� + this.clickJpushNotificationMessage(); + //閫氱煡闄愭潈 + this.notificationSet(); + + + } + + /** + * 寮�鍚�氱煡鏉冮檺 + */ + private void notificationSet() { + boolean isBoolean = PermissionUtils.isNotificationEnabled(_mActivity); + if (!isBoolean) { + ConfirmationCancelDialog confirmationCancelDialog = new ConfirmationCancelDialog(_mActivity); + confirmationCancelDialog.setTitle("鎻愮ず"); + confirmationCancelDialog.setContent("閫氱煡鏉冮檺娌″紑鍚�,灏嗘棤娉曟敹鍒版帹閫佷俊鎭�."); + confirmationCancelDialog.setConfirmation("鍓嶅線璁剧疆"); + confirmationCancelDialog.show(); + confirmationCancelDialog.setYesOnclickListener(new ConfirmationCancelDialog.onYesOnclickListener() { + @Override + public void Confirm() { + confirmationCancelDialog.dismiss(); + PermissionUtils.openNotificationSettings(_mActivity); + + } + }); + confirmationCancelDialog.setNoOnclickListener(new ConfirmationCancelDialog.onNoOnclickListener() { + @Override + public void Cancel() { + confirmationCancelDialog.dismiss(); + } + }); + + } + } + + /** + * 鐩戝惉缃戠粶鐘舵�佸彉鍖� + */ + private void networkMonitoring() { + IntentFilter intentFilter = new IntentFilter(); + intentFilter.addAction("android.net.conn.CONNECTIVITY_CHANGE"); + networkChangeReceiver = new NetworkChangeReceiver(); + registerReceiver(networkChangeReceiver, intentFilter); } private void initEvent() { viewBinding.myPowerStationBottomIl1.clickTv.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { - currentFragmentIndex = 0; - bottomViewChangeOfStyle(); - } - }); - viewBinding.myPowerStationBottomIl2.clickTv.setOnClickListener(new View.OnClickListener() { - @Override - public void onClick(View v) { currentFragmentIndex = 1; bottomViewChangeOfStyle(); + postEventBus(HomepageTitleTabSwitch.powerstation); } }); + viewBinding.myMessageBottomIl2.clickTv.setOnClickListener(new View.OnClickListener() { + @Override + public void onClick(View v) { + currentFragmentIndex = 2; + bottomViewChangeOfStyle(); + postEventBus(HomepageTitleTabSwitch.message); + } + }); + viewBinding.myMeBottomIl3.clickTv.setOnClickListener(new View.OnClickListener() { + @Override + public void onClick(View v) { + currentFragmentIndex = 3; + bottomViewChangeOfStyle(); + postEventBus(HomepageTitleTabSwitch.me); + } + }); + } + @Override + protected void onDestroy() { + super.onDestroy(); + HdlUniLogic.getInstance().checkRemoveOtherUniMPEventCallBack(); + //绉婚櫎鐩戝惉 + HDLLinkLocalSdk.getInstance().removeAllTopicsListener(allTopicsListener); + //绉婚櫎鐩戝惉缃戠粶鐘舵�佸彉鍖� + unregisterReceiver(networkChangeReceiver); + + } + private void initView() { - viewBinding.myPowerStationBottomIl1.titleTv.setText(R.string.my_power_station_鐢电珯); - viewBinding.myPowerStationBottomIl2.titleTv.setText(R.string.my_power_station_鎴戠殑); + viewBinding.myPowerStationBottomIl1.titleTv.setText("棣栭〉");// + viewBinding.myMessageBottomIl2.titleTv.setText(R.string.message); + viewBinding.myMeBottomIl3.titleTv.setText(R.string.power_station_me); this.bottomViewChangeOfStyle(); } private void bottomViewChangeOfStyle() { - if (this.currentFragmentIndex == 0) { - viewBinding.myPowerStationFcv1.setVisibility(View.VISIBLE); - viewBinding.myPowerStationFcv2.setVisibility(View.GONE); + if (this.currentFragmentIndex == 1) { + viewBinding.myPowerStationFcv1.setVisibility(View.VISIBLE);//鏄剧ず鐢电珯鐣岄潰 + viewBinding.myMessageFcv2.setVisibility(View.GONE);//闅愯棌娑堟伅鐣岄潰 + viewBinding.myMeFcv3.setVisibility(View.GONE);//闅愯棌鎴戠殑鐣岄潰 viewBinding.myPowerStationBottomIl1.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.selectedpowerstation)); viewBinding.myPowerStationBottomIl1.titleTv.setTextColor(getColor(R.color.text_90000000)); - viewBinding.myPowerStationBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedme)); - viewBinding.myPowerStationBottomIl2.titleTv.setTextColor(getColor(R.color.text_65000000)); - } else { - viewBinding.myPowerStationFcv1.setVisibility(View.GONE); - viewBinding.myPowerStationFcv2.setVisibility(View.VISIBLE); + viewBinding.myMessageBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.message_unselected)); + viewBinding.myMessageBottomIl2.titleTv.setTextColor(getColor(R.color.text_65000000)); + viewBinding.myMeBottomIl3.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedme)); + viewBinding.myMeBottomIl3.titleTv.setTextColor(getColor(R.color.text_65000000)); + } else if (this.currentFragmentIndex == 2) { + viewBinding.myPowerStationFcv1.setVisibility(View.GONE);//闅愯棌鐢电珯鐣岄潰 + viewBinding.myMessageFcv2.setVisibility(View.VISIBLE);//鏄剧ず娑堟伅鐣岄潰 + viewBinding.myMeFcv3.setVisibility(View.GONE);//闅愯棌鎴戠殑鐣岄潰 viewBinding.myPowerStationBottomIl1.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedpowerstation)); viewBinding.myPowerStationBottomIl1.titleTv.setTextColor(getColor(R.color.text_65000000)); - viewBinding.myPowerStationBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.selectedme)); - viewBinding.myPowerStationBottomIl2.titleTv.setTextColor(getColor(R.color.text_90000000)); - - + viewBinding.myMessageBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.message_select)); + viewBinding.myMessageBottomIl2.titleTv.setTextColor(getColor(R.color.text_90000000)); + viewBinding.myMeBottomIl3.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedme)); + viewBinding.myMeBottomIl3.titleTv.setTextColor(getColor(R.color.text_65000000)); + } else if (this.currentFragmentIndex == 3) { + viewBinding.myPowerStationFcv1.setVisibility(View.GONE);//闅愯棌鐢电珯鐣岄潰 + viewBinding.myMessageFcv2.setVisibility(View.GONE);//闅愯棌娑堟伅鐣岄潰 + viewBinding.myMeFcv3.setVisibility(View.VISIBLE);//鏄剧ず鎴戠殑鐣岄潰 + viewBinding.myPowerStationBottomIl1.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.unselectedpowerstation)); + viewBinding.myPowerStationBottomIl1.titleTv.setTextColor(getColor(R.color.text_65000000)); + viewBinding.myMessageBottomIl2.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.message_unselected)); + viewBinding.myMessageBottomIl2.titleTv.setTextColor(getColor(R.color.text_65000000)); + viewBinding.myMeBottomIl3.iconIv.setImageDrawable(AppCompatResources.getDrawable(_mActivity, R.drawable.selectedme)); + viewBinding.myMeBottomIl3.titleTv.setTextColor(getColor(R.color.text_90000000)); } } + /** + * 鍙戝竷鐐瑰嚮浜嬩欢 + * + * @param tabSwitch - + */ + private void postEventBus(HomepageTitleTabSwitch tabSwitch) { + BaseEventBus baseEventBus = new BaseEventBus(); + baseEventBus.setTopic(ConstantManage.homepage_title_tab_switch); + baseEventBus.setType(tabSwitch.toString()); + EventBus.getDefault().postSticky(baseEventBus); + } + + public void requestPermissions() { + String[] ary = PermissionUtils.checkPermission(_mActivity, new String[]{Manifest.permission.ACCESS_FINE_LOCATION}); + if (ary.length > 0) { + requestPermissions(ary, PermissionUtils.STATUS_SUCCESS); + } else { + if (mPermissionsResultCallback != null) { + mPermissionsResultCallback.succeed(); + } + } + } + + @Override + public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) { + super.onRequestPermissionsResult(requestCode, permissions, grantResults); + if (requestCode == PermissionUtils.STATUS_SUCCESS) { + for (int i = 0; i < permissions.length; i++) { + if (grantResults[i] == PackageManager.PERMISSION_GRANTED) { + if (mPermissionsResultCallback != null) { + mPermissionsResultCallback.succeed(); + } + } + + } + } + + } + + + private PermissionsResultCallback mPermissionsResultCallback; + + public void setPermissionsResultCallback(PermissionsResultCallback permissionsResultCallback) { + mPermissionsResultCallback = permissionsResultCallback; + } + + public interface PermissionsResultCallback { + + void succeed(); + + void failing(); + + } + + + /** + * 娉ㄥ唽鎵�鏈変富棰樻暟鎹殑鐩戝惉 + */ + private void registerAllTopicsListener() { + allTopicsListener = new EventListener() { + @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("鐩戝惉鍒癕odbus鏁版嵁--->" + new Gson().toJson(response), false); +// if (response.getTopic().endsWith("custom/native/inverter/up")) { + HDLUniMP.UniCallBackBaseBean uniCallBackBaseBean = new HDLUniMP.UniCallBackBaseBean(); + uniCallBackBaseBean.setType(response.getTopic()); + uniCallBackBaseBean.setData(response.getData()); + 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); + } else if (linkResponse.getTopic().endsWith("/custom/device/list/upload")) { + //閫嗗彉鍣ㄦ湁鏂皁id閫氱煡涓婚 + if (linkResponse.getData() == null) { + HdlLogLogic.print("閫嗗彉鍣ㄦ湁鏂皁id閫氱煡--->鏁版嵁涓虹┖", 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); + } + + /** + * 鍒濆鍖杕qtt瀹㈡埛绔� + */ + public void initMqttClient() { + HdlMqttLogic.getInstance().getMqttRemoteInfo(HomeType.A, new CloudCallBeak<MqttInfo>() { + @Override + public void onSuccess(MqttInfo info) { + if (info != null) { + MqttRecvClient.init(_mActivity, info.getUrl(), info.getClientId(), info.getUserName(), info.getPassWord()); + } + } + + @Override + public void onFailure(HDLException e) { + HdlLogLogic.print("璇诲彇mqtt杩滅▼淇℃伅澶辫触--->" + e.getMessage(), e.getCode(), true); + } + }); + } + + @Subscribe(threadMode = ThreadMode.MAIN) + public void onEventMessage(BaseEventBus event) { + + if (event == null) { + return; + } + 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; + } + int index = -1; + 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])) { + 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璁㈤槄锛屽姞瑙e瘑浼氱敤鍒拌鍙傛暟; + HDLLinkConfig.getInstance().setAesKey(deviceRemoteInfo.getSecret());//璁剧疆mqtt閫氳绉橀挜搴� + } + } + + @Override + public void onFailure(HDLException e) { + + } + }); + } + } else if (event.getTopic().contains(HdlOtaLogic.localDownloadProgress)) { + //涓嬭浇浜戠椹卞姩鎴栬�呭浐浠舵枃浠跺埌鏈湴,鑷繁璁$畻杩涘害鏉′笂鎶ュ埌uni閭h竟 + 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); + } else if (event.getTopic().contains(ConstantManage.network_change_post)) { +// String wifi_ssid = WifiUtils.getInstance().getCurrentConnectWifiSsid();//鑾峰彇WiFi鐨剆sid闇�瑕佷綅缃潈闄愮殑 + HdlLogLogic.print("鐩戝惉缃戠粶鐘舵��--->" + event.getData().toString() + "(" + event.getType() + ")", true); + //绗竴娆″惎鍔ˋpp,浠ュ強鍒囨崲缃戠粶鐨勬椂鍊欐洿鏂� + 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(); + } + }); + } + }); + } + } + } + + /** + * 鐐瑰嚮鏋佸厜閫氱煡鏍忔秷鎭繘鏉� + */ + private void clickJpushNotificationMessage() { + Intent intent = getIntent(); + if (intent != null) { + String key = intent.getStringExtra("skip"); + if (key != null) { + //瑙﹀彂娑堟伅鐐瑰嚮浜嬩欢 + viewBinding.myMessageBottomIl2.clickTv.performClick(); + } + } + } + + + /** + * 鐗╃悊鎸夐敭杩斿洖浜嬩欢 + */ + @Override + public void onBackPressed() { + if (AppManagerUtils.getAppManager().getActivitySize() <= 1) { + if (backPressTimes == 0) { + HdlThreadLogic.toast(_mActivity, R.string.kill_app); + backPressTimes = 1; + new Thread() { + @Override + public void run() { + try { + Thread.sleep(2000); + } catch (InterruptedException e) { + e.printStackTrace(); + } finally { + backPressTimes = 0; + } + } + }.start(); + return; + } else { + AppManagerUtils.getAppManager().finishAllActivity(); + Process.killProcess(Process.myPid()); + } + } + super.onBackPressed(); + } + } \ No newline at end of file -- Gitblit v1.8.0