Skip to content

Commit be75366

Browse files
committed
fix 重发消息
1 parent fc192bd commit be75366

File tree

2 files changed

+21
-19
lines changed

2 files changed

+21
-19
lines changed

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

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1386,7 +1386,22 @@ public void onResult(int code, Void aVoid, Throwable throwable) {
13861386
@ReactMethod
13871387
public void resendMessage(String messageId, final Promise promise) {
13881388
LogUtil.w(TAG, "resendMessage" + messageId);
1389-
sessionService.resendMessage(messageId);
1389+
sessionService.queryMessage(messageId, new SessionService.OnMessageQueryListener() {
1390+
@Override
1391+
public int onResult(int code, IMMessage message) {
1392+
Map<String, Object> map = message.getLocalExtension();
1393+
if (map != null) {
1394+
if (map.containsKey("resend")) {
1395+
return -1;
1396+
}
1397+
}
1398+
promise.resolve("200");
1399+
sessionService.resendMessage(message);
1400+
1401+
return 0;
1402+
}
1403+
});
1404+
13901405
}
13911406

13921407
/**

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

Lines changed: 5 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -608,29 +608,16 @@ private void refreshMessageList(List<IMMessage> messageList) {
608608
/**
609609
* 重发消息到服务器
610610
*
611-
* @param messageId
611+
* @param item
612612
*/
613-
public void resendMessage(String messageId) {
613+
public void resendMessage(IMMessage item) {
614614
// 重置状态为unsent
615-
queryMessage(messageId, new OnMessageQueryListener() {
616-
@Override
617-
public int onResult(int code, IMMessage message) {
618-
Map<String, Object> map = message.getLocalExtension();
619-
if (map != null) {
620-
if (map.containsKey("resend")) {
621-
return -1;
622-
}
623-
}
624-
IMMessage item = message;
625-
item.setStatus(MsgStatusEnum.sending);
626-
deleteItem(item, true);
615+
item.setStatus(MsgStatusEnum.sending);
616+
deleteItem(item, true);
627617
// onMsgSend(item);
628618
// appendPushConfig(item);
629619
// getMsgService().sendMessage(item, true);
630-
sendMessageSelf(item, null, true);
631-
return 0;
632-
}
633-
});
620+
sendMessageSelf(item, null, true);
634621
}
635622

636623
/**

0 commit comments

Comments
 (0)