添加ugc消息体的使用demo

谷俊
1 parent b979c751
Showing 5 changed files with 212 additions and 9 deletions
app/src/main/java/com/cnlive/im/adapter/ChatRoomAdpter.java
app/src/main/java/com/cnlive/im/adapter/base/ItemClickListener.java
app/src/main/java/com/cnlive/im/ui/ChatRoomActivity.java
app/src/main/java/com/cnlive/im/ui/PrivateActivity.java
app/src/main/java/com/cnlive/im/util/MessageType.java
@@ -16,6 +16,7 @@ import com.cnlive.im.adapter.base.BaseRecyclerAdapter;
 import com.cnlive.im.adapter.base.ItemClickListener;
 import com.cnlive.im.mode.ImagMessage;
 import com.cnlive.im.mode.StringMessage;
+import com.cnlive.im.mode.UgcVideoMessage;
 import com.cnlive.im.mode.VideoMessage;
 import com.cnlive.im.mode.VoiceMessage;
 import com.cnlive.im.util.FileUtil;
@@ -39,6 +40,8 @@ public class ChatRoomAdpter extends BaseRecyclerAdapter {
     private int voiceOppsite = 6;
     private int videoUser = 7;
     private int videoOppsite = 8;
+    private int ugcVideoUser = 9;
+    private int ugcVideoOppsite = 10;
     private Context mContext;
     private ItemClickListener mItemClickListener;
@@ -79,6 +82,12 @@ public class ChatRoomAdpter extends BaseRecyclerAdapter {
                 return videoUser;
             else return videoOppsite;
+        } else if (o instanceof UgcVideoMessage) {
+            UgcVideoMessage o1 = (UgcVideoMessage) o;
+            if (o1.isUserSend())
+                return ugcVideoUser;
+            else return ugcVideoOppsite;
+
         }
         return 0;
     }
@@ -101,6 +110,10 @@ public class ChatRoomAdpter extends BaseRecyclerAdapter {
             return new VideoMessageHolder(LayoutInflater.from(mContext).inflate(R.layout.video_layout_item_user, null));
         } else if (viewType == videoOppsite) {
             return new VideoMessageHolder(LayoutInflater.from(mContext).inflate(R.layout.video_layout_item_oppsite, null));
+        } else if (viewType == ugcVideoUser) {
+            return new VideoMessageHolder(LayoutInflater.from(mContext).inflate(R.layout.video_layout_item_user, null));
+        } else if (viewType == ugcVideoOppsite) {
+            return new VideoMessageHolder(LayoutInflater.from(mContext).inflate(R.layout.video_layout_item_oppsite, null));
         }
         return null;
     }
@@ -127,6 +140,11 @@ public class ChatRoomAdpter extends BaseRecyclerAdapter {
             final Object o = mItems.get(position);
             final VideoMessage o1 = (VideoMessage) o;
             holder1.showMessage(o1);
+        } else if (holder instanceof UgcVideoMessageHolder) {
+            final UgcVideoMessageHolder holder1 = (UgcVideoMessageHolder) holder;
+            final Object o = mItems.get(position);
+            final UgcVideoMessage o1 = (UgcVideoMessage) o;
+            holder1.showMessage(o1);
         }
     }
@@ -382,4 +400,78 @@ public class ChatRoomAdpter extends BaseRecyclerAdapter {
         }
     }
+    public class UgcVideoMessageHolder extends RecyclerView.ViewHolder {
+
+        private TextView video_user_name;
+        private ImageView video_cover;
+        private View videoLayout;
+        private TextView status;
+
+        public UgcVideoMessageHolder(View itemView) {
+            super(itemView);
+            video_user_name = (TextView) itemView.findViewById(R.id.user_name);
+            video_cover = (ImageView) itemView.findViewById(R.id.img_content);
+            videoLayout = itemView.findViewById(R.id.videoLayout);
+            status = (TextView) itemView.findViewById(R.id.status);
+        }
+
+        public void showMessage(final UgcVideoMessage videoMessage) {
+            video_user_name.setText(videoMessage.getCnUgcMessage().getUserInfo().getUserName());
+            switch (videoMessage.getCnUgcMessage().getStatus()) {
+                case IChat.CN_MSG_STATUS_SENDING:
+                    if (status != null)
+                        status.setText("发送中");
+                    Glide.with(mContext).load(videoMessage.getCnUgcMessage().getCoverPath()).into(video_cover);
+                    break;
+                case IChat.CN_MSG_STATUS_SEND_FAIL:
+                    if (status != null)
+                        status.setText("发送失败");
+                    Glide.with(mContext).load(videoMessage.getCnUgcMessage().getCoverPath()).into(video_cover);
+                    break;
+                case IChat.CN_MSG_STATUS_SEND_SUCCESS:
+                    if (status != null)
+                        status.setText("发送成功");
+                    sendSuccess(videoMessage);
+                    break;
+            }
+        }
+
+        private void sendSuccess(final UgcVideoMessage videoMessage) {
+            videoLayout.setOnClickListener(new View.OnClickListener() {
+                @Override
+                public void onClick(View v) {
+                    if (mItemClickListener != null)
+                        mItemClickListener.onUgcVideoClick(videoMessage);
+                }
+            });
+            if (videoMessage.getCnUgcMessage().isSelf()) {
+                Glide.with(mContext).load(videoMessage.getCnUgcMessage().getCoverPath()).into(video_cover);
+            } else {
+                String coverUuid = videoMessage.getCnUgcMessage().getFileId() + "_image";
+                final String imagePath = FileUtil.getCacheFilePath(coverUuid);
+                if (FileUtil.isCacheFileExist(coverUuid)) {
+                    if (video_cover != null && mContext != null)
+                        Glide.with(mContext).load(imagePath).into(video_cover);
+                } else {
+                    if (!videoMessage.isDownloading()) {
+                        videoMessage.setDownloading(true);
+                        videoMessage.getCnUgcMessage().getCover().getImage(imagePath, new IChat.OnDownloadListener() {
+                            @Override
+                            public void onSuccess() {
+                                videoMessage.setDownloading(false);
+                                if (video_cover != null && mContext != null)
+                                    Glide.with(mContext).load(imagePath).into(video_cover);
+                            }
+
+                            @Override
+                            public void onError(int i, String s) {
+                                videoMessage.setDownloading(false);
+                            }
+                        });
+                    }
+                }
+            }
+        }
+    }
+
 }
@@ -3,6 +3,7 @@ package com.cnlive.im.adapter.base;
 import android.graphics.drawable.AnimationDrawable;
 import com.cnlive.im.mode.ImagMessage;
+import com.cnlive.im.mode.UgcVideoMessage;
 import com.cnlive.im.mode.VideoMessage;
 import com.cnlive.im.mode.VoiceMessage;
@@ -16,5 +17,7 @@ public interface ItemClickListener {
     void onVideoClick(VideoMessage videoMessage);
+    void onUgcVideoClick(UgcVideoMessage ugcVideoMessage);
+
     void onImageClick(ImagMessage imagMessage);
 }
@@ -40,6 +40,7 @@ import com.cnlive.im.adapter.ChatRoomAdpter;
 import com.cnlive.im.adapter.base.ItemClickListener;
 import com.cnlive.im.mode.ImagMessage;
 import com.cnlive.im.mode.StringMessage;
+import com.cnlive.im.mode.UgcVideoMessage;
 import com.cnlive.im.mode.VideoMessage;
 import com.cnlive.im.mode.VoiceMessage;
 import com.cnlive.im.util.AudioRecordUtil;
@@ -53,6 +54,7 @@ import com.cnlive.libs.util.chat.base.IChat;
 import com.cnlive.libs.util.chat.model.CNBaseMessage;
 import com.cnlive.libs.util.chat.model.CNImgMessage;
 import com.cnlive.libs.util.chat.model.CNMessage;
+import com.cnlive.libs.util.chat.model.CNUgcMessage;
 import com.cnlive.libs.util.chat.model.CNUserInfo;
 import com.cnlive.libs.util.chat.model.CNVideoMessage;
 import com.cnlive.libs.util.chat.model.CNVoiceMessage;
@@ -228,7 +230,8 @@ public class ChatRoomActivity extends AppCompatActivity implements View.OnClickL
      */
     public void updateItem(CNBaseMessage o) {
         int updateIndex = groupChatOneListMy.indexOf(o.getMessageId());
-        if (updateIndex < 0 || chatListAdapterOne.getItemCount() <= 0) return;
+        if (updateIndex < 0 || chatListAdapterOne.getItemCount() <= 0 || updateIndex > chatListAdapterOne.getItemCount() - 1)
+            return;
         if (o.getMsgType() == IChat.CN_MSG_TYPE_TEXT) {
             CNMessage o1 = (CNMessage) o;
             chatListAdapterOne.updateItem(new StringMessage(MessageType.stringMessage, o1, o1.isSelf()), updateIndex);
@@ -243,6 +246,10 @@ public class ChatRoomActivity extends AppCompatActivity implements View.OnClickL
             CNVideoMessage ol = (CNVideoMessage) o;
             VideoMessage videoMessage = new VideoMessage(MessageType.videoMessage, ol, ol.isSelf());
             chatListAdapterOne.updateItem(videoMessage, updateIndex);
+        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_UGC) {
+            CNUgcMessage ol = (CNUgcMessage) o;
+            UgcVideoMessage ugcVideoMessage = new UgcVideoMessage(MessageType.ugcVideoMessage, ol, ol.isSelf());
+            chatListAdapterOne.updateItem(ugcVideoMessage, updateIndex);
         }
     }
@@ -267,8 +274,13 @@ public class ChatRoomActivity extends AppCompatActivity implements View.OnClickL
             CNVideoMessage ol = (CNVideoMessage) o;
             VideoMessage videoMessage = new VideoMessage(MessageType.videoMessage, ol, ol.isSelf());
             chatListAdapterOne.addItem(videoMessage);
+        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_UGC) {
+            CNUgcMessage ol = (CNUgcMessage) o;
+            UgcVideoMessage ugcVideoMessage = new UgcVideoMessage(MessageType.ugcVideoMessage, ol, ol.isSelf());
+            chatListAdapterOne.addItem(ugcVideoMessage);
         }
-        listViewOne.smoothScrollToPosition(chatListAdapterOne.getItemCount() - 1);
+        if (chatListAdapterOne.getItemCount() > 0)
+            listViewOne.smoothScrollToPosition(chatListAdapterOne.getItemCount() - 1);
     }
@@ -380,7 +392,7 @@ public class ChatRoomActivity extends AppCompatActivity implements View.OnClickL
                 openSystemRecorder();
                 break;
             case R.id.ugcVideoBtn:
-
+                openSystemRecorder();
                 break;
         }
     }
@@ -562,6 +574,37 @@ public class ChatRoomActivity extends AppCompatActivity implements View.OnClickL
     }
     @Override
+    public void onUgcVideoClick(UgcVideoMessage ugcVideoMessage) {
+        if (ugcVideoMessage.getCnUgcMessage().isSelf()) {
+            Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
+            intent.putExtra("videoPath", ugcVideoMessage.getCnUgcMessage().getVideoPath());
+            startActivity(intent);
+        } else {
+            String videoUuid = ugcVideoMessage.getCnUgcMessage().getFileId() + "_video";
+            final String videoPath = FileUtil.getCacheFilePath(videoUuid);
+            if (FileUtil.isCacheFileExist(videoUuid)) {
+                Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
+                intent.putExtra("videoPath", videoPath);
+                startActivity(intent);
+            } else {
+                ugcVideoMessage.getCnUgcMessage().getVideo().getVideo(videoPath, new IChat.OnDownloadListener() {
+                    @Override
+                    public void onSuccess() {
+                        Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
+                        intent.putExtra("videoPath", videoPath);
+                        startActivity(intent);
+                    }
+
+                    @Override
+                    public void onError(int i, String s) {
+
+                    }
+                });
+            }
+        }
+    }
+
+    @Override
     public void onImageClick(final ImagMessage imagMessage) {
         if (imagMessage.getCnImgMessage().isSelf()) {
             Intent intent = new Intent(ChatRoomActivity.this, ImageViewActivity.class);
@@ -42,6 +42,7 @@ import com.cnlive.im.adapter.base.ItemClickListener;
 import com.cnlive.im.mode.CNMessageModole;
 import com.cnlive.im.mode.ImagMessage;
 import com.cnlive.im.mode.StringMessage;
+import com.cnlive.im.mode.UgcVideoMessage;
 import com.cnlive.im.mode.VideoMessage;
 import com.cnlive.im.mode.VoiceMessage;
 import com.cnlive.im.util.AudioRecordUtil;
@@ -55,6 +56,7 @@ import com.cnlive.libs.util.chat.base.IChat;
 import com.cnlive.libs.util.chat.model.CNBaseMessage;
 import com.cnlive.libs.util.chat.model.CNImgMessage;
 import com.cnlive.libs.util.chat.model.CNMessage;
+import com.cnlive.libs.util.chat.model.CNUgcMessage;
 import com.cnlive.libs.util.chat.model.CNUserInfo;
 import com.cnlive.libs.util.chat.model.CNVideoMessage;
 import com.cnlive.libs.util.chat.model.CNVoiceMessage;
@@ -266,7 +268,7 @@ public class PrivateActivity extends AppCompatActivity implements View.OnClickLi
                 openSystemRecorder();
                 break;
             case R.id.ugcVideoBtn:
-
+                openSystemRecorder();
                 break;
         }
     }
@@ -443,7 +445,8 @@ public class PrivateActivity extends AppCompatActivity implements View.OnClickLi
      */
     public void updateItem(CNBaseMessage o) {
         int updateIndex = messageList.indexOf(o.getMessageId());
-        if (updateIndex < 0 || chatListAdapter.getItemCount() <= 0) return;
+        if (updateIndex < 0 || chatListAdapter.getItemCount() <= 0 || updateIndex > chatListAdapter.getItemCount() - 1)
+            return;
         if (o.getMsgType() == IChat.CN_MSG_TYPE_TEXT) {
             CNMessage o1 = (CNMessage) o;
             chatListAdapter.updateItem(new StringMessage(MessageType.stringMessage, o1, o1.isSelf()), updateIndex);
@@ -458,6 +461,10 @@ public class PrivateActivity extends AppCompatActivity implements View.OnClickLi
             CNVideoMessage ol = (CNVideoMessage) o;
             VideoMessage videoMessage = new VideoMessage(MessageType.videoMessage, ol, ol.isSelf());
             chatListAdapter.updateItem(videoMessage, updateIndex);
+        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_UGC) {
+            CNUgcMessage ol = (CNUgcMessage) o;
+            UgcVideoMessage ugcVideoMessage = new UgcVideoMessage(MessageType.ugcVideoMessage, ol, ol.isSelf());
+            chatListAdapter.updateItem(ugcVideoMessage, updateIndex);
         }
     }
@@ -467,7 +474,6 @@ public class PrivateActivity extends AppCompatActivity implements View.OnClickLi
      * @param o
      */
     private void showMessage(CNBaseMessage o, boolean isReceivedMsg) {
-        messageList.add(o.getMessageId());
         if (o.getMsgType() == IChat.CN_MSG_TYPE_TEXT) {
             if (isReceivedMsg) {
                 CNMessage o1 = (CNMessage) o;
@@ -484,29 +490,56 @@ public class PrivateActivity extends AppCompatActivity implements View.OnClickLi
                         sendInfo = 4;
                     } else if ("4".equals(type)) {
                         Log.v(TAG, o1.getContent().toString());
+                        messageList.add(o.getMessageId());
                         chatListAdapter.addItem(new StringMessage(MessageType.stringMessage, o1, false));
-                        chatListView.smoothScrollToPosition(chatListAdapter.getItemCount() - 1);
                     }
                 } catch (JSONException e) {
                     e.printStackTrace();
                 }
             } else {
                 CNMessage o1 = (CNMessage) o;
-                chatListAdapter.addItem(new StringMessage(MessageType.stringMessage, o1, o1.isSelf()));
+                JSONObject jsonObject = null;
+                try {
+                    jsonObject = new JSONObject(o1.getContent().toString());
+                    String type = (String) jsonObject.get("type");
+                    String message = (String) jsonObject.get("message");
+                    Toast.makeText(PrivateActivity.this, "发送消息成功", Toast.LENGTH_SHORT).show();
+                    if ("3".equals(type) && message.equals("你好我们可以进行私聊吗")) {
+                        sendInfo = 2;
+                        Toast.makeText(PrivateActivity.this, "申请已发送等待对方验证", Toast.LENGTH_SHORT).show();
+                    } else if ("3".equals(type) && message.equals("拒绝")) {
+                        sendInfo = 5;
+                    } else if ("3".equals(type) && message.equals("同意")) {
+                        sendInfo = 1;
+                    } else if ("4".equals(type)) {
+                        messageList.add(o.getMessageId());
+                        chatListAdapter.addItem(new StringMessage(MessageType.stringMessage, o1, true));
+                    }
+                } catch (JSONException e) {
+                }
             }
         } else if (o.getMsgType() == IChat.CN_MSG_TYPE_IMAGE) {
+            messageList.add(o.getMessageId());
             CNImgMessage o1 = (CNImgMessage) o;
             chatListAdapter.addItem(new ImagMessage(MessageType.imaMessage, o1, o1.isSelf()));
         } else if (o.getMsgType() == IChat.CN_MSG_TYPE_VOICE) {
+            messageList.add(o.getMessageId());
             CNVoiceMessage o1 = (CNVoiceMessage) o;
             VoiceMessage voiceMessage = new VoiceMessage(MessageType.voiceMessage, o1, o1.isSelf());
             chatListAdapter.addItem(voiceMessage);
         } else if (o.getMsgType() == IChat.CN_MSG_TYPE_VIDEO) {
+            messageList.add(o.getMessageId());
             CNVideoMessage ol = (CNVideoMessage) o;
             VideoMessage videoMessage = new VideoMessage(MessageType.videoMessage, ol, ol.isSelf());
             chatListAdapter.addItem(videoMessage);
+        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_UGC) {
+            messageList.add(o.getMessageId());
+            CNUgcMessage ol = (CNUgcMessage) o;
+            UgcVideoMessage ugcVideoMessage = new UgcVideoMessage(MessageType.ugcVideoMessage, ol, ol.isSelf());
+            chatListAdapter.addItem(ugcVideoMessage);
         }
-        chatListView.smoothScrollToPosition(chatListAdapter.getItemCount() - 1);
+        if (chatListAdapter.getItemCount() > 0)
+            chatListView.smoothScrollToPosition(chatListAdapter.getItemCount() - 1);
     }
     /**
@@ -759,6 +792,37 @@ public class PrivateActivity extends AppCompatActivity implements View.OnClickLi
     }
     @Override
+    public void onUgcVideoClick(UgcVideoMessage ugcVideoMessage) {
+        if (ugcVideoMessage.getCnUgcMessage().isSelf()) {
+            Intent intent = new Intent(PrivateActivity.this, VideoActivity.class);
+            intent.putExtra("videoPath", ugcVideoMessage.getCnUgcMessage().getVideoPath());
+            startActivity(intent);
+        } else {
+            String videoUuid = ugcVideoMessage.getCnUgcMessage().getFileId() + "_video";
+            final String videoPath = FileUtil.getCacheFilePath(videoUuid);
+            if (FileUtil.isCacheFileExist(videoUuid)) {
+                Intent intent = new Intent(PrivateActivity.this, VideoActivity.class);
+                intent.putExtra("videoPath", videoPath);
+                startActivity(intent);
+            } else {
+                ugcVideoMessage.getCnUgcMessage().getVideo().getVideo(videoPath, new IChat.OnDownloadListener() {
+                    @Override
+                    public void onSuccess() {
+                        Intent intent = new Intent(PrivateActivity.this, VideoActivity.class);
+                        intent.putExtra("videoPath", videoPath);
+                        startActivity(intent);
+                    }
+
+                    @Override
+                    public void onError(int i, String s) {
+
+                    }
+                });
+            }
+        }
+    }
+
+    @Override
     public void onImageClick(final ImagMessage imagMessage) {
         if (imagMessage.getCnImgMessage().isSelf()) {
             Intent intent = new Intent(PrivateActivity.this, ImageViewActivity.class);
@@ -10,4 +10,5 @@ public class MessageType {
     public static final String imaMessage = "2";
     public static final String voiceMessage = "3";
     public static final String videoMessage = "4";
+    public static final String ugcVideoMessage = "5";
 }