screen/application/api/controller/UserSiteMsg.php

<?php

namespace app\api\controller;
use app\common\controller\Api;
use app\common\model\SiteMsg;
use app\common\model\SiteMsgRead;

/**
 * 会员站内信息接口
 */
class UserSiteMsg extends Api
{
    protected $noNeedRight="*";
    /**
     * 列表
     * @ApiParams (name=type,description=不传全部1已读2未读)
     * @ApiParams (name=page,description=分页)
     * @ApiParams (name=limit,description=分页)
     * @ApiReturnParams (name=source,description=来源)
     * @ApiReturnParams (name=title,description=标题)
     * @ApiReturnParams (name=content,description=内容)
     * @ApiReturnParams (name=create_time,description=发布时间)
     */
    public function index(){
        $user=$this->auth->getUser();
        $query=(new SiteMsg)->getQuery();
        $query->whereIn('user_id',[0,$user['id']]);
        $query->order('id','desc');
        $type=input('type');
        if($type==1){
            $query
                ->whereExists("select * from site_msg_read where site_msg_read.site_msg_id=site_msg.id and site_msg_read.user_id={$user['id']}");
        }elseif ($type==2){
            $query
                ->whereNotExists("select * from site_msg_read where site_msg_read.site_msg_id=site_msg.id and site_msg_read.user_id={$user['id']}");
        }
        $list=$query
            ->field('user_id',true)
            ->paginate(input('limit',15));
        $this->success('',$list);
    }
    /**
     * 详情
     * @ApiParams (name=id,description=信ID)
     */
    public function show(){
        $data=$this->_validate([
            'id'=>['require'],
        ]);
        $user=$this->auth->getUser();
        $msg=SiteMsg::findOrFail($data['id']);
        if(!$msg->read()->filterUser($user)->find()) {
            $msg->read()->save([
                'user_id' => $user->id,
            ]);
        }
        $this->success('',$msg);
    }
}