add updateAudioMessagePlayStatus

Author: xhp

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

@@ -61,6 +61,7 @@
 import com.netease.nimlib.sdk.msg.MessageBuilder;
 import com.netease.nimlib.sdk.msg.MsgService;
 import com.netease.nimlib.sdk.msg.SystemMessageService;
+import com.netease.nimlib.sdk.msg.constant.MsgStatusEnum;
 import com.netease.nimlib.sdk.msg.constant.SessionTypeEnum;
 import com.netease.nimlib.sdk.msg.model.IMMessage;
 import com.netease.nimlib.sdk.msg.model.QueryDirectionEnum;
@@ -1283,6 +1284,21 @@ public int onResult(int code, IMMessage message) {
 
     }
 
+    @ReactMethod
+    public void updateAudioMessagePlayStatus(String messageId, final Promise promise) {
+        LogUtil.w(TAG, "revokeMessage" + messageId);
+        sessionService.queryMessage(messageId, new SessionService.OnMessageQueryListener() {
+
+            @Override
+            public int onResult(int code, IMMessage message) {
+                if (code == ResponseCode.RES_SUCCESS && message != null) {
+                    sessionService.updateMessage(message, MsgStatusEnum.read);
+                }
+                return 0;
+            }
+        });
+    }
+
     /**
      * 消息删除
      *

android/src/main/java/com/netease/im/session/SessionService.java

@@ -59,6 +59,8 @@
 import java.util.Map;
 import java.util.Set;
 
+import static com.netease.nimlib.sdk.NIMClient.getService;
+
 /**
  * Created by dowin on 2017/5/10.
  */
@@ -83,6 +85,8 @@ public class SessionService {
     private Handler handler;
     private boolean mute = false;
 
+    private boolean canSended = true;
+
     private SessionService() {
     }
 
@@ -507,7 +511,7 @@ private void registerObservers(boolean register) {
             return;
         }
         hasRegister = register;
-        MsgServiceObserve service = NIMClient.getService(MsgServiceObserve.class);
+        MsgServiceObserve service = getService(MsgServiceObserve.class);
         service.observeReceiveMessage(incomingMessageObserver, register);
         service.observeMessageReceipt(messageReceiptObserver, register);
 
@@ -551,11 +555,16 @@ public void startSession(Handler handler, String sessionId, String type) {
         sessionTypeEnum = SessionUtil.getSessionType(type);
 
         if (sessionTypeEnum == SessionTypeEnum.P2P) {
+            canSended = NIMClient.getService(FriendService.class).isMyFriend(sessionId);
             this.mute = !NIMClient.getService(FriendService.class).isNeedMessageNotify(sessionId);
         } else {
             Team t = TeamDataCache.getInstance().getTeamById(sessionId);
-            if (t != null)
+            if (t != null) {
                 this.mute = t.mute();
+                canSended = t.isMyTeam();
+            } else {
+                canSended = false;
+            }
         }
         registerObservers(true);
         getMsgService().setChattingAccount(sessionId, sessionTypeEnum);
@@ -811,13 +820,18 @@ public MsgService getMsgService() {
         if (msgService == null) {
             synchronized (SessionService.class) {
                 if (msgService == null) {
-                    msgService = NIMClient.getService(MsgService.class);
+                    msgService = getService(MsgService.class);
                 }
             }
         }
         return msgService;
     }
 
+    public void updateMessage(final IMMessage message, MsgStatusEnum statusEnum) {
+        message.setStatus(statusEnum);
+        getMsgService().updateIMMessageStatus(message);
+    }
+
     public void sendMessage(final IMMessage message, final OnSendMessageListener onSendMessageListener) {
 
 
@@ -873,7 +887,7 @@ private boolean isOriginImageHasDownloaded(final IMMessage message) {
     }
 
     void observerAttachProgress(boolean register) {
-        NIMClient.getService(MsgServiceObserve.class).observeAttachmentProgress(new Observer<AttachmentProgress>() {
+        getService(MsgServiceObserve.class).observeAttachmentProgress(new Observer<AttachmentProgress>() {
             @Override
             public void onEvent(AttachmentProgress attachmentProgress) {
                 ReactCache.emit(ReactCache.observeAttachmentProgress, ReactCache.createAttachmentProgress(attachmentProgress));
@@ -887,7 +901,7 @@ public void downloadAttachment(IMMessage message, boolean isThumb) {
         if (isOriginImageHasDownloaded(message)) {
             return;
         }
-        AbortableFuture future = NIMClient.getService(MsgService.class).downloadAttachment(message, isThumb);
+        AbortableFuture future = getService(MsgService.class).downloadAttachment(message, isThumb);
     }
 
     public interface OnSendMessageListener {