基于环信的Android聊天APP（三）

2017-02-23
1.再来就是聊天列表页面的刷新

和qq类似，当收到消息的时候首页列表应该更新消息，还要去重，来看一下效果，感觉这里的重点就是ui更新，去重，消息的显示。这里建议去看官方的Demo
2.看一下核心逻辑代码(如果用easeUI基本我这个就用不到了)

import android.app.Activity;
import android.content.Context;
import android.util.Log;
import android.util.Pair;
import android.widget.Toast;

import com.fanyafeng.wechat.chat.ChatBean;
import com.fanyafeng.wechat.login.LoginContract;
import com.hyphenate.EMMessageListener;
import com.hyphenate.chat.EMClient;
import com.hyphenate.chat.EMConversation;
import com.hyphenate.chat.EMImageMessageBody;
import com.hyphenate.chat.EMMessage;
import com.hyphenate.chat.EMTextMessageBody;

import org.json.JSONObject;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.TreeSet;

/**
 * Author： fanyafeng
 * Data： 17/2/20 上午11:20
 * Email: fanyafeng@live.cn
 */
public class MainPresenter implements MainContract.Presenter, EMMessageListener {
    private Context context;
    private MainContract.View mainView;

    private EMMessageListener emMessageListener;

    private List< MainMessageBean> messageBeanList = new ArrayList<>();

    public MainPresenter(Context context, MainContract.View mainView) {
        this.context = context;
        this.mainView = mainView;
        mainView.setPresenter(this);
        emMessageListener = this;
    }

    private void sortConversationByLastChatTime(List< Pair< Long, EMConversation>> conversationList) {
        Collections.sort(conversationList, new Comparator< Pair< Long, EMConversation>>() {
            @Override
            public int compare(final Pair< Long, EMConversation> con1, final Pair< Long, EMConversation> con2) {

                if (con1.first.equals(con2.first)) {
                    return 0;
                } else if (con2.first.longValue() > con1.first.longValue()) {
                    return 1;
                } else {
                    return -1;
                }
            }

        });
    }

    private List< EMConversation> loadConversationList() {
        // get all conversations
        Map< String, EMConversation> conversations = EMClient.getInstance().chatManager().getAllConversations();
        List< Pair< Long, EMConversation>> sortList = new ArrayList< Pair< Long, EMConversation>>();
        /**
         * lastMsgTime will change if there is new message during sorting
         * so use synchronized to make sure timestamp of last message won't change.
         */
        synchronized (conversations) {
            for (EMConversation conversation : conversations.values()) {
                if (conversation.getAllMessages().size() != 0) {
                    sortList.add(new Pair< Long, EMConversation>(conversation.getLastMessage().getMsgTime(), conversation));
                }
            }
        }
        try {
            // Internal is TimSort algorithm, has bug
            sortConversationByLastChatTime(sortList);
        } catch (Exception e) {
            e.printStackTrace();
        }
        List< EMConversation> list = new ArrayList< EMConversation>();
        for (Pair< Long, EMConversation> sortItem : sortList) {
            list.add(sortItem.second);
        }
        return list;
    }

    @Override
    public void start() {
        EMClient.getInstance().chatManager().addMessageListener(emMessageListener);
        int conversationSize = loadConversationList().size();

        Set< MainMessageBean> mainMessageBeanSet = new TreeSet<>();

        for (int i = 0; i < conversationSize; i++) {
            EMConversation emConversation = loadConversationList().get(i);

            EMMessage emMessage = emConversation.getAllMessages().get(0);
            MainMessageBean mainMessageBean = new MainMessageBean();

            mainMessageBean.setNickName(EMClient.getInstance().getCurrentUser().equals(emMessage.getTo()) ? emMessage.getFrom() : emMessage.getTo());
            if (emMessage.getBody() instanceof EMTextMessageBody) {
                mainMessageBean.setMessageDetail(((EMTextMessageBody) emMessage.getBody()).getMessage());
            } else if (emMessage.getBody() instanceof EMImageMessageBody) {
                mainMessageBean.setMessageDetail("[图片]");
            }
            mainMessageBean.setMessageTime(emMessage.getMsgTime());

            mainMessageBeanSet.add(mainMessageBean);
        }

        messageBeanList.addAll(new ArrayList<>(mainMessageBeanSet));


        mainView.initRecycleView(messageBeanList);

    }


    @Override
    public void initRecycleView() {

    }

    @Override
    public void removeMessageListener() {
        EMClient.getInstance().chatManager().removeMessageListener(emMessageListener);
    }


    @Override
    public void onMessageReceived(List< EMMessage> list) {

        Set< MainMessageBean> mainMessageBeanSet = new TreeSet<>(messageBeanList);

        for (EMMessage emMessage : list) {
            MainMessageBean mainMessageBean = new MainMessageBean();
            mainMessageBean.setNickName(emMessage.getFrom());
            mainMessageBean.setMessageTime(emMessage.getMsgTime());
            if (emMessage.getBody() instanceof EMTextMessageBody) {
                mainMessageBean.setMessageDetail(((EMTextMessageBody) emMessage.getBody()).getMessage());
            }
            mainMessageBeanSet.add(mainMessageBean);

        }
        messageBeanList.clear();

        messageBeanList.addAll(new ArrayList<>(mainMessageBeanSet));


        ((Activity) context).runOnUiThread(new Runnable() {
            @Override
            public void run() {
                mainView.notifyChanged();
            }
        });

    }

    @Override
    public void onCmdMessageReceived(List< EMMessage> list) {

    }

    @Override
    public void onMessageRead(List< EMMessage> list) {

    }

    @Override
    public void onMessageDelivered(List< EMMessage> list) {

    }

    @Override
    public void onMessageChanged(EMMessage emMessage, Object o) {

    }
}