add observeAccountNotice 账户变动通知

Author: xhp

android/src/main/java/com/netease/im/ReactCache.java

@@ -81,6 +81,7 @@ public class ReactCache {
     public final static String observeBlackList = "observeBlackList";//'黑名单'
     public final static String observeAttachmentProgress = "observeAttachmentProgress";//'上传下载进度'
     public final static String observeOnKick = "observeOnKick";//'被踢出'
+    public final static String observeAccountNotice = "observeAccountNotice";//'账户变动通知'
 
     final static String TAG = "ReactCache";
     private static ReactContext reactContext;

android/src/main/java/com/netease/im/login/RecentContactObserver.java

@@ -6,6 +6,9 @@
 import com.facebook.react.bridge.WritableMap;
 import com.netease.im.RNNeteaseImModule;
 import com.netease.im.ReactCache;
+import com.netease.im.session.extension.AccountNoticeAttachment;
+import com.netease.im.session.extension.CustomAttachment;
+import com.netease.im.session.extension.CustomAttachmentType;
 import com.netease.im.uikit.cache.SimpleCallback;
 import com.netease.im.uikit.cache.TeamDataCache;
 import com.netease.nimlib.sdk.NIMClient;
@@ -16,6 +19,7 @@
 import com.netease.nimlib.sdk.auth.constant.LoginSyncStatus;
 import com.netease.nimlib.sdk.msg.MsgService;
 import com.netease.nimlib.sdk.msg.MsgServiceObserve;
+import com.netease.nimlib.sdk.msg.constant.MsgTypeEnum;
 import com.netease.nimlib.sdk.msg.constant.SessionTypeEnum;
 import com.netease.nimlib.sdk.msg.model.IMMessage;
 import com.netease.nimlib.sdk.msg.model.RecentContact;
@@ -227,7 +231,29 @@ public int compare(RecentContact o1, RecentContact o2) {
 
         @Override
         public void onEvent(List<IMMessage> imMessages) {
-
+            if (imMessages == null || imMessages.isEmpty()) {
+                return;
+            }
+            for (IMMessage m : imMessages) {
+                if (m.getMsgType() == MsgTypeEnum.custom) {
+                    CustomAttachment attachment = null;
+                    try {
+                        attachment = (CustomAttachment) m.getAttachment();
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                    if (attachment != null && attachment.getType() == CustomAttachmentType.AccountNotice) {
+                        AccountNoticeAttachment noticeAttachment = null;
+                        try {
+                            noticeAttachment = (AccountNoticeAttachment) attachment;
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                        ReactCache.emit(ReactCache.observeAccountNotice, noticeAttachment == null ? null : noticeAttachment.toReactNative());
+                        break;
+                    }
+                }
+            }
         }
     };
     Observer<List<RecentContact>> messageObserver = new Observer<List<RecentContact>>() {
@@ -301,7 +327,7 @@ public void onEvent(StatusCode code) {
             }
             WritableMap r = Arguments.createMap();
             String codeValue;
-            switch (code){
+            switch (code) {
                 case PWD_ERROR:
                     codeValue = "10";
                     break;