聊天记录断层问题处理

app/enterprise/controller/Im.php

@@ -231,7 +231,7 @@ class Im extends BaseController
         if($last_id){
             $where[]=['msg_id','<',$last_id];
         }
-        $list = Message::getList($map, $where, 'msg_id desc', $listRows, $pageSize);
+        $list = Message::getList($map, $where, 'msg_id desc', $listRows, $pageSize, $this->uid);
         $data = $this->recombileMsg($list);
         // 如果是群聊并且是第一页消息，需要推送@数据给用户
         if($param['is_group']==1 && $param['page']==1){

app/enterprise/model/Message.php

@@ -32,10 +32,11 @@ class Message extends BaseModel
     }
 
     // 查询聊天记录
-    public static function getList($map,$where,$sort,$listRows,$pageSize){
+    public static function getList($map,$where,$sort,$listRows,$pageSize,$user_id){
         $list= (new self())
         ->where($map)
         ->where($where)
+        ->where(" (find_in_set({$user_id},`del_user`) = 0 or del_user is null)")
         ->order($sort)
         ->paginate(['list_rows'=>$listRows,'page'=>$pageSize]);
         return $list;

app/manage/controller/Message.php

@@ -50,7 +50,7 @@ class Message extends BaseController
         if($last_id){
             $where[]=['msg_id','<',$last_id];
         }
-        $list = MessageModel::getList($map, $where, 'msg_id desc', $listRows, $pageSize);
+        $list = MessageModel::getList($map, $where, 'msg_id desc', $listRows, $pageSize, $this->uid);
         $data = $this->recombileMsg($list);
         return success('', $data, $list->total(),$list->currentPage());
     }