Android实现聊天记录上传本地服务器(即时通讯)
即时通讯功能,使用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<String, RobotUser> 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<EMMessage> emMessages = new ArrayList<>(); List<RemoteMessage> remoteMessages = new ArrayList<>(); int pageNo = 1; private void getHistoryMsg(String sendUser, String receiveUser) { HashMap<String, Object> 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<array.length();i++) { RemoteMessage remoteMessage = gson.fromJson(array.get(i).toString(),RemoteMessage.class); convertMsg(remoteMessage); } Log.e(TAG,"emMessages.size()="+emMessages.size()); //下拉加载 if (emMessages.size()< 10) { haveMoreData = false; } else { haveMoreData = true; } importDataBase(emMessages); } } catch (JSONException e) { e.printStackTrace(); hideWaitDialog(); } } }); } /* * 将从接口获取的数据转换成EMMessage对象 * */ private void convertMsg(RemoteMessage remoteMessage) { EMMessage message = null; Log.e(TAG,"getHistoryMsg Message="+ remoteMessage.getMessage()+","+remoteMessage.getSendTime()+","+remoteMessage.getCreateDate()); if (remoteMessage.getMesType().equals("1")) { message = EMMessage.createTxtSendMessage(remoteMessage.getMessage(), remoteMessage.getReceiveUser()); } else if (remoteMessage.getMesType().equals("2")) { message = EMMessageUtils.createLocationMsg(remoteMessage); } else if (remoteMessage.getMesType().equals("3")) {//语音 message = createVoiceMsg(remoteMessage); } else if (remoteMessage.getMesType().equals("4")) {//视频 message = EMMessageUtils.createVideoMsg(remoteMessage); getFile(message,remoteMessage.getMesType(),remoteMessage.getFileUrl(),((EMVideoMessageBody)message.getBody()).getFileName()); } else if (remoteMessage.getMesType().equals("5")) {//图片 message = createImageMsg(remoteMessage); } else if (remoteMessage.getMesType().equals("6")) {//文件 message = createFileMsg(remoteMessage); } else if (remoteMessage.getMesType().equals("7")) {//语音 message = EMMessage.createTxtSendMessage(remoteMessage.getMessage(), remoteMessage.getReceiveUser()); message.setAttribute(Constant.MESSAGE_ATTR_IS_VOICE_CALL,true); } else if (remoteMessage.getMesType().equals("8")) {//视频电话 message = EMMessage.createTxtSendMessage(remoteMessage.getMessage(), remoteMessage.getReceiveUser()); message.setAttribute(Constant.MESSAGE_ATTR_IS_VIDEO_CALL,true); } else if (remoteMessage.getMesType().equals("9")) { message = EMMessage.createTxtSendMessage(remoteMessage.getMessage(), remoteMessage.getReceiveUser()); message.setAttribute("is_office",true); } if (remoteMessage.getSendUser().equals(DemoHelper.getInstance().getCurrentUsernName())) { message.setDirection(EMMessage.Direct.SEND); } else { message.setDirection(EMMessage.Direct.RECEIVE); } if (remoteMessage.getReceiveType().equals("0")) { message.setChatType(EMMessage.ChatType.Chat); } else { message.setChatType(EMMessage.ChatType.GroupChat); } // message.setChatType(EMMessage.ChatType.Chat); message.setFrom(remoteMessage.getSendUser()); message.setMsgId(remoteMessage.getMsgId()); message.setMsgTime(Long.valueOf(remoteMessage.getSendTime())); message.setStatus(EMMessage.Status.SUCCESS); conversation.insertMessage(message); // updateMsg(message); emMessages.add(message); } private EMMessage createFileMsg(RemoteMessage remoteMessage) { EMMessage message = null; String msgStr = remoteMessage.getMessage(); String[] msgArr = msgStr.split(","); String localurl=""; for (int j=0;j<msgArr.length;j++) { String[] lat = msgArr[j].split(":"); if (lat[0].contains("localUrl")) { localurl = lat[1].trim(); } } message = EMMessageUtils.createFileSendMessage(remoteMessage.getSendUser(),localurl, remoteMessage.getReceiveUser()); getFile(message,remoteMessage.getMesType(),remoteMessage.getFileUrl(),((EMFileMessageBody)message.getBody()).getFileName()); ((EMFileMessageBody)message.getBody()).setRemoteUrl(remoteMessage.getFileUrl()); return message; } private EMMessage createImageMsg(RemoteMessage remoteMessage) { EMMessage message = null; String msgStr = remoteMessage.getMessage(); String[] msgArr = msgStr.split(","); String localurl=""; for (int j=0;j<msgArr.length;j++) { String[] lat = msgArr[j].split(":"); if (lat[0].contains("localurl")) { localurl = lat[1].trim(); } } message = EMMessageUtils.createImageSendMessage(remoteMessage.getSendUser(),localurl, false, remoteMessage.getReceiveUser()); getFile(message,remoteMessage.getMesType(),remoteMessage.getFileUrl(),((EMImageMessageBody)message.getBody()).getFileName()); ((EMImageMessageBody)message.getBody()).setRemoteUrl(remoteMessage.getFileUrl()); return message; } private EMMessage createVoiceMsg(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=""; for (int j=0;j<msgArr.length;j++) { String[] lat = msgArr[j].split(":"); if (lat[0].contains("localurl")) { localurl = lat[1].trim(); } } message = EMMessageUtils.createVoiceSendMessage(localurl, size, remoteMessage.getReceiveUser()); ((EMVoiceMessageBody)message.getBody()).setRemoteUrl(remoteMessage.getFileUrl()); getFile(message,remoteMessage.getMesType(),remoteMessage.getFileUrl(),((EMVoiceMessageBody)message.getBody()).getFileName()); return message; } /* * 下载文件 * */ HttpURLConnection con; private void downLoad(EMMessage emMessage,String type,String path, String fileName) { try { URL url = new URL(path); con = (HttpURLConnection) url.openConnection(); con.setReadTimeout(5000); con.setConnectTimeout(5000); con.setRequestProperty("Charset", "UTF-8"); con.setRequestMethod("GET"); if (con.getResponseCode() == 200) { InputStream is = con.getInputStream();//获取输入流 FileOutputStream fileOutputStream = null;//文件输出流 if (is != null) { String toUser = ""; if (emMessage.direct() == EMMessage.Direct.RECEIVE) { toUser = emMessage.getFrom(); } File file = FileLoadUtils.createFileEm(type,fileName,toUser); fileOutputStream = new FileOutputStream(file);//指定文件保存路径,代码看下一步 byte[] buf = new byte[1024]; int ch; while ((ch = is.read(buf)) != -1) { fileOutputStream.write(buf, 0, ch);//将获取到的流写入文件中 } } if (fileOutputStream != null) { fileOutputStream.flush(); fileOutputStream.close(); } if (type.equals("4")) { String thum = FileLoadUtils.getThumnailPath(emMessage.getFrom(),((EMVideoMessageBody)emMessage.getBody()).getLocalUrl()); Log.e(TAG,"downLoad thum="+thum); ((EMVideoMessageBody)emMessage.getBody()).setLocalThumb(thum); } Log.d(TAG,"下载成功"); // getActivity().runOnUiThread(new Runnable() { // @Override // public void run() { // Toast.makeText(getActivity(),"下载成功"+fileName,Toast.LENGTH_SHORT).show(); // } // }); } else { Log.d(TAG,"下载失败"); // getActivity().runOnUiThread(new Runnable() { // @Override // public void run() { // Toast.makeText(getActivity(),"下载失败",Toast.LENGTH_SHORT).show(); // } // }); } } catch (Exception e) { e.printStackTrace(); }finally { //最后将conn断开连接 if (con != null) { con.disconnect(); con = null; } } } private void getFile(EMMessage message,String type,String path, String fileName) { new AsyncTask<Void, Void, Void>() { @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<EMMessage> messages) { new AsyncTask<Void, Void, Void>() { @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<String, Object> 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(); } } }); } /** * chat row provider * 发送企业名片时,修改过此处,否则还是文本格式 * */ 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); } }); } /** * 加载更多,haveMoreData的变化 */ private void loadMoreLocalMessage() { Log.e(TAG,"loadMoreLocalMessage isloading="+isloading+",haveMoreData="+haveMoreData+","+listView.getFirstVisiblePosition()); if (listView.getFirstVisiblePosition() == 0 && !isloading && haveMoreData) { List<EMMessage> 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(); } } /** * 向本地服务器发送消息,需要在ChatActivity中调用 */ public OnClickSendListener onClickSendListener; public void setOnItemClickListener(OnClickSendListener onClickBottomListener) { this.onClickSendListener = onClickBottomListener; } public interface OnClickSendListener{ /** * 发送消息事件 */ public void onSendClick(EMMessage message); } /** * 下拉加载,在ChatFragment中调用 */ 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<String, String> 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; } /* * 修改SDK中的创建文件类型的消息,改成使用自己的路径 * */ 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;j<msgArr.length;j++) { String[] lat = msgArr[j].split(":"); if (lat[0].contains("localUrl")) { localurl = lat[1].trim(); } else if (lat[0].equals("thumbnailUrl")) { if (lat.length>1) { 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<locArr.length;j++) { String[] lat = locArr[j].split(":"); if (lat[0].equals("location")) { locationAddress = lat[1]; } else if (lat[0].equals("lat")) { latitude = Double.valueOf(lat[1]); } else if (lat[0].equals("lng")) { longitude = Double.valueOf(lat[1]); } } message = EMMessage.createLocationSendMessage(latitude, longitude, locationAddress, remoteMessage.getReceiveUser()); return message; } }
5. FileLoadUtils.java:向本地服务器上传数据
public class FileLoadUtils { private static final String TAG = "FileLoadUtils"; public FileLoadUtils() { } …… /** * 上传消息到服务器,表单形式上传 */ public static void postFile(final String url, final Map<String, String> 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/*"), file); String filename = file.getName(); // 参数分别为, 请求key ,文件名称 , RequestBody requestBody.addFormDataPart(imgStr, filename, body); } if (file1 != null) { Log.e("FileLoadUtils","file="+file1.getPath()+","+file1.getName()); // MediaType.parse() 里面是上传的文件类型。 RequestBody body = RequestBody.create(MediaType.parse("image/*"), file1); String filename = file1.getName(); // 参数分别为, 请求key ,文件名称 , RequestBody requestBody.addFormDataPart(param1, filename, body); } if (map != null) { // map 里面是请求中所需要的 key 和 value Set<Map.Entry<String, String>> entries = map.entrySet(); for (Map.Entry entry : entries) { String key = String.valueOf(entry.getKey()); String value = String.valueOf(entry.getValue()); Log.d("HttpUtils", "key=="+key+",value=="+value); requestBody.addFormDataPart(key,value); } } String token = SavePreferences.getString(Const.TOKEN_KEY); Request request = new Request.Builder().url(url).header("token", token).post(requestBody.build()).build(); // readTimeout("请求超时时间" , 时间单位); client.newBuilder().readTimeout(5000, TimeUnit.MILLISECONDS).build() .newCall(request).enqueue(callback); } /** * 获取文件保存地址,toUser指发送消息过来的好友名称 */ 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<EMMessage> 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); } /** * refresh and select the last */ 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); } /** * refresh and seek to the position */ 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; } /** * get count of messages */ public int getCount() { return messages == null ? 0 : messages.length; } /** * get number of message type, here 14 = (EMMessage.Type) * 2 */ public int getViewTypeCount() { if(customRowProvider != null && customRowProvider.getCustomChatRowTypeCount() > 0){ return customRowProvider.getCustomChatRowTypeCount() + 14; } return 14; } /** * get type of item */ 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); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。
赞 (0)