撤回、删除消息事件持久化

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

 package com.wecloud.im.service.impl;
 
+import com.wecloud.im.post.MessageBuilder;
 import io.geekidea.springbootplus.framework.common.api.ApiCode;
 import io.geekidea.springbootplus.framework.common.api.ApiResult;
 import io.geekidea.springbootplus.framework.common.exception.BusinessException;
@@ -273,6 +274,12 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
 
         eventPublisher.publishEvent(new ClientSendMessageEvent(imApplication.getId(), messageById));
 
+        // 组装消息
+        Map<String, Object> content = new HashMap<>();
+        content.put("operator", imClientSender.getClientId());
+        ImMessage imMessage = MessageBuilder.buildEventMessage(MsgTypeEnum.MSG_WITHDRAW, imApplication,
+                imClientSender, new ImConversation().setId(messageById.getFkConversationId()), JsonUtils.encodeJson(content));
+        this.save(imMessage);
 
         if (saveOk) {
             // 查询该会话所有成员
@@ -373,6 +380,13 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
                 throw new BusinessException("未查找到消息发送者");
             }
 
+            // 组装消息
+            Map<String, Object> content = new HashMap<>();
+            content.put("operator", imClientSender.getClientId());
+            ImMessage imMessage = MessageBuilder.buildEventMessage(MsgTypeEnum.MSG_DELETE, imApplication,
+                    imClientSender, new ImConversation().setId(message.getFkConversationId()), JsonUtils.encodeJson(content));
+            this.save(imMessage);
+
             if (saveOk) {
                 // 查询该会话所有成员
                 List<ImConversationMembers> membersList = imConversationMembersService.list(