diff --git a/hs-im-server/im-service/src/main/java/com/lld/im/service/message/dao/mapper/ImMessageHistoryMapper.java b/hs-im-server/im-service/src/main/java/com/lld/im/service/message/dao/mapper/ImMessageHistoryMapper.java
index 155122b..ae23ab1 100644
--- a/hs-im-server/im-service/src/main/java/com/lld/im/service/message/dao/mapper/ImMessageHistoryMapper.java
+++ b/hs-im-server/im-service/src/main/java/com/lld/im/service/message/dao/mapper/ImMessageHistoryMapper.java
@@ -2,9 +2,11 @@ package com.lld.im.service.message.dao.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.lld.im.service.message.dao.ImMessageHistoryEntity;
+import org.apache.ibatis.annotations.Select;
 import org.springframework.stereotype.Repository;
 
 import java.util.Collection;
+import java.util.List;
 
 @Repository
 public interface ImMessageHistoryMapper extends BaseMapper<ImMessageHistoryEntity> {
@@ -15,4 +17,8 @@ public interface ImMessageHistoryMapper extends BaseMapper<ImMessageHistoryEntit
      * @return
      */
     Integer insertBatchSomeColumn(Collection<ImMessageHistoryEntity> entityList);
+
+
+    @Select("select from_id,to_id,max(message_key) messageKey from im_message_history where owner_id = #{operater}  group by from_id,to_id")
+    List<ImMessageHistoryEntity> selectMessageByOwnId(String operater);
 }