撤回、删除消息事件持久化添加被操作id落库

core/src/main/java/com/wecloud/im/service/impl/ImMessageServiceImpl.java

@@ -278,7 +278,7 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         Map<String, Object> content = new HashMap<>();
         Map<String, Object> content = new HashMap<>();
         content.put("operator", imClientSender.getClientId());
         content.put("operator", imClientSender.getClientId());
         content.put("beOperatedMsgId", imMsgRecall.getMsgId());
         content.put("beOperatedMsgId", imMsgRecall.getMsgId());
-        content.put("msgOwner", messageById.getSender());
+        content.put("msgOwner", msgOwner.getClientId());
         ImMessage imMessage = MessageBuilder.buildEventMessage(MsgTypeEnum.MSG_WITHDRAW, imApplication,
         ImMessage imMessage = MessageBuilder.buildEventMessage(MsgTypeEnum.MSG_WITHDRAW, imApplication,
                 imClientSender, new ImConversation().setId(messageById.getFkConversationId()), JsonUtils.encodeJson(content));
                 imClientSender, new ImConversation().setId(messageById.getFkConversationId()), JsonUtils.encodeJson(content));
         this.save(imMessage);
         this.save(imMessage);
@@ -386,7 +386,7 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
             Map<String, Object> content = new HashMap<>();
             Map<String, Object> content = new HashMap<>();
             content.put("operator", imClientSender.getClientId());
             content.put("operator", imClientSender.getClientId());
             content.put("beOperatedMsgId", message.getId());
             content.put("beOperatedMsgId", message.getId());
-            content.put("msgOwner", message.getSender());
+            content.put("msgOwner", msgOwner.getClientId());
             ImMessage imMessage = MessageBuilder.buildEventMessage(MsgTypeEnum.MSG_DELETE, imApplication,
             ImMessage imMessage = MessageBuilder.buildEventMessage(MsgTypeEnum.MSG_DELETE, imApplication,
                     imClientSender, new ImConversation().setId(message.getFkConversationId()), JsonUtils.encodeJson(content));
                     imClientSender, new ImConversation().setId(message.getFkConversationId()), JsonUtils.encodeJson(content));
             this.save(imMessage);
             this.save(imMessage);