Android: Imitate WeChat source code

Source code introduction: Test account: 123456888 Password: 123456888 For individual developers or small businesses, it is a trend to use third-party IM. After all, it is almost impractical to have an entire IM system for operational use (technical threshold and maintenance cost). So I summarized my previous experience and gains and made this APP that completely imitates WeChat. In general, the big architecture here still uses the UIdemo officially provided by Huanxin, but many of the details and most of the pages are carefully written by me according to the logic and UI design of WeChat. In terms of functions, it currently solves social functions such as friend system, user information, single chat, group chat, etc., and will continue to update functions such as changing chat background, searching local users, circle of friends, and more chat emoticons in the future. . . 1. Registration and login part: 1.1 Rewrite the default blue bottom line of EditText to WeChat green 1.2 Login and registration buttons monitor the input box and change color 1.3 Password plain text and hidden 2. Home page 2.1 Fully imitate the WeChat bottom navigation 2.2 The plus button in the upper right corner can enter "Initiate Group Chat" and "Add Friends" 2.3 Display the number of unread messages and unread notifications 3. Chat list page: 3.1 Group chat avatar is a combination of group members' avatars, there are 1.2.3.4.5 types of avatars 3.2 Top function. After pinning, the conversation item is placed at the top of the list and changes its background color like WeChat. 3.3 Delete list function to delete the conversation record. 4. Address book page 4.1 Display friend list 4.2 Enter and apply for notification 4.3 Enter group chat list 5. Discovery page (friend circle function is being developed...) 6. User details page 6.1 Profile settings (currently the information that can be changed is: avatar, nickname, gender) 6.2 WeChat account can only be set once. 6.3 Settings page (notification, sound, vibration, logout) 7. User application notification7.1 Sort by time from recent to far7.2 Display the reason for application7.3 Processing status (added, agreed) 8. Find and add users8.1 Find users by user's mobile phone number8.2 Display user information if the searched user exists8.3 If the user is already a friend, display the "Send Message" button8.4 If the user is not a friend, display Add Friend and ask to enter the reason for application9. Initiate a group chat9.1 You can search for friends by user nickname in the input box9.2 The avatar of the user added to the group chat can be dynamically displayed at the top10. The chat page can send voice, text, pictures and videos (more emoticons and chat background settings will be updated later) 11 Chat settings11.1 Single chat: pin chat, do not disturb, and clear chat history11.2 Group chat: display group member list, add group members, delete group members (group owner can operate), modify group name, pin chat, block and clear group messages

Source code effect:

Source code snippet:

 package com.fanxin.app.fx; 
  
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID; 
  
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONException;
 import com.alibaba.fastjson.JSONObject;
 import com.easemob.EMConnectionListener;
 import com.easemob.EMError;
 import com.easemob.chat.EMChat;
 import com.easemob.chat.EMChatManager;
 import com.easemob.chat.EMContactListener;
 import com.easemob.chat.EMContactManager;
 import com.easemob.chat.EMConversation;
 import com.easemob.chat.EMGroupManager;
 import com.easemob.chat.EMMessage;
 import com.easemob.chat.EMNotifier;
 import com.easemob.chat.GroupChangeListener;
 import com.easemob.chat.TextMessageBody;
 import com.easemob.chat.EMMessage.ChatType;
 import com.easemob.chat.EMMessage.Type;
 import com.fanxin.app.Constant;
 import com.fanxin.app.DemoApplication;
 import com.fanxin.app.R;
 import com.fanxin.app.activity.BaseActivity;
 import com.fanxin.app.db.InviteMessgeDao;
 import com.fanxin.app.db.UserDao;
 import com.fanxin.app.domain.InviteMessage;
 import com.fanxin.app.domain.InviteMessage.InviteMesageStatus;
 import com.fanxin.app.domain.User;
 import com.fanxin.app.fx.others.LoadDataFromServer;
 import com.fanxin.app.fx.others.LoadDataFromServer.DataCallBack;
 import com.zdp.aseo.content.AseoZdpAseo;
 import com.easemob.exceptions.EaseMobException;
 import com.easemob.util.EMLog;
 import com.easemob.util.HanziToPinyin;
 import com.easemob.util.NetUtils; 
  
 import android.annotation.SuppressLint;
 import android.content.BroadcastReceiver;
 import android.content.Context;
 import android.content.DialogInterface;
 import android.content.Intent;
 import android.content.IntentFilter;
 import android.os.Bundle;
 import android.support.v4.app.Fragment;
 import android.support.v4.app.FragmentTransaction;
 import android.text.TextUtils;
 import android.util.Log;
 import android.view.KeyEvent;
 import android.view.View;
 import android.view.View.OnClickListener;
 import android.widget.ImageView;
 import android.widget.TextView;
 import android.widget.Toast; 
  
 @SuppressLint ( "DefaultLocale" )
 public   class MainActivity extends BaseActivity {
 //Unread message textview  
 private TextView unreadLabel;
 // Unread contacts textview  
    TextView unreadAddressLable;
 protected   static   final String TAG = "MainActivity" ; 
  
 private Fragment[] fragments;
 public FragmentCoversation homefragment;
 private FragmentFriends contactlistfragment;
 private FragmentFind findfragment;
 private FragmentProfile profilefragment;
 private ImageView[] imagebuttons;
 private TextView[] textviews;
 private   int index;
 // The index of the current fragment  
 private   int currentTabIndex;
 private NewMessageBroadcastReceiver msgReceiver;
 private android.app.AlertDialog.Builder conflictBuilder;
 private android.app.AlertDialog.Builder accountRemovedBuilder;
 private   boolean isConflictDialogShow;
 private   boolean isAccountRemovedDialogShow;
 // The account is logged in elsewhere  
 public   boolean isConflict = false ;
 // The account was removed  
 private   boolean isCurrentAccountRemoved = false ; 
  
 private InviteMessgeDao inviteMessgeDao;
 private UserDao userDao; 
  
 private ImageView iv_add;
 private ImageView iv_search; 
  
 /**
 * Check if the current user has been deleted
 */  
 public   boolean getCurrentAccountRemoved() {
 return isCurrentAccountRemoved;
 } 
  
 @Override  
 protected   void onCreate(Bundle savedInstanceState) {
 super .onCreate(savedInstanceState);
 if (savedInstanceState != null  
                && savedInstanceState.getBoolean(Constant.ACCOUNT_REMOVED,
 false )) {
 // Prevent the app from crashing after being removed if the user does not click the OK button and then presses the home button, and then re-enters the app in the background for a long time  
 // The same applies to the judgments added to the three fragments  
            DemoApplication.getInstance().logout( null );
 finish();
            startActivity( new Intent( this , LoginActivity. class ));
 return ;
 } else   if (savedInstanceState != null  
                && savedInstanceState.getBoolean( "isConflict" , false )) {
 // Prevent the app from crashing after being kicked out without clicking the OK button and then pressing the home button, and then entering the app again in the background for a long time  
 // The same applies to the judgments added to the three fragments  
 finish();
            startActivity( new Intent( this , LoginActivity. class ));
 return ;
 }
        setContentView(R.layout.activity_mian_temp);
 initView(); 
  
 if (getIntent().getBooleanExtra( "conflict" , false )
                && !isConflictDialogShow) {
            showConflictDialog();
 } else   if (getIntent().getBooleanExtra(Constant.ACCOUNT_REMOVED, false )
                && !isAccountRemovedDialogShow) {
            showAccountRemovedDialog();
 }
        AseoZdpAseo.init( this , AseoZdpAseo.SCREEN_TYPE);
        iv_add = (ImageView) this .findViewById(R.id.iv_add);
        iv_search = (ImageView) this .findViewById(R.id.iv_search);
        iv_add.setOnClickListener( new OnClickListener() { 
  
 @Override  
 public   void onClick(View v) {
                AddPopWindow addPopWindow = new AddPopWindow(MainActivity. this );
                addPopWindow.showPopupWindow(iv_add);
 } 
  
 });
        iv_search.setOnClickListener( new OnClickListener() { 
  
 @Override  
 public   void onClick(View v) { 
  
 } 
  
 }); 
  
        TextView tv_online = (TextView) this .findViewById(R.id.tv_online);
        tv_online.setOnClickListener( new OnClickListener() { 
  
 @Override  
 public   void onClick(View v) {
                startActivity( new Intent(MainActivity. this ,
                        LasterLoginUserActivity. class ));
 } 
  
 }); 
  
 } 
  
 private   void initView() {
        unreadLabel = (TextView) findViewById(R.id.unread_msg_number);
        unreadAddressLable = (TextView) findViewById(R.id.unread_address_number); 
  
        homefragment = new FragmentCoversation();
        contactlistfragment = new FragmentFriends();
        findfragment = new FragmentFind();
        profilefragment = new FragmentProfile();
        fragments = new Fragment[] { homefragment, contactlistfragment,
                findfragment, profilefragment };
        imagebuttons = new ImageView[ 4 ];
        imagebuttons[ 0 ] = (ImageView) findViewById(R.id.ib_weixin);
        imagebuttons[ 1 ] = (ImageView) findViewById(R.id.ib_contact_list);
        imagebuttons[ 2 ] = (ImageView) findViewById(R.id.ib_find);
        imagebuttons[ 3 ] = (ImageView) findViewById(R.id.ib_profile);
        AseoZdpAseo.initBan( this , findViewById(R.id.aseo_brand));
        imagebuttons[ 0 ].setSelected( true );
        textviews = new TextView[ 4 ];
        textviews[ 0 ] = (TextView) findViewById(R.id.tv_weixin);
        textviews[ 1 ] = (TextView) findViewById(R.id.tv_contact_list);
        textviews[ 2 ] = (TextView) findViewById(R.id.tv_find);
        textviews[ 3 ] = (TextView) findViewById(R.id.tv_profile);
        textviews[ 0 ].setTextColor( 0xFF45C01A );
 // Add and display the first fragment  
        getSupportFragmentManager().beginTransaction()
                .add(R.id.fragment_container, homefragment)
                .add(R.id.fragment_container, contactlistfragment)
                .add(R.id.fragment_container, profilefragment)
                .add(R.id.fragment_container, findfragment)
                .hide(contactlistfragment).hide(profilefragment)
                .hide(findfragment).show(homefragment).commit();
        inviteMessgeDao = new InviteMessgeDao( this );
        userDao = new UserDao( this ); 
  
 // Register a BroadcastReceiver to receive messages  
        msgReceiver = new NewMessageBroadcastReceiver();
        IntentFilter intentFilter = new IntentFilter(EMChatManager
                .getInstance().getNewMessageBroadcastAction());
        intentFilter.setPriority( 3 );
        registerReceiver(msgReceiver, intentFilter); 
  
 // Register a BroadcastReceiver for the ack receipt message  
        IntentFilter ackMessageIntentFilter = new IntentFilter(EMChatManager
                .getInstance().getAckMessageBroadcastAction());
        ackMessageIntentFilter.setPriority( 3 );
        registerReceiver(ackMessageReceiver, ackMessageIntentFilter); 
  
 // Register a BroadcastReceiver for transparent message transmission  
        IntentFilter cmdMessageIntentFilter = new IntentFilter(EMChatManager
                .getInstance().getCmdMessageBroadcastAction());
        cmdMessageIntentFilter.setPriority( 3 );
        registerReceiver(cmdMessageReceiver, cmdMessageIntentFilter); 
  
 //Register a BroadcastReceiver for offline messages  
 // IntentFilter offlineMessageIntentFilter = new  
 // IntentFilter(EMChatManager.getInstance()  
 // .getOfflineMessageBroadcastAction());  
 // registerReceiver(offlineMessageReceiver, offlineMessageIntentFilter);   
  
 // setContactListener to monitor changes in contacts, etc.  
        EMContactManager.getInstance().setContactListener(
 new MyContactListener());
 // Register a listener to monitor the connection status  
        EMChatManager.getInstance().addConnectionListener(
 new MyConnectionListener());
 // Register group chat related listeners  
        EMGroupManager.getInstance().addGroupChangeListener(
 new MyGroupChangeListener());
 // Notify the SDK that the UI has been initialized, the corresponding receiver and listener have been registered, and the broadcast can be accepted  
        EMChat.getInstance().setAppInited(); 
  
 } 
  
 public   void onTabClicked(View view) {
 switch (view.getId()) {
 case R.id.re_weixin:
 index = 0 ;
 break ;
 case R.id.re_contact_list:
 index = 1 ;
 break ;
 case R.id.re_find:
 index = 2 ;
 break ;
 case R.id.re_profile:
 index = 3 ;
 break ; 
  
 } 
  
 if (currentTabIndex != index) {
            FragmentTransaction trx = getSupportFragmentManager()
                    .beginTransaction();
            trx.hide(fragments[currentTabIndex]);
 if (!fragments[index].isAdded()) {
                trx.add(R.id.fragment_container, fragments[index]);
 }
            trx.show(fragments[index]).commit();
 }
        imagebuttons[currentTabIndex].setSelected( false );
 // Set the current tab to selected state  
        imagebuttons[index].setSelected( true );
        textviews[currentTabIndex].setTextColor( 0xFF999999 );
        textviews[index].setTextColor( 0xFF45C01A );
        currentTabIndex = index;
 } 
  
 /**
 * Display the account login dialog
 */  
 private   void showConflictDialog() {
        isConflictDialogShow = true ;
        DemoApplication.getInstance().logout( null );
        String st = getResources().getString(R.string.Logoff_notification);
 if (!MainActivity. this .isFinishing()) {
 // clear up global variables  
 try {
 if (conflictBuilder == null )
                    conflictBuilder = new android.app.AlertDialog.Builder(
                            MainActivity.this );
                conflictBuilder.setTitle(st);
                conflictBuilder.setMessage(R.string.connect_conflict);
                conflictBuilder.setPositiveButton(R.string.ok,
 new DialogInterface.OnClickListener() { 
  
 @Override  
 public   void onClick(DialogInterface dialog,
 int which) {
                                dialog.dismiss();
                                conflictBuilder = null ;
                                finish();
                                startActivity( new Intent(MainActivity. this ,
                                        LoginActivity. class ));
 }
 });
                conflictBuilder.setCancelable( false );
                conflictBuilder.create().show();
                isConflict = true ;
            } catch (Exception e) {
 EMLog.e(TAG,
 "---------color conflictBuilder error" + e.getMessage());
 } 
  
 } 
  
 } 
  
 /**
 * Account removed dialog
 */  
 private   void showAccountRemovedDialog() {
        isAccountRemovedDialogShow = true ;
        DemoApplication.getInstance().logout( null );
        String st5 = getResources().getString(R.string.Remove_the_notification);
 if (!MainActivity. this .isFinishing()) {
 // clear up global variables  
 try {
 if (accountRemovedBuilder == null )
                    accountRemovedBuilder = new android.app.AlertDialog.Builder(
                            MainActivity.this );
                accountRemovedBuilder.setTitle(st5);
                accountRemovedBuilder.setMessage(R.string.em_user_remove);
                accountRemovedBuilder.setPositiveButton(R.string.ok,
 new DialogInterface.OnClickListener() { 
  
 @Override  
 public   void onClick(DialogInterface dialog,
 int which) {
                                dialog.dismiss();
                                accountRemovedBuilder = null ;
                                finish();
                                startActivity( new Intent(MainActivity. this ,
                                        LoginActivity. class ));
 }
 });
                accountRemovedBuilder.setCancelable( false );
                accountRemovedBuilder.create().show();
                isCurrentAccountRemoved = true ;
            } catch (Exception e) {
 EMLog.e(TAG,
 "---------color userRemovedBuilder error"  
                                + e.getMessage());
 } 
  
 } 
  
 } 
  
 /**
 * New message broadcast receiver
 *
 *
 */  
 private   class NewMessageBroadcastReceiver extends BroadcastReceiver {
 @Override  
 public   void onReceive(Context context, Intent intent) {
 // After the main page receives a message, it is mainly used to indicate that it is unread. The actual message content needs to be viewed on the chat page   
  
            String from = intent.getStringExtra( "from" );
 // message id  
            String msgId = intent.getStringExtra( "msgid" );
            EMMessage message = EMChatManager.getInstance().getMessage(msgId);
 // 2014-10-22 Fixed the bug that on some machines, the content of the message sent by the other party on the chat page is not displayed immediately  
 if (ChatActivity.activityInstance != null ) {
 if (message.getChatType() == ChatType.GroupChat) {
 if (message.getTo().equals(
                            ChatActivity.activityInstance.getToChatUsername()))
 return ;
 } else {
 if (from.equals(ChatActivity.activityInstance
                            .getToChatUsername()))
 return ;
 }
 } 
  
 // Unregister the broadcast receiver, otherwise the broadcast will be received in ChatActivity  
 abortBroadcast(); 
  
            notifyNewMessage(message); 
  
 // Refresh bottom bar message unread  
            updateUnreadLabel();
 if (currentTabIndex == 0 ) {
 // If the current page is the chat history page, refresh this page  
 if (homefragment != null ) {
                    homefragment.refresh();
 }
 } 
  
 }
 } 
  
 /**
 * Message receipt BroadcastReceiver
 */  
 private BroadcastReceiver ackMessageReceiver = new BroadcastReceiver() { 
  
 @Override  
 public   void onReceive(Context context, Intent intent) {
 abortBroadcast(); 
  
            String msgid = intent.getStringExtra( "msgid" );
            String from = intent.getStringExtra( "from" ); 
  
            EMConversation conversation = EMChatManager.getInstance()
                    .getConversation(from);
 if (conversation != null ) {
 // Set the message to be read  
                EMMessage msg = conversation.getMessage(msgid); 
  
 if (msg != null ) { 
  
 // 2014-11-5 Fixed the bug that on some machines, when the other party sends a read receipt on the chat page, it does not immediately show that the message has been read  
 if (ChatActivity.activityInstance != null ) {
 if (msg.getChatType() == ChatType.Chat) {
 if (from.equals(ChatActivity.activityInstance
                                    .getToChatUsername()))
 return ;
 }
 } 
  
                    msg.isAcked = true ;
 }
 } 
  
 }
 }; 
  
 /**
 * BroadcastReceiver
 */  
 private BroadcastReceiver cmdMessageReceiver = new BroadcastReceiver() { 
  
 @Override  
 public   void onReceive(Context context, Intent intent) {
 abortBroadcast();
 // EMLog.d(TAG, "Received transparent message");  
 // // Get cmd message object  
 //  
 // EMMessage message = intent.getParcelableExtra("message");  
 // // Get the message body  
 // CmdMessageBody cmdMsgBody = (CmdMessageBody) message.getBody();  
 // String action = cmdMsgBody.action; // Get custom action  
 //  
 // // Get extended attributes. Omitted here.  
 // // message.getStringAttribute("");  
 //EMLog.d(TAG,  
 // String.format("transmitted message: action:%s,message:%s", action,  
 // message.toString()));  
 // String st9 = getResources().getString(  
 // R.string.receive_the_passthrough);  
 // Toast.makeText(MainActivity.this, st9 + action,  
 // Toast.LENGTH_SHORT)  
 // .show();  
 }
 }; 
  
 /**
 * Offline message BroadcastReceiver sdk After logging in, the server will push offline messages to the client. This receiver is the notification UI
 * Who sent offline messages? The UI can perform corresponding operations, such as downloading user information
 */  
 // private BroadcastReceiver offlineMessageReceiver = new  
 // BroadcastReceiver() {  
 //  
 // @Override  
 // public void onReceive(Context context, Intent intent) {  
 // String[] users = intent.getStringArrayExtra("fromuser");  
 // String[] groups = intent.getStringArrayExtra("fromgroup");  
 // if (users != null) {  
 // for (String user : users) {  
 // System.out.println("Received user offline message: " + user);  
 // }  
 // }  
 // if (groups != null) {  
 // for (String group : groups) {  
 // System.out.println("Received group offline message: " + group);  
 // }  
 // }  
 // }  
 // };   
  
 /***
 * Friend change listener
 *
 */  
 private   class MyContactListener implements EMContactListener { 
  
 @Override  
 public   void onContactAdded(List<string> usernameList) { 
  
            refreshFriendsList();
 // Refresh the UI  
 if (currentTabIndex == 1 )
                contactlistfragment.refresh(); 
  
 } 
  
 @Override  
 public   void onContactDeleted( final List<string> usernameList) {
 // deleted  
            Map<string, user= "" > localUsers = DemoApplication.getInstance()
                    .getContactList();
 for (String username : usernameList) {
                localUsers.remove(username);
                userDao.deleteContact(username);
                inviteMessgeDao.deleteMessage(username);
 }
            runOnUiThread( new Runnable() {
 public   void run() {
 // If you are chatting with this user  
                    String st10 = getResources().getString(
                            R.string.have_you_removed);
 if (ChatActivity.activityInstance != null  
                            && usernameList
                                    .contains(ChatActivity.activityInstance
                                            .getToChatUsername())) {
                        Toast.makeText(
                                MainActivity.this ,
                                ChatActivity.activityInstance
                                        .getToChatUsername() + st10,
                                Toast.LENGTH_SHORT).show();
                        ChatActivity.activityInstance.finish();
 }
                    updateUnreadLabel();
 // Refresh the UI  
 if (currentTabIndex == 1 )
                        contactlistfragment.refresh();
 else   if (currentTabIndex == 0 )
                        homefragment.refresh();
 }
 }); 
  
 } 
  
 @Override  
 public   void onContactInvited(String username, String reason) {
 // If you do not process the invitation (accept or reject) after receiving it, the server will automatically send it again after the connection is disconnected, so the client does not need to remind it again  
            List<invitemessage> msgs = inviteMessgeDao.getMessagesList(); 
  
 for (InviteMessage inviteMessage : msgs) {
 if (inviteMessage.getGroupId() == null  
                        && inviteMessage.getFrom().equals(username)) {
                    inviteMessgeDao.deleteMessage(username);
 }
 }
 // Javabean encapsulated by yourself  
            InviteMessage msg = new InviteMessage();
            msg.setFrom(username);
            msg.setTime(System.currentTimeMillis());
            msg.setReason(reason);
 Log.d(TAG, username + "Request to add you as a friend, reason: " + reason);
 // Set the corresponding status  
            msg.setStatus(InviteMesageStatus.BEINVITEED);
            notifyNewIviteMessage(msg); 
  
 } 
  
 @Override  
 public   void onContactAgreed( final String username) { 
  
            List<invitemessage> msgs = inviteMessgeDao.getMessagesList();
 for (InviteMessage inviteMessage : msgs) {
 if (inviteMessage.getFrom().equals(username)) {
 return ;
 }
 }
            runOnUiThread( new Runnable() {
 public   void run() { 
  
                    addFriendToList(username);
 }
 }); 
  
 } 
  
 @Override  
 public   void onContactRefused(String username) {
 // Reference agreed, invited to implement this function, demo not implemented  
 Log.d(username, username + "rejected your friend request" );
 } 
  
 } 
  
 /**
 * Save prompt new message
 *
 * @param msg
 */  
 private   void notifyNewIviteMessage(InviteMessage msg) {
 saveInviteMsg(msg);
 // Prompt that there is a new message  
        EMNotifier.getInstance(getApplicationContext()).notifyOnNewMsg(); 
  
 // Refresh bottom bar message unread  
        updateUnreadAddressLable();
 // Refresh the friend page ui  
 if (currentTabIndex == 1 )
            contactlistfragment.refresh();
 } 
  
 /**
 * Save invitation and other msg
 *
 * @param msg
 */  
 private   void saveInviteMsg(InviteMessage msg) {
 // Save msg  
        inviteMessageDao.saveMessage(msg);
 // Unread count plus 1  
        User user = DemoApplication.getInstance().getContactList()
                .get(Constant.NEW_FRIENDS_USERNAME);
 if (user.getUnreadMsgCount() == 0 )
            user.setUnreadMsgCount(user.getUnreadMsgCount() + 1 );
 } 
  
 /**
 * set head
 *
 * @param username
 * @return
 */  
 @SuppressLint ( "DefaultLocale" )
    User setUserHead(String username) {
        User user = new User();
        user.setUsername(username);
        String headerName = null ;
 if (!TextUtils.isEmpty(user.getNick())) {
            headerName = user.getNick();
 } else {
            headerName = user.getUsername();
 }
 if (username.equals(Constant.NEW_FRIENDS_USERNAME)) {
            user.setHeader( "" );
 } else   if (Character.isDigit(headerName.charAt( 0 ))) {
            user.setHeader( "#" );
 } else {
            user.setHeader(HanziToPinyin.getInstance()
                    .get(headerName.substring( 0 , 1 )).get( 0 ).target.substring( 0 ,
 1 ).toUpperCase());
 char header = user.getHeader().toLowerCase().charAt( 0 );
 if (header < 'a' || header > 'z' ) {
                user.setHeader( "#" );
 }
 }
 return user;
 } 
  
 /**
 * Connection listener
 *
 */  
 private   class MyConnectionListener implements EMConnectionListener { 
  
 @Override  
 public   void onConnected() {
            runOnUiThread( new Runnable() { 
  
 @Override  
 public   void run() {
                    homefragment.errorItem.setVisibility(View.GONE);
 } 
  
 });
 } 
  
 @Override  
 public   void onDisconnected( final   int error) {
 final String st1 = getResources().getString(
                    R.string.Less_than_chat_server_connection);
 final String st2 = getResources().getString(
                    R.string.the_current_network);
            runOnUiThread( new Runnable() { 
  
 @Override  
 public   void run() {
 if (error == EMError.USER_REMOVED) {
 // Display that the account has been removed  
                        showAccountRemovedDialog();
 } else   if (error == EMError.CONNECTION_CONFLICT) {
 // Display the account login dialog on other devices  
                        showConflictDialog();
 } else {
                        homefragment.errorItem.setVisibility(View.VISIBLE);
 if (NetUtils.hasNetwork(MainActivity. this ))
                            homefragment.errorText.setText(st1);
 else  
                            homefragment.errorText.setText(st2); 
  
 }
 } 
  
 });
 }
 } 
  
 /**
 * MyGroupChangeListener
 */  
 private   class MyGroupChangeListener implements GroupChangeListener { 
  
 @Override  
 public   void onInvitationReceived(String groupId, String groupName,
                String inviter, String reason) { 
  
 // Invited  
            String st3 = getResources().getString(
                    R.string.Invite_you_to_join_a_group_chat);
            User user = DemoApplication.getInstance().getContactList()
                    .get(inviter);
 if (user != null ) {
                EMMessage msg = EMMessage.createReceiveMessage(Type.TXT);
                msg.setChatType(ChatType.GroupChat);
                msg.setFrom(inviter);
                msg.setTo(groupId);
                msg.setMsgId(UUID.randomUUID().toString());
                msg.addBody( new TextMessageBody(user.getNick() + st3));
                msg.setAttribute( "useravatar" , user.getAvatar());
                msg.setAttribute( "usernick" , user.getNick());
 // Save the invitation message  
                EMChatManager.getInstance().saveMessage(msg);
 // Remind new messages  
                EMNotifier.getInstance(getApplicationContext())
                        .notifyOnNewMsg();
 }
            runOnUiThread( new Runnable() {
 public   void run() {
                    updateUnreadLabel();
 // Refresh the UI  
 if (currentTabIndex == 0 )
                        homefragment.refresh();
 // if (CommonUtils.getTopActivity(MainActivity.this).equals(  
 // GroupsActivity.class.getName())) {  
 // GroupsActivity.instance.onResume();  
 // }  
 }
 }); 
  
 } 
  
 @Override  
 public   void onInvitationAcpted(String groupId, String inviter,
                String reason) { 
  
 } 
  
 @Override  
 public   void onInvitationDeclinated(String groupId, String invitee,
                String reason) { 
  
 } 
  
 @Override  
 public   void onUserRemoved(String groupId, String groupName) {
 // Prompt the user that they have been T-ed. This step is omitted in the demo.  
 // Refresh the UI  
            runOnUiThread( new Runnable() {
 public   void run() {
 try {
                        updateUnreadLabel();
 if (currentTabIndex == 0 )
                            homefragment.refresh();
 // if (CommonUtils.getTopActivity(MainActivity.this)  
 // .equals(GroupsActivity.class.getName())) {  
 // GroupsActivity.instance.onResume();  
 // }  
                    } catch (Exception e) {
                        EMLog.e(TAG, "refresh exception " + e.getMessage());
 }
 }
 });
 } 
  
 @Override  
 public   void onGroupDestroy(String groupId, String groupName) {
 // The group was disbanded  
 // Prompt that the user group has been disbanded, demo omitted  
 // Refresh the UI  
            runOnUiThread( new Runnable() {
 public   void run() {
                    updateUnreadLabel();
 if (currentTabIndex == 0 )
                        homefragment.refresh();
 // if (CommonUtils.getTopActivity(MainActivity.this).equals(  
 // GroupsActivity.class.getName())) {  
 // GroupsActivity.instance.onResume();  
 // }  
 }
 }); 
  
 } 
  
 @Override  
 public   void onApplicationReceived(String groupId, String groupName,
                String applyer, String reason) {
 // User applies to join group chat  
            InviteMessage msg = new InviteMessage();
            msg.setFrom(applyer);
            msg.setTime(System.currentTimeMillis());
            msg.setGroupId(groupId);
            msg.setGroupName(groupName);
            msg.setReason(reason);
 Log.d(TAG, applyer + "Apply to join group chat: " + groupName);
            msg.setStatus(InviteMesageStatus.BEAPPLYED);
            notifyNewIviteMessage(msg);
 } 
  
 @Override  
 public   void onApplicationAccept(String groupId, String groupName,
                String accepter) {
            String st4 = getResources().getString(
                    R.string.Agreed_to_your_group_chat_application);
 // The application to join the group is approved  
            EMMessage msg = EMMessage.createReceiveMessage(Type.TXT);
            msg.setChatType(ChatType.GroupChat);
            msg.setFrom(accepter);
            msg.setTo(groupId);
            msg.setMsgId(UUID.randomUUID().toString());
            msg.addBody( new TextMessageBody(accepter + st4));
 //Save the consent message  
            EMChatManager.getInstance().saveMessage(msg);
 // Remind new messages  
            EMNotifier.getInstance(getApplicationContext()).notifyOnNewMsg(); 
  
            runOnUiThread( new Runnable() {
 public   void run() {
                    updateUnreadLabel();
 // Refresh the UI  
 if (currentTabIndex == 0 )
                        homefragment.refresh();
 // if (CommonUtils.getTopActivity(MainActivity.this).equals(  
 // GroupsActivity.class.getName())) {  
 // GroupsActivity.instance.onResume();  
 // }  
 }
 });
 } 
  
 @Override  
 public   void onApplicationDeclinated(String groupId, String groupName,
                String decliner, String reason) {
 // The application to join the group was rejected, and the demo was not implemented  
 } 
  
 } 
  
 @Override  
 protected   void onResume() {
 super .onResume();
 if (!isConflict || !isCurrentAccountRemoved) {
 // initView();  
            updateUnreadLabel();
            updateUnreadAddressLable();
            EMChatManager.getInstance().activityResumed();
 } 
  
 } 
  
 @Override  
 protected   void onSaveInstanceState(Bundle outState) {
        outState.putBoolean( "isConflict" , isConflict);
        outState.putBoolean(Constant.ACCOUNT_REMOVED, isCurrentAccountRemoved);
 super .onSaveInstanceState(outState);
 } 
  
 @Override  
 protected   void onNewIntent(Intent intent) {
 super .onNewIntent(intent);
 if (getIntent().getBooleanExtra( "conflict" , false )
                && !isConflictDialogShow) {
            showConflictDialog();
 } else   if (getIntent().getBooleanExtra(Constant.ACCOUNT_REMOVED, false )
                && !isAccountRemovedDialogShow) {
            showAccountRemovedDialog();
 }
 } 
  
 /**
 * Refresh the number of unread messages
 */  
 public   void updateUnreadLabel() {
 int count = getUnreadMsgCountTotal();
 if (count > 0 ) {
            unreadLabel.setText(String.valueOf(count));
            unreadLabel.setVisibility(View.VISIBLE);
 } else {
            unreadLabel.setVisibility(View.INVISIBLE);
 }
 } 
  
 /**
 * Get unread applications and notification messages
 *
 * @return
 */  
 public   int getUnreadAddressCountTotal() {
 int unreadAddressCountTotal = 0 ;
 if (DemoApplication.getInstance().getContactList()
                .get(Constant.NEW_FRIENDS_USERNAME) != null )
            unreadAddressCountTotal = DemoApplication.getInstance()
                    .getContactList().get(Constant.NEW_FRIENDS_USERNAME)
                    .getUnreadMsgCount();
 return unreadAddressCountTotal;
 } 
  
 /**
 * Refresh application and notification message count
 */  
 public   void updateUnreadAddressLable() {
        runOnUiThread( new Runnable() {
 public   void run() {
 int count = getUnreadAddressCountTotal();
 if (count > 0 ) {
                    unreadAddressLable.setText(String.valueOf(count));
                    unreadAddressLable.setVisibility(View.VISIBLE);
 } else {
                    unreadAddressLable.setVisibility(View.INVISIBLE);
 }
 }
 }); 
  
 } 
  
 /**
 * Get the number of unread messages
 *
 * @return
 */  
 public   int getUnreadMsgCountTotal() {
 int unreadMsgCountTotal = 0 ;
        unreadMsgCountTotal = EMChatManager.getInstance().getUnreadMsgsCount();
 return unreadMsgCountTotal;
 } 
  
 public   void refreshFriendsList() {
        List<string> usernames = new ArrayList<string>();
 try {
            usernames = EMContactManager.getInstance().getContactUserNames();
        } catch (EaseMobException e1) {
            e1.printStackTrace();
 }
 if (usernames != null && usernames.size() > 0 ) {
            String totaluser = usernames.get( 0 );
 for ( int i = 1 ; i < usernames.size(); i++) {
 final String split = "66split88" ;
                totaluser += split + usernames.get(i);
 }
            totaluser = totaluser.replace(Constant.NEW_FRIENDS_USERNAME, "" );
            totaluser = totaluser.replace(Constant.GROUP_USERNAME, "" ); 
  
            Map<string, string= "" > map = new HashMap<string, string= "" >(); 
  
            map.put( "uids" , totaluser); 
  
            LoadDataFromServer task = new LoadDataFromServer(MainActivity. this ,
                    Constant.URL_Friends, map); 
  
            task.getData( new DataCallBack() { 
  
 @Override  
 public   void onDataCallBack(JSONObject data) {
 try {
 int code = data.getInteger( "code" );
 if (code == 1 ) {
                            JSONArray josnArray = data.getJSONArray( "friends" ); 
  
                            saveFriends(josnArray); 
  
 } 
  
                    } catch (JSONException e) {
                        Log.e( "MainActivity" , "update friendsLiST ERROR" );
                        e.printStackTrace();
 }
 }
 });
 } 
  
 } 
  
 private   void saveFriends(JSONArray josnArray) { 
  
        Map<string, user= "" > map = new HashMap<string, user= "" >(); 
  
 if (josnArray != null ) {
 for ( int i = 0 ; i < josnArray.size(); i++) {
                JSONObject json = (JSONObject) josnArray.getJSONObject(i);
 try {
                    String hxid = json.getString( "hxid" );
                    String fxid = json.getString( "fxid" );
                    String nick = json.getString( "nick" );
                    String avatar = json.getString( "avatar" );
                    String sex = json.getString( "sex" );
                    String region = json.getString( "region" );
                    String sign = json.getString( "sign" );
                    String tel = json.getString( "tel" ); 
  
                    User user = new User();
                    user.setFxid(fxid);
                    user.setUsername(hxid);
                    user.setBeizhu( "" );
                    user.setNick(nick);
                    user.setRegion(region);
                    user.setSex(sex);
                    user.setTel(tel);
                    user.setSign(sign);
                    user.setAvatar(avatar);
                    setUserHearder(hxid, user);
                    map.put(hxid, user); 
  
                } catch (JSONException e) {
 // TODO Auto-generated catch block  
                    e.printStackTrace();
 } 
  
 }
 }
 // Add user "application and notification"  
        User newFriends = new User();
        newFriends.setUsername(Constant.NEW_FRIENDS_USERNAME);
        String strChat = getResources().getString(
                R.string.Application_and_notify);
        newFriends.setNick(strChat);
        newFriends.setBeizhu( "" );
        newFriends.setFxid( "" );
        newFriends.setHeader( "" );
        newFriends.setRegion( "" );
        newFriends.setSex( "" );
        newFriends.setTel( "" );
        newFriends.setSign( "" );
        newFriends.setAvatar( "" );
        map.put(Constant.NEW_FRIENDS_USERNAME, newFriends);
 // Add "group chat"  
        User groupUser = new User();
        String strGroup = getResources().getString(R.string.group_chat);
        groupUser.setUsername(Constant.GROUP_USERNAME);
        groupUser.setNick(strGroup);
        groupUser.setHeader( "" );
        groupUser.setNick(strChat);
 groupUser.setBeizhu( "" );
        groupUser.setFxid( "" );
        groupUser.setHeader( "" );
        groupUser.setRegion( "" );
        groupUser.setSex( "" );
        groupUser.setTel( "" );
        groupUser.setSign( "" );
        groupUser.setAvatar( "" );
        map.put(Constant.GROUP_USERNAME, groupUser); 
  
 // Store in memory  
        DemoApplication.getInstance().setContactList(map);
 // Store in db  
        UserDao dao = new UserDao(MainActivity. this );
        List<user> users = new ArrayList<user>(map.values());
        dao.saveContactList(users); 
  
 } 
  
 /**
 * Set the header attribute to facilitate the display of contacts by header classification in the communication, and quickly locate the contact through the ABCD... letter column on the right
 *
 * @param username
 * @param user
 */  
 @SuppressLint ( "DefaultLocale" )
 protected   void setUserHearder(String username, User user) {
        String headerName = null ;
 if (!TextUtils.isEmpty(user.getNick())) {
            headerName = user.getNick();
 } else {
            headerName = user.getUsername();
 }
        headerName = headerName.trim();
 if (username.equals(Constant.NEW_FRIENDS_USERNAME)) {
            user.setHeader( "" );
 } else   if (Character.isDigit(headerName.charAt( 0 ))) {
            user.setHeader( "#" );
 } else {
            user.setHeader(HanziToPinyin.getInstance()
                    .get(headerName.substring( 0 , 1 )).get( 0 ).target.substring( 0 ,
 1 ).toUpperCase());
 char header = user.getHeader().toLowerCase().charAt( 0 );
 if (header < 'a' || header > 'z' ) {
                user.setHeader( "#" );
 }
 }
 } 
  
 private   void addFriendToList( final String hxid) {
        Map<string, string= "" > map_uf = new HashMap<string, string= "" >();
        map_uf.put( "hxid" , hxid);
        LoadDataFromServer task = new LoadDataFromServer( null ,
                Constant.URL_Get_UserInfo, map_uf);
        task.getData( new DataCallBack() {
 @Override  
 public   void onDataCallBack(JSONObject data) {
 try { 
  
 int code = data.getInteger( "code" );
 if (code == 1 ) { 
  
                        JSONObject json = data.getJSONObject( "user" );
 if (json != null && json.size() != 0 ) { 
  
 }
                        String nick = json.getString( "nick" );
                        String avatar = json.getString( "avatar" ); 
  
                        String hxid = json.getString( "hxid" );
                        String fxid = json.getString( "fxid" );
                        String region = json.getString( "region" );
                        String sex = json.getString( "sex" );
                        String sign = json.getString( "sign" );
                        String tel = json.getString( "tel" );
                        User user = new User(); 
  
                        user.setUsername(hxid);
                        user.setNick(nick);
                        user.setAvatar(avatar);
                        user.setFxid(fxid);
                        user.setRegion(region);
                        user.setSex(sex);
                        user.setSign(sign);
                        user.setTel(tel);
                        setUserHearder(hxid, user);
                        Map<string, user= "" > userlist = DemoApplication
                                .getInstance().getContactList();
                        Map<string, user= "" > map_temp = new HashMap<string, user= "" >();
                        map_temp.put(hxid, user);
                        userlist.putAll(map_temp);
 // Store in memory  
                        DemoApplication.getInstance().setContactList(userlist);
 // Store in db  
                        UserDao dao = new UserDao(MainActivity. this ); 
  
                        dao.saveContact(user); 
  
 // Javabean encapsulated by yourself  
                        InviteMessage msg = new InviteMessage();
                        msg.setFrom(hxid);
                        msg.setTime(System.currentTimeMillis()); 
  
                        String reason_temp = nick + "66split88" + avatar
                                + "66split88"  
                                + String.valueOf(System.currentTimeMillis())
 + "66split88" + "Request approved" ;
                        msg.setReason(reason_temp); 
  
                        msg.setStatus(InviteMesageStatus.BEAGREED);
                        User userTemp = DemoApplication.getInstance()
                                .getContactList()
                                .get(Constant.NEW_FRIENDS_USERNAME);
 if (userTemp != null  
                                && userTemp.getUnreadMsgCount() == 0 ) {
                            userTemp.setUnreadMsgCount(userTemp
                                    .getUnreadMsgCount() + 1 );
 }
                        notifyNewIviteMessage(msg);
 } 
  
                } catch (JSONException e) { 
  
                    e.printStackTrace();
 } 
  
 } 
  
 }); 
  
 } 
  
 private   long exitTime = 0 ; 
  
 @Override  
 public   boolean onKeyDown( int keyCode, KeyEvent event) {
 if (keyCode == KeyEvent.KEYCODE_BACK
                && event.getAction() == KeyEvent.ACTION_DOWN) {
 if ((System.currentTimeMillis() - exitTime) > 2000 ) {
 Toast.makeText(getApplicationContext(), "Press again to exit the program" ,
                        Toast.LENGTH_SHORT).show();
                exitTime = System.currentTimeMillis();
 } else {
                Intent intent = new Intent(Intent.ACTION_MAIN);
                intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
                intent.addCategory(Intent.CATEGORY_HOME);
                AseoZdpAseo.initFinalTimer( this , AseoZdpAseo.BOTH_TYPE);
                startActivity(intent); 
  
 }
 return   true ;
 }
 return   super .onKeyDown(keyCode, event);
 } 
  
 }
 </string,></string,></string,></string,></string,></user></user></string,></string,></string,></string,></string></string></invitemessage></invitemessage></string,></string></string>

Download address: http://down..com/data/2109302