package com.lomocoin.imlib; import java.util.ArrayList; import java.util.List; import com.facebook.react.bridge.ReactContextBaseJavaModule; import com.facebook.react.bridge.ReactApplicationContext; import com.facebook.react.bridge.ReactMethod; import com.facebook.react.bridge.Promise; import android.Manifest; import android.app.Activity; import android.app.ActivityManager; import android.app.Notification; import android.app.NotificationManager; import android.app.PendingIntent; import android.content.Context; import android.content.Intent; import android.content.pm.PackageManager; import android.net.Uri; import android.os.Build; import android.support.annotation.Nullable; import com.facebook.react.bridge.ReadableArray; import com.facebook.react.bridge.ReadableMap; import com.facebook.react.bridge.UiThreadUtil; import com.facebook.react.bridge.WritableArray; import com.facebook.react.bridge.WritableMap; import com.facebook.react.bridge.Arguments; import com.facebook.react.modules.core.DeviceEventManagerModule; import com.google.firebase.iid.FirebaseInstanceId; import android.support.v4.app.ActivityCompat; import android.support.v4.content.ContextCompat; import android.text.TextUtils; import android.util.Log; import io.rong.imlib.IRongCallback; import io.rong.imlib.RongCommonDefine; import io.rong.imlib.RongIMClient; import io.rong.imlib.RongIMClient.ResultCallback; import io.rong.imlib.model.Conversation; import io.rong.imlib.model.Conversation.ConversationType; import io.rong.imlib.model.Discussion; import io.rong.imlib.model.Message; import io.rong.imlib.model.MessageContent; import io.rong.imlib.model.SearchConversationResult; import io.rong.message.ImageMessage; import io.rong.message.RecallNotificationMessage; import io.rong.message.RichContentMessage; import io.rong.message.TextMessage; import io.rong.message.VoiceMessage; import io.rong.push.RongPushClient; import io.rong.push.common.RongException; /** * 融云原生功能模块 * * @author qiaojiayan * @date 17/8/2 下午5:34 */ public class RongCloudIMLibModule extends ReactContextBaseJavaModule { protected ReactApplicationContext context; private AudioRecoderUtils recoderUtils; private String AtargId = ""; private String aPushContent = ""; private String aPushData = ""; private Promise Apromise = null; private int Atype = 0; private String extra = ""; public void addAudioListener() { if (recoderUtils == null) { recoderUtils = new AudioRecoderUtils(); } recoderUtils.setOnAudioStatusUpdateListener(new AudioRecoderUtils.OnAudioStatusUpdateListener() { @Override public void onUpdate(double db, long time) { } @Override public void onStop(String filePath, long time) { sendVoiceMsg(filePath, time); } }); } /** * 发送语音消息 * * @param filePath 文件路径 * @param time 单位毫秒 */ public void sendVoiceMsg(String filePath, long time) { try { // if (time < 1000) { Apromise.reject("-500", "-500"); } else { int duration = (int) Math.ceil(time / 1000); sendVoiceMessage(Atype, AtargId, filePath, duration, aPushContent, aPushData, extra, Apromise); } } catch (Exception e) { } } /** * @param reactContext */ public RongCloudIMLibModule(ReactApplicationContext reactContext) { super(reactContext); context = reactContext; } @Override public String getName() { return "RongCloudIMLibModule"; } @ReactMethod public void initWithAppKey(String appKey) { // Log.e("isme", "rong init appkey:" + appKey); try { RongPushClient.registerFCM(context); String appId = FirebaseInstanceId.getInstance().getToken(); // FirebaseMessaging.getInstance().subscribeToTopic("testTopic"); // Log.e("isme", "token:" + appId); } catch (RongException e) { // e.printStackTrace(); } RongIMClient.init(context, appKey); } @ReactMethod public void logout(final Promise promise) { try { RongIMClient.getInstance().logout(); promise.resolve("success"); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void disconnect(boolean isReceivePush, final Promise promise) { try { RongIMClient.getInstance().disconnect(isReceivePush); promise.resolve("success"); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void connectWithToken(String token, final Promise promise) { final RongCloudIMLibModule instance = this; RongIMClient.setOnRecallMessageListener(new RongIMClient.OnRecallMessageListener() { @Override public boolean onMessageRecalled(Message message, RecallNotificationMessage recallNotificationMessage) { try { WritableMap map = Arguments.createMap(); map.putInt("messageId", message.getMessageId()); instance.sendEvent("onMessageRecalled", map); return true; } catch (Exception e) { } return false; } }); RongIMClient.setOnReceiveMessageListener(new RongIMClient.OnReceiveMessageListener() { @Override public boolean onReceived(final Message message, int i) { try { WritableMap map = Arguments.createMap(); WritableMap msg = instance.formatMessage(message); map.putMap("message", msg); map.putString("left", "0"); map.putString("errcode", "0"); instance.sendEvent("onRongMessageReceived", map); return true; } catch (Exception e) { } //考虑是否需要发送推送到通知栏 UiThreadUtil.runOnUiThread(new Runnable() { @Override public void run() { try { Activity activity = getCurrentActivity(); // if (isBackground(activity)) { //关闭 按home键后的消息提醒 if (false) { Uri.Builder builder = Uri.parse("rong://" + activity.getPackageName()).buildUpon(); builder.appendPath("conversation").appendPath("lomostar") .appendQueryParameter("targetId", message.getTargetId()) .appendQueryParameter("title", ""); Uri uri = builder.build(); Intent intent = context.getPackageManager().getLaunchIntentForPackage(activity.getPackageName()); intent.setData(uri); String title = "LoMoStar"; String tickerText = context.getResources().getString(context.getResources().getIdentifier("rc_notification_ticker_text", "string", context.getPackageName())); PendingIntent intent1 = PendingIntent.getActivity(context, 300, intent, PendingIntent.FLAG_UPDATE_CURRENT); Notification notification = NotificationUtil.createNotification(activity, title, intent1, tickerText); NotificationManager nm = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE); if (notification != null) { nm.notify(2000, notification); } } } catch (Exception e) { Log.e("isme", "考虑是否需要发送推送到通知栏 error"); } } }); return false; } }); RongIMClient.connect(token, new RongIMClient.ConnectCallback() { /** * Token 错误，在线上环境下主要是因为 Token 已经过期，您需要向 App Server 重新请求一个新的 Token */ @Override public void onTokenIncorrect() { Log.e("isme", "rong connect onTokenIncorrect"); promise.reject("-1", "tokenIncorrect"); } /** * 连接融云成功 * @param userid 当前 token */ @Override public void onSuccess(String userid) { Log.e("isme", "rong connect onSuccess"); WritableMap map = Arguments.createMap(); map.putString("userid", userid); promise.resolve(map); } /** * 连接融云失败 * @param errorCode 错误码，可到官网 查看错误码对应的注释 */ @Override public void onError(RongIMClient.ErrorCode errorCode) { Log.e("isme", "连接融云失败 code:" + errorCode.getValue()); promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } private boolean isBackground(Context context) { ActivityManager activityManager = (ActivityManager) context.getSystemService(Context.ACTIVITY_SERVICE); List appProcesses = activityManager.getRunningAppProcesses(); for (ActivityManager.RunningAppProcessInfo appProcess : appProcesses) { if (appProcess.processName.equals(context.getPackageName())) { if (appProcess.importance == ActivityManager.RunningAppProcessInfo.IMPORTANCE_BACKGROUND) { Log.i("isme", "后台"); return true; } else { Log.i("isme", "前台"); return false; } } } return false; } @ReactMethod public void getLatestMessages(int mType, String targetId, int count, final Promise promise) { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getLatestMessages(type, targetId, count, new ResultCallback>() { @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } @Override public void onSuccess(List messages) { WritableArray data = Arguments.createArray(); if (messages != null && !messages.isEmpty()) { for (int i = 0; i < messages.size(); i++) { Message message = messages.get(i); WritableMap item = formatMessage(message); data.pushMap(item); } } promise.resolve(data); } }); } @ReactMethod public void getHistoryMessages(int mType, String targetId, int oldestMessageId, int count, final Promise promise) { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getHistoryMessages(type, targetId, oldestMessageId, count, new ResultCallback>() { @Override public void onSuccess(List messages) { WritableArray data = Arguments.createArray(); if (messages != null && !messages.isEmpty()) { for (int i = 0; i < messages.size(); i++) { Message message = messages.get(i); WritableMap item = formatMessage(message); data.pushMap(item); } } promise.resolve(data); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } @ReactMethod public void getDesignatedTypeHistoryMessages(int mType, String targetId, String objectName, int oldestMessageId, int count, final Promise promise) { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getHistoryMessages(type, targetId, objectName, oldestMessageId, count, new ResultCallback>() { @Override public void onSuccess(List messages) { WritableArray data = Arguments.createArray(); if (messages != null && !messages.isEmpty()) { for (int i = 0; i < messages.size(); i++) { Message message = messages.get(i); WritableMap item = formatMessage(message); data.pushMap(item); } } promise.resolve(data); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } @ReactMethod public void getDesignatedDirectionypeHistoryMessages(int mType, String targetId, String objectName, int baseMessageId, int count, int direction, final Promise promise) { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getHistoryMessages(type, targetId, objectName, baseMessageId, count, getMessageDirection(direction), new ResultCallback>() { @Override public void onSuccess(List messages) { WritableArray data = Arguments.createArray(); if (messages != null && !messages.isEmpty()) { for (int i = 0; i < messages.size(); i++) { Message message = messages.get(i); WritableMap item = formatMessage(message); data.pushMap(item); } } promise.resolve(data); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } @ReactMethod public void getBaseOnSentTimeHistoryMessages(int mType, String targetId, long sentTime, int before, int after, final Promise promise) { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getHistoryMessages(type, targetId, sentTime, before, after, new ResultCallback>() { @Override public void onSuccess(List messages) { WritableArray data = Arguments.createArray(); if (messages != null && !messages.isEmpty()) { for (int i = 0; i < messages.size(); i++) { Message message = messages.get(i); WritableMap item = formatMessage(message); data.pushMap(item); } } promise.resolve(data); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } /** * 搜索会话 * * @param keyWord 关键词 * @param promise */ @ReactMethod public void searchConversations(String keyWord, final Promise promise) { ConversationType[] type = {formatConversationType(1), formatConversationType(3)}; String[] objName = {"RC:TxtMsg"}; RongIMClient.getInstance().searchConversations(keyWord, type, objName, new ResultCallback>() { @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } @Override public void onSuccess(List messages) { WritableArray data = Arguments.createArray(); if (messages != null && !messages.isEmpty()) { for (int i = 0; i < messages.size(); i++) { WritableMap msg = Arguments.createMap(); SearchConversationResult item = messages.get(i); Conversation conversation = item.getConversation(); msg.putInt("conversationType", conversation.getConversationType().getValue()); msg.putString("targetId", conversation.getTargetId()); msg.putString("conversationTitle", conversation.getConversationTitle()); msg.putInt("unreadMessageCount", conversation.getUnreadMessageCount()); msg.putString("receivedTime", conversation.getReceivedTime() + ""); msg.putString("sentTime", conversation.getSentTime() + ""); msg.putString("senderUserId", conversation.getSenderUserId()); msg.putInt("lastestMessageId", conversation.getLatestMessageId()); msg.putString("lastestMessageDirection", ""); msg.putBoolean("isTop", conversation.isTop()); msg.putInt("receivedStatus", conversation.getReceivedStatus().getFlag()); msg.putInt("sentStatus", conversation.getSentStatus().getValue()); msg.putString("draft", conversation.getDraft()); msg.putString("objectName", conversation.getObjectName()); msg.putBoolean("hasUnreadMentioned", conversation.getMentionedCount() > 0); MessageContent message = conversation.getLatestMessage(); if (message instanceof TextMessage) { TextMessage mMsg = (TextMessage) message; msg.putString("msgType", "text"); msg.putString("lastestMessage", mMsg.getContent()); msg.putString("extra", mMsg.getExtra()); } else if (message instanceof RichContentMessage) { RichContentMessage mMsg = (RichContentMessage) message; msg.putString("msgType", "image"); msg.putString("extra", mMsg.getExtra()); msg.putString("imageUrl", mMsg.getImgUrl()); } else if (message instanceof ImageMessage) { ImageMessage mMsg = (ImageMessage) message; msg.putString("msgType", "image"); msg.putString("extra", mMsg.getExtra()); if (mMsg != null && mMsg.getRemoteUri() != null) { msg.putString("imageUrl", mMsg.getRemoteUri().toString()); } else { msg.putString("imageUrl", ""); } } else if (message instanceof VoiceMessage) { VoiceMessage mMsg = (VoiceMessage) message; msg.putString("msgType", "voice"); msg.putString("extra", mMsg.getExtra()); msg.putInt("duration", mMsg.getDuration()); } else if (message instanceof RecallNotificationMessage) { RecallNotificationMessage recallNotificationMessage = (RecallNotificationMessage) message; msg.putString("type", "recall"); msg.putString("operatorId", recallNotificationMessage.getOperatorId()); msg.putString("recallTime", recallNotificationMessage.getRecallTime() + ""); msg.putString("originalObjectName", recallNotificationMessage.getOriginalObjectName()); } data.pushMap(msg); } } promise.resolve(data); } }); } /** * 获取会话列表 * * @param promise */ @ReactMethod public void getConversationList(final Promise promise) { ConversationType[] type = {formatConversationType(1), formatConversationType(3)}; RongIMClient.getInstance().getConversationList(new ResultCallback>() { @Override public void onSuccess(List conversations) { WritableArray data = Arguments.createArray(); if (conversations != null && !conversations.isEmpty()) { for (int i = 0; i < conversations.size(); i++) { Conversation conversation = conversations.get(i); WritableMap msg = Arguments.createMap(); msg.putInt("conversationType", conversation.getConversationType().getValue()); msg.putString("targetId", conversation.getTargetId()); msg.putString("conversationTitle", conversation.getConversationTitle()); msg.putInt("unreadMessageCount", conversation.getUnreadMessageCount()); msg.putString("receivedTime", conversation.getReceivedTime() + ""); msg.putString("sentTime", conversation.getSentTime() + ""); msg.putString("senderUserId", conversation.getSenderUserId()); msg.putInt("lastestMessageId", conversation.getLatestMessageId()); msg.putString("lastestMessageDirection", ""); msg.putBoolean("isTop", conversation.isTop()); msg.putInt("receivedStatus", conversation.getReceivedStatus().getFlag()); msg.putInt("sentStatus", conversation.getSentStatus().getValue()); msg.putString("draft", conversation.getDraft()); msg.putString("objectName", conversation.getObjectName()); msg.putBoolean("hasUnreadMentioned", conversation.getMentionedCount() > 0); MessageContent message = conversation.getLatestMessage(); if (message instanceof TextMessage) { TextMessage mMsg = (TextMessage) message; msg.putString("msgType", "text"); msg.putString("lastestMessage", mMsg.getContent()); msg.putString("extra", mMsg.getExtra()); } else if (message instanceof RichContentMessage) { RichContentMessage mMsg = (RichContentMessage) message; msg.putString("msgType", "image"); msg.putString("extra", mMsg.getExtra()); msg.putString("imageUrl", mMsg.getImgUrl()); } else if (message instanceof ImageMessage) { ImageMessage mMsg = (ImageMessage) message; msg.putString("msgType", "image"); msg.putString("extra", mMsg.getExtra()); if (mMsg != null && mMsg.getRemoteUri() != null) { msg.putString("imageUrl", mMsg.getRemoteUri().toString()); } else { msg.putString("imageUrl", ""); } } else if (message instanceof VoiceMessage) { VoiceMessage mMsg = (VoiceMessage) message; msg.putString("msgType", "voice"); msg.putString("extra", mMsg.getExtra()); msg.putInt("duration", mMsg.getDuration()); } else if (message instanceof RecallNotificationMessage) { RecallNotificationMessage recallNotificationMessage = (RecallNotificationMessage) message; msg.putString("type", "recall"); msg.putString("operatorId", recallNotificationMessage.getOperatorId()); msg.putString("recallTime", recallNotificationMessage.getRecallTime() + ""); msg.putString("originalObjectName", recallNotificationMessage.getOriginalObjectName()); } data.pushMap(msg); } } promise.resolve(data); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }, type); } /** * 发送文字消息 * * @param mType 类型 * @param targetId id * @param content 内容 * @param pushContent 推送通知内容 * @param pushData 推送data * @param extra 附加信息 * @param promise */ @ReactMethod public void sendTextMessage(int mType, String targetId, String content, String pushContent, String pushData, String extra, final Promise promise) { TextMessage textMessage = TextMessage.obtain(content); textMessage.setExtra(extra); ConversationType type = formatConversationType(mType); RongIMClient.getInstance().sendMessage(type, targetId, textMessage, pushContent, pushData, new IRongCallback.ISendMessageCallback() { @Override public void onAttached(Message message) { } @Override public void onSuccess(Message message) { promise.resolve(message.getMessageId() + ""); } @Override public void onError(Message message, RongIMClient.ErrorCode errorCode) { promise.reject(message.getMessageId() + "", errorCode.getValue() + ""); } }); } @ReactMethod public void sendImageMessage(int mType, String targetId, String imageUrl, String pushContent, String pushData, String extra, final Promise promise) { try { // 图片处理 容易出现异常闪退 imageUrl = ImgCompressUtils.compress(context, imageUrl);//压缩图片处理 if (imageUrl.startsWith("content")) { imageUrl = "file://" + BitmapUtils.getRealFilePath(context, Uri.parse(imageUrl)); } else { imageUrl = "file://" + imageUrl; } ConversationType type = formatConversationType(mType); Uri uri = Uri.parse(imageUrl); ImageMessage imageMessage = ImageMessage.obtain(uri, uri, true); imageMessage.setExtra(extra); RongIMClient.getInstance().sendImageMessage(type, targetId, imageMessage, pushContent, pushData, new RongIMClient.SendImageMessageCallback() { @Override public void onAttached(Message message) { } @Override public void onError(Message message, RongIMClient.ErrorCode errorCode) { promise.reject(message.getMessageId() + "", errorCode.getValue() + ""); } @Override public void onSuccess(Message message) { promise.resolve(message.getMessageId() + ""); } @Override public void onProgress(Message message, int i) { } }); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void sendVoiceMessage(int mType, String targetId, String voiceData, int duration, String pushContent, String pushData, String extra, final Promise promise) { VoiceMessage voiceMessage = VoiceMessage.obtain(Uri.parse(voiceData), duration); voiceMessage.setExtra(extra); ConversationType type = formatConversationType(mType); RongIMClient.getInstance().sendMessage(type, targetId, voiceMessage, pushContent, pushData, new IRongCallback.ISendMessageCallback() { @Override public void onAttached(Message message) { } @Override public void onSuccess(Message message) { promise.resolve(message.getMessageId() + ""); } @Override public void onError(Message message, RongIMClient.ErrorCode errorCode) { promise.reject(message.getMessageId() + "", errorCode.getValue() + ""); } }); } //开始播放 @ReactMethod public void audioPlayStart(String filePath, Promise promise) { try { AudioPlayUtils.start(filePath); promise.resolve("success"); } catch (Exception e) { promise.reject("error", "error"); } } //停止播放 @ReactMethod public void audioPlayStop(Promise promise) { try { AudioPlayUtils.stop(); promise.resolve("success"); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void clearUnreadMessage(int mType, String targetId, Promise promise) { try { ConversationType type = formatConversationType(mType); boolean is = RongIMClient.getInstance().clearMessagesUnreadStatus(type, targetId); promise.resolve(is); } catch (Exception e) { promise.reject("error", "error"); } } //停止播放 @ReactMethod public void getFCMToken(Promise promise) { try { String appId = FirebaseInstanceId.getInstance().getToken(); if (!TextUtils.isEmpty(appId)) { promise.resolve(appId); } else { promise.reject("error", "error"); } } catch (Exception e) { promise.reject("error", "error"); } } /** * @param message * @return */ protected WritableMap formatMessage(Message message) { WritableMap msg = Arguments.createMap(); msg.putInt("conversationType", message.getConversationType().getValue()); msg.putString("targetId", message.getTargetId()); msg.putString("messageId", message.getMessageId() + ""); msg.putString("receivedTime", message.getReceivedTime() + ""); msg.putString("sentTime", message.getSentTime() + ""); msg.putString("senderUserId", message.getSenderUserId()); msg.putString("messageUId", message.getUId()); msg.putInt("messageDirection", message.getMessageDirection().getValue()); msg.putInt("receivedStatus", message.getReceivedStatus().getFlag()); msg.putInt("sentStatus", message.getSentStatus().getValue()); msg.putString("objectName", message.getObjectName()); if (message.getContent() instanceof TextMessage) { TextMessage textMessage = (TextMessage) message.getContent(); msg.putString("type", "text"); msg.putString("content", textMessage.getContent()); msg.putString("extra", textMessage.getExtra()); if (textMessage.getMentionedInfo() != null) { msg.putString("mentionedContent", textMessage.getMentionedInfo().getMentionedContent()); WritableArray array = Arguments.createArray(); String currentId = RongIMClient.getInstance().getCurrentUserId(); boolean isMentionedMe = false; if (textMessage.getMentionedInfo().getMentionedUserIdList() != null && textMessage.getMentionedInfo().getMentionedUserIdList().size() > 0) { for (String id : textMessage.getMentionedInfo().getMentionedUserIdList()) { array.pushString(id); if (id.equals(currentId)) { isMentionedMe = true; } } } else { isMentionedMe = true; } msg.putArray("userIdList", array); msg.putInt("mentionedType", textMessage.getMentionedInfo().getType().getValue()); msg.putBoolean("isMentionedMe", isMentionedMe); } } else if (message.getContent() instanceof ImageMessage) { ImageMessage richContentMessage = (ImageMessage) message.getContent(); msg.putString("type", "image"); if (richContentMessage != null && richContentMessage.getRemoteUri() != null) { msg.putString("imageUrl", richContentMessage.getRemoteUri().toString()); } else { msg.putString("imageUrl", ""); } msg.putString("extra", richContentMessage.getExtra()); } else if (message.getContent() instanceof VoiceMessage) { VoiceMessage voiceMessage = (VoiceMessage) message.getContent(); msg.putString("type", "voice"); if (voiceMessage != null && voiceMessage.getUri() != null) { msg.putString("wavAudioData", voiceMessage.getUri().toString()); } else { msg.putString("wavAudioData", ""); } msg.putString("duration", voiceMessage.getDuration() + ""); msg.putString("extra", voiceMessage.getExtra()); } else if (message.getContent() instanceof RecallNotificationMessage) { RecallNotificationMessage recallNotificationMessage = (RecallNotificationMessage) message.getContent(); msg.putString("type", "recall"); msg.putString("operatorId", recallNotificationMessage.getOperatorId()); msg.putString("recallTime", recallNotificationMessage.getRecallTime() + ""); msg.putString("originalObjectName", recallNotificationMessage.getOriginalObjectName()); } return msg; } protected void sendMessage(ConversationType type, String targetId, MessageContent content, String pushContent, final Promise promise) { String pushData = ""; RongIMClient.getInstance().sendMessage(type, targetId, content, pushContent, pushData, new IRongCallback.ISendMessageCallback() { @Override public void onAttached(Message message) { } @Override public void onSuccess(Message message) { promise.resolve(message.getMessageId() + ""); } @Override public void onError(Message message, RongIMClient.ErrorCode errorCode) { promise.reject(message.getMessageId() + "", errorCode.getValue() + ""); } }); } @ReactMethod public void voiceBtnPressIn(int mType, String targetId, String pushContent, String pushData, String extra, final Promise promise) { try { if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) { String[] p = {Manifest.permission.RECORD_AUDIO, Manifest.permission.WRITE_EXTERNAL_STORAGE}; int state1 = ContextCompat.checkSelfPermission(context, p[0]); int state2 = ContextCompat.checkSelfPermission(context, p[1]); if (state1 != PackageManager.PERMISSION_GRANTED || state2 != PackageManager.PERMISSION_GRANTED) { ActivityCompat.requestPermissions(getCurrentActivity(), p, 1); promise.reject("permission_error", "error"); return; } } if (mType >= 0) { this.Atype = mType; } if (targetId != null && targetId.length() > 0) { this.AtargId = targetId; } if (pushContent != null && pushContent.length() > 0) { this.aPushContent = pushContent; } if (pushData != null && pushData.length() > 0) { this.aPushData = pushData; } if (promise != null) { this.Apromise = promise; } if (extra != null && extra.length() > 0) { this.extra = extra; } addAudioListener(); recoderUtils.startRecord(); // promise.resolve("success"); } catch (Exception e) { Log.e("isme", "inthis 2132"); e.printStackTrace(); promise.reject("permission_error", "error"); } } @ReactMethod public void voiceBtnPressOut(int mType, String targetId, String pushContent, String pushData, String extra, final Promise promise) { try { if (mType >= 0) { this.Atype = mType; } if (targetId != null && targetId.length() > 0) { this.AtargId = targetId; } if (pushContent != null && pushContent.length() > 0) { this.aPushContent = pushContent; } if (pushData != null && pushData.length() > 0) { this.aPushData = pushData; } if (extra != null && extra.length() > 0) { this.extra = extra; } if (promise != null) { this.Apromise = promise; } if (recoderUtils == null) { return; } recoderUtils.stopRecord(); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void voiceBtnPressCancel(int mType, String targetId, final Promise promise) { try { if (recoderUtils == null) { return; } recoderUtils.cancelRecord(); promise.resolve("success"); } catch (Exception e) { promise.reject("error", "error"); } } //设置会话消息提醒 isBlocked（true 屏蔽 false 新消息提醒） （return 0:（屏蔽） 1:（新消息提醒）） @ReactMethod public void setConversationNotificationStatus(int mType, String targetId, boolean isBlocked, final Promise promise) { try { ConversationType type = formatConversationType(mType); Conversation.ConversationNotificationStatus status = isBlocked ? Conversation.ConversationNotificationStatus.DO_NOT_DISTURB ://勿扰 屏蔽 Conversation.ConversationNotificationStatus.NOTIFY;//消息通知 RongIMClient.getInstance().setConversationNotificationStatus(type, targetId, status, new ResultCallback() { @Override public void onSuccess(Conversation.ConversationNotificationStatus state) { int isNotify = state == Conversation.ConversationNotificationStatus.NOTIFY ? 1 : 0; promise.resolve(isNotify);//1:（新消息提醒） 0:（屏蔽） } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } //获取会话消息提醒状态 （return 1:（新消息提醒） 0:（屏蔽） ） @ReactMethod public void getConversationNotificationStatus(int mType, String targetId, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getConversationNotificationStatus(type, targetId, new ResultCallback() { @Override public void onSuccess(Conversation.ConversationNotificationStatus state) { int isNotify = state == Conversation.ConversationNotificationStatus.NOTIFY ? 1 : 0; promise.resolve(isNotify);//1:（新消息提醒） 0:（屏蔽） } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } ////屏蔽全局新消息提醒 @ReactMethod public void screenGlobalNotification(final Promise promise) { try { RongIMClient.getInstance().setNotificationQuietHours("00:00:00", 1339, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } //移除全局新消息屏蔽 @ReactMethod public void removeScreenOfGlobalNotification(final Promise promise) { try { RongIMClient.getInstance().removeNotificationQuietHours(new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } ////获取全局新消息提醒状态 （return 0:(全局消息屏蔽) 1:(全局新消息提醒)） @ReactMethod public void getGlobalNotificationStatus(final Promise promise) { try { RongIMClient.getInstance().getNotificationQuietHours(new RongIMClient.GetNotificationQuietHoursCallback() { @Override public void onSuccess(String s, int i) { if (i > 0) { promise.resolve(0); } else { promise.resolve(1); } } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void getTotalUnreadCount(final Promise promise) { try { RongIMClient.getInstance().getTotalUnreadCount(new ResultCallback() { @Override public void onSuccess(Integer integer) { promise.resolve(integer); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } // 获取某个会话类型的target 的未读消息数 @ReactMethod public void getTargetUnreadCount(int mType, String targetId, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getUnreadCount(type, targetId, new ResultCallback() { @Override public void onSuccess(Integer integer) { promise.resolve(integer); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } // 获取某些会话类型（conversationTypes为数组）的未读消息数 @ReactMethod public void getConversationsUnreadCount(ReadableArray conversationTypes, final Promise promise) { try { List lists = new ArrayList<>(); for (int i = 0; i < conversationTypes.size(); i++) { lists.add(formatConversationType(conversationTypes.getInt(i))); } ConversationType[] types = (ConversationType[]) lists.toArray(new ConversationType[lists.size()]); RongIMClient.getInstance().getUnreadCount(types, new ResultCallback() { @Override public void onSuccess(Integer integer) { promise.resolve(integer); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } // 删除消息 @ReactMethod public void deleteTargetMessages(int mType, String targetId, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().deleteMessages(type, targetId, new ResultCallback() { @Override public void onSuccess(Boolean aBoolean) { promise.resolve(aBoolean); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } // Discussion start /** * 创建讨论组 * * @param name 讨论组名称，如：当前所有成员的名字的组合。 * @param userIdList 讨论组成员 Id 列表。 * @param promise 创建讨论组成功后的回调。 */ @ReactMethod public void createDiscussion(String name, ReadableArray userIdList, final Promise promise) { try { String newName = name.length() > 40 ? name.substring(0, 40) : name; List userList = new ArrayList<>(); for (int i = 0; i < userIdList.size(); i++) { userList.add(userIdList.getString(i)); } RongIMClient.getInstance().createDiscussion(newName, userList, new RongIMClient.CreateDiscussionCallback() { @Override public void onSuccess(String s) { WritableMap map = Arguments.createMap(); map.putString("discussionId", s); promise.resolve(map); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 添加一名或者一组用户加入讨论组 * * @param discussionId 讨论组 Id。 * @param userIdList 邀请的用户 Id 列表。 * @param promise 执行操作的回调。 */ @ReactMethod public void addMemberToDiscussion(String discussionId, ReadableArray userIdList, final Promise promise) { try { List userList = new ArrayList<>(); for (int i = 0; i < userIdList.size(); i++) { userList.add(userIdList.getString(i)); } RongIMClient.getInstance().addMemberToDiscussion(discussionId, userList, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 供创建者将某用户移出讨论组。 * 如果当前登陆用户不是此讨论组的创建者并且此讨论组没有开放加人权限，则会返回错误 {@link RongIMClient.ErrorCode}。 * 不能使用此接口将自己移除，否则会返回错误 {@link RongIMClient.ErrorCode}。 * 如果您需要退出该讨论组，可以使用 {@link #quitDiscussion(String, Promise)} 方法 * * @param discussionId 讨论组 Id。 * @param userId 用户 Id。 * @param promise 执行操作的回调 */ @ReactMethod public void removeMemberFromDiscussion(String discussionId, String userId, final Promise promise) { try { RongIMClient.getInstance().removeMemberFromDiscussion(discussionId, userId, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 退出当前用户所在的某讨论组 * * @param discussionId 讨论组 Id * @param promise 执行操作的回调 */ @ReactMethod public void quitDiscussion(String discussionId, final Promise promise) { try { RongIMClient.getInstance().quitDiscussion(discussionId, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 获取讨论组信息和设置。 * * @param discussionId 讨论组 Id。 * @param promise 获取讨论组的回调。 */ @ReactMethod public void getDiscussion(String discussionId, final Promise promise) { try { RongIMClient.getInstance().getDiscussion(discussionId, new ResultCallback() { @Override public void onSuccess(Discussion discussion) { try { WritableMap dis = Arguments.createMap(); WritableArray memberIdList = Arguments.createArray(); List userList = discussion.getMemberIdList(); for (String userId : userList) { memberIdList.pushString(userId); } dis.putString("id", discussion.getId()); dis.putString("name", discussion.getName()); dis.putString("creatorId", discussion.getCreatorId()); dis.putBoolean("isOpen", discussion.isOpen()); dis.putArray("memberIdList", memberIdList); promise.resolve(dis); } catch (Exception e) { promise.reject("error", "error"); } } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 设置讨论组名称。 * * @param discussionId 讨论组 Id。 * @param name 讨论组名称。 * @param promise 设置讨论组的回调。 */ @ReactMethod public void setDiscussionName(String discussionId, String name, final Promise promise) { try { RongIMClient.getInstance().setDiscussionName(discussionId, name, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 设置讨论组成员邀请权限。 * 讨论组默认开放加人权限，即所有成员都可以加人。 * 如果关闭加人权限之后，只有讨论组的创建者有加人权限。 * * @param discussionId 讨论组 Id。 * @param isOpen 邀请状态，默认为开放。 * @param promise 设置权限的回调。 */ @ReactMethod public void setDiscussionInviteStatus(String discussionId, int isOpen, final Promise promise) { try { RongIMClient.DiscussionInviteStatus status = RongIMClient.DiscussionInviteStatus.setValue(isOpen); RongIMClient.getInstance().setDiscussionInviteStatus(discussionId, status, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } // Discussion end /** * 删除消息 * * @param messageIds 消息id * @param promise */ @ReactMethod public void deleteMessages(ReadableArray messageIds, final Promise promise) { try { int[] ids = new int[messageIds.size()]; for (int i = 0; i < messageIds.size(); i++) { ids[i] = Integer.valueOf(messageIds.getString(i)); } RongIMClient.getInstance().deleteMessages(ids, new ResultCallback() { @Override public void onSuccess(Boolean aBoolean) { promise.resolve(aBoolean); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } // Black List @ReactMethod public void addToBlacklist(String id, final Promise promise) { try { RongIMClient.getInstance().addToBlacklist(id, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void removeFromBlacklist(String id, final Promise promise) { try { RongIMClient.getInstance().removeFromBlacklist(id, new RongIMClient.OperationCallback() { @Override public void onSuccess() { promise.resolve("success"); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void getBlacklistStatus(String id, final Promise promise) { try { RongIMClient.getInstance().getBlacklistStatus(id, new ResultCallback() { @Override public void onSuccess(RongIMClient.BlacklistStatus blacklistStatus) { promise.resolve(blacklistStatus.getValue() == 0); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void getBlacklist(final Promise promise) { try { RongIMClient.getInstance().getBlacklist(new RongIMClient.GetBlacklistCallback() { @Override public void onSuccess(String[] strings) { WritableArray array = Arguments.createArray(); for (String id : strings) { array.pushString(id); } promise.resolve(array); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 消息置顶 * * @param mType * @param targetId * @param isTop * @param promise */ @ReactMethod public void setConversationToTop(int mType, String targetId, boolean isTop, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().setConversationToTop(type, targetId, isTop, new ResultCallback() { @Override public void onSuccess(Boolean aBoolean) { promise.resolve(aBoolean); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void removeConversation(int mType, String targetId, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().removeConversation(type, targetId, new ResultCallback() { @Override public void onSuccess(Boolean aBoolean) { promise.resolve(aBoolean); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } @ReactMethod public void clearTargetMessages(int mType, String targetId, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().clearMessages(type, targetId, new ResultCallback() { @Override public void onSuccess(Boolean aBoolean) { promise.resolve(aBoolean); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 获取指定消息列表 * * @param conversationTypes 类型 array * @param promise */ @ReactMethod public void getTopConversationList(ReadableArray conversationTypes, final Promise promise) { try { List lists = new ArrayList<>(); for (int i = 0; i < conversationTypes.size(); i++) { lists.add(formatConversationType(conversationTypes.getInt(i))); } ConversationType[] types = (ConversationType[]) lists.toArray(new ConversationType[lists.size()]); RongIMClient.getInstance().getConversationList(new ResultCallback>() { @Override public void onSuccess(List conversations) { WritableArray array = Arguments.createArray(); for (Conversation conversation : conversations) { if (conversation.isTop()) { WritableMap msg = Arguments.createMap(); msg.putInt("conversationType", conversation.getConversationType().getValue()); msg.putString("targetId", conversation.getTargetId()); msg.putString("conversationTitle", conversation.getConversationTitle()); msg.putInt("unreadMessageCount", conversation.getUnreadMessageCount()); msg.putString("receivedTime", conversation.getReceivedTime() + ""); msg.putString("sentTime", conversation.getSentTime() + ""); msg.putString("senderUserId", conversation.getSenderUserId()); msg.putInt("lastestMessageId", conversation.getLatestMessageId()); msg.putString("lastestMessageDirection", ""); msg.putBoolean("isTop", conversation.isTop()); msg.putInt("receivedStatus", conversation.getReceivedStatus().getFlag()); msg.putInt("sentStatus", conversation.getSentStatus().getValue()); msg.putString("draft", conversation.getDraft()); msg.putString("objectName", conversation.getObjectName()); msg.putBoolean("hasUnreadMentioned", conversation.getMentionedCount() > 0); MessageContent message = conversation.getLatestMessage(); if (message instanceof TextMessage) { TextMessage mMsg = (TextMessage) message; msg.putString("msgType", "text"); msg.putString("lastestMessage", mMsg.getContent()); msg.putString("extra", mMsg.getExtra()); } else if (message instanceof RichContentMessage) { RichContentMessage mMsg = (RichContentMessage) message; msg.putString("msgType", "image"); msg.putString("extra", mMsg.getExtra()); msg.putString("imageUrl", mMsg.getImgUrl()); } else if (message instanceof ImageMessage) { ImageMessage mMsg = (ImageMessage) message; msg.putString("msgType", "image"); msg.putString("extra", mMsg.getExtra()); if (mMsg != null && mMsg.getRemoteUri() != null) { msg.putString("imageUrl", mMsg.getRemoteUri().toString()); } else { msg.putString("imageUrl", ""); } } else if (message instanceof VoiceMessage) { VoiceMessage mMsg = (VoiceMessage) message; msg.putString("msgType", "voice"); msg.putString("extra", mMsg.getExtra()); msg.putInt("duration", mMsg.getDuration()); } else if (message instanceof RecallNotificationMessage) { RecallNotificationMessage recallNotificationMessage = (RecallNotificationMessage) message; msg.putString("type", "recall"); msg.putString("operatorId", recallNotificationMessage.getOperatorId()); msg.putString("recallTime", recallNotificationMessage.getRecallTime() + ""); msg.putString("originalObjectName", recallNotificationMessage.getOriginalObjectName()); } array.pushMap(msg); } } promise.resolve(array); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }, types); } catch (Exception e) { promise.reject("error", "error"); } } /** * 撤回消息 * * @param msg 消息实体 * @param push 推送内容 可为空 * @param promise */ @ReactMethod public void recallMessage(final ReadableMap msg, String push, final Promise promise) { try { Message message = new Message(); message.setUId(msg.getString("messageUId")); message.setConversationType(formatConversationType(msg.getInt("conversationType"))); message.setTargetId(msg.getString("targetId")); message.setSentTime(Long.valueOf(msg.getString("sentTime"))); message.setMessageId(Integer.valueOf(msg.getString("messageId"))); message.setReceivedTime(Long.valueOf(msg.getString("receivedTime"))); message.setSenderUserId(msg.getString("senderUserId")); message.setObjectName(msg.getString("objectName")); message.setExtra(msg.getString("extra")); RongIMClient.getInstance().recallMessage(message, push, new ResultCallback() { @Override public void onSuccess(RecallNotificationMessage recallNotificationMessage) { promise.resolve(msg.getString("messageId")); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 获取会话草稿 * * @param mType 类型 * @param targetId id * @param promise */ @ReactMethod public void getTextMessageDraft(int mType, String targetId, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().getTextMessageDraft(type, targetId, new ResultCallback() { @Override public void onSuccess(String s) { promise.resolve(s); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 保存消息草稿 * * @param mType 类型 * @param targetId id * @param content 内容 * @param promise */ @ReactMethod public void saveTextMessageDraft(int mType, String targetId, String content, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().saveTextMessageDraft(type, targetId, content, new ResultCallback() { @Override public void onSuccess(Boolean aBoolean) { promise.resolve(aBoolean); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } /** * 清除消息草稿 * * @param mType 类型 * @param targetId id * @param promise */ @ReactMethod public void clearTextMessageDraft(int mType, String targetId, final Promise promise) { try { ConversationType type = formatConversationType(mType); RongIMClient.getInstance().clearTextMessageDraft(type, targetId, new ResultCallback() { @Override public void onSuccess(Boolean aBoolean) { promise.resolve(aBoolean); } @Override public void onError(RongIMClient.ErrorCode errorCode) { promise.reject(errorCode.getValue() + "", errorCode.getMessage()); } }); } catch (Exception e) { promise.reject("error", "error"); } } protected void sendEvent(String eventName, @Nullable WritableMap params) { context.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class) .emit(eventName, params); } private ConversationType formatConversationType(int type) { switch (type) { case 1: return ConversationType.PRIVATE; case 2: return ConversationType.DISCUSSION; case 3: return ConversationType.GROUP; default: return ConversationType.PRIVATE; } } private RongCommonDefine.GetMessageDirection getMessageDirection(int direction) { if (direction == RongCommonDefine.GetMessageDirection.BEHIND.ordinal()) { return RongCommonDefine.GetMessageDirection.BEHIND; } return RongCommonDefine.GetMessageDirection.FRONT; } }