| | |
|---|
| | | import android.os.Bundle; |
|---|
| | | import android.view.KeyEvent; |
|---|
| | | import android.view.LayoutInflater; |
|---|
| | | import android.view.View; |
|---|
| | | import android.widget.Toast; |
|---|
| | | |
|---|
| | | import androidx.appcompat.app.AppCompatActivity; |
|---|
| | |
|---|
| | | import com.jeremyliao.liveeventbus.LiveEventBus; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 首页 |
|---|
| | |
|---|
| | | private List<Fragment> fragments = new ArrayList<>(); |
|---|
| | | private long mExitTime; |
|---|
| | | MqttManager mqttManager; |
|---|
| | | private Map<String, String> workerIddata = new HashMap<>(); |
|---|
| | | |
|---|
| | | |
|---|
| | | private enum Tab { |
|---|
| | | ORDER, MAP, MY |
|---|
| | |
|---|
| | | super.onCreate(savedInstanceState); |
|---|
| | | binding = ActivityMainBinding.inflate(LayoutInflater.from(this)); |
|---|
| | | setContentView(binding.getRoot()); |
|---|
| | | |
|---|
| | | setupFragments(); |
|---|
| | | initView(); |
|---|
| | | initTab(); |
|---|
| | |
|---|
| | | } catch (Exception e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | mqttManager = new MqttManager(this); |
|---|
| | | mqttManager.connect(); |
|---|
| | | mqttManager = new MqttManager(this, this); |
|---|
| | | LiveEventBus.get(CommonKeyName.NetworkCallback).observeForever(new Observer<Object>() { |
|---|
| | | @Override |
|---|
| | | public void onChanged(Object o) { |
|---|
| | |
|---|
| | | |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | //mq传来的消息 |
|---|
| | | LiveEventBus.get(CommonKeyName.MQTTData).observeForever(new Observer<Object>() { |
|---|
| | | @Override |
|---|
| | | public void onChanged(Object o) { |
|---|
| | | workerIddata.put((String) o, (String) o); |
|---|
| | | |
|---|
| | | binding.redDotImg.setVisibility(View.VISIBLE); |
|---|
| | | |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | LiveEventBus.get(CommonKeyName.RedLotRefresh).observeForever(new Observer<Object>() { |
|---|
| | | @Override |
|---|
| | | public void onChanged(Object o) { |
|---|
| | | if (o instanceof Boolean) { |
|---|
| | | if ((boolean) o) { |
|---|
| | | binding.redDotImg.setVisibility(View.GONE); |
|---|
| | | workerIddata.clear(); |
|---|
| | | } |
|---|
| | | } else if (o instanceof String) { |
|---|
| | | workerIddata.remove(o); |
|---|
| | | if (workerIddata.size() == 0) { |
|---|
| | | binding.redDotImg.setVisibility(View.GONE); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | registNetCallBack(); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | private void initTab() { |
|---|
| | | TabAdapter adapter = new TabAdapter(getSupportFragmentManager(), fragments); |
|---|
| | | TabAdapter adapter = new TabAdapter(this, fragments); |
|---|
| | | binding.viewPager.setAdapter(adapter); |
|---|
| | | binding.viewPager.setPagingEnabled(false); |
|---|
| | | binding.viewPager.setCurrentItem(1, false); // 默认显示地图页 |
|---|
| | | binding.viewPager.setOffscreenPageLimit(fragments.size()); |
|---|
| | | binding.viewPager.setCurrentItem(1); // 默认显示地图页 |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | @Override |
|---|
| | | protected void onDestroy() { |
|---|
| | | super.onDestroy(); |
|---|
| | | //关闭MQ |
|---|
| | | |
|---|
| | | try { |
|---|
| | | //关闭MQ |
|---|
| | | mqttManager.disconnect(); |
|---|
| | | unregisterNetworkCallback(); |
|---|
| | | } catch (Exception e) { |
|---|
| | |
|---|
| | | private void unregisterNetworkCallback() { |
|---|
| | | NetUtils.unregisterReceiver(this); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
