kge/application/api/controller/Message.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
/**
 * 消息
 */
class Message extends Api
{
    protected $noNeedLogin = [];
    protected $noNeedRight = ['*'];

    //消息页信息
    public function index(){
        $rs = [
            'msg_first'      => Db::name('message')->where('user_id',$this->auth->id)->order('id desc')->find(),  //第一条个人消息
            'msg_unread_num' => Db::name('message')->where('user_id',$this->auth->id)->where('status',0)->count(),//个人消息未读数量
            'msgsys_first'   => Db::name('message_sys')->order('id desc')->find(),//第一条系统消息
        ];

        //系统消息未读数量
        $all_num = Db::name('message_sys')->count();
        $read_num = Db::name('user_messagesys')->where('user_id',$this->auth->id)->count();
        $rs['msgsys_unread_num'] = abs($all_num - $read_num);

        //动态评论未读数量
        $map = [
            'dt.user_id' => $this->auth->id,
            'a.level'    => 1,
            'a.is_read'  => 0,
        ];
        $dt_answer_unread = Db::name('topic_dongtai_answer')->alias('a')
            ->join('topic_dongtai dt','a.dt_id = dt.id','LEFT')
            ->where($map)->count();

        //动态点赞未读数量
        $map = [
            'dt.user_id' => $this->auth->id,
            'g.is_read'  => 0,
        ];
        $dt_good_unread = Db::name('topic_dongtai_good')->alias('g')
            ->join('topic_dongtai dt','g.dt_id = dt.id','LEFT')
            ->where($map)->count();

        //互动消息未读数量
        $rs['dongtai_unread_num'] = $dt_answer_unread + $dt_good_unread;


        $this->success(1,$rs);
    }

    //个人消息全部改为已读
    public function message_read(){
        Db::startTrans();
        //读取即为已读
        $map = [
            'user_id'  => $this->auth->id,
            'status'   => 0,
        ];
        $rs = Db::name('message')->where($map)->update(['status'=>1]);
        if($rs === false){
            Db::rollback();
            $this->error('操作失败');
        }


        //系统消息
        //全部未读
        $rs = Db::name('user_messagesys')->where('user_id',$this->auth->id)->delete();
        if($rs === false){
            Db::rollback();
            $this->error('操作失败');
        }

        //循环全部已读
        $list = Db::name('message_sys')->column('id');
        if(!empty($list)){
            $newall = [];
            foreach($list as $key => $msg_id){
                $newall[] = [
                    'user_id' => $this->auth->id,
                    'msg_id' => $msg_id,
                ];
            }
            if(!empty($newall)){
                $rs = Db::name('user_messagesys')->insertAll($newall);
                if($rs === false){
                    Db::rollback();
                    $this->error('操作失败');
                }
            }
        }

        Db::commit();
        $this->success();
    }

    //我的个人消息列表
    public function mylist(){
        $list = Db::name('message')->where('user_id',$this->auth->id)->autopage()->order('id desc')->select();

        //读取即为已读
        $map = [
            'user_id' => $this->auth->id,
            'status' => 0,
        ];
        Db::name('message')->where($map)->update(['status'=>1]);
        $this->success('success',$list);
    }

    /*
     * 获取系统消息列表
     */
    public function getmessagesys() {

        $list = Db::name('message_sys')->autopage()->order('id desc')->select();

        Db::startTrans();
        //系统消息
        //全部未读
        $rs = Db::name('user_messagesys')->where('user_id',$this->auth->id)->delete();
        if($rs === false){
            Db::rollback();
            $this->error('操作失败');
        }

        //循环全部已读
        $list2 = Db::name('message_sys')->column('id');
        if(!empty($list2)){
            $newall = [];
            foreach($list2 as $key => $msg_id){
                $newall[] = [
                    'user_id' => $this->auth->id,
                    'msg_id' => $msg_id,
                ];
            }
            if(!empty($newall)){
                $rs = Db::name('user_messagesys')->insertAll($newall);
                if($rs === false){
                    Db::rollback();
                    $this->error('操作失败');
                }
            }
        }

        Db::commit();
        $this->success("获取成功！",$list);
    }

    //最新一条房间内公告
    public function getmessageroom() {

        $info = Db::name('message_room')->order('id desc')->find();

        $this->success("获取成功！",$info);
    }










}