111

common/src/main/java/com/yunbao/common/CommonAppContext.java

@@ -36,6 +36,7 @@ public class CommonAppContext extends MultiDexApplication {
     public static String lang = "chinese";
     public static FirebaseAnalytics mFirebaseAnalytics;
     public static AppEventsLogger logger;
+    public static boolean isReady = false;
 
     @Override
     public void onCreate() {

common/src/main/java/com/yunbao/common/manager/imrongcloud/RongcloudIMManager.java

@@ -10,6 +10,7 @@ import androidx.annotation.NonNull;
 import com.bumptech.glide.Glide;
 import com.bumptech.glide.load.resource.bitmap.CircleCrop;
 import com.bumptech.glide.request.RequestOptions;
+import com.yunbao.common.Constants;
 import com.yunbao.common.CommonAppConfig;
 import com.yunbao.common.bean.BaseModel;
 import com.yunbao.common.bean.IMLoginModel;
@@ -26,6 +27,10 @@ import io.rong.imlib.RongCoreClient;
 import io.rong.imlib.RongIMClient;
 import io.rong.imlib.model.Conversation;
 import io.rong.imlib.model.Message;
+import io.rong.message.TextMessage;
+
+import static com.yunbao.common.CommonAppContext.Ingroup;
+import static com.yunbao.common.CommonAppContext.isReady;
 
 /**
  * 会话列表
@@ -33,7 +38,7 @@ import io.rong.imlib.model.Message;
  */
 public class RongcloudIMManager {
     //融云开发者平台注册app唯一识别符
-    private static final String RONG_IM_KEY = "uwd1c0sxu1p71";
+    public static final String RONG_IM_KEY = "uwd1c0sxu1p71";
     private static final String CLASSNAME = "RongcloudIMManager";
 
     /**
@@ -48,17 +53,13 @@ public class RongcloudIMManager {
         initPhotoGlide();
     }
 
-    private static RongIMClient.OnReceiveMessageWrapperListener listener = new RongIMClient.OnReceiveMessageWrapperListener() {
-        @Override
-        public boolean onReceived(Message message, int left, boolean hasPackage, boolean offline) {
-            return false;
-        }
-    };
+    private static RongIMClient.OnReceiveMessageWrapperListener mListener ;
 
     /**
      * 设置消息接受监听器
      */
-    public static void addRongcloudIMOnReceiveMessageListener() {
+    public static void addRongcloudIMOnReceiveMessageListener(RongIMClient.OnReceiveMessageWrapperListener listener) {
+        mListener = listener;
         IMCenter.getInstance().addOnReceiveMessageListener(listener);
     }
 
@@ -66,7 +67,8 @@ public class RongcloudIMManager {
      * 移除消息接受监听器
      */
     public static void removeRongcloudIMOnReceiveMessageListener() {
-        IMCenter.getInstance().removeOnReceiveMessageListener(listener);
+        if (null!=mListener)
+        IMCenter.getInstance().removeOnReceiveMessageListener(mListener);
     }
 
     /**
@@ -113,6 +115,7 @@ public class RongcloudIMManager {
             public void onSuccess(String s) {
                 //连接成功，如果 onDatabaseOpened() 时没有页面跳转，也可在此时进行跳转。
                 Log.e(CLASSNAME, "onSuccess:" + s);
+                isReady = true;
                 //添加融云连接状态监听
                 RongcloudIMManager.setIMStatusListener();
             }