即时通讯功能，使用SDK里封装的方法，获取聊天记录，接口请求成功，但获取不到数据。使用本地的服务器保存聊天记录，实现方法如下：
1. ChatFragment.java中请求聊天记录：
public class ChatFragment extends EaseChatFragment implements EaseChatFragmentHelper {
@Override
protected void setUpView() {
setChatFragmentHelper(this);
String userName = DemoHelper.getInstance().getCurrentUsernName();
conversation = EMClient.getInstance().chatManager().getConversation(toChatUsername, EaseCommonUtils.getConversationType(chatType), true);
Log.e(TAG,"conversation.getAllMsgCount()="+conversation.getAllMsgCount());
if (conversation.getAllMsgCount() != 0 && conversation.getAllMsgCount() != 1) {
setLisener();
} else {
conversation.clearAllMessages();
conversation.clear();
showWaitDialog("数据加载中……").show();
getHistoryMsg(userName,toChatUsername);
}
}
private void setLisener() {
if (chatType == Constant.CHATTYPE_SINGLE) {
Map robotMap = DemoHelper.getInstance().getRobotList();
if(robotMap!=null && robotMap.containsKey(toChatUsername)){
isRobot = true;
}
}
super.setUpView();
……
setOnRefresh1Listener(new OnRefresh1Listener() {
@Override
public boolean refresh(int page) {
pageNo = page;
getHistoryMsg(DemoHelper.getInstance().getCurrentUsernName(),toChatUsername);
return false;
}
});
}
List emMessages = new ArrayList<>();
List remoteMessages = new ArrayList<>();
int pageNo = 1;
private void getHistoryMsg(String sendUser, String receiveUser) {
HashMap baseParam = new HashMap<>(4);
baseParam.put("pageNo",pageNo);
baseParam.put("pageSize",10);
if (chatType == EaseConstant.CHATTYPE_GROUP) {
baseParam.put("sendUser",receiveUser);
baseParam.put("receiveUser",receiveUser);
} else {
baseParam.put("sendUser",sendUser);
baseParam.put("receiveUser",receiveUser);
}
OkHttpUtil.post(TAG, WebApi.MSN_CHAT_LIST, baseParam, new StringCallback() {
@Override
public void onError(Call call, Exception e, int id) {
Log.e(TAG,"getHistoryMsg e="+ e);
}
@Override
public void onResponse(String response, int id) {
Log.e(TAG,"getHistoryMsg response="+ response);
try {
JSonObject object = new JSonObject(response);
if (object.getInt("code") == 200) {
JSonObject object1 = object.getJSonObject("data");
Gson gson = new Gson();
if (pageNo == 1) {
remoteMessages.clear();
}
ListPageBean listPageBean = gson.fromJson(object1.toString(),ListPageBean.class);
if (listPageBean.isLastPage()) {
isLastPage = true;
} else {
isLastPage = false;
}
JSonArray array = object1.getJSonArray("list");
for (int i = 0;i() {
@Override
protected Void doInBackground(Void... params) {
downLoad(message,type,path,fileName);
return null;
}
@Override
protected void onPostExecute(Void result) {
super.onPostExecute(result);
Log.e(TAG,"getFile"+result);
}
}.execute();
}
private void importDatabase(List messages) {
new AsyncTask() {
@Override
protected Void doInBackground(Void... params) {
EMClient.getInstance().chatManager().importMessages(emMessages);
return null;
}
@Override
protected void onPostExecute(Void result) {
super.onPostExecute(result);
handler.postDelayed(new Runnable() {
@Override
public void run() {
setLisener();
hideWaitDialog();
}
},3000);
Log.e(TAG,"importMessages"+result);
}
}.execute();
}
@Override
protected void registerExtendMenuItem() {
//use the menu in base class
super.registerExtendMenuItem();
//extend menu items
inputMenu.registerExtendMenuItem(R.string.attach_video, R.drawable.em_chat_video_selector, ITEM_VIDEO, extendMenuItemClickListener);
inputMenu.registerExtendMenuItem(R.string.attach_file, R.drawable.em_chat_file_selector, ITEM_FILE, extendMenuItemClickListener);
if(chatType == Constant.CHATTYPE_SINGLE){
inputMenu.registerExtendMenuItem(R.string.attach_voice_call, R.drawable.em_chat_voice_call_selector, ITEM_VOICE_CALL, extendMenuItemClickListener);
inputMenu.registerExtendMenuItem(R.string.attach_video_call, R.drawable.em_chat_video_call_selector, ITEM_VIDEO_CALL, extendMenuItemClickListener);
inputMenu.registerExtendMenuItem("企业名片", R.drawable.em_chat_video_call_selector, ITEM_OFFICE_CARD, extendMenuItemClickListener);
} else if (chatType == Constant.CHATTYPE_GROUP) { // 音视频会议
inputMenu.registerExtendMenuItem(R.string.voice_and_video_conference, R.drawable.em_chat_video_call_selector, ITEM_CONFERENCE_CALL, extendMenuItemClickListener);
// inputMenu.registerExtendMenuItem(R.string.title_live, R.drawable.em_chat_video_call_selector, ITEM_LIVE, extendMenuItemClickListener);
}
}
@Override
public boolean onExtendMenuItemClick(int itemId, View view) {
switch (itemId) {
case ITEM_VIDEO:
Log.e(TAG,"onExtendMenuItemClick ITEM_VIDEO");
Intent intent = new Intent(getActivity(), ImageGridActivity.class);
startActivityForResult(intent, REQUEST_CODE_SELECT_VIDEO);
break;
……
case ITEM_OFFICE_CARD:
Log.e(TAG,"onExtendMenuItemClick ITEM_OFFICE_CARD");
startOfficeCard();
break;
default:
break;
}
//keep exist extend menu
return false;
}
private void startOfficeCard() {
HashMap baseParam = WebFrontUtil.getbaseParam();
baseParam.put("id", SavePreferences.getString(Const.OFFICE_ID));
OkHttpUtil.post(TAG, WebApi.PUNISH_OFFICE_DETAIL, baseParam, new StringCallback() {
@Override
public void onError(Call call, Exception e, int id) {
Log.e(TAG,"startOfficeCard e="+e);
}
@Override
public void onResponse(String response, int id) {
Log.e(TAG,"startOfficeCard response="+response);
try {
JSonObject object = new JSonObject(response);
Gson gson = new Gson();
if ((int)object.get("code") == 200) {
JSonObject object1 = object.getJSonObject("data");
OfficeBean officeBean = gson.fromJson(object1.toString(),OfficeBean.class);
String content = "officeId:"+officeBean.getId()+",公司名称:"+officeBean.getName()+",地址:"+officeBean.getAddr()+",联系电话:"+officeBean.getOfficeTel();
EMMessage message = EMMessage.createTxtSendMessage(content, toChatUsername);
message.setAttribute("is_office",true);
sendMessage(message);
}
} catch (JSonException e) {
e.printStackTrace();
}
}
});
}
private final class CustomChatRowProvider implements EaseCustomChatRowProvider {
@Override
public int getCustomChatRowTypeCount() {
//here the number is the message type in EMMessage::Type
//which is used to count the number of different chat row
return 14;
}
@Override
public int getCustomChatRowType(EMMessage message) {
if(message.getType() == EMMessage.Type.TXT){
//voice call
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)){
//video call
return message.direct() == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_VIDEO_CALL : MESSAGE_TYPE_SENT_VIDEO_CALL;
}
//messagee recall
else if(message.getBooleanAttribute(Constant.MESSAGE_TYPE_RECALL, false)){
return MESSAGE_TYPE_RECALL;
} else if (!"".equals(message.getStringAttribute(Constant.MSG_ATTR_CONF_ID,""))) {
return MESSAGE_TYPE_CONFERENCE_INVITE;
} else if (Constant.OP_INVITE.equals(message.getStringAttribute(Constant.EM_CONFERENCE_OP, ""))) {
return MESSAGE_TYPE_LIVE_INVITE;
}else if (message.getBooleanAttribute("is_office",false)) {
return message.direct() == EMMessage.Direct.RECEIVE? MESSAGE_TYPE_RECV_CARD: MESSAGE_TYPE_SEND_CARD;
}
}
return 0;
}
@Override
@Override
public EaseChatRowPresenter getCustomChatRow(EMMessage message, int position, baseAdapter adapter) {
if(message.getType() == EMMessage.Type.TXT){
// voice call or video call
if (message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VOICE_CALL, false) ||
message.getBooleanAttribute(Constant.MESSAGE_ATTR_IS_VIDEO_CALL, false)){
EaseChatRowPresenter presenter = new EaseChatVoiceCallPresenter();
return presenter;
}
if (message.getBooleanAttribute("is_office",false)) {
Log.e(TAG,"getCustomChatRow is_office");
EaseChatRowPresenter presenter = new EaseChatCardPresenter();
return presenter;
}
//recall message
else if(message.getBooleanAttribute(Constant.MESSAGE_TYPE_RECALL, false)){
EaseChatRowPresenter presenter = new EaseChatRecallPresenter();
return presenter;
} else if (!"".equals(message.getStringAttribute(Constant.MSG_ATTR_CONF_ID,""))) {
return new ChatRowConferenceInvitePresenter();
} else if (Constant.OP_INVITE.equals(message.getStringAttribute(Constant.EM_CONFERENCE_OP, ""))) {
return new ChatRowLivePresenter();
}
}
return null;
}
}
private Dialog mWaitDialog;
public Dialog showWaitDialog(String text) {
if (mWaitDialog == null) {
mWaitDialog = DialogManager.getWaitDialog(getActivity(), text);
}
if (mWaitDialog != null) {
TextView textView = mWaitDialog.findViewById(R.id.tv_message);
textView.setText(text);
mWaitDialog.show();
}
return mWaitDialog;
}
public void hideWaitDialog() {
try {
if (mWaitDialog != null) {
mWaitDialog.dismiss();
}
mWaitDialog = null;
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
2. EaseChatFragment.java: 发送消息，加载更多，定义了发送接口，以便activity页面调用；
public class EaseChatFragment extends EasebaseFragment implements EMMessageListener {
……
……
protected void setRefreshLayoutListener() {
swipeRefreshLayout.setonRefreshListener(new SwipeRefreshLayout.onRefreshListener() {
@Override
public void onRefresh() {
handler.postDelayed(new Runnable() {
@Override
public void run() {
if (!isRoaming) {
loadMoreLocalMessage();
} else {
loadMoreRoamingMessages();
}
}
}, 600);
}
});
}
private void loadMoreLocalMessage() {
Log.e(TAG,"loadMoreLocalMessage isloading="+isloading+",haveMoreData="+haveMoreData+","+listView.getFirstVisiblePosition());
if (listView.getFirstVisiblePosition() == 0 && !isloading && haveMoreData) {
List messages;
try {
messages = conversation.loadMoreMsgFromDB(conversation.getAllMessages().size() == 0 ? "" : conversation.getAllMessages().get(0).getMsgId(),
pagesize);
} catch (Exception e1) {
swipeRefreshLayout.setRefreshing(false);
return;
}
if (messages.size() > 0) {
messageList.refreshSeekTo(messages.size() - 1);
if (messages.size() != pagesize) {
haveMoreData = false;
}
} else {
haveMoreData = false;
if (onRefreshListener != null) {
int size = conversation.getAllMessages().size();
Log.e(TAG,"size="+size);
int pageNo = size/10+1;
onRefreshListener.refresh(pageNo);
}
}
isloading = false;
} else {
Toast.makeText(getActivity(), getResources().getString(R.string.no_more_messages),
Toast.LENGTH_SHORT).show();
}
swipeRefreshLayout.setRefreshing(false);
}
……
protected void sendMessage(EMMessage message){
if (message == null) {
return;
}
Log.e(TAG,"sendMessage username="+message.getUserName()+",to="+message.getTo()+",from="+message.getFrom()
+",status="+message.status()+",direct="+message.direct()+",keySet="+message.ext().keySet()
+",type="+message.getType()+",MsgId="+message.getMsgId()
+",body="+message.getBody().toString());
if(chatFragmentHelper != null){
//set extension
chatFragmentHelper.onSetMessageAttributes(message);
}
if (chatType == EaseConstant.CHATTYPE_GROUP){
message.setChatType(ChatType.GroupChat);
}else if(chatType == EaseConstant.CHATTYPE_CHATROOM){
message.setChatType(ChatType.ChatRoom);
}
message.setMessageStatusCallback(messageStatusCallback);
// Send message.
EMClient.getInstance().chatManager().sendMessage(message);
//调用向本地服务器发送消息的接口
if (onClickSendListener != null) {
onClickSendListener.onSendClick(message);
}
//refresh ui
if(isMessageListInited) {
messageList.refreshSelectLast();
}
}
public onClickSendListener onClickSendListener;
public void setonItemClickListener(onClickSendListener onClickBottomListener) {
this.onClickSendListener = onClickBottomListener;
}
public interface OnClickSendListener{
public void onSendClick(EMMessage message);
}
public OnRefresh1Listener onRefreshListener;
public void setOnRefresh1Listener(OnRefresh1Listener onClickBottomListener) {
this.onRefreshListener = onClickBottomListener;
}
public interface OnRefresh1Listener{
public boolean refresh(int page);
}
3. ChatActivity.java：调用fragment的发送接口，以向本地服务器发送消息；
public class ChatActivity extends baseActivity{
……
@Override
protected void onCreate(Bundle arg0) {
super.onCreate(arg0);
setContentView(R.layout.em_activity_chat);
activityInstance = this;
//get user id or group id
toChatUsername = getIntent().getExtras().getString("userId");
//use EaseChatFratFragment
chatFragment = new ChatFragment();
//pass parameters to chat fragment
chatFragment.setArguments(getIntent().getExtras());
getSupportFragmentManager().beginTransaction().add(R.id.container, chatFragment).commit();
chatFragment.setonItemClickListener(new EaseChatFragment.onClickSendListener() {
@Override
public void onSendClick(EMMessage message) {
sendRemoteMsg(message);
}
});
}
……
private void sendRemoteMsg(EMMessage message) {
Map baseParam = new HashMap<>();
baseParam.put("id","");
baseParam.put("msgId",message.getMsgId());
baseParam.put("sendUser",message.getFrom());
baseParam.put("receiveUser",message.getTo());
Log.e(TAG,"receiveType="+message.getChatType().name());
String chatType ="";
if (message.getChatType() == EMMessage.ChatType.Chat) {
chatType = "0";
} else {
chatType = "1";
}
baseParam.put("receiveType",chatType);
int type = 1;
File file = null,file1 = null;
int size = 0;
Log.e(TAG,"type="+message.getType().name());
if (message.getType().name().toString().equals("TXT")) {
if (message.getBooleanAttribute("is_office",false)) {
type = 9;
} else {
type = 1;
}
EMTextMessageBody emTextMessageBody = ((EMTextMessageBody) message.getBody());
baseParam.put("message",emTextMessageBody.getMessage());
} else if (message.getType().name().toString().equals("LOCATION")) {
type = 2;
baseParam.put("message",message.getBody().toString());
} else if (message.getType().name().toString().equals("VOICE")) {
type = 3;
EMVoiceMessageBody emVoiceMessageBody = ((EMVoiceMessageBody) message.getBody());
String filePath = emVoiceMessageBody.getLocalUrl();
file = new File(filePath);
baseParam.put("size",emVoiceMessageBody.getLength()+"");
baseParam.put("message",message.getBody().toString());
} else if (message.getType().name().toString().equals("VIDEO")) {
type = 4;
EMVideoMessageBody emVideoMessageBody = ((EMVideoMessageBody) message.getBody());
String filePath = emVideoMessageBody.getLocalUrl();
file = new File(filePath);
baseParam.put("size",emVideoMessageBody.getDuration()+"");
String thumbnail = emVideoMessageBody.getLocalThumb();
Log.e(TAG,"thumbnail="+thumbnail+","+emVideoMessageBody.getLocalThumb()+",size="+emVideoMessageBody.getDuration()+","+emVideoMessageBody.getVideoFileLength());
file1 = new File(thumbnail);
baseParam.put("message",message.getBody().toString());
} else if(message.getType().name().toString().equals("IMAGE")) {
type = 5;
String filePath = ((EMImageMessageBody) message.getBody()).getLocalUrl();
file = new File(filePath);
baseParam.put("message",message.getBody().toString());
} else if (message.getType().name().toString().equals("FILE")) {
type = 6;
String filePath = ((EMFileMessageBody) message.getBody()).getLocalUrl();
file = new File(filePath);
baseParam.put("message",message.getBody().toString());
} else {
type = 1;
baseParam.put("message",message.getBody().toString());
}
baseParam.put("mesType",String.valueOf(type));
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
baseParam.put("sendTime",format.format(new Date(message.getMsgTime())));
Log.e(TAG,"baseParam="+ baseParam);
FileLoadUtils.postFile(WebApi.MSN_CHAT_SAVE, baseParam, "mesFile", file,"thuFile",file1, new Callback() {
@Override
public void onFailure(Call call, IOException e) {
Log.e(TAG,"sendRemoteMsg e="+ e);
}
@Override
public void onResponse(Call call, Response response) throws IOException {
String result = FileLoadUtils.getResponseBody(response);
Log.e(TAG,"sendRemoteMsg response="+ result+","+response);
}
});
}
}
4. EMMessageUtils.java： ChatFragment.java中获取聊天记录后，将各种类型的聊天记录转化成相应的格式：
public class EMMessageUtils {
private static final String TAG = "EMMessageUtils";
public static EMMessage createImageSendMessage(String fromUser, String var0, boolean var1, String var2) {
File file = new File(var0);
String path = "";
if (!file.exists()) {
String fileName = file.getName();
path = FileLoadUtils.base_PATH + fromUser + "/image/"+fileName;
file = new File(path);
} else {
path = var0;
}
EMMessage var3 = EMMessage.createSendMessage(EMMessage.Type.IMAGE);
var3.setTo(var2);
EMImageMessageBody var4 = new EMImageMessageBody(file);
var4.setSendOriginalImage(var1);
var3.addBody(var4);
return var3;
}
public static EMMessage createVoiceSendMessage(String var0, int var1, String var2) {
File file = new File(var0);
File pathFile = new File(file.getParent());
if (!pathFile.exists()) {
pathFile.mkdirs();
}
if (!file.exists()) {
try {
file.createNewFile();
} catch (IOException e) {
e.printStackTrace();
}
}
EMMessage var3 = EMMessage.createSendMessage(EMMessage.Type.VOICE);
EMVoiceMessageBody var4 = new EMVoiceMessageBody(file, var1);
var3.addBody(var4);
var3.setTo(var2);
return var3;
// }
}
public static EMMessage createVideoSendMessage(String fromUser,String var0, String var1, int var2, String var3) {
File file = new File(var0);
String path = "";
if (!file.exists()) {
String fileName = file.getName();
path = FileLoadUtils.base_PATH + fromUser + "/video/"+fileName;
file = new File(path);
} else {
path = var0;
}
Log.e(TAG,"createVideoSendMessage path="+path);
EMMessage var5 = EMMessage.createSendMessage(EMMessage.Type.VIDEO);
var5.setTo(var3);
EMVideoMessageBody var6 = new EMVideoMessageBody(path, var1, var2, file.length());
var5.addBody(var6);
return var5;
}
public static EMMessage createFileSendMessage(String fromUser,String var0, String var1) {
File file = new File(var0);
Log.e(TAG,"createFileSendMessage var0="+var0);
String path = "";
if (!file.exists()) {
String fileName = file.getName();
path = FileLoadUtils.base_PATH + fromUser + "/file/"+fileName;
file = new File(path);
} else {
path = var0;
}
EMMessage var3 = EMMessage.createSendMessage(EMMessage.Type.FILE);
var3.setTo(var1);
EMNormalFileMessageBody var4 = new EMNormalFileMessageBody(file);
var3.addBody(var4);
return var3;
}
public static EMMessage createVideoMsg(RemoteMessage remoteMessage) {
EMMessage message = null;
int size = 0;
if (!StringUtils.isEmpty(remoteMessage.getSize())) {
size = Integer.valueOf(remoteMessage.getSize());
}
String msgStr = remoteMessage.getMessage();
String[] msgArr = msgStr.split(",");
String localurl="";
String thumbnailUrl= "";
for (int j=0;j1) {
thumbnailUrl = lat[1].trim();
}
}
}
message = createVideoSendMessage(remoteMessage.getSendUser(),localurl, remoteMessage.getThuImg(), size, remoteMessage.getReceiveUser());
((EMVideoMessageBody)message.getBody()).setRemoteUrl(remoteMessage.getFileUrl());
return message;
}
public static EMMessage createLocationMsg(RemoteMessage remoteMessage) {
EMMessage message = null;
String locStr = remoteMessage.getMessage();
String[] locArr = locStr.split(",");
double latitude=0,longitude=0;
String locationAddress="";
for (int j=0;j
5. FileLoadUtils.java：向本地服务器上传数据
public class FileLoadUtils {
private static final String TAG = "FileLoadUtils";
public FileLoadUtils() {
}
……
public static void postFile(final String url, final Map map,String imgStr, File file,String param1,File file1, Callback callback) {
OkHttpClient client = new OkHttpClient();
// form 表单形式上传
MultipartBody.Builder requestBody = new MultipartBody.Builder().setType(MultipartBody.FORM);
if (file != null) {
Log.e("FileLoadUtils","file="+file.getPath()+","+file.getName());
// MediaType.parse() 里面是上传的文件类型。
RequestBody body = RequestBody.create(MediaType.parse("image
public static File createFileEm(String type,String FileName,String toUser) {
String path = null;
if (toUser != null && !toUser.equals("") ) {
if (type.equals("3")) {
path = base_PATH + toUser + "/voice/" ;
} else if (type.equals("4")) {
path = base_PATH + toUser + "/video/";
}else if (type.equals("6")) {
path = base_PATH + toUser + "/file/";
} else {
path = base_PATH + toUser + "/image/";
}
} else {
if (type.equals("3")) {
path = PathUtil.getInstance().getVoicePath() + "/" ;
} else if (type.equals("4")) {
path = PathUtil.getInstance().getVideoPath() + "/";
}else if (type.equals("6")) {
path = PathUtil.getInstance().getFilePath() + "/";
} else {
path = PathUtil.getInstance().getImagePath() + "/";
}
}
File file = new File(path);
if (!file.exists()) {
file.mkdirs();
}
return new File(path, FileName);
}
public static String getThumnailPath(String fromUser,String videoPath) {
String fileName = "thvideo" + System.currentTimeMillis();
createFileEm("5",fileName,fromUser);
// File file = new File(getMSNbasePath("5",fromUser), fileName);
File file = createFileEm("5",fileName,fromUser);
try {
FileOutputStream fos = new FileOutputStream(file);
Bitmap ThumbBitmap = ThumbnailUtils.createVideoThumbnail(videoPath, 3);
ThumbBitmap.compress(Bitmap.CompressFormat.JPEG, 100, fos);
fos.close();
} catch (Exception e) {
e.printStackTrace();
}
return file.getAbsolutePath();
}
6. 发送企业名片后的显示：
发送完信息后，有个UI刷新的过程messageList.refreshSelectLast();－－－－> messageAdapter.refreshSelectLast();
EaseMessageAdapter.java
public class EaseMessageAdapter extends baseAdapter{
private final static String TAG = "EaseMessageAdapter";
private Context context;
private static final int HANDLER_MESSAGE_REFRESH_LIST = 0;
private static final int HANDLER_MESSAGE_SELECT_LAST = 1;
private static final int HANDLER_MESSAGE_SEEK_TO = 2;
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_expression = 12;
private static final int MESSAGE_TYPE_RECV_expression = 13;
private static final int MESSAGE_TYPE_SEND_CARD = 14;
private static final int MESSAGE_TYPE_RECV_CARD = 15;
private EMConversation conversation;
EMMessage[] messages = null;
private String toChatUsername;
private MessageListItemClickListener itemClickListener;
private EaseCustomChatRowProvider customRowProvider;
private ListView listView;
private EaseMessageListItemStyle itemStyle;
public EaseMessageAdapter(Context context, String username, int chatType, ListView listView) {
this.context = context;
this.listView = listView;
toChatUsername = username;
this.conversation = EMClient.getInstance().chatManager().getConversation(username, EaseCommonUtils.getConversationType(chatType), true);
}
Handler handler = new Handler() {
private void refreshList() {
// you should not call getAllMessages() in UI thread
// otherwise there is problem when refreshing UI and there is new message arrive
java.util.List var = conversation.getAllMessages();
Log.e(TAG,"EMMessage.size="+var.size());
messages = var.toArray(new EMMessage[var.size()]);
conversation.markAllMessagesAsRead();
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 (messages != null && messages.length > 0) {
listView.setSelection(messages.length - 1);
}
break;
case HANDLER_MESSAGE_SEEK_TO:
int position = message.arg1;
listView.setSelection(position);
break;
default:
break;
}
}
};
public void refresh() {
if (handler.hasMessages(HANDLER_MESSAGE_REFRESH_LIST)) {
return;
}
android.os.Message msg = handler.obtainMessage(HANDLER_MESSAGE_REFRESH_LIST);
handler.sendMessage(msg);
}
public void refreshSelectLast() {
final int TIME_DELAY_REFRESH_SELECT_LAST = 100;
handler.removeMessages(HANDLER_MESSAGE_REFRESH_LIST);
handler.removeMessages(HANDLER_MESSAGE_SELECT_LAST);
handler.sendEmptyMessageDelayed(HANDLER_MESSAGE_REFRESH_LIST, TIME_DELAY_REFRESH_SELECT_LAST);
handler.sendEmptyMessageDelayed(HANDLER_MESSAGE_SELECT_LAST, TIME_DELAY_REFRESH_SELECT_LAST);
}
public void refreshSeekTo(int position) {
handler.sendMessage(handler.obtainMessage(HANDLER_MESSAGE_REFRESH_LIST));
}
public EMMessage getItem(int position) {
if (messages != null && position < messages.length) {
return messages[position];
}
return null;
}
public long getItemId(int position) {
return position;
}
public int getCount() {
return messages == null ? 0 : messages.length;
}
public int getViewTypeCount() {
if(customRowProvider != null && customRowProvider.getCustomChatRowTypeCount() > 0){
return customRowProvider.getCustomChatRowTypeCount() + 14;
}
return 14;
}
public int getItemViewType(int position) {
EMMessage message = getItem(position);
if (message == null) {
return -1;
}
if(customRowProvider != null && customRowProvider.getCustomChatRowType(message) > 0){
return customRowProvider.getCustomChatRowType(message) + 13;
}
if (message.getType() == EMMessage.Type.TXT) {
if(message.getBooleanAttribute(EaseConstant.MESSAGE_ATTR_IS_BIG_expression, false)){
return message.direct() == EMMessage.Direct.RECEIVE ? MESSAGE_TYPE_RECV_expression : MESSAGE_TYPE_SENT_expression;
}
//企业名片
if (message.getBooleanAttribute("is_office",false)) {
return message.direct() == EMMessage.Direct.RECEIVE? MESSAGE_TYPE_RECV_CARD: MESSAGE_TYPE_SEND_CARD;
}
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 -1;// invalid
}
//重点
protected EaseChatRowPresenter createChatRowPresenter(EMMessage message, int position) {
Log.e(TAG,"createChatRowPresenter");
if(customRowProvider != null && customRowProvider.getCustomChatRow(message, position, this) != null){
return customRowProvider.getCustomChatRow(message, position, this);
}
EaseChatRowPresenter presenter = null;
switch (message.getType()) {
case TXT:
if(message.getBooleanAttribute(EaseConstant.MESSAGE_ATTR_IS_BIG_expression, false)){
presenter = new EaseChatBigexpressionPresenter();
}else{
Log.e(TAG,"TXT is_office");
if (message.getBooleanAttribute("is_office",false)) {
Log.e(TAG,"TXT is_office true");
presenter = new EaseChatCardPresenter();
} else {
presenter = new EaseChatTextPresenter();
}
}
break;
case LOCATION:
presenter = new EaseChatLocationPresenter();
break;
case FILE:
presenter = new EaseChatFilePresenter();
break;
case IMAGE:
presenter = new EaseChatImagePresenter();
break;
case VOICE:
presenter = new EaseChatVoicePresenter();
break;
case VIDEO:
presenter = new EaseChatVideoPresenter();
break;
default:
break;
}
return presenter;
}
@SuppressLint("NewApi")
public View getView(final int position, View convertView, ViewGroup parent) {
EMMessage message = getItem(position);
EaseChatRowPresenter presenter = null;
Log.e(TAG,""+message.getBooleanAttribute("is_office",false)+","+message.getBody());
if (convertView == null) {
presenter = createChatRowPresenter(message, position);
convertView = presenter.createChatRow(context, message, position, this);
convertView.setTag(presenter);
} else {
presenter = (EaseChatRowPresenter) convertView.getTag();
}
presenter.setup(message, position, itemClickListener, itemStyle);
return convertView;
}
public void setItemStyle(EaseMessageListItemStyle itemStyle){
this.itemStyle = itemStyle;
}
public void setItemClickListener(MessageListItemClickListener listener){
itemClickListener = listener;
}
public void setCustomChatRowProvider(EaseCustomChatRowProvider rowProvider){
customRowProvider = rowProvider;
}
}
7. EaseChatCardPresenter.java
public class EaseChatCardPresenter extends EaseChatRowPresenter {
private static final String TAG = "EaseChatFilePresenter";
@Override
protected EaseChatRow onCreateChatRow(Context cxt, EMMessage message, int position, baseAdapter adapter) {
return new EaseChatRowCard(cxt, message, position, adapter);
}
@Override
public void onBubbleClick(EMMessage message) {
EMTextMessageBody fileMessageBody = (EMTextMessageBody) message.getBody();
//点击发送完后的企业名片需要的操作，还没有处理
……
if (message.direct() == EMMessage.Direct.RECEIVE && !message.isAcked() && message.getChatType() == EMMessage.ChatType.Chat) {
try {
EMClient.getInstance().chatManager().ackMessageRead(message.getFrom(), message.getMsgId());
} catch (HyphenateException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
8.EaseChatRowCard.java
public class EaseChatRowCard extends EaseChatRow{
private static final String TAG = "EaseChatRowCard";
protected TextView fileNameView;
protected TextView fileSizeView;
protected TextView fileStateView;
protected TextView tvOfficeAddr;
protected TextView tvOfficeTel;
private EMTextMessageBody fileMessageBody;
public EaseChatRowCard(Context context, EMMessage message, int position, baseAdapter adapter) {
super(context, message, position, adapter);
}
@Override
protected void onInflateView() {
inflater.inflate(message.direct() == EMMessage.Direct.RECEIVE ?
R.layout.ease_row_received_card : R.layout.ease_row_sent_card, this);
}
@Override
protected void onFindViewById() {
fileNameView = (TextView) findViewById(R.id.tv_file_name);
fileSizeView = (TextView) findViewById(R.id.tv_file_size);
fileStateView = (TextView) findViewById(R.id.tv_file_state);
percentageView = (TextView) findViewById(R.id.percentage);
tvOfficeAddr = (TextView) findViewById(R.id.tv_officeAddr);
tvOfficeTel = (TextView) findViewById(R.id.tv_officeTel);
}
@Override
protected void onSetUpView() {
fileMessageBody = (EMTextMessageBody) message.getBody();
String content = fileMessageBody.getMessage();
Log.e(TAG,"content="+content);
if (message.getBooleanAttribute("is_office",false)) {
String[] contentArr = content.split(",");
OfficeCard card = new OfficeCard();
card.setOfficeId(contentArr[0]);
card.setOfficeName(contentArr[1]);
card.setAddr(contentArr[2]);
card.setTel(contentArr[3]);
fileNameView.setText(card.getOfficeName());
tvOfficeAddr.setText(card.getAddr());
tvOfficeTel.setText(card.getTel());
}
}
@Override
protected void onViewUpdate(EMMessage msg) {
switch (msg.status()) {
case CREATE:
onMessageCreate();
break;
case SUCCESS:
onMessageSuccess();
break;
case FAIL:
onMessageError();
break;
case INPROGRESS:
onMessageInProgress();
break;
}
}
private void onMessageCreate() {
progressBar.setVisibility(View.VISIBLE);
if (percentageView != null)
percentageView.setVisibility(View.INVISIBLE);
if (statusView != null)
statusView.setVisibility(View.INVISIBLE);
}
private void onMessageSuccess() {
progressBar.setVisibility(View.INVISIBLE);
if (percentageView != null)
percentageView.setVisibility(View.INVISIBLE);
if (statusView != null)
statusView.setVisibility(View.INVISIBLE);
}
private void onMessageError() {
progressBar.setVisibility(View.INVISIBLE);
if (percentageView != null)
percentageView.setVisibility(View.INVISIBLE);
if (statusView != null)
statusView.setVisibility(View.VISIBLE);
}
private void onMessageInProgress() {
progressBar.setVisibility(View.VISIBLE);
if (percentageView != null) {
percentageView.setVisibility(View.VISIBLE);
percentageView.setText(message.progress() + "%");
}
if (statusView != null)
statusView.setVisibility(View.INVISIBLE);
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持考高分网。
