栖笔处 – 君看蕙风来处

#### 一、前言

------------

本来是想用来介绍 `聊天列表界面`的实现，想了想，顺便把`发送消息`+`聊天内容`的方法也带上吧。

主要有三个模块：

（1）和某人发送消息

（2）查询和某人的聊天记录

（3）会话界面列表数据

先看下数据表结构：

![](/storage/images/20220805/17c9353884be6393c2d702f452c2144d.png)

![](/storage/images/20220805/9a1fcf14a720e2ac0e57716b291c82dc.png)

#### 一、发送消息

------------

发送消息对接的是 `融云`（这里不多赘述，只讲解存储聊天格式），发送成功后把内容存入数据表中。

> 存储后的数据可看上图

代码如下：

public function send()
    {
        $uid = $this->auth->id;
        $touid = $this->request->request('touid');//对方uid
        $type = $this->request->request('type');  //消息类型
        $content = $this->request->request('content');//发送内容
    
        if ($uid == $touid) {
            $this->error("不能给自己发消息");
        }
        //分组
        $item = [$uid, $touid];
        sort($item);
        $data = [
            'type'    => $type,
            'content' => $content,
            'uid'     => $uid,
            'touid'   => $touid,
            'is_read' => 0,
            'lab'   => $item[0] . '-' . $item[1]
        ];
    
        //调用融云发送消息
        $this->sendMsg($uid, $touid, $data);
    
        //插入数据库
        $result = ChatLog::create($data);
        if (!$result) {
            $this->error('发送失败');
        }
        $this->success('发送成功');
    }

#### 二、聊天内容

------------

思路流程：

（1）查询 `自己`给`对方`，`对方`给`自己`发的所有内容，倒序排序。

（2）判断每条消息发送人，处理双方 头像 昵称 发送时间 内容类型等数据。

（3）最后使用函数翻转整个数组，让最新一条数据展示在聊天页面最下方。

public function record()
    {
		//当前登录用户信息
        $user = $this->auth->getUser();
        $uid  = $user->id;
        $avatar   = $user->avatar;
        $nickname = $user->nickname;
    
        $touid = $this->request->request('touid');  //对方uid
        $page  = $this->request->request('page', 1); //页码
    
        $to_user = User::get($touid);
        if (!$to_user) {
            $this->error("对方信息错误");
        }
    
        //聊天记录
        $list = ChatLog::where(['uid' => $uid, 'touid' => $touid])
            ->whereOr(function ($query) use ($touid, $uid) {
                $query->where(['uid' => $touid, 'touid' => $uid]);
            })->order('id desc')->page($page, 10)->select();
        if ($list) {
            foreach ($list as $v) {
                $v['createtime_txt'] = date('Y-m-d H:i:s', $v['createtime']);
				//发送人是否为自己
                $v['sender'] = $uid == $v['uid'] ? 1 : 0;
                if ($v['uid'] == $uid) {
                    $v['avatar'] = get_upload_path($avatar);
                    $v['nickname'] = $nickname;
                } else {
                    $v['avatar'] = get_upload_path($to_user['avatar']);
                    $v['nickname'] = $to_user['nickname'];
                }
    
                //消息类型处理
                if ($v['type'] == 2) {
                    $v['content'] = get_upload_path($v['content']);
                }
                if ($v['type'] == 3) {
                    $v['content'] = json_decode(html_entity_decode($v['content']));
                }
            }
            //改为已读
            ChatLog::where(['uid' => $uid, 'touid' => $touid, 'is_read' => 0])->update(['is_read' => 1]);
        }
        $list = array_reverse($list); //数组翻转
        return $this->success("请求成功", $list);
    }
#### 三、会话列表

------------
效果图如下,比较简陋：

![](/storage/images/20220805/b287da53a483a6be8970353f466b83d8.png)

> mysql查询主要分为二步

（1）查询当前用户所有数据,按时间倒序排序

SELECT * FROM `jx_chat_log` WHERE touid = $uid or uid = $uid having 1 ORDER BY createtime desc
	
（2）用子查询，对查询的结果根据`lab`字段分组

SELECT * FROM ( 
    	SELECT * FROM `jx_chat_log` WHERE touid = $uid or uid = $uid having 1 ORDER BY createtime desc
    ) `tmp` GROUP BY tmp.lab

> php对数据处理

最后对查询效果进行处理（对时间的优化可以更具体，比如昨日，xx小时前）

public function list()
    {
        $uid = $this->auth->id;
        $sql = "SELECT * FROM ( 
                    SELECT * FROM `jx_chat_log` WHERE touid = $uid or uid = $uid  having 1 ORDER BY createtime desc
                ) `tmp` GROUP BY tmp.lab";
        $list = Db::query($sql);
    
        foreach ($list as &$v) {
            //消息类型:1=文字,2=图片,3=音频
            switch ($v['type']) {
                case '2':
                    $v['content'] = "[图片]";
                    break;
                case '3':
                    $v['content'] = "[音频]";
                    break;
                default:
                    # code...
                    break;
            }
            // 字段处理
            if ($v['uid'] == $uid) {
                $v['uid'] = $v['touid'];
            }
			//头像昵称
            $user = User::get($v['uid']);
            $v['nickname']   = $user['nickname'];
            $v['avatar']     = $user['avatar'];
            $v['createtime'] = date("Y-m-d H:i:s", $v['createtime']);
            unset($v);
        }
        $this->success("请求成功", $list);
    }

效果如下

{
		"code": 1,
		"msg": "请求成功",
		"time": "1657762967",
		"data": [
			{
				"uid": 10000,
				"nickname": "偏是晴来渐暖",
				"avatar": "/uploads/20220705/13bdb2f887e7001267b53150e2ddfbc3.jpeg",
				"content": "[图片]",
				"type": 2,
				"is_read": 0,
				"createtime": "2022-07-14 16:57:32"
			},
			{
				"uid": 10001,
				"nickname": "教练A",
				"avatar": "/uploads/20220705/13bdb2f887e7001267b53150e2ddfbc3.jpeg",
				"content": "10001  最后一条。",
				"type": 1,
				"is_read": 0,
				"createtime": "2022-07-14 12:57:32"
			}
		]
	}

PHP+Mysql 聊天记录聊天会话列表