制作高仿QQ的聊天系统（二）—— Adapter & Activity

package com.kale.mycmcc;

import java.text.SimpleDateFormat;
import java.util.Date;

import android.app.Activity;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.view.ViewStub;
import android.widget.BaseAdapter;
import android.widget.ImageView;
import android.widget.ProgressBar;
import android.widget.TextView;

import com.umeng.fb.model.Conversation;
import com.umeng.fb.model.Reply;

/**
 * @author:Jack Tony
 * @description : 定义回话界面的adapter
 * @date :2015年2月9日
 */
class ReplyAdapter extends BaseAdapter {

    // 表示是一对一聊天，有两个类型的信息
    private final int VIEW_TYPE_COUNT = 2;
    // 用户的标识
    private final int VIEW_TYPE_USER = 0;
    // 开发者的标识
    private final int VIEW_TYPE_DEV = 1; 

    // 一次性加载多少条数据
    // private final int LOAD_DATA_NUM = 10;

    private int mCurrentCount = 10; // 默认一次性显示多少条数据

    private DataCallbackActivity mActivity; // 实现反馈接口的activity
    // 回话对象
    private Conversation mConversation; 

    public ReplyAdapter(DataCallbackActivity activity, Conversation conversation) {
        mActivity = activity;
        mConversation = conversation;
    }

    /**
     * @description 添加了一条新数据后调用此方法
     *
     */
    public void addOneCount() {
        mCurrentCount++;
    }

    @Override
    public int getCount() {
        // 如果开始时的数目小于一次性显示的数目，就按照当前的数目显示，否则会数组越界
        int totalCount = mConversation.getReplyList().size();
        if (totalCount < mCurrentCount) {
            mCurrentCount = totalCount;
        }
        return mCurrentCount;
    }

    @Override
    public Object getItem(int position) {
        // getCurrentPosition(position)通过计算得出当前相对的position
        position = getCurrentPosition(position);
        return mConversation.getReplyList().get(position);
    }

    @Override
    public long getItemId(int position) {
        return getCurrentPosition(position);
    }

    /* 
     * @return 表示当前适配器中有两种类型的数据，也就是说item会加载两个布局
     */
    @Override
    public int getViewTypeCount() {
        // 这里是一对一聊天，所以是两种类型
        return VIEW_TYPE_COUNT;
    }

    /* 
     * 通过list中的反馈对象，判断对象的类型，然后返回当前position对应的数据类型
     * 
     * @param position
     * @return 
     */
    @Override
    public int getItemViewType(int position) {
        position = getCurrentPosition(position);
        // 获取单条回复
        Reply reply = mConversation.getReplyList().get(position);
        if (Reply.TYPE_DEV_REPLY.equals(reply.type)) {
            // 开发者回复Item布局
            return VIEW_TYPE_DEV;
        } else {
            // 用户反馈、回复Item布局
            return VIEW_TYPE_USER;
        }
    }
    
    @Override
    public View getView(int position, View convertView, ViewGroup parent) {
        // 计算出位置
        position = getCurrentPosition(position);
        // 得到当前位置的reply对象
        Reply reply = mConversation.getReplyList().get(position);
        // 通过converView来优化listview
        if (convertView == null) {
            LayoutInflater inflater = LayoutInflater.from((Activity) mActivity);
            // 根据Type的类型来加载不同的Item布局
            if (Reply.TYPE_DEV_REPLY.equals(reply.type)) {
                // 如果是开发者回复的，那么就加载开发者回复的布局
                convertView = inflater.inflate(R.layout.umeng_fb_dev_reply, null);
            } else {
                convertView = inflater.inflate(R.layout.umeng_fb_user_reply, null);
            }
        }
        // 放入消息
        TextView textView = ViewHolder.get(convertView, R.id.reply_textView);
        textView.setText(reply.content);

        /**
         * 检查发送状态，如果发送失败就进行提示
         * 这里的提示信息有进度条和感叹号两种。如果正在发送就显示进度条，如果发送失败就显示感叹号
         */
        if (!Reply.TYPE_DEV_REPLY.equals(reply.type)) {
            //System.out.println("states = " + reply.status);
            ImageView msgErrorIv;
            ProgressBar msgSentingPb;
            // 根据Reply的状态来设置replyStateFailed的状态，如果发送失败就显示提示图标
            msgErrorIv = (ImageView) ViewHolder.get(convertView, R.id.msg_error_imageView);
            msgSentingPb = (ProgressBar) ViewHolder.get(convertView, R.id.msg_senting_progressBar);
            
            if (Reply.STATUS_NOT_SENT.equals(reply.status)) {
                msgSentingPb.setVisibility(View.GONE);
                msgErrorIv.setVisibility(View.VISIBLE);
            } else if (Reply.STATUS_SENDING.equals(reply.status) || Reply.STATUS_WILL_SENT.equals(reply.status)) {
                msgSentingPb.setVisibility(View.VISIBLE);
                msgErrorIv.setVisibility(View.GONE);
            } else {
                msgSentingPb.setVisibility(View.GONE);
                msgErrorIv.setVisibility(View.GONE);
            }
        }

        /**
         * 设置回复时间，两条Reply之间相差1分钟则展示时间
         */
        ViewStub timeView = ViewHolder.get(convertView, R.id.time_view_stub);
        if ((position + 1) < mConversation.getReplyList().size()) {
            Reply nextReply = mConversation.getReplyList().get(position + 1);
            // 当两条回复相差1分钟时显示时间
            if (nextReply.created_at - reply.created_at > 1 * 60 * 1000) {
                timeView.setVisibility(View.VISIBLE);
                TextView timeTv = ViewHolder.get(convertView, R.id.msg_Time_TextView);
                Date replyTime = new Date(reply.created_at);
                SimpleDateFormat sdf = new SimpleDateFormat("HH:mm");
                timeTv.setText(sdf.format(replyTime));
            } else {
                timeView.setVisibility(View.GONE);
            }
        }
        return convertView;
    }

    /**
     * @description 重要方法，计算出当前的position
     *
     * @param position
     * @return 当前的position
     */
    private int getCurrentPosition(int position) {
        int totalCount = mConversation.getReplyList().size();
        if (totalCount < mCurrentCount) {
            mCurrentCount = totalCount;
        }
        return totalCount - mCurrentCount + position;
        // return position;
    }

    /**
     * @description 加载之前的聊天信息
     *
     * @param dataCount    一次性加载的数据数目
     */
    public void loadOldData(int dataCount) {
        int totalCount = mConversation.getReplyList().size();
        if (mCurrentCount >= totalCount) {
            // 如果要加载的数据超过了数据的总量，算出实际加载的数据条数
            dataCount = dataCount - (mCurrentCount - totalCount);
            mCurrentCount = totalCount;
        }
        mCurrentCount += dataCount;
        /**
         * 下面的代码可以放在异步任务中执行，这里图省事就没写异步任务。 对于这种从磁盘读取之前数据的人物，用asynTask就行，不用loader
         */
        mActivity.onUpdateSuccess(dataCount);
    }

}

package com.kale.mycmcc;

import java.util.List;

import android.content.Context;
import android.content.Intent;
import android.os.Bundle;
import android.support.v4.widget.SwipeRefreshLayout;
import android.support.v4.widget.SwipeRefreshLayout.OnRefreshListener;
import android.text.Editable;
import android.text.TextUtils;
import android.text.TextWatcher;
import android.view.KeyEvent;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.View.OnKeyListener;
import android.view.inputmethod.InputMethodManager;
import android.widget.AbsListView;
import android.widget.AbsListView.OnScrollListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ListView;
import android.widget.Toast;

import com.umeng.fb.FeedbackAgent;
import com.umeng.fb.SyncListener;
import com.umeng.fb.model.Conversation;
import com.umeng.fb.model.Conversation.OnChangeListener;
import com.umeng.fb.model.Reply;
import com.umeng.message.PushAgent;

public class CustomActivity extends BaseActivity implements DataCallbackActivity {

    private final int LOAD_DATA_NUM = 10;

    private static Context mContext;
    private Conversation mComversation;

    private EditText mInputEt;
    private SwipeRefreshLayout mSwipeLayout;
    private ListView mListView;
    private ReplyAdapter mAdapter;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.umeng_fb__conversation);

        mContext = this;
        mComversation = new FeedbackAgent(this).getDefaultConversation();
        mAdapter = new ReplyAdapter(this, mComversation);

        inMainActivity();
        initView(); // 初始化各种view
        sync(false); // 更新数据

        // 开启语音反馈
        // new FeedbackAgent(this).openAudioFeedback();
        new FeedbackAgent(this).sync();

        mComversation.setOnChangeListener(new OnChangeListener() {

            @Override
            public void onChange() {
                // 发送消息后会自动调用此方法，在这里更新下发送状态
                updateData();
            }
        });
    }

    /**
     * @description 应该在主activity使用的方法
     *
     */
    private void inMainActivity() {
        // 开启友盟消息推送服务
        PushAgent.getInstance(this).enable();
        // 开启反馈回复推送服务
        FeedbackAgent fbAgent = new FeedbackAgent(this);
        fbAgent.openFeedbackPush();

    }

    /**
     * @description 初始化各种view
     *
     */
    private void initView() {
        mSwipeLayout = (SwipeRefreshLayout) findViewById(R.id.swipe_container);
        mSwipeLayout.setSize(SwipeRefreshLayout.DEFAULT);
        // 设置下拉圆圈上的颜色，蓝色、绿色、橙色、红色
        mSwipeLayout.setColorSchemeResources(android.R.color.holo_blue_bright, android.R.color.holo_green_light,
                android.R.color.holo_orange_light, android.R.color.holo_red_light);
        mSwipeLayout.setOnRefreshListener(new OnRefreshListener() {

            @Override
            public void onRefresh() {
                mAdapter.loadOldData(LOAD_DATA_NUM);
            }
        });

        /**
         * list不显示分割线，设置滚动监听器，设置适配器
         */
        mListView = (ListView) findViewById(R.id.conversation_listView);
        // 设置listview不显示分割线
        mListView.setDivider(null);
        mListView.setAdapter(mAdapter);
        mListView.setOnScrollListener(new ListViewListener());

        /**
         * 设置发送按钮的事件
         */
        final Button sendBtn = (Button) findViewById(R.id.conversation_send_btn);
        sendBtn.setEnabled(false);
        sendBtn.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                sendMsgToDev();
            }
        });

        /**
         * 设置发送消息的按钮和输入框 按下回车键，发送消息
         */
        mInputEt = (EditText) findViewById(R.id.conversation_editText);
        mInputEt.setOnKeyListener(new OnKeyListener() {

            @Override
            public boolean onKey(View v, int keyCode, KeyEvent event) {
                // 这两个条件必须同时成立，如果仅仅用了enter判断，就会执行两次
                if (keyCode == KeyEvent.KEYCODE_ENTER && event.getAction() == KeyEvent.ACTION_DOWN) {
                    sendMsgToDev();
                    return true;
                }
                return false;
            }
        });
        // 给editText添加监听器
        mInputEt.addTextChangedListener(new TextWatcher() {

            @Override
            public void onTextChanged(CharSequence s, int start, int before, int count) {
                // 输入过程中，还在内存里，没到屏幕上
            }

            @Override
            public void beforeTextChanged(CharSequence s, int start, int count, int after) {
                // 在输入之前会触发的
            }

            @Override
            public void afterTextChanged(Editable s) {
                // 输入完将要显示到屏幕上时会触发
                boolean isEmpty = s.toString().trim().isEmpty();
                sendBtn.setEnabled(!isEmpty);
                sendBtn.setTextColor(isEmpty ? 0xffa1a2a5 : 0xffffffff);
            }
        });

    }

    /**
     * @description 发送消息
     *
     */
    private void sendMsgToDev() {
        String replyMsg = mInputEt.getText().toString().trim();
        mInputEt.getText().clear();
        if (!TextUtils.isEmpty(replyMsg)) {
            // 将反馈信息放入回话中，有可能发送失败，失败的话在适配器中处理
            mComversation.addUserReply(replyMsg);
            sync(false);
            mAdapter.addOneCount();
        }
    }

    /*
     * 当这个activity在最上方时不重复启动activity， 如果调用了startActivity，那么就更新下视图
     * 
     * @param intent
     */
    @Override
    protected void onNewIntent(Intent intent) {
        super.onNewIntent(intent);
        sync(true);
        mAdapter.addOneCount();
    }

    /**
     * @description 更新数据
     *
     */
    private void updateData() {
        mAdapter.notifyDataSetChanged();
    }

    /**
     * @description 将数据和服务器同步
     *
     */
    private void sync(final boolean isDevReply) {
        if (!isDevReply) {
            // 如果不是开发者回复的信息，那么就先更新数据，再同步到服务器（快）
            updateData();
        }
        mComversation.sync(new SyncListener() {

            @Override
            public void onSendUserReply(List<Reply> replyList) {
            }

            /*
             * 接收开发者回复的信息
             */
            @Override
            public void onReceiveDevReply(List<Reply> replyList) {
                if (replyList == null || replyList.size() < 1) {
                    return;
                }
                if (isDevReply) {
                    // 如果是开发者回复的，就在这里进行数据的同步操作
                    updateData();
                }
            }
        });
        updateData();
    }

    /*
     * 当加载旧的数据完成后的回调方法
     * 
     * @param dataNum 加载了多少个旧的数据
     */
    @Override
    public void onUpdateSuccess(int dataNum) {
        mSwipeLayout.setRefreshing(false);
        // 加载完毕旧的数据，跳到刷新出来数据的位置
        if (dataNum - 1 >= 0) {
            mListView.setSelection(dataNum - 1);
        } else {
            Toast.makeText(mContext, "没有数据了", 0).show();
            mListView.setSelection(0);
        }
    }

    @Override
    public void onUpdateError() {
        // TODO 自动生成的方法存根

    }

    /**
     * @description 因为这里获取数据很快，所以看不出效果。
     *              当你的数据是从数据库或磁盘中读取的，并且加载的数据很多的时候就可以用下面的方法了。
     *
     */
    private void loadOldData() {
        // 如果滚动到顶部，就刷新出旧的数据
        // System.out.println(" load old data");
        /*
         * mSwipeLayout.setRefreshing(true);
         * mAdapter.loadOldData(LOAD_DATA_NUM); mSwipeLayout.setEnabled(false);
         */
    }

    /**
     * @author:Jack Tony
     * @description : 监听listview的滑动状态，如果到了顶部就刷新数据
     * @date :2015年2月9日
     */
    private class ListViewListener implements OnScrollListener {

        InputMethodManager inputMethodManager;

        public ListViewListener() {
            inputMethodManager = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
        }

        @Override
        public void onScroll(AbsListView view, int firstVisibleItem, int visibleItemCount, int totalItemCount) {
        }

        @Override
        public void onScrollStateChanged(AbsListView view, int scrollState) {
            switch (scrollState) {
            // 滚动结束
            case OnScrollListener.SCROLL_STATE_IDLE:
                // 滚动停止
                if (view.getLastVisiblePosition() == (view.getCount() - 1)) {
                    // 如果滚动到底部，就强制显示输入法
                    // inputMethodManager.showSoftInput(mInputEt,
                    // InputMethodManager.SHOW_FORCED);
                } else if (view.getFirstVisiblePosition() == 0) {
                    loadOldData();
                }
                break;
            case OnScrollListener.SCROLL_STATE_FLING:
                // 开始滚动
                break;
            case OnScrollListener.SCROLL_STATE_TOUCH_SCROLL:
                if (inputMethodManager.isActive()) {
                    // 正在滚动， 如果在滚动，就隐藏输入法
                    inputMethodManager.hideSoftInputFromWindow(view.getWindowToken(), 0);
                }
                break;
            }

        }

    }
}