CNLive Android Team / CNIMDemo · Files

package com.cnlive.im.ui;

import android.Manifest;
import android.app.Activity;
import android.content.Context;
import android.content.Intent;
import android.content.pm.PackageManager;
import android.graphics.Bitmap;
import android.graphics.drawable.AnimationDrawable;
import android.media.ThumbnailUtils;
import android.net.Uri;
import android.os.Build;
import android.os.Bundle;
import android.os.Handler;
import android.provider.MediaStore;
import android.support.annotation.NonNull;
import android.support.v4.app.ActivityCompat;
import android.support.v4.content.ContextCompat;
import android.support.v7.app.AppCompatActivity;
import android.support.v7.widget.LinearLayoutManager;
import android.support.v7.widget.RecyclerView;
import android.text.Editable;
import android.text.TextUtils;
import android.text.TextWatcher;
import android.util.Log;
import android.view.Gravity;
import android.view.MotionEvent;
import android.view.View;
import android.view.inputmethod.InputMethodManager;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ImageView;
import android.widget.LinearLayout;
import android.widget.RelativeLayout;
import android.widget.TextView;
import android.widget.Toast;

import com.cnlive.im.R;
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;
import com.cnlive.im.util.FileUtil;
import com.cnlive.im.util.MediaUtil;
import com.cnlive.im.util.MessageType;
import com.cnlive.im.util.TimeUtils;
import com.cnlive.im.util.UploadImageUtils;
import com.cnlive.libs.util.chat.ChatUtil;
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;

import java.io.File;
import java.io.FileInputStream;
import java.util.ArrayList;


/**
 * @author 陈硕
 * @time 2017/3/7  14:36
 * @desc ${TODD}
 */
public class ChatRoomActivity extends AppCompatActivity implements View.OnClickListener, ItemClickListener {
    private static final String TAG = "ChatRoomActivity";

    private final int CAPTURE_VIDEO_ACTIVITY_REQUEST_CODE = 0x2001;

    private ArrayList<String> msgIds = new ArrayList<>();
    private String roomIdOne = "ChatRoom10";
    private EditText editText;
    private Button send_messageOneBtn;
    private RecyclerView listViewOne;
    private ChatRoomAdpter chatListAdapterOne;
    private Button foundChatBtn;
    private Handler mHandler;
    private RelativeLayout re_chat;
    //    private LinearLayout lin_user;
//    private EditText user_id, user_name;
    private Button exit_chat1;
    public static String user_name_string;
    private boolean isUserLogin = false;
    private ImageView ima_send;
    private Button sendVoice;

    private Context context;
    private AudioRecordUtil mAudioRecordUtil;
    private PopupWindowFactory mPop;
    private ImageView mImageView;
    private TextView mTextView;
    private ImageView keybordBtn;

    private LinearLayout sendMsgLayout;
    private LinearLayout cancelSendLayout;

    private boolean isVoiceBtnVisible = false;


    public static final int IMG_FROM_PICTURE = 0x1001;
    public static final int VOICE = 0x1002;
    public static final int PICTURE_REQUEST_CODE = 0x1003;
    public static final int VOICE_REQUEST_CODE = 0x1004;
    private long l;
    int duration;

    private String mFilePath;

    // 所需的全部权限
    static final String[] PERMISSIONS = new String[]{
            Manifest.permission.RECORD_AUDIO,
            Manifest.permission.WRITE_EXTERNAL_STORAGE
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        //取消状态栏
        setContentView(R.layout.activity_groupchat);
        context = this;
        initUI();
        mAudioRecordUtil = new AudioRecordUtil();
        mAudioRecordUtil.setOnAudioStatusUpdateListener(onAudioStatusUpdateListener);
        //设置监听
        mHandler = new Handler();
        ChatUtil.setOnConnectStatusListener(connectStatusListener);
        ChatUtil.setOnChatRoomActionListener(chatRoomActionListener);
        ChatUtil.setOnReceiveChatroomMessageListener(receiveMessageListener);
        ChatUtil.setUploadProgressListener(uploadProgressListener);
        ChatUtil.setKickedOfflineListener(onKickedOfflineListener);
        Intent intent = getIntent();
        user_name_string = intent.getStringExtra("user_name_string");
        String user_id_string = intent.getStringExtra("user_id_string");
        if (user_name_string != null)
            ChatUtil.login(new CNUserInfo(user_id_string, user_name_string, ""), connectListener);
        else ChatUtil.logOut(connectListener);
        requestPermission();

    }


    private void initUI() {

        final View view = View.inflate(this, R.layout.layout_microphone, null);
        mPop = new PopupWindowFactory(this, view);
        mImageView = (ImageView) view.findViewById(R.id.iv_recording_icon);
        mTextView = (TextView) view.findViewById(R.id.tv_recording_time);
        sendMsgLayout = (LinearLayout) view.findViewById(R.id.send_layout);
        cancelSendLayout = (LinearLayout) view.findViewById(R.id.cancel_send_layout);
        ima_send = (ImageView) findViewById(R.id.ima_send);
        exit_chat1 = (Button) findViewById(R.id.exit_chat1);
//        user_id = (EditText) findViewById(R.id.user_ID);
//        user_name = (EditText) findViewById(R.id.user_name);
//        lin_user = (LinearLayout) findViewById(R.id.lin_user);
        re_chat = (RelativeLayout) findViewById(R.id.re_chat);
        foundChatBtn = (Button) findViewById(R.id.creatChat);
        listViewOne = (RecyclerView) findViewById(R.id.chat_list_viewOne);
        editText = (EditText) findViewById(R.id.message_content);
        editText.addTextChangedListener(textWatcher);
        send_messageOneBtn = (Button) findViewById(R.id.send_messageOne);
        ima_send.setOnClickListener(this);
        exit_chat1.setOnClickListener(this);
        foundChatBtn.setOnClickListener(this);
        send_messageOneBtn.setOnClickListener(this);
        chatListAdapterOne = new ChatRoomAdpter(ChatRoomActivity.this, false);
        chatListAdapterOne.setonVoiceItemClickListener(this);
        listViewOne.setLayoutManager(new LinearLayoutManager(ChatRoomActivity.this));
        listViewOne.setAdapter(chatListAdapterOne);

        sendVoice = (Button) findViewById(R.id.send_voice);
        re_chat = (RelativeLayout) findViewById(R.id.activity_chat_room);
        keybordBtn = (ImageView) findViewById(R.id.keybord);
        keybordBtn.setOnClickListener(this);

        findViewById(R.id.videoBtn).setOnClickListener(this);
        findViewById(R.id.ugcVideoBtn).setOnClickListener(this);


        StartListener();


    }


    /**
     * 发送消息监听
     */
    private IChat.OnSendMessageListener sendMessageListener = new IChat.OnSendMessageListener() {
        @Override
        public void onAttached(CNBaseMessage o) {
            showMessage(o);
        }

        @Override
        public void onSuccess(final CNBaseMessage o) {
            updateItem(o, -1);
        }

        @Override
        public void onError(CNBaseMessage o, int i, String s) {
            updateItem(o, -1);
        }
    };

    //连接状态监听
    private IChat.OnConnectStatusListener connectStatusListener = new IChat.OnConnectStatusListener() {
        @Override
        public void onConnectStatus(int i, String s) {
            Log.i(TAG, "连接状态监听" + i + "   " + s);
        }
    };


    private IChat.OnReceiveMessageListener receiveMessageListener = new IChat.OnReceiveMessageListener() {
        @Override
        public void processMessage(final CNBaseMessage o) {
            if (!o.getTargetId().equals(roomIdOne)) return;
            showMessage(o);
        }
    };

    private IChat.OnUploadProgressListener uploadProgressListener = new IChat.OnUploadProgressListener() {
        @Override
        public void onMessagesUpdate(CNBaseMessage message, int elemIdx, int taskId, int progress) {
            if (!message.getTargetId().equals(roomIdOne)) return;
            updateItem(message, progress);
        }
    };


    /**
     * 更新消息
     */
    public void updateItem(CNBaseMessage o, int progress) {
        int updateIndex = msgIds.indexOf(o.getMessageId());
        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);
        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_IMAGE) {
            CNImgMessage o1 = (CNImgMessage) o;
            chatListAdapterOne.updateItem(new ImagMessage(MessageType.imaMessage, o1, o1.isSelf(), progress < 0 ? 0 : progress), updateIndex);
        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_VOICE) {
            CNVoiceMessage o1 = (CNVoiceMessage) o;
            VoiceMessage voiceMessage = new VoiceMessage(MessageType.voiceMessage, o1, o1.isSelf(), progress < 0 ? 0 : progress);
            chatListAdapterOne.updateItem(voiceMessage, updateIndex);
        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_VIDEO) {
            CNVideoMessage ol = (CNVideoMessage) o;
            VideoMessage videoMessage = new VideoMessage(MessageType.videoMessage, ol, ol.isSelf(), progress < 0 ? 0 : progress);
            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(), progress < 0 ? 0 : progress);
            chatListAdapterOne.updateItem(ugcVideoMessage, updateIndex);
        }
    }

    /**
     * 展示消息
     *
     * @param o
     */
    private void showMessage(CNBaseMessage o) {
        msgIds.add(o.getMessageId());
        if (o.getMsgType() == IChat.CN_MSG_TYPE_TEXT) {
            CNMessage o1 = (CNMessage) o;
            chatListAdapterOne.addItem(new StringMessage(MessageType.stringMessage, o1, o1.isSelf()));
        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_IMAGE) {
            CNImgMessage o1 = (CNImgMessage) o;
            chatListAdapterOne.addItem(new ImagMessage(MessageType.imaMessage, o1, o1.isSelf()));
        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_VOICE) {
            CNVoiceMessage o1 = (CNVoiceMessage) o;
            VoiceMessage voiceMessage = new VoiceMessage(MessageType.voiceMessage, o1, o1.isSelf());
            chatListAdapterOne.addItem(voiceMessage);
        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_VIDEO) {
            CNVideoMessage o1 = (CNVideoMessage) o;
            VideoMessage videoMessage = new VideoMessage(MessageType.videoMessage, o1, o1.isSelf());
            chatListAdapterOne.addItem(videoMessage);
        } else if (o.getMsgType() == IChat.CN_MSG_TYPE_UGC) {
            CNUgcMessage o1 = (CNUgcMessage) o;
            UgcVideoMessage ugcVideoMessage = new UgcVideoMessage(MessageType.ugcVideoMessage, o1, o1.isSelf());
            chatListAdapterOne.addItem(ugcVideoMessage);
        }
        if (chatListAdapterOne.getItemCount() > 0)
            listViewOne.smoothScrollToPosition(chatListAdapterOne.getItemCount() - 1);
    }


    //聊天室操作
    private IChat.OnChatRoomActionListener chatRoomActionListener = new IChat.OnChatRoomActionListener() {
        @Override
        public void onJoining(String s) {
            Log.i(TAG, "chatRoomActionListener" + "   onJoining" + s);
        }

        @Override
        public void onJoined(String s) {
            Log.i(TAG, "chatRoomActionListener     " + "onJoined" + s);
        }

        @Override
        public void onQuited(String s) {
            Log.i(TAG, "chatRoomActionListener     " + "onQuited" + s);
        }

        @Override
        public void onError(String s, int i, String s1) {
            Log.i(TAG, "chatRoomActionListener     " + "onError" + s);

        }
    };

    //被踢下线状态
    private IChat.OnKickedOfflineListener onKickedOfflineListener = new IChat.OnKickedOfflineListener() {
        @Override
        public void disconnected(int what, final String extra) {
            Log.e(TAG, what + " : " + extra);
            mHandler.post(new Runnable() {
                @Override
                public void run() {
                    Toast.makeText(ChatRoomActivity.this, extra, Toast.LENGTH_SHORT).show();
                }
            });
        }

        @Override
        public void conByDevId(final int what, final String extra) {
            Log.e(TAG, what + " : " + extra);
            mHandler.post(new Runnable() {
                @Override
                public void run() {
                    Toast.makeText(ChatRoomActivity.this, extra, Toast.LENGTH_SHORT).show();

                }
            });
        }
    };


    // 加入聊天室监听
    private IChat.OnOperationListener onOperationListener = new IChat.OnOperationListener() {
        @Override
        public void onSuccess(int what, final String extra) {
            Log.v(TAG, +what + extra);


        }

        @Override
        public void onError(int what, String extra) {
            Log.v(TAG, "加入聊天室" + what + extra);

        }
    };

    @Override
    public void onClick(View view) {
        switch (view.getId()) {
            //向聊天室1发送消息
            case R.id.send_messageOne:
                //发送聊天室消息
                if (editText.getText().toString().isEmpty()) {
                    Toast.makeText(this, "不能发送空消息呦~", Toast.LENGTH_SHORT).show();
                } else {
                    ChatUtil.sendMessage(IChat.CHATROOM, roomIdOne, editText.getText().toString(), sendMessageListener);
                    editText.setText("");
                }
                break;
            case R.id.creatChat:
                ChatUtil.joinChatRoom(roomIdOne, -1, onOperationListener);
                break;
            case R.id.exit_chat1:
                ChatUtil.quitChatRoom(roomIdOne, onOperationListener);
                break;
            case R.id.ima_send:
                fromPicture();
                break;
            case R.id.keybord:
                if (!isVoiceBtnVisible) {
                    editText.setVisibility(View.GONE);
                    sendVoice.setVisibility(View.VISIBLE);
                    keybordBtn.setImageResource(R.drawable.keybord);
                    InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
                    imm.hideSoftInputFromWindow(editText.getWindowToken(), 0);
                    isVoiceBtnVisible = true;
                } else {
                    sendVoice.setVisibility(View.GONE);
                    editText.setVisibility(View.VISIBLE);
                    keybordBtn.setImageResource(R.drawable.voice);
                    isVoiceBtnVisible = false;
                }
                break;
            case R.id.videoBtn:
                openSystemRecorder();
                break;
            case R.id.ugcVideoBtn:
                openSystemRecorder();
                break;
        }
    }

    private void openSystemRecorder() {
        // 创建拍照Intent并将控制权返回给调用的程序
        Intent intent = new Intent();
        intent.setAction(MediaStore.ACTION_VIDEO_CAPTURE);
        intent.addCategory(Intent.CATEGORY_DEFAULT);

        // 保存录像到指定的路径
        File file = new File("/sdcard/video.mp4");
        Uri uri = Uri.fromFile(file);
        intent.putExtra(MediaStore.EXTRA_OUTPUT, uri);

        // 启动图像捕获Intent
        startActivityForResult(intent, CAPTURE_VIDEO_ACTIVITY_REQUEST_CODE);
    }


    public void fromPicture() {
        if (Build.VERSION.SDK_INT >= 23) {
            int checkCallPhonePermission = ContextCompat.checkSelfPermission(ChatRoomActivity.this, Manifest.permission.WRITE_EXTERNAL_STORAGE);
            if (checkCallPhonePermission != PackageManager.PERMISSION_GRANTED) {
                requestPermissions(new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE}, PICTURE_REQUEST_CODE);
                return;
            } else {
                toIntentPicture();
            }
        } else {
            toIntentPicture();
        }
    }


    private void toIntentPicture() {
        Intent intent = new Intent();
        intent.setType("image/*");
        intent.setAction(Intent.ACTION_PICK);
        startActivityForResult(Intent.createChooser(intent, "Complete action using"), IMG_FROM_PICTURE);
    }


    @Override
    public void onActivityResult(int requestCode, int resultCode, Intent data) {
        super.onActivityResult(requestCode, resultCode, data);
        if (resultCode == Activity.RESULT_OK) {
            switch (requestCode) {
                case IMG_FROM_PICTURE:
                    Uri selectedImage = data.getData();
                    String picturePath = UploadImageUtils.getPath(this, selectedImage);
                    Uri uri = Uri.parse("file://" + picturePath);
                    ChatUtil.sendImaMessage(IChat.CHATROOM, roomIdOne, uri, uri, sendMessageListener);
                    break;
                case CAPTURE_VIDEO_ACTIVITY_REQUEST_CODE:
                    String videoPath = data.getData().getPath();
                    Bitmap bitmap = ThumbnailUtils.createVideoThumbnail(videoPath, MediaStore.Images.Thumbnails.FULL_SCREEN_KIND);
                    String imgPath = FileUtil.createFile(bitmap, System.currentTimeMillis() + "");
                    ChatUtil.sendVideoMessage(IChat.CHATROOM, roomIdOne, videoPath, imgPath, MediaUtil.getInstance().getDuration(videoPath), sendMessageListener);
                    break;
                default:
                    break;
            }
        }
    }


    private IChat.OnConnectListener connectListener = new IChat.OnConnectListener() {


        @Override
        public void onTokenIncorrect(String s) {
            Log.e(TAG, "ConnectListener TokenIncorrect");

        }

        @Override
        public void onSuccess(final String s) {
            Log.e(TAG, "ConnectListener 连接监听" + s);

        }

        @Override
        public void onError(int i, final String s) {
            Log.e(TAG, "ConnectListener errorCode : " + i + " : errorMessage : " + s);


        }
    };

    /**
     * 播放语音文件
     *
     * @param voicePath
     * @param animationDrawable
     */
    private void startVoice(String voicePath, final AnimationDrawable animationDrawable) {
        try {
            FileInputStream fis = new FileInputStream(voicePath);
            MediaUtil.getInstance().play(fis);
            animationDrawable.start();
            MediaUtil.getInstance().setEventListener(new MediaUtil.EventListener() {
                @Override
                public void onStop() {
                    animationDrawable.stop();
                    animationDrawable.selectDrawable(0);
                }
            });
        } catch (Exception e) {
        }
    }

    @Override
    public void onItemClick(final VoiceMessage voiceMessage, final AnimationDrawable animationDrawable) {
        if (voiceMessage == null) {
            Toast.makeText(this, "数据异常", Toast.LENGTH_LONG).show();
            return;
        }
        if (voiceMessage.getCnVoiceMessage().isSelf()) {
            startVoice(voiceMessage.getCnVoiceMessage().getVoiceUri().getPath(), animationDrawable);
        } else {
            //设置本地已读
            voiceMessage.getCnVoiceMessage().setRead(true);
            String voiceUuid = voiceMessage.getCnVoiceMessage().getUuid();
            final String voicePath = FileUtil.getCacheFilePath(voiceUuid);
            if (FileUtil.isCacheFileExist(voiceUuid)) {
                File file = new File(voicePath);
                if (file.length() < voiceMessage.getCnVoiceMessage().getDataSize()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                    return;
                }
                startVoice(voicePath, animationDrawable);
            } else {
                if (voiceMessage.isDownloading()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                } else {
                    voiceMessage.setDownloading(true);
                    voiceMessage.getCnVoiceMessage().getVoice(voicePath, new IChat.OnDownloadListener() {
                        @Override
                        public void onSuccess() {
                            voiceMessage.setDownloading(false);
                            startVoice(voicePath, animationDrawable);
                        }

                        @Override
                        public void onError(int i, String s) {
                            voiceMessage.setDownloading(false);
                        }
                    });
                }
            }
        }
    }

    @Override
    public void onVideoClick(final VideoMessage videoMessage) {
        if (videoMessage.getCnVideoMessage().isSelf()) {
            Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
            intent.putExtra("videoPath", videoMessage.getCnVideoMessage().getVideoPath());
            startActivity(intent);
        } else {
            String videoUuid = videoMessage.getCnVideoMessage().getVideo().getUuid();
            final String videoPath = FileUtil.getCacheFilePath(videoUuid);
            if (FileUtil.isCacheFileExist(videoUuid)) {
                File file = new File(videoPath);
                if (file.length() < videoMessage.getCnVideoMessage().getVideo().getSize()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                    return;
                }
                Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
                intent.putExtra("videoPath", videoPath);
                startActivity(intent);
            } else {
                if (videoMessage.isDownloading()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                } else {
                    videoMessage.setDownloading(true);
                    videoMessage.getCnVideoMessage().getVideo().getVideo(videoPath, new IChat.OnDownloadListener() {
                        @Override
                        public void onSuccess() {
                            videoMessage.setDownloading(false);
                            Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
                            intent.putExtra("videoPath", videoPath);
                            startActivity(intent);
                        }

                        @Override
                        public void onError(int i, String s) {
                            videoMessage.setDownloading(false);
                        }
                    });
                }
            }
        }

    }

    @Override
    public void onUgcVideoClick(final 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)) {
                File file = new File(videoPath);
                if (file.length() < ugcVideoMessage.getCnUgcMessage().getVideo().getSize()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                    return;
                }
                Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
                intent.putExtra("videoPath", videoPath);
                startActivity(intent);
            } else {
                if (ugcVideoMessage.isDownloading()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                } else {
                    ugcVideoMessage.setDownloading(true);
                    ugcVideoMessage.getCnUgcMessage().getVideo().getVideo(videoPath, new IChat.OnDownloadListener() {
                        @Override
                        public void onSuccess() {
                            ugcVideoMessage.setDownloading(false);
                            Intent intent = new Intent(ChatRoomActivity.this, VideoActivity.class);
                            intent.putExtra("videoPath", videoPath);
                            startActivity(intent);
                        }

                        @Override
                        public void onError(int i, String s) {
                            ugcVideoMessage.setDownloading(false);
                        }
                    });
                }
            }
        }
    }

    @Override
    public void onImageClick(final ImagMessage imagMessage) {
        if (imagMessage.getCnImgMessage().isSelf()) {
            Intent intent = new Intent(ChatRoomActivity.this, ImageViewActivity.class);
            intent.putExtra("path", imagMessage.getCnImgMessage().getImagePath());
            startActivity(intent);
        } else {
            String remoteUuid = imagMessage.getCnImgMessage().getRemoteUuid();
            final String imagePath = FileUtil.getCacheFilePath(remoteUuid);
            if (FileUtil.isCacheFileExist(remoteUuid)) {
                File file = new File(imagePath);
                if (file.length() < imagMessage.getCnImgMessage().getRemoteSize()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                    return;
                }
                Intent intent = new Intent(ChatRoomActivity.this, ImageViewActivity.class);
                intent.putExtra("path", imagePath);
                startActivity(intent);
            } else {
                if (imagMessage.isDownloading()) {
                    Toast.makeText(context, "请稍等，正在下载...", Toast.LENGTH_SHORT).show();
                } else {
                    imagMessage.setDownloading(true);
                    imagMessage.getCnImgMessage().getRemoteImage(imagePath, new IChat.OnDownloadListener() {
                        @Override
                        public void onSuccess() {
                            imagMessage.setDownloading(false);
                            Intent intent = new Intent(ChatRoomActivity.this, ImageViewActivity.class);
                            intent.putExtra("path", imagePath);
                            startActivity(intent);
                        }

                        @Override
                        public void onError(int i, String s) {
                            imagMessage.setDownloading(false);
                            Toast.makeText(context, "下载失败", Toast.LENGTH_SHORT).show();
                        }
                    });
                }
            }
        }
    }


    /**************************************************************************/

    /**
     * 开启扫描之前判断权限是否打开
     */
    private void requestPermission() {
        //判断是否开启摄像头权限
        if ((ContextCompat.checkSelfPermission(context,
                Manifest.permission.WRITE_EXTERNAL_STORAGE) == PackageManager.PERMISSION_GRANTED) &&
                (ContextCompat.checkSelfPermission(context,
                        Manifest.permission.RECORD_AUDIO) == PackageManager.PERMISSION_GRANTED)
                && (ContextCompat.checkSelfPermission(context,
                Manifest.permission.CAMERA) == PackageManager.PERMISSION_GRANTED)) {
            StartListener();

            //判断是否开启语音权限
        } else {
            //请求获取摄像头权限
            ActivityCompat.requestPermissions((Activity) context,
                    new String[]{Manifest.permission.WRITE_EXTERNAL_STORAGE, Manifest.permission.RECORD_AUDIO, Manifest.permission.CAMERA}, VOICE_REQUEST_CODE);
        }
    }

    @Override
    public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) {
        super.onRequestPermissionsResult(requestCode, permissions, grantResults);
        if (requestCode == VOICE_REQUEST_CODE) {
            if ((grantResults[0] == PackageManager.PERMISSION_GRANTED) && (grantResults[1] == PackageManager.PERMISSION_GRANTED)) {
                StartListener();
            } else {
                Toast.makeText(context, "已拒绝权限！", Toast.LENGTH_SHORT).show();
            }
        }
    }

    float downX;
    float downY;

    public void StartListener() {

        //Button的touch监听
        sendVoice.setOnTouchListener(new View.OnTouchListener() {
            @Override
            public boolean onTouch(View v, MotionEvent event) {
                if (lacksPermissions(PERMISSIONS)) {
                    if (lacksPermission(PERMISSIONS[0])) {
                        Toast.makeText(ChatRoomActivity.this, "没有麦克风权限，请前往“设置 - 应用 - 权限”中开启权限", Toast.LENGTH_SHORT).show();

                    } else if (lacksPermission(PERMISSIONS[1])) {
                        Toast.makeText(ChatRoomActivity.this, "没有文件读写权限，请前往“设置 - 应用 - 权限”中开启权限", Toast.LENGTH_SHORT).show();

                    }
                } else {

                    switch (event.getAction()) {

                        case MotionEvent.ACTION_DOWN:
                            mPop.showAtLocation(re_chat, Gravity.CENTER, 0, 0);

                            sendVoice.setText("松开发送");
                            mAudioRecordUtil.startRecord();
                            downX = event.getX();
                            downY = event.getY();

                            break;

                        case MotionEvent.ACTION_UP:

                            if (cancelSendLayout.getVisibility() == View.VISIBLE) {
                                cancelSendLayout.setVisibility(View.GONE);
                                sendMsgLayout.setVisibility(View.VISIBLE);
                            }
                            float moveX = Math.abs(event.getX() - downX);
                            float moveY = Math.abs(event.getY() - downY);
                            if (moveY > 100) {
//                                Toast.makeText(ChatRoomActivity.this, "cancel", Toast.LENGTH_SHORT).show();
                                mAudioRecordUtil.cancelRecord();
                            } else {
                                mAudioRecordUtil.stopRecord();        //结束录音（保存录音文件）
                            }
                            mPop.dismiss();
                            mTextView.setText("00:00");
                            sendVoice.setText("按住说话");
                            break;
                        case MotionEvent.ACTION_MOVE:
                            float moveXm = Math.abs(event.getX() - downX);
                            float moveYm = Math.abs(event.getY() - downY);
                            if (moveYm > 100) {
//                                Toast.makeText(ChatRoomActivity.this, "cancel", Toast.LENGTH_SHORT).show();
                                if (sendMsgLayout.getVisibility() == View.VISIBLE) {
                                    sendMsgLayout.setVisibility(View.GONE);
                                    cancelSendLayout.setVisibility(View.VISIBLE);
                                }
                            } else {
                                if (cancelSendLayout.getVisibility() == View.VISIBLE) {
                                    cancelSendLayout.setVisibility(View.GONE);
                                    sendMsgLayout.setVisibility(View.VISIBLE);
                                }
                            }
                            break;
                    }
                }
                return true;
            }
        });

    }

    // 判断权限集合
    public boolean lacksPermissions(String... permissions) {
        for (String permission : permissions) {
            if (lacksPermission(permission)) {
                return true;
            }
        }
        return false;
    }

    // 判断是否缺少权限
    private boolean lacksPermission(String permission) {
        return ContextCompat.checkSelfPermission(this, permission) == PackageManager.PERMISSION_DENIED;
    }

    private AudioRecordUtil.OnAudioStatusUpdateListener onAudioStatusUpdateListener = new AudioRecordUtil.OnAudioStatusUpdateListener() {
        @Override
        public void onUpdate(double db, long time) {
            mImageView.getDrawable().setLevel((int) (3000 + 6000 * db / 100));
            mTextView.setText(TimeUtils.long2String(time));
        }

        @Override
        public void onStop(String filePath) {
            duration = (int) mAudioRecordUtil.getDuration();
            mFilePath = filePath;
            ChatUtil.sendVoiceMessage(IChat.CHATROOM, roomIdOne, Uri.parse(mFilePath), duration, sendMessageListener);
        }
    };

    private TextWatcher textWatcher = new TextWatcher() {
        @Override
        public void beforeTextChanged(CharSequence charSequence, int i, int i1, int i2) {
        }

        @Override
        public void onTextChanged(CharSequence charSequence, int i, int i1, int i2) {

        }

        @Override
        public void afterTextChanged(Editable editable) {
            if (!TextUtils.isEmpty(editable)) {
                ima_send.setVisibility(View.GONE);
                send_messageOneBtn.setVisibility(View.VISIBLE);
            } else {
                send_messageOneBtn.setVisibility(View.GONE);
                ima_send.setVisibility(View.VISIBLE);
            }
        }
    };

    @Override
    protected void onPause() {
        super.onPause();
        MediaUtil.getInstance().stop();
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        ChatUtil.removeUploadProgressListener(uploadProgressListener);
        ChatUtil.removeReceiveMessageListener(receiveMessageListener);
        ChatUtil.removeConnectListener(connectListener);
        ChatUtil.removeConnectStatusListener(connectStatusListener);
    }

}