public class MainActivity extends BaseActivity implements EMEventListener

/**
   * 監(jiān)聽(tīng)事件
   */
  @Override
  public void onEvent(EMNotifierEvent event) {
    switch (event.getEvent()) {
    case EventNewMessage: // 普通消息
    {
      EMMessage message = (EMMessage) event.getData();
      // 提示新消息
      HXSDKHelper.getInstance().getNotifier().onNewMsg(message);
      refreshUI();
      break;
    }
    case EventOfflineMessage: {
      refreshUI();
      break;
    }
    case EventConversationListChanged: {
      refreshUI();
      break;
    }

    default:
      break;
    }
  }

private void init() {
    // setContactListener監(jiān)聽(tīng)聯(lián)系人的變化等
    EMContactManager.getInstance().setContactListener(new MyContactListener());
    // 注冊(cè)一個(gè)監(jiān)聽(tīng)連接狀態(tài)的listener
    connectionListener = new MyConnectionListener();
    EMChatManager.getInstance().addConnectionListener(connectionListener);

    groupChangeListener = new MyGroupChangeListener();
    // 注冊(cè)群聊相關(guān)的listener
  }

/**
 * 聯(lián)系人列表頁(yè)
 */
public class ContactlistFragment extends Fragment {
  public static final String TAG = "ContactlistFragment";
  private ContactAdapter adapter;
  private List<User> contactList;
  private ListView listView;
  private boolean hidden;
  private Sidebar sidebar;
  private InputMethodManager inputMethodManager;
  private List<String> blackList;
  ImageButton clearSearch;
  EditText query;
  HXContactSyncListener contactSyncListener;
  HXBlackListSyncListener blackListSyncListener;
  View progressBar;
  Handler handler = new Handler();
  private User toBeProcessUser;
  private String toBeProcessUsername;

  /**
   * 這里注冊(cè)了兩個(gè)監(jiān)聽(tīng)器，目的在于同步聯(lián)系人信息
   * 當(dāng)聯(lián)系人發(fā)生變化、黑名單發(fā)生變化，通知這里注冊(cè)的監(jiān)聽(tīng)器
   * 進(jìn)而刷新界面
   *
   */
  class HXContactSyncListener implements HXSDKHelper.HXSyncListener {
    @Override
    public void onSyncSucess(final boolean success) {
      EMLog.d(TAG, "on contact list sync success:" + success);
      ContactlistFragment.this.getActivity().runOnUiThread(new Runnable() {
        public void run() {
          getActivity().runOnUiThread(new Runnable(){
            @Override
            public void run() {
              if(success){
                progressBar.setVisibility(View.GONE);
                refresh();
              }else{
                String s1 = getResources().getString(R.string.get_failed_please_check);
                Toast.makeText(getActivity(), s1, 1).show();
                progressBar.setVisibility(View.GONE);
              }
            }

          });
        }
      });
    }
  }

  class HXBlackListSyncListener implements HXSyncListener{
    @Override
    public void onSyncSucess(boolean success) {
      getActivity().runOnUiThread(new Runnable(){
        @Override
        public void run() {
          blackList = EMContactManager.getInstance().getBlackListUsernames();
          refresh();
        }
      });
    }

  };

  @Override
  public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {
    return inflater.inflate(R.layout.fragment_contact_list, container, false);
  }

  @Override
  public void onActivityCreated(Bundle savedInstanceState) {
    super.onActivityCreated(savedInstanceState);
    //防止被T后，沒(méi)點(diǎn)確定按鈕然后按了home鍵，長(zhǎng)期在后臺(tái)又進(jìn)app導(dǎo)致的crash
    if(savedInstanceState != null && savedInstanceState.getBoolean("isConflict", false))
      return;
    inputMethodManager = (InputMethodManager) getActivity().getSystemService(Context.INPUT_METHOD_SERVICE);
    listView = (ListView) getView().findViewById(R.id.list);
    sidebar = (Sidebar) getView().findViewById(R.id.sidebar);
    sidebar.setListView(listView);

    //黑名單列表
    blackList = EMContactManager.getInstance().getBlackListUsernames();
    contactList = new ArrayList<User>();
    // 獲取設(shè)置contactlist
    getContactList();
    //搜索框
    query = (EditText) getView().findViewById(R.id.query);
    query.setHint(R.string.search);
    clearSearch = (ImageButton) getView().findViewById(R.id.search_clear);
    query.addTextChangedListener(new TextWatcher() {
      public void onTextChanged(CharSequence s, int start, int before, int count) {
        adapter.getFilter().filter(s);
        if (s.length() > 0) {
          clearSearch.setVisibility(View.VISIBLE);
        } else {
          clearSearch.setVisibility(View.INVISIBLE);
        }
      }
      public void beforeTextChanged(CharSequence s, int start, int count, int after) {
      }
      public void afterTextChanged(Editable s) {
      }
    });
    clearSearch.setOnClickListener(new OnClickListener() {
      @Override
      public void onClick(View v) {
        query.getText().clear();
        hideSoftKeyboard();
      }
    });

    // 設(shè)置adapter
    adapter = new ContactAdapter(getActivity(), R.layout.row_contact, contactList);
    listView.setAdapter(adapter);
    listView.setOnItemClickListener(new OnItemClickListener() {

      @Override
      public void onItemClick(AdapterView<?> parent, View view, int position, long id) {
        String username = adapter.getItem(position).getUsername();
        if (Constant.NEW_FRIENDS_USERNAME.equals(username)) {
          // 進(jìn)入申請(qǐng)與通知頁(yè)面
          User user = DemoApplication.getInstance().getContactList().get(Constant.NEW_FRIENDS_USERNAME);
          user.setUnreadMsgCount(0);
          startActivity(new Intent(getActivity(), NewFriendsMsgActivity.class));
        } else if (Constant.GROUP_USERNAME.equals(username)) {
          // 進(jìn)入群聊列表頁(yè)面
          startActivity(new Intent(getActivity(), GroupsActivity.class));
        } else if(Constant.CHAT_ROOM.equals(username)){
          //進(jìn)入聊天室列表頁(yè)面
          startActivity(new Intent(getActivity(), PublicChatRoomsActivity.class));
        }else {
          // demo中直接進(jìn)入聊天頁(yè)面，實(shí)際一般是進(jìn)入用戶(hù)詳情頁(yè)
          startActivity(new Intent(getActivity(), ChatActivity.class).putExtra("userId", adapter.getItem(position).getUsername()));
        }
      }
    });
    listView.setOnTouchListener(new OnTouchListener() {
      @Override
      public boolean onTouch(View v, MotionEvent event) {
        // 隱藏軟鍵盤(pán)
        if (getActivity().getWindow().getAttributes().softInputMode
            != WindowManager.LayoutParams.SOFT_INPUT_STATE_HIDDEN) {
          if (getActivity().getCurrentFocus() != null)
            inputMethodManager.hideSoftInputFromWindow(getActivity().getCurrentFocus().getWindowToken(),
                InputMethodManager.HIDE_NOT_ALWAYS);
        }
        return false;
      }
    });

    ImageView addContactView = (ImageView) getView().findViewById(R.id.iv_new_contact);
    // 進(jìn)入添加好友頁(yè)
    addContactView.setOnClickListener(new OnClickListener() {

      @Override
      public void onClick(View v) {
        startActivity(new Intent(getActivity(), AddContactActivity.class));
      }
    });
    registerForContextMenu(listView);

    progressBar = (View) getView().findViewById(R.id.progress_bar);

    contactSyncListener = new HXContactSyncListener();
    HXSDKHelper.getInstance().addSyncContactListener(contactSyncListener);

    blackListSyncListener = new HXBlackListSyncListener();
    HXSDKHelper.getInstance().addSyncBlackListListener(blackListSyncListener);

    if (!HXSDKHelper.getInstance().isContactsSyncedWithServer()) {
      progressBar.setVisibility(View.VISIBLE);
    } else {
      progressBar.setVisibility(View.GONE);
    }
  }

  @Override
  public void onCreateContextMenu(ContextMenu menu, View v, ContextMenuInfo menuInfo) {
    super.onCreateContextMenu(menu, v, menuInfo);
    if (((AdapterContextMenuInfo) menuInfo).position > 2) {
      toBeProcessUser = adapter.getItem(((AdapterContextMenuInfo) menuInfo).position);
      toBeProcessUsername = toBeProcessUser.getUsername();
      getActivity().getMenuInflater().inflate(R.menu.context_contact_list, menu);
    }
  }

  @Override
  public boolean onContextItemSelected(MenuItem item) {
    if (item.getItemId() == R.id.delete_contact) {
      try {
        // 刪除此聯(lián)系人
        deleteContact(toBeProcessUser);
        // 刪除相關(guān)的邀請(qǐng)消息
        InviteMessgeDao dao = new InviteMessgeDao(getActivity());
        dao.deleteMessage(toBeProcessUser.getUsername());
      } catch (Exception e) {
        e.printStackTrace();
      }
      return true;
    }else if(item.getItemId() == R.id.add_to_blacklist){
      moveToBlacklist(toBeProcessUsername);
      return true;
    }
    return super.onContextItemSelected(item);
  }

  /**
   * 當(dāng)該Fragment對(duì)象改變了隱藏狀態(tài)（由isHidden()方法返回）時(shí)，系統(tǒng)會(huì)調(diào)用這個(gè)方法。
   * Fragment初始是不隱藏的，只要Fragment對(duì)象改變了它的顯示狀態(tài)，就會(huì)調(diào)用該方法。
   * 參數(shù)hidden 如果該Fragment對(duì)象現(xiàn)在是隱藏的，則該參數(shù)是true，否則是false。
   */
  @Override
  public void onHiddenChanged(boolean hidden) {
    super.onHiddenChanged(hidden);
    this.hidden = hidden;
    if (!hidden) {
      refresh();
    }
  }

  @Override
  public void onResume() {
    super.onResume();
    if (!hidden) {
      refresh();
    }
  }

  /**
   * 刪除聯(lián)系人
   * 
   * @param toDeleteUser
   */
  public void deleteContact(final User tobeDeleteUser) {
    String st1 = getResources().getString(R.string.deleting);
    final String st2 = getResources().getString(R.string.Delete_failed);
    final ProgressDialog pd = new ProgressDialog(getActivity());
    pd.setMessage(st1);
    pd.setCanceledOnTouchOutside(false);
    pd.show();
    new Thread(new Runnable() {
      public void run() {
        try {
          EMContactManager.getInstance().deleteContact(tobeDeleteUser.getUsername());
          // 刪除db和內(nèi)存中此用戶(hù)的數(shù)據(jù)
          UserDao dao = new UserDao(getActivity());
          dao.deleteContact(tobeDeleteUser.getUsername());
          DemoApplication.getInstance().getContactList().remove(tobeDeleteUser.getUsername());
          getActivity().runOnUiThread(new Runnable() {
            public void run() {
              pd.dismiss();
              adapter.remove(tobeDeleteUser);
              adapter.notifyDataSetChanged();

            }
          });
        } catch (final Exception e) {
          getActivity().runOnUiThread(new Runnable() {
            public void run() {
              pd.dismiss();
              Toast.makeText(getActivity(), st2 + e.getMessage(), 1).show();
            }
          });

        }

      }
    }).start();

  }

  /**
   * 把user移入到黑名單
   */
  private void moveToBlacklist(final String username){
    final ProgressDialog pd = new ProgressDialog(getActivity());
    String st1 = getResources().getString(R.string.Is_moved_into_blacklist);
    final String st2 = getResources().getString(R.string.Move_into_blacklist_success);
    final String st3 = getResources().getString(R.string.Move_into_blacklist_failure);
    pd.setMessage(st1);
    pd.setCanceledOnTouchOutside(false);
    pd.show();
    new Thread(new Runnable() {
      public void run() {
        try {
          //加入到黑名單
          EMContactManager.getInstance().addUserToBlackList(username,false);
          getActivity().runOnUiThread(new Runnable() {
            public void run() {
              pd.dismiss();
              Toast.makeText(getActivity(), st2, 0).show();
              refresh();
            }
          });
        } catch (EaseMobException e) {
          e.printStackTrace();
          getActivity().runOnUiThread(new Runnable() {
            public void run() {
              pd.dismiss();
              Toast.makeText(getActivity(), st3, 0).show();
            }
          });
        }
      }
    }).start();

  }

  // 刷新ui
  public void refresh() {
    try {
      // 可能會(huì)在子線程中調(diào)到這方法
      getActivity().runOnUiThread(new Runnable() {
        public void run() {
          getContactList();
          adapter.notifyDataSetChanged();
        }
      });
    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  @Override
  public void onDestroy() {
    if (contactSyncListener != null) {
      HXSDKHelper.getInstance().removeSyncContactListener(contactSyncListener);
      contactSyncListener = null;
    }
    if(blackListSyncListener != null){
      HXSDKHelper.getInstance().removeSyncBlackListListener(blackListSyncListener);
    }
    super.onDestroy();
  }

  public void showProgressBar(boolean show) {
    if (progressBar != null) {
      if (show) {
        progressBar.setVisibility(View.VISIBLE);
      } else {
        progressBar.setVisibility(View.GONE);
      }
    }
  }

  /**
   * 獲取聯(lián)系人列表，并過(guò)濾掉黑名單和排序
   */
  private void getContactList() {
    contactList.clear();
    //獲取本地好友列表
    Map<String, User> users = DemoApplication.getInstance().getContactList();
    Iterator<Entry<String, User>> iterator = users.entrySet().iterator();
    while (iterator.hasNext()) {
      Entry<String, User> entry = iterator.next();
      if (!entry.getKey().equals(Constant.NEW_FRIENDS_USERNAME)
          && !entry.getKey().equals(Constant.GROUP_USERNAME)
          && !entry.getKey().equals(Constant.CHAT_ROOM)
          && !blackList.contains(entry.getKey())){
        EMLog.i(TAG, "獲取聯(lián)系人="+entry.getValue());
        contactList.add(entry.getValue());
      }
    }
    // 排序
    Collections.sort(contactList, new Comparator<User>() {

      @Override
      public int compare(User lhs, User rhs) {
        return lhs.getUsername().compareTo(rhs.getUsername());
      }
    });

    // 加入"群聊"和"聊天室"
    if(users.get(Constant.CHAT_ROOM) != null)
      contactList.add(0, users.get(Constant.CHAT_ROOM));
    if(users.get(Constant.GROUP_USERNAME) != null)
      contactList.add(0, users.get(Constant.GROUP_USERNAME));

    // 把"申請(qǐng)與通知"添加到首位
    if(users.get(Constant.NEW_FRIENDS_USERNAME) != null)
      contactList.add(0, users.get(Constant.NEW_FRIENDS_USERNAME));
  }

  void hideSoftKeyboard() {
    if (getActivity().getWindow().getAttributes().softInputMode != 
        WindowManager.LayoutParams.SOFT_INPUT_STATE_HIDDEN) {
      if (getActivity().getCurrentFocus() != null)
        inputMethodManager.hideSoftInputFromWindow(getActivity().getCurrentFocus().getWindowToken(),
            InputMethodManager.HIDE_NOT_ALWAYS);
    }
  }

  @Override
  public void onSaveInstanceState(Bundle outState) {
    super.onSaveInstanceState(outState);
    if(((MainActivity)getActivity()).isConflict){
      outState.putBoolean("isConflict", true);
    }else if(((MainActivity)getActivity()).getCurrentAccountRemoved()){
      outState.putBoolean(Constant.ACCOUNT_REMOVED, true);
    }

  }
}

public void addSyncGroupListener(HXSyncListener listener) {
    if (listener == null) {
      return;
    }
    if (!syncGroupsListeners.contains(listener)) {
      syncGroupsListeners.add(listener);
    }
  }

  public void removeSyncGroupListener(HXSyncListener listener) {
    if (listener == null) {
      return;
    }
    if (syncGroupsListeners.contains(listener)) {
      syncGroupsListeners.remove(listener);
    }
  }

  public void addSyncContactListener(HXSyncListener listener) {
    if (listener == null) {
      return;
    }
    if (!syncContactsListeners.contains(listener)) {
      syncContactsListeners.add(listener);
    }
  }

  public void removeSyncContactListener(HXSyncListener listener) {
    if (listener == null) {
      return;
    }
    if (syncContactsListeners.contains(listener)) {
      syncContactsListeners.remove(listener);
    }
  }

  public void addSyncBlackListListener(HXSyncListener listener) {
    if (listener == null) {
      return;
    }
    if (!syncBlackListListeners.contains(listener)) {
      syncBlackListListeners.add(listener);
    }
  }

  public void removeSyncBlackListListener(HXSyncListener listener) {
    if (listener == null) {
      return;
    }
    if (syncBlackListListeners.contains(listener)) {
      syncBlackListListeners.remove(listener);
    }
  }
  public void noitifyGroupSyncListeners(boolean success){
    for (HXSyncListener listener : syncGroupsListeners) {
      listener.onSyncSucess(success);
    }
  }
  public void notifyContactsSyncListener(boolean success){
    for (HXSyncListener listener : syncContactsListeners) {
      listener.onSyncSucess(success);
    }
  }
   public void notifyBlackListSyncListener(boolean success){
    for (HXSyncListener listener : syncBlackListListeners) {
      listener.onSyncSucess(success);
    }
  }