环信UI开源Demo情景分析十二、聊天界面（四）

public MessageAdapter(Context context, String username, int chatType) { this.username = username; this.context = context; inflater = LayoutInflater.from(context); activity = (Activity) context; this.conversation = EMChatManager.getInstance().getConversation(username); }

Handler handler = new Handler() { private void refreshList() { // UI线程不能直接使用conversation.getAllMessages() // 否则在UI刷新进程中，如果收到新的消息，会致使并提问题 messages = (EMMessage[]) conversation.getAllMessages().toArray(new EMMessage[conversation.getAllMessages().size()]); for (int i = 0; i < messages.length; i++) { // getMessage will set message as read status conversation.getMessage(i); } notifyDataSetChanged(); } @Override public void handleMessage(android.os.Message message) { switch (message.what) { case HANDLER_MESSAGE_REFRESH_LIST: refreshList(); break; case HANDLER_MESSAGE_SELECT_LAST: if (activity instanceof ChatActivity) { ListView listView = ((ChatActivity) activity).getListView(); if (messages.length > 0) { listView.setSelection(messages.length - 1); } } break; case HANDLER_MESSAGE_SEEK_TO: int position = message.arg1; if (activity instanceof ChatActivity) { ListView listView = ((ChatActivity) activity).getListView(); listView.setSelection(position); } break; default: break; } } };

/** * 获得item数 */ public int getCount() { return messages == null ? 0 : messages.length; }

/** * 刷新页面 */ public void refresh() { if (handler.hasMessages(HANDLER_MESSAGE_REFRESH_LIST)) { return; } android.os.Message msg = handler.obtainMessage(HANDLER_MESSAGE_REFRESH_LIST); handler.sendMessage(msg); }

/** * 刷新页面, 选择最后1个 */ public void refreshSelectLast() { handler.sendMessage(handler.obtainMessage(HANDLER_MESSAGE_REFRESH_LIST)); handler.sendMessage(handler.obtainMessage(HANDLER_MESSAGE_SELECT_LAST)); }     /**      * 刷新页面, 选择Position      */     public void refreshSeekTo(int position) {         handler.sendMessage(handler.obtainMessage(HANDLER_MESSAGE_REFRESH_LIST));         android.os.Message msg = handler.obtainMessage(HANDLER_MESSAGE_SEEK_TO);         msg.arg1 = position;         handler.sendMessage(msg);     }

public EMMessage getItem(int position) { if (messages != null && position < messages.length) { return messages[position]; } return null; } public long getItemId(int position) { return position; }

private static final int MESSAGE_TYPE_RECV_TXT = 0; private static final int MESSAGE_TYPE_SENT_TXT = 1; private static final int MESSAGE_TYPE_SENT_IMAGE = 2; private static final int MESSAGE_TYPE_SENT_LOCATION = 3; private static final int MESSAGE_TYPE_RECV_LOCATION = 4; private static final int MESSAGE_TYPE_RECV_IMAGE = 5; private static final int MESSAGE_TYPE_SENT_VOICE = 6; private static final int MESSAGE_TYPE_RECV_VOICE = 7; private static final int MESSAGE_TYPE_SENT_VIDEO = 8; private static final int MESSAGE_TYPE_RECV_VIDEO = 9; private static final int MESSAGE_TYPE_SENT_FILE = 10; private static final int MESSAGE_TYPE_RECV_FILE = 11; private static final int MESSAGE_TYPE_SENT_VOICE_CALL = 12; private static final int MESSAGE_TYPE_RECV_VOICE_CALL = 13; private static final int MESSAGE_TYPE_SENT_VIDEO_CALL = 14; private static final int MESSAGE_TYPE_RECV_VIDEO_CALL = 15;     /**      * 获得item类型数      */     public int getViewTypeCount() {         return 16;     }

/** * 获得item类型 */ public int getItemViewType(int position) { EMMessage message = getItem(position); if (message == null) { return ⑴; } if (message.getType() == EMMessage.Type.TXT) { if (message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VOICE_CALL, false)) return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_VOICE_CALL : MESSAGE_TYPE_SENT_VOICE_CALL; else if (message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VIDEO_CALL, false)) return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_VIDEO_CALL : MESSAGE_TYPE_SENT_VIDEO_CALL; return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_TXT : MESSAGE_TYPE_SENT_TXT; } if (message.getType() == EMMessage.Type.IMAGE) { return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_IMAGE : MESSAGE_TYPE_SENT_IMAGE; } if (message.getType() == EMMessage.Type.LOCATION) { return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_LOCATION : MESSAGE_TYPE_SENT_LOCATION; } if (message.getType() == EMMessage.Type.VOICE) { return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_VOICE : MESSAGE_TYPE_SENT_VOICE; } if (message.getType() == EMMessage.Type.VIDEO) { return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_VIDEO : MESSAGE_TYPE_SENT_VIDEO; } if (message.getType() == EMMessage.Type.FILE) { return message.direct == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_FILE : MESSAGE_TYPE_SENT_FILE; } return ⑴;// invalid }

private View createViewByMessage(EMMessage message, int position) { switch (message.getType()) { case LOCATION: return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_location, null) : inflater.inflate(R.layout.row_sent_location, null); case IMAGE: return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_picture, null) : inflater.inflate(R.layout.row_sent_picture, null); case VOICE: return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_voice, null) : inflater.inflate(R.layout.row_sent_voice, null); case VIDEO: return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_video, null) : inflater.inflate(R.layout.row_sent_video, null); case FILE: return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_file, null) : inflater.inflate(R.layout.row_sent_file, null); default: // 语音通话 if (message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VOICE_CALL, false)) return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_voice_call, null) : inflater.inflate(R.layout.row_sent_voice_call, null); // 视频通话 else if (message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VIDEO_CALL, false)) return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_video_call, null) : inflater.inflate(R.layout.row_sent_video_call, null); return message.direct == EMMessage.Direct.RECEIVE ? inflater.inflate(R.layout.row_received_message, null) : inflater.inflate(R.layout.row_sent_message, null); } }

public View getView(final int position, View convertView, ViewGroup parent) { // 获得具体的消息对象 final EMMessage message = getItem(position); // 取得消息类型 ChatType chatType = message.getChatType(); // 生命1个holder final ViewHolder holder; if (convertView == null) { holder = new ViewHolder(); // 创建该消息的布局 convertView = createViewByMessage(message, position); if (message.getType() == EMMessage.Type.IMAGE) { try { // 消息为图片格式 holder.iv = ((ImageView) convertView.findViewById(R.id.iv_sendPicture)); holder.iv_avatar = (ImageView) convertView.findViewById(R.id.iv_userhead); holder.tv = (TextView) convertView.findViewById(R.id.percentage); holder.pb = (ProgressBar) convertView.findViewById(R.id.progressBar); holder.staus_iv = (ImageView) convertView.findViewById(R.id.msg_status); holder.tv_usernick = (TextView) convertView.findViewById(R.id.tv_userid); } catch (Exception e) { } } else if (message.getType() == EMMessage.Type.TXT) { try { // 消息为文本格式 holder.pb = (ProgressBar) convertView.findViewById(R.id.pb_sending); holder.staus_iv = (ImageView) convertView.findViewById(R.id.msg_status); holder.iv_avatar = (ImageView) convertView.findViewById(R.id.iv_userhead); // 这里是文字内容 holder.tv = (TextView) convertView.findViewById(R.id.tv_chatcontent); holder.tv_usernick = (TextView) convertView.findViewById(R.id.tv_userid); } catch (Exception e) { } // 语音通话及视频通话 if (message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VOICE_CALL, false) || message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VIDEO_CALL, false)) { holder.iv = (ImageView) convertView.findViewById(R.id.iv_call_icon); holder.tv = (TextView) convertView.findViewById(R.id.tv_chatcontent); } } else if (message.getType() == EMMessage.Type.VOICE) { // 消息为声音 try { holder.iv = ((ImageView) convertView.findViewById(R.id.iv_voice)); holder.iv_avatar = (ImageView) convertView.findViewById(R.id.iv_userhead); holder.tv = (TextView) convertView.findViewById(R.id.tv_length); holder.pb = (ProgressBar) convertView.findViewById(R.id.pb_sending); holder.staus_iv = (ImageView) convertView.findViewById(R.id.msg_status); holder.tv_usernick = (TextView) convertView.findViewById(R.id.tv_userid); holder.iv_read_status = (ImageView) convertView.findViewById(R.id.iv_unread_voice); } catch (Exception e) { } } else if (message.getType() == EMMessage.Type.LOCATION) { try { // 消息为地理位置 holder.iv_avatar = (ImageView) convertView.findViewById(R.id.iv_userhead); holder.tv = (TextView) convertView.findViewById(R.id.tv_location); holder.pb = (ProgressBar) convertView.findViewById(R.id.pb_sending); holder.staus_iv = (ImageView) convertView.findViewById(R.id.msg_status); holder.tv_usernick = (TextView) convertView.findViewById(R.id.tv_userid); } catch (Exception e) { } } else if (message.getType() == EMMessage.Type.VIDEO) { try { // 消息为视频文件 holder.iv = ((ImageView) convertView.findViewById(R.id.chatting_content_iv)); holder.iv_avatar = (ImageView) convertView.findViewById(R.id.iv_userhead); holder.tv = (TextView) convertView.findViewById(R.id.percentage); holder.pb = (ProgressBar) convertView.findViewById(R.id.progressBar); holder.staus_iv = (ImageView) convertView.findViewById(R.id.msg_status); holder.size = (TextView) convertView.findViewById(R.id.chatting_size_iv); holder.timeLength = (TextView) convertView.findViewById(R.id.chatting_length_iv); holder.playBtn = (ImageView) convertView.findViewById(R.id.chatting_status_btn); holder.container_status_btn = (LinearLayout) convertView.findViewById(R.id.container_status_btn); holder.tv_usernick = (TextView) convertView.findViewById(R.id.tv_userid); } catch (Exception e) { } } else if (message.getType() == EMMessage.Type.FILE) { try { // 消息为文件 holder.iv_avatar = (ImageView) convertView.findViewById(R.id.iv_userhead); holder.tv_file_name = (TextView) convertView.findViewById(R.id.tv_file_name); holder.tv_file_size = (TextView) convertView.findViewById(R.id.tv_file_size); holder.pb = (ProgressBar) convertView.findViewById(R.id.pb_sending); holder.staus_iv = (ImageView) convertView.findViewById(R.id.msg_status); holder.tv_file_download_state = (TextView) convertView.findViewById(R.id.tv_file_state); holder.ll_container = (LinearLayout) convertView.findViewById(R.id.ll_file_container); // 这里是进度值 holder.tv = (TextView) convertView.findViewById(R.id.percentage); } catch (Exception e) { } try { holder.tv_usernick = (TextView) convertView.findViewById(R.id.tv_userid); } catch (Exception e) { } } // 设置TAG convertView.setTag(holder); } else { // 获得TAG holder = (ViewHolder) convertView.getTag(); } // 群聊时，显示接收的消息的发送人的名称 if (chatType == ChatType.GroupChat && message.direct == EMMessage.Direct.RECEIVE) { // demo里使用username代码nick holder.tv_usernick.setText(message.getFrom()); } // 如果是发送的消息并且不是群聊消息，显示已读textview if (message.direct == EMMessage.Direct.SEND && chatType != ChatType.GroupChat) { holder.tv_ack = (TextView) convertView.findViewById(R.id.tv_ack); holder.tv_delivered = (TextView) convertView.findViewById(R.id.tv_delivered); if (holder.tv_ack != null) { if (message.isAcked) { if (holder.tv_delivered != null) { holder.tv_delivered.setVisibility(View.INVISIBLE); } holder.tv_ack.setVisibility(View.VISIBLE); } else { holder.tv_ack.setVisibility(View.INVISIBLE); // check and display msg delivered ack status if (holder.tv_delivered != null) { if (message.isDelivered) { holder.tv_delivered.setVisibility(View.VISIBLE); } else { holder.tv_delivered.setVisibility(View.INVISIBLE); } } } } } else { // 如果是文本或地图消息并且不是group messgae，显示的时候给对方发送已读回执 if ((message.getType() == Type.TXT || message.getType() == Type.LOCATION) && !message.isAcked && chatType != ChatType.GroupChat) { // 不是语音通话记录 if (!message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VOICE_CALL, false)) { try { EMChatManager.getInstance().ackMessageRead(message.getFrom(), message.getMsgId()); // 发送已读回执 message.isAcked = true; } catch (Exception e) { e.printStackTrace(); } } } } // 设置用户头像 setUserAvatar(message, holder.iv_avatar); switch (message.getType()) { // 根据消息type显示item case IMAGE: // 图片 handleImageMessage(message, holder, position, convertView); break; case TXT: // 文本 if (message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VOICE_CALL, false) || message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VIDEO_CALL, false)) // 音视频通话 handleCallMessage(message, holder, position); else handleTextMessage(message, holder, position); break; case LOCATION: // 位置 handleLocationMessage(message, holder, position, convertView); break; case VOICE: // 语音 handleVoiceMessage(message, holder, position, convertView); break; case VIDEO: // 视频 handleVideoMessage(message, holder, position, convertView); break; case FILE: // 1般文件 handleFileMessage(message, holder, position, convertView); break; default: // not supported } // 重发 if (message.direct == EMMessage.Direct.SEND) { View statusView = convertView.findViewById(R.id.msg_status); // 重发按钮点击事件 statusView.setOnClickListener(new OnClickListener() { @Override public void onClick(View v) { // 显示重发消息的自定义alertdialog Intent intent = new Intent(activity, AlertDialog.class); intent.putExtra("msg", activity.getString(R.string.confirm_resend)); intent.putExtra("title", activity.getString(R.string.resend)); intent.putExtra("cancel", true); intent.putExtra("position", position); if (message.getType() == EMMessage.Type.TXT) activity.startActivityForResult(intent, ChatActivity.REQUEST_CODE_TEXT); else if (message.getType() == EMMessage.Type.VOICE) activity.startActivityForResult(intent, ChatActivity.REQUEST_CODE_VOICE); else if (message.getType() == EMMessage.Type.IMAGE) activity.startActivityForResult(intent, ChatActivity.REQUEST_CODE_PICTURE); else if (message.getType() == EMMessage.Type.LOCATION) activity.startActivityForResult(intent, ChatActivity.REQUEST_CODE_LOCATION); else if (message.getType() == EMMessage.Type.FILE) activity.startActivityForResult(intent, ChatActivity.REQUEST_CODE_FILE); else if (message.getType() == EMMessage.Type.VIDEO) activity.startActivityForResult(intent, ChatActivity.REQUEST_CODE_VIDEO); } }); } else { final String st = context.getResources().getString(R.string.Into_the_blacklist); // 长按头像，移入黑名单 holder.iv_avatar.setOnLongClickListener(new OnLongClickListener() { @Override public boolean onLongClick(View v) { Intent intent = new Intent(activity, AlertDialog.class); intent.putExtra("msg", st); intent.putExtra("cancel", true); intent.putExtra("position", position); activity.startActivityForResult(intent, ChatActivity.REQUEST_CODE_ADD_TO_BLACKLIST); return true; } }); } // 时间 TextView timestamp = (TextView) convertView.findViewById(R.id.timestamp); if (position == 0) { timestamp.setText(DateUtils.getTimestampString(new Date(message.getMsgTime()))); timestamp.setVisibility(View.VISIBLE); } else { // 两条消息时间离得如果稍长，显示时间 EMMessage prevMessage = getItem(position - 1); if (prevMessage != null && DateUtils.isCloseEnough(message.getMsgTime(), prevMessage.getMsgTime())) { timestamp.setVisibility(View.GONE); } else { timestamp.setText(DateUtils.getTimestampString(new Date(message.getMsgTime()))); timestamp.setVisibility(View.VISIBLE); } } return convertView; }

/** * 显示用户头像 * * @param message * @param imageView */ private void setUserAvatar(EMMessage message, ImageView imageView) { if (message.direct == Direct.SEND) { // 显示自己头像 UserUtils.setUserAvatar(context, EMChatManager.getInstance().getCurrentUser(), imageView); } else { UserUtils.setUserAvatar(context, message.getFrom(), imageView); } }

/** * 文本消息 * * @param message * @param holder * @param position */ private void handleTextMessage(EMMessage message, ViewHolder holder, final int position) { TextMessageBody txtBody = (TextMessageBody) message.getBody(); Spannable span = SmileUtils.getSmiledText(context, txtBody.getMessage()); // 设置内容 holder.tv.setText(span, BufferType.SPANNABLE); // 设置长按事件监听 holder.tv.setOnLongClickListener(new OnLongClickListener() { @Override public boolean onLongClick(View v) { activity.startActivityForResult((new Intent(activity, ContextMenu.class)).putExtra("position", position).putExtra("type", EMMessage.Type.TXT.ordinal()), ChatActivity.REQUEST_CODE_CONTEXT_MENU); return true; } }); if (message.direct == EMMessage.Direct.SEND) { switch (message.status) { case SUCCESS: // 发送成功 holder.pb.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.GONE); break; case FAIL: // 发送失败 holder.pb.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.VISIBLE); break; case INPROGRESS: // 发送中 holder.pb.setVisibility(View.VISIBLE); holder.staus_iv.setVisibility(View.GONE); break; default: // 发送消息 sendMsgInBackground(message, holder); } } }

/** * 音视频通话记录 * * @param message * @param holder * @param position */ private void handleCallMessage(EMMessage message, ViewHolder holder, final int position) { TextMessageBody txtBody = (TextMessageBody) message.getBody(); holder.tv.setText(txtBody.getMessage()); }

/**      * 图片消息      *      * @param message      * @param holder      * @param position      * @param convertView      */     private void handleImageMessage(final EMMessage message, final ViewHolder holder, final int position, View convertView) {         //给当前图片设置1个tag避免多张图片蹿乱         holder.pb.setTag(position);         holder.iv.setOnLongClickListener(new OnLongClickListener() {             @Override             public boolean onLongClick(View v) {                 //长按设置事件                 activity.startActivityForResult((new Intent(activity, ContextMenu.class)).putExtra("position", position).putExtra("type", EMMessage.Type.IMAGE.ordinal()), ChatActivity.REQUEST_CODE_CONTEXT_MENU);                 return true;             }         });         // 接收方向的消息         if (message.direct == EMMessage.Direct.RECEIVE) {             // "it is receive msg";             if (message.status == EMMessage.Status.INPROGRESS) {                 // "!!!! back receive";正在接收的时候显示默许图片                 holder.iv.setImageResource(R.drawable.default_image);                 //显示下载进度条                 showDownloadImageProgress(message, holder);                 // downloadImage(message, holder);             } else {                 // "!!!! not back receive, show image directly");                 //发送图片                 holder.pb.setVisibility(View.GONE);                 holder.tv.setVisibility(View.GONE);                 holder.iv.setImageResource(R.drawable.default_image);                 ImageMessageBody imgBody = (ImageMessageBody) message.getBody();                 if (imgBody.getLocalUrl() != null) {                     // String filePath = imgBody.getLocalUrl();                     String remotePath = imgBody.getRemoteUrl();                     String filePath = ImageUtils.getImagePath(remotePath);                     String thumbRemoteUrl = imgBody.getThumbnailUrl();                     String thumbnailPath = ImageUtils.getThumbnailImagePath(thumbRemoteUrl);                     //将图片加载到Imageview里面                     showImageView(thumbnailPath, holder.iv, filePath, imgBody.getRemoteUrl(), message);                 }             }             return;         }         // 发送的消息         // process send message         // send pic, show the pic directly         ImageMessageBody imgBody = (ImageMessageBody) message.getBody();         String filePath = imgBody.getLocalUrl();         if (filePath != null && new File(filePath).exists()) {             showImageView(ImageUtils.getThumbnailImagePath(filePath), holder.iv, filePath, null, message);         } else {             showImageView(ImageUtils.getThumbnailImagePath(filePath), holder.iv, filePath, IMAGE_DIR, message);         }         switch (message.status) {         //图片加载状态         case SUCCESS:             holder.pb.setVisibility(View.GONE);             holder.tv.setVisibility(View.GONE);             holder.staus_iv.setVisibility(View.GONE);             break;         case FAIL:             holder.pb.setVisibility(View.GONE);             holder.tv.setVisibility(View.GONE);             holder.staus_iv.setVisibility(View.VISIBLE);             break;         case INPROGRESS:             holder.staus_iv.setVisibility(View.GONE);             holder.pb.setVisibility(View.VISIBLE);             holder.tv.setVisibility(View.VISIBLE);             if (timers.containsKey(message.getMsgId()))                 return;             // set a timer 设置1个定时器来显示图片的进度             final Timer timer = new Timer();             timers.put(message.getMsgId(), timer);             timer.schedule(new TimerTask() {                 @Override                 public void run() {                     activity.runOnUiThread(new Runnable() {                         public void run() {                             holder.pb.setVisibility(View.VISIBLE);                             holder.tv.setVisibility(View.VISIBLE);                             holder.tv.setText(message.progress + "%");                             if (message.status == EMMessage.Status.SUCCESS) {                                 holder.pb.setVisibility(View.GONE);                                 holder.tv.setVisibility(View.GONE);                                 // message.setSendingStatus(Message.SENDING_STATUS_SUCCESS);                                 timer.cancel();                             } else if (message.status == EMMessage.Status.FAIL) {                                 //发送失败                                 holder.pb.setVisibility(View.GONE);                                 holder.tv.setVisibility(View.GONE);                                 // message.setSendingStatus(Message.SENDING_STATUS_FAIL);                                 // message.setProgress(0);                                 holder.staus_iv.setVisibility(View.VISIBLE);                                 Toast.makeText(activity, activity.getString(R.string.send_fail) + activity.getString(R.string.connect_failuer_toast), 0).show();                                 timer.cancel();                             }                         }                     });                 }             }, 0, 500);             break;         default:             sendPictureMessage(message, holder);         }     }

/** * 视频消息 * * @param message * @param holder * @param position * @param convertView */ private void handleVideoMessage(final EMMessage message, final ViewHolder holder, final int position, View convertView) { //获得视频对象 VideoMessageBody videoBody = (VideoMessageBody) message.getBody(); // final File image=new File(PathUtil.getInstance().getVideoPath(), // videoBody.getFileName()); String localThumb = videoBody.getLocalThumb(); holder.iv.setOnLongClickListener(new OnLongClickListener() { @Override public boolean onLongClick(View v) { //长按菜单 activity.startActivityForResult(new Intent(activity, ContextMenu.class).putExtra("position", position).putExtra("type", EMMessage.Type.VIDEO.ordinal()), ChatActivity.REQUEST_CODE_CONTEXT_MENU); return true; } }); if (localThumb != null) { //展现视频缩略图 showVideoThumbView(localThumb, holder.iv, videoBody.getThumbnailUrl(), message); } if (videoBody.getLength() > 0) { //设置视频时长 String time = DateUtils.toTimeBySecond(videoBody.getLength()); holder.timeLength.setText(time); } //播放按钮 holder.playBtn.setImageResource(R.drawable.video_download_btn_nor); if (message.direct == EMMessage.Direct.RECEIVE) { //接收到的视频 if (videoBody.getVideoFileLength() > 0) { //视频大小 String size = TextFormater.getDataSize(videoBody.getVideoFileLength()); holder.size.setText(size); } } else { //发送的视频 if (videoBody.getLocalUrl() != null && new File(videoBody.getLocalUrl()).exists()) { String size = TextFormater.getDataSize(new File(videoBody.getLocalUrl()).length()); holder.size.setText(size); } } if (message.direct == EMMessage.Direct.RECEIVE) { // System.err.println("it is receive msg"); //显示进度条 if (message.status == EMMessage.Status.INPROGRESS) { // System.err.println("!!!! back receive"); holder.iv.setImageResource(R.drawable.default_image); showDownloadImageProgress(message, holder); } else { // System.err.println("!!!! not back receive, show image directly"); holder.iv.setImageResource(R.drawable.default_image); if (localThumb != null) { showVideoThumbView(localThumb, holder.iv, videoBody.getThumbnailUrl(), message); } } return; } //对进度条设置tag holder.pb.setTag(position); // until here ,deal with send video msg //发送的结果 switch (message.status) { case SUCCESS: holder.pb.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.GONE); holder.tv.setVisibility(View.GONE); break; case FAIL: holder.pb.setVisibility(View.GONE); holder.tv.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.VISIBLE); break; case INPROGRESS: if (timers.containsKey(message.getMsgId())) return; // set a timer final Timer timer = new Timer(); timers.put(message.getMsgId(), timer); timer.schedule(new TimerTask() { @Override public void run() { //500毫秒更新1次 activity.runOnUiThread(new Runnable() { @Override public void run() { holder.pb.setVisibility(View.VISIBLE); holder.tv.setVisibility(View.VISIBLE); holder.tv.setText(message.progress + "%"); if (message.status == EMMessage.Status.SUCCESS) { holder.pb.setVisibility(View.GONE); holder.tv.setVisibility(View.GONE); // message.setSendingStatus(Message.SENDING_STATUS_SUCCESS); timer.cancel(); } else if (message.status == EMMessage.Status.FAIL) { holder.pb.setVisibility(View.GONE); holder.tv.setVisibility(View.GONE); // message.setSendingStatus(Message.SENDING_STATUS_FAIL); // message.setProgress(0); holder.staus_iv.setVisibility(View.VISIBLE); Toast.makeText(activity, activity.getString(R.string.send_fail) + activity.getString(R.string.connect_failuer_toast), 0).show(); timer.cancel(); } } }); } }, 0, 500); break; default: // sendMsgInBackground(message, holder); sendPictureMessage(message, holder); } }

<span style="font-size:18px;"> /** * 语音消息 * * @param message * @param holder * @param position * @param convertView */ private void handleVoiceMessage(final EMMessage message, final ViewHolder holder, final int position, View convertView) { //语音对象 VoiceMessageBody voiceBody = (VoiceMessageBody) message.getBody(); holder.tv.setText(voiceBody.getLength() + """); //语音播放事件 holder.iv.setOnClickListener(new VoicePlayClickListener(message, holder.iv, holder.iv_read_status, this, activity, username)); holder.iv.setOnLongClickListener(new OnLongClickListener() { @Override public boolean onLongClick(View v) { //长按上下文菜单 activity.startActivityForResult((new Intent(activity, ContextMenu.class)).putExtra("position", position).putExtra("type", EMMessage.Type.VOICE.ordinal()), ChatActivity.REQUEST_CODE_CONTEXT_MENU); return true; } }); if (((ChatActivity) activity).playMsgId != null && ((ChatActivity) activity).playMsgId.equals(message.getMsgId()) && VoicePlayClickListener.isPlaying) { AnimationDrawable voiceAnimation; //显示声音播放动画 if (message.direct == EMMessage.Direct.RECEIVE) { holder.iv.setImageResource(R.anim.voice_from_icon); } else { holder.iv.setImageResource(R.anim.voice_to_icon); } voiceAnimation = (AnimationDrawable) holder.iv.getDrawable(); voiceAnimation.start(); } else { //显示为播放状态下的界面 if (message.direct == EMMessage.Direct.RECEIVE) { holder.iv.setImageResource(R.drawable.chatfrom_voice_playing); } else { holder.iv.setImageResource(R.drawable.chatto_voice_playing); } } if (message.direct == EMMessage.Direct.RECEIVE) { if (message.isListened()) { // 隐藏语音未听标志 holder.iv_read_status.setVisibility(View.INVISIBLE); } else { holder.iv_read_status.setVisibility(View.VISIBLE); } System.err.println("it is receive msg"); if (message.status == EMMessage.Status.INPROGRESS) { holder.pb.setVisibility(View.VISIBLE); System.err.println("!!!! back receive"); //监听收到的语音文件消息完成下载 ((FileMessageBody) message.getBody()).setDownloadCallback(new EMCallBack() { @Override public void onSuccess() { activity.runOnUiThread(new Runnable() { @Override public void run() { //下载以后更新数据 holder.pb.setVisibility(View.INVISIBLE); notifyDataSetChanged(); } }); } @Override public void onProgress(int progress, String status) { } @Override public void onError(int code, String message) { activity.runOnUiThread(new Runnable() { @Override public void run() { //下载失败，隐藏进度条 holder.pb.setVisibility(View.INVISIBLE); } }); } }); } else { //没有进度的情况 holder.pb.setVisibility(View.INVISIBLE); } return; } // until here, deal with send voice msg //消息的结果 switch (message.status) { case SUCCESS: holder.pb.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.GONE); break; case FAIL: holder.pb.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.VISIBLE); break; case INPROGRESS: holder.pb.setVisibility(View.VISIBLE); holder.staus_iv.setVisibility(View.GONE); break; default: sendMsgInBackground(message, holder); } }</span>

/** * 文件消息 * * @param message * @param holder * @param position * @param convertView */ private void handleFileMessage(final EMMessage message, final ViewHolder holder, int position, View convertView) { final NormalFileMessageBody fileMessageBody = (NormalFileMessageBody) message.getBody(); final String filePath = fileMessageBody.getLocalUrl(); holder.tv_file_name.setText(fileMessageBody.getFileName()); holder.tv_file_size.setText(TextFormater.getDataSize(fileMessageBody.getFileSize())); holder.ll_container.setOnClickListener(new OnClickListener() { //文件点击事件 @Override public void onClick(View view) { File file = new File(filePath); if (file != null && file.exists()) { // 文件存在，直接打开（SDK所提供的类） FileUtils.openFile(file, (Activity) context); } else { // 下载 context.startActivity(new Intent(context, ShowNormalFileActivity.class).putExtra("msgbody", fileMessageBody)); } if (message.direct == EMMessage.Direct.RECEIVE && !message.isAcked) { try { //文件确认 EMChatManager.getInstance().ackMessageRead(message.getFrom(), message.getMsgId()); message.isAcked = true; } catch (EaseMobException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }); String st1 = context.getResources().getString(R.string.Have_downloaded); String st2 = context.getResources().getString(R.string.Did_not_download); if (message.direct == EMMessage.Direct.RECEIVE) { // 接收的消息 System.err.println("it is receive msg"); File file = new File(filePath); if (file != null && file.exists()) { holder.tv_file_download_state.setText(st1); } else { holder.tv_file_download_state.setText(st2); } return; } // until here, deal with send voice msg switch (message.status) { case SUCCESS: holder.pb.setVisibility(View.INVISIBLE); holder.tv.setVisibility(View.INVISIBLE); holder.staus_iv.setVisibility(View.INVISIBLE); break; case FAIL: holder.pb.setVisibility(View.INVISIBLE); holder.tv.setVisibility(View.INVISIBLE); holder.staus_iv.setVisibility(View.VISIBLE); break; case INPROGRESS: if (timers.containsKey(message.getMsgId())) return; // set a timer final Timer timer = new Timer(); timers.put(message.getMsgId(), timer); timer.schedule(new TimerTask() { @Override public void run() { activity.runOnUiThread(new Runnable() { //与语音消息1样的处理 @Override public void run() { holder.pb.setVisibility(View.VISIBLE); holder.tv.setVisibility(View.VISIBLE); holder.tv.setText(message.progress + "%"); if (message.status == EMMessage.Status.SUCCESS) { holder.pb.setVisibility(View.INVISIBLE); holder.tv.setVisibility(View.INVISIBLE); timer.cancel(); } else if (message.status == EMMessage.Status.FAIL) { holder.pb.setVisibility(View.INVISIBLE); holder.tv.setVisibility(View.INVISIBLE); holder.staus_iv.setVisibility(View.VISIBLE); Toast.makeText(activity, activity.getString(R.string.send_fail) + activity.getString(R.string.connect_failuer_toast), 0).show(); timer.cancel(); } } }); } }, 0, 500); break; default: // 发送消息 sendMsgInBackground(message, holder); } }

/** * 处理位置消息 * * @param message * @param holder * @param position * @param convertView */ private void handleLocationMessage(final EMMessage message, final ViewHolder holder, final int position, View convertView) { //位置信息对象 TextView locationView = ((TextView) convertView.findViewById(R.id.tv_location)); LocationMessageBody locBody = (LocationMessageBody) message.getBody(); locationView.setText(locBody.getAddress()); //经纬度信息 LatLng loc = new LatLng(locBody.getLatitude(), locBody.getLongitude()); //地图点击事假 locationView.setOnClickListener(new MapClickListener(loc, locBody.getAddress())); locationView.setOnLongClickListener(new OnLongClickListener() { @Override public boolean onLongClick(View v) { //长按 上下文菜单 activity.startActivityForResult((new Intent(activity, ContextMenu.class)).putExtra("position", position).putExtra("type", EMMessage.Type.LOCATION.ordinal()), ChatActivity.REQUEST_CODE_CONTEXT_MENU); return false; } }); if (message.direct == EMMessage.Direct.RECEIVE) { return; } // deal with send message //消息发送状态 switch (message.status) { case SUCCESS: holder.pb.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.GONE); break; case FAIL: holder.pb.setVisibility(View.GONE); holder.staus_iv.setVisibility(View.VISIBLE); break; case INPROGRESS: holder.pb.setVisibility(View.VISIBLE); break; default: sendMsgInBackground(message, holder); } }

/** * 发送消息 * * @param message * @param holder<pre name="code" class="java"> /* * 文件下载 * chat sdk will automatic download thumbnail image for the image message we * need to register callback show the download progress */ private void showDownloadImageProgress(final EMMessage message, final ViewHolder holder) { System.err.println("!!! show download image progress"); // final ImageMessageBody msgbody = (ImageMessageBody) // message.getBody(); final FileMessageBody msgbody = (FileMessageBody) message.getBody(); if (holder.pb != null) holder.pb.setVisibility(View.VISIBLE); if (holder.tv != null) holder.tv.setVisibility(View.VISIBLE); // 异步下载文件 msgbody.setDownloadCallback(new EMCallBack() { @Override public void onSuccess() { activity.runOnUiThread(new Runnable() { @Override public void run() { // message.setBackReceive(false); if (message.getType() == EMMessage.Type.IMAGE) { holder.pb.setVisibility(View.GONE); holder.tv.setVisibility(View.GONE); } notifyDataSetChanged(); } }); } @Override public void onError(int code, String message) { } @Override public void onProgress(final int progress, String status) { if (message.getType() == EMMessage.Type.IMAGE) { activity.runOnUiThread(new Runnable() { //显示下载进度 @Override public void run() { holder.tv.setText(progress + "%"); } }); } } }); }

/* * 发送图片 send message with new sdk */ private void sendPictureMessage(final EMMessage message, final ViewHolder holder) { try { // 获得发送对象 String to = message.getTo(); // before send, update ui holder.staus_iv.setVisibility(View.GONE); holder.pb.setVisibility(View.VISIBLE); holder.tv.setVisibility(View.VISIBLE); holder.tv.setText("0%"); final long start = System.currentTimeMillis(); // if (chatType == ChatActivity.CHATTYPE_SINGLE) { EMChatManager.getInstance().sendMessage(message, new EMCallBack() { // 异步发送 @Override public void onSuccess() { Log.d(TAG, "send image message successfully"); activity.runOnUiThread(new Runnable() { public void run() { // send success holder.pb.setVisibility(View.GONE); holder.tv.setVisibility(View.GONE); } }); } @Override public void onError(int code, String error) { activity.runOnUiThread(new Runnable() { public void run() { holder.pb.setVisibility(View.GONE); holder.tv.setVisibility(View.GONE); // message.setSendingStatus(Message.SENDING_STATUS_FAIL); holder.staus_iv.setVisibility(View.VISIBLE); Toast.makeText(activity, activity.getString(R.string.send_fail) + activity.getString(R.string.connect_failuer_toast), 0).show(); } }); } @Override public void onProgress(final int progress, String status) { activity.runOnUiThread(new Runnable() { public void run() { holder.tv.setText(progress + "%"); } }); } }); } catch (Exception e) { e.printStackTrace(); } }

/** * 更新ui上消息发送状态 * * @param message * @param holder */ private void updateSendedView(final EMMessage message, final ViewHolder holder) { activity.runOnUiThread(new Runnable() { @Override public void run() { // send success if (message.getType() == EMMessage.Type.VIDEO) { holder.tv.setVisibility(View.GONE); } System.out.println("message status : " + message.status); if (message.status == EMMessage.Status.SUCCESS) { // if (message.getType() == EMMessage.Type.FILE) { // holder.pb.setVisibility(View.INVISIBLE); // holder.staus_iv.setVisibility(View.INVISIBLE); // } else { // holder.pb.setVisibility(View.GONE); // holder.staus_iv.setVisibility(View.GONE); // } } else if (message.status == EMMessage.Status.FAIL) { // if (message.getType() == EMMessage.Type.FILE) { // holder.pb.setVisibility(View.INVISIBLE); // } else { // holder.pb.setVisibility(View.GONE); // } // holder.staus_iv.setVisibility(View.VISIBLE); Toast.makeText(activity, activity.getString(R.string.send_fail) + activity.getString(R.string.connect_failuer_toast), 0).show(); } notifyDataSetChanged(); } }); }

/** * load image into image view * 显示图片到控件中 * @param thumbernailPath * @param iv * @param position * @return the image exists or not */ private boolean showImageView(final String thumbernailPath, final ImageView iv, final String localFullSizePath, String remoteDir, final EMMessage message) { // String imagename = // localFullSizePath.substring(localFullSizePath.lastIndexOf("/") + 1, // localFullSizePath.length()); // final String remote = remoteDir != null ? remoteDir+imagename : // imagename; final String remote = remoteDir; EMLog.d("###", "local = " + localFullSizePath + " remote: " + remote); // first check if the thumbnail image already loaded into cache //获得缓存文件 Bitmap bitmap = ImageCache.getInstance().get(thumbernailPath); if (bitmap != null) { //文件存在 // thumbnail image is already loaded, reuse the drawable iv.setImageBitmap(bitmap); iv.setClickable(true); iv.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { System.err.println("image view on click"); //显示大图界面 Intent intent = new Intent(activity, ShowBigImage.class); File file = new File(localFullSizePath); if (file.exists()) { Uri uri = Uri.fromFile(file); intent.putExtra("uri", uri); System.err.println("here need to check why download everytime"); } else { // The local full size pic does not exist yet. // ShowBigImage needs to download it from the server // first // intent.putExtra("", message.get); ImageMessageBody body = (ImageMessageBody) message.getBody(); intent.putExtra("secret", body.getSecret()); intent.putExtra("remotepath", remote); } if (message != null && message.direct == EMMessage.Direct.RECEIVE && !message.isAcked && message.getChatType() != ChatType.GroupChat) { try { EMChatManager.getInstance().ackMessageRead(message.getFrom(), message.getMsgId()); message.isAcked = true; } catch (Exception e) { e.printStackTrace(); } } activity.startActivity(intent); } }); return true; } else { //文件不存在 重新加载 new LoadImageTask().execute(thumbernailPath, localFullSizePath, remote, message.getChatType(), iv, activity, message); return true; } }

/** * 展现视频缩略图 * * @param localThumb * 本地缩略图路径 * @param iv * @param thumbnailUrl * 远程缩略图路径 * @param message */ private void showVideoThumbView(String localThumb, ImageView iv, String thumbnailUrl, final EMMessage message) { // first check if the thumbnail image already loaded into cache Bitmap bitmap = ImageCache.getInstance().get(localThumb); if (bitmap != null) { // thumbnail image is already loaded, reuse the drawable iv.setImageBitmap(bitmap); iv.setClickable(true); iv.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { VideoMessageBody videoBody = (VideoMessageBody) message.getBody(); System.err.println("video view is on click"); Intent intent = new Intent(activity, ShowVideoActivity.class); intent.putExtra("localpath", videoBody.getLocalUrl()); intent.putExtra("secret", videoBody.getSecret()); intent.putExtra("remotepath", videoBody.getRemoteUrl()); if (message != null && message.direct == EMMessage.Direct.RECEIVE && !message.isAcked && message.getChatType() != ChatType.GroupChat) { message.isAcked = true; try { EMChatManager.getInstance().ackMessageRead(message.getFrom(), message.getMsgId()); } catch (Exception e) { e.printStackTrace(); } } activity.startActivity(intent); } }); } else { new LoadVideoImageTask().execute(localThumb, thumbnailUrl, iv, activity, message, this); } }

/* * 点击地图消息listener */ class MapClickListener implements View.OnClickListener { LatLng location; String address; public MapClickListener(LatLng loc, String address) { location = loc; this.address = address; } @Override public void onClick(View v) { Intent intent; //将聊天界面上的地图用地图界面显示出来 intent = new Intent(context, BaiduMapActivity.class); intent.putExtra("latitude", location.latitude); intent.putExtra("longitude", location.longitude); intent.putExtra("address", address); activity.startActivity(intent); } }