火灾消防物联网测试.zip

package com.langkai.www.electricalfiredeviceapp.ui; import android.app.Notification; import android.app.NotificationChannel; import android.app.NotificationManager; import android.app.PendingIntent; import android.content.Context; import android.content.Intent; import android.graphics.Bitmap; import android.graphics.BitmapFactory; import android.graphics.Color; import android.os.Build; import android.os.Handler; import android.os.Bundle; import android.support.v4.app.NotificationCompat; import android.support.v4.widget.DrawerLayout; import android.support.v7.widget.DividerItemDecoration; import android.support.v7.widget.LinearLayoutManager; import android.support.v7.widget.RecyclerView; import android.util.Log; import android.view.View; import android.widget.Button; import android.widget.LinearLayout; import android.widget.Toast; import com.jwenfeng.library.pulltorefresh.BaseRefreshListener; import com.jwenfeng.library.pulltorefresh.PullToRefreshLayout; import com.langkai.www.electricalfiredeviceapp.bean.MonitorPointChannel; import com.langkai.www.electricalfiredeviceapp.R; import com.langkai.www.electricalfiredeviceapp.adapter.MonitorPointAdapter; import com.langkai.www.electricalfiredeviceapp.bean.MonitorPoint; import com.langkai.www.electricalfiredeviceapp.bean.MonitorPointList; import com.langkai.www.electricalfiredeviceapp.utils.Constant; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Timer; import java.util.TimerTask; public class MonitorPointListActivity extends MqttServiceActivity implements BaseRefreshListener, View.OnClickListener { private String TAG = MonitorPointListActivity.class.getSimpleName(); private final String alarmChannelId = "alarm_notify"; private final String faultChannelId = "fault_notify"; private Map<String, MonitorPoint> monitorPointMap; private List<String> mDataList; private boolean isRefreshing = false; private boolean isShown = false; private boolean isBackKeyPressed = false; private MonitorPointAdapter mAdapter = null; private DrawerLayout drawerLayout; private LinearLayout mainLeftDrawerLayout; private RecyclerView recyclerView; private PullToRefreshLayout pullToRefreshLayout; private LinearLayoutManager manager; private Button appSettingButton; NotificationManager notificationManager = null; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_monitor_point_list); pullToRefreshLayout = findViewById(R.id.pull_fresh_layout); pullToRefreshLayout.setRefreshListener(this); mDataList = new ArrayList<>(); monitorPointMap = new HashMap<>(); mAdapter = new MonitorPointAdapter(this, mDataList, monitorPointMap); recyclerView = findViewById(R.id.recycle_view); manager = new LinearLayoutManager(this); manager.setOrientation(LinearLayoutManager.VERTICAL); recyclerView.setLayoutManager(manager); recyclerView.setAdapter(mAdapter); recyclerView.addItemDecoration(new DividerItemDecoration(this, DividerItemDecoration.VERTICAL)); notificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE); drawerLayout = findViewById(R.id.main_drawer_layout); drawerLayout.setScrimColor(Color.TRANSPARENT); mainLeftDrawerLayout = findViewById(R.id.main_left_drawer_layout); appSettingButton = findViewById(R.id.app_setting_button); appSettingButton.setOnClickListener(this); initData(); } @Override protected void onPause() { super.onPause(); isShown = false; } @Override protected void onResume() { super.onResume(); isShown = true; if(mAdapter != null){ mAdapter.notifyDataSetChanged(); } } @Override protected void onDestroy() { super.onDestroy(); if(Build.VERSION.SDK_INT >= Build.VERSION_CODES.O){ notificationManager.cancelAll(); notificationManager.deleteNotificationChannel(alarmChannelId); }else{ notificationManager.cancelAll(); } } private void initData(){ for(int i = 1 ; i < 50; i++){ String id = String.format(Locale.ENGLISH,"%05d", i); mDataList.add(id); MonitorPoint mp = new MonitorPoint(id, "未定义"); MonitorPointChannel ch1 = new MonitorPointChannel(1, Constant.FUNCTION_RESIDUAL_CURRENT); ch1.setChannelStatus(Constant.STATUS_OK); ch1.setValue(30.22); mp.addMonitorPointChannel(1, ch1); MonitorPointChannel ch2 = new MonitorPointChannel(2, Constant.FUNCTION_TEMPERATURE); ch2.setChannelStatus(Constant.STATUS_FAULT); ch2.setChannelFaultType(Constant.FAULT_BREAK); mp.addMonitorPointChannel(2, ch2); MonitorPointChannel ch3 = new MonitorPointChannel(3, Constant.FUNCTION_RUNNING_CURRENT); ch3.setChannelStatus(Constant.STATUS_ALARM); ch3.setChannelAlarmType(Constant.ALARM_UPPER_LIMIT); ch3.setValue(20); mp.addMonitorPointChannel(3, ch3); MonitorPointChannel ch4 = new MonitorPointChannel(4, Constant.FUNCTION_RUNNING_VOLT); ch4.setChannelStatus(Constant.STATUS_DISCONNECTED); mp.addMonitorPointChannel(4, ch4); for(int chno = 5; chno <= 12; chno++){ MonitorPointChannel ch = new MonitorPointChannel(chno, Constant.FUNCTION_RESIDUAL_CURRENT); ch1.setChannelStatus(Constant.STATUS_OK); ch1.setValue(30.22); mp.addMonitorPointChannel(chno, ch); } /* for(int ch = 2; ch <= 3; ch++){ mp.addMonitorPointChannel(ch, new MonitorPointChannel(ch)); } */ monitorPointMap.put(id, mp); } mAdapter.notifyDataSetChanged(); } @Override protected void onServiceBound() { super.onServiceBound(); //connectIotService(); } @Override protected void onServiceUnbound() { super.onServiceUnbound(); disconnectIotService(); } @Override public void serviceConnected() { super.serviceConnected(); new Handler().postDelayed(new Runnable() { @Override public void run() { requestMonitorPointList(); } }, 1000); } @Override public void monitorPointListUpdate(MonitorPointList list) { List<MonitorPointList.MonitorPointInfo> infoList = list.getDeviceInfos(); for(int i = 0 ; i < infoList.size(); i++){ MonitorPointList.MonitorPointInfo info = infoList.get(i); if(!mDataList.contains(info.getId())){ String id = info.getId(); mDataList.add(id); monitorPointMap.put(id, new MonitorPoint(id, info.getName(), info.getStatus())); } } mAdapter.notifyDataSetChanged(); pullToRefreshLayout.finishRefresh(); isRefreshing = false; } @Override public void monitorPointUpdate(MonitorPoint mp) { String id = mp.getDeviceId(); if(!monitorPointMap.containsKey(id)) return; MonitorPoint preMp = monitorPointMap.get(id); if(preMp.getMonitorPointStatus() != Constant.STATUS_ALARM && mp.getMonitorPointStatus() == Constant.STATUS_ALARM) { //报警提示 setupNotification(mp, Constant.ALARM_NOTIFICATION); }else if(preMp.getMonitorPointStatus() == Constant.STATUS_OK &&(mp.getMonitorPointStatus() == Constant.STATUS_DISCONNECTED || mp.getMonitorPointStatus() == Constant.S