application/user/controllerMsg.php

<?php
/**
 * Created by PhpStorm.
 * User: 水木易安 <i@yangyongan.com>
 * Date: 2018/5/15 1:37
 */


namespace app\user\controller;


use think\Controller;
use think\Db;

class Msg extends Controller
{
    function unread()
    {
        if (uid()) {
            $unread = db('user_message')->where('to', uid())->where('is_read', 0)->count();

            $user = Db::name('system_user')->find(uid());
            if ($user) {

                session('user', $user);
                return $this->success($unread, '', $user);
            } else {

                return $this->error("用户信息已经失效");
            }

        } else {
            return $this->error("未登录");
        }
    }

    function msg()
    {
        if (uid()) {

            $map['m.to'] = uid();
            if (input('type') == 0 || input('type') == 1) {
                $map['m.is_read'] = input('type');
            }


            $msg = db('user_message')->alias('m')->join('system_user u', 'm.from=u.id')
                ->where($map)
                ->field('m.*,u.avatar,u.id as uid,u.nickname')->paginate();

            return $this->success('消息', '', $msg);

        } else {
            return $this->error("未登录");
        }
    }


    function mark_read()
    {
        if (uid()) {
            if (input('msg_id')) {

                $msg = db('user_message')->alias('m')->join('system_user u', 'm.from=u.id')
                    ->where('m.to', uid())->where('m.id', input('msg_id'))
                    ->field('m.*,u.nickname,u.id as uid,u.avatar')->find();
                if ($msg) {
                    $mark = db('user_message')->where('id', $msg['id'])->update(['is_read' => 1]);
                    if ($mark) {
                        return $this->success("标记成功", '', $msg);
                    } else {
                        return $this->success("标记失败或者已读", '', $msg);
                    }
                } else {
                    return $this->error("无权阅读信件");
                }
            } else {
                $mark = db('user_message')->where('to', uid())->update(['is_read' => 1]);
                if ($mark) {
                    return $this->success("全部标记成功");
                } else {
                    return $this->success("全部标记失败或者已读");
                }
            }
        } else {
            return $this->error("请登录");
        }
    }


}