You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
654 lines
22 KiB
654 lines
22 KiB
<?php
|
|
|
|
namespace app\enterprise\controller;
|
|
|
|
use app\BaseController;
|
|
use app\enterprise\model\Comment;
|
|
use app\enterprise\model\File;
|
|
use app\enterprise\model\Likes;
|
|
use app\enterprise\model\Posts as PostsModel;
|
|
use app\enterprise\model\Friend;
|
|
use app\enterprise\model\PostsFile;
|
|
use app\enterprise\model\PostsNotice;
|
|
use app\enterprise\model\PostsPrivacyUsers;
|
|
use app\enterprise\model\User;
|
|
use think\facade\Db;
|
|
|
|
class Posts extends BaseController
|
|
{
|
|
|
|
protected $url='';
|
|
protected $privacyUserArr = [2,4];
|
|
|
|
public function __construct()
|
|
{
|
|
parent::__construct(app());
|
|
$this->url=getDiskUrl().'/';
|
|
}
|
|
|
|
// 朋友圈列表
|
|
public function index()
|
|
{
|
|
$where = '(p.delete_time = 0 and p.privacy > 0 and p.status = 1) ';
|
|
$where .= ' and ( p.user_id = ' . $this->uid;
|
|
|
|
$friendIds = Friend::getFriendIds($this->uid);
|
|
|
|
if ($friendIds) {
|
|
$friendIdStr = implode(',',$friendIds);
|
|
$where .= ' or ( p.privacy = 1 and p.user_id in (' . $friendIdStr . '))';
|
|
|
|
// 可见
|
|
$where = $this->getPostsWhereOr($where);
|
|
}
|
|
$where .= ')';
|
|
|
|
$field = 'p.id,p.content,p.location,p.address as location_address,p.type,p.user_id,p.create_time';
|
|
$order = 'p.create_time desc';
|
|
$model = new PostsModel();
|
|
$list = $this->paginate($model->alias('p')->where($where)->field($field)->order($order));
|
|
|
|
$data = [];
|
|
if ($list) {
|
|
$data = $list->toArray()['data'];
|
|
foreach ($data as &$item) {
|
|
|
|
$item['user'] = $this->getFriendUserInfo($item['user_id']);
|
|
|
|
$item['files'] = PostsFile::getPostsFile($item['id']);
|
|
|
|
$userIdArr = $friendIds;
|
|
$userIdArr[] = $this->uid;
|
|
|
|
$likesData = Likes::getPostsLikes($item['id'], $this->uid, $userIdArr);
|
|
$item['likes'] = $likesData['likes'];
|
|
$item['is_like'] = $likesData['is_like'];
|
|
|
|
$item['comment'] = Comment::getPostsComment($item['id'], $this->uid, $userIdArr);
|
|
}
|
|
}
|
|
return success('', $data,$list->total(),$list->currentPage());
|
|
}
|
|
|
|
// 获取好友用户信息
|
|
protected function getFriendUserInfo($user_id):array
|
|
{
|
|
$friendNickname = Friend::where(['create_user' => $this->uid, 'friend_user_id' => $user_id, 'status' => 1])->value('nickname');
|
|
$user = User::getUserInfo(['user_id' => $user_id, 'status' => 1], 'realname, avatar, user_id');
|
|
if (empty($friendNickname)) {
|
|
$friendNickname = $user['realname'];
|
|
}
|
|
return [
|
|
'user_id' => $user_id,
|
|
'avatar' => $user['avatar'] ? getDiskUrl() .'/'. $user['avatar'] : avatarUrl($user['avatar'], $user['realname'], $user['user_id'], 120),
|
|
'nickname' => $friendNickname
|
|
];
|
|
}
|
|
|
|
// 好友可见、不可见查询条件
|
|
protected function getPostsWhereOr($whereOr):string
|
|
{
|
|
$prefix = config('database.connections.mysql.prefix');
|
|
|
|
$whereOr .= " or ( p.privacy = 2 and exists (
|
|
select 1 from {$prefix}posts_privacy_users pvu
|
|
where pvu.posts_id = p.id
|
|
and pvu.type = 1 and pvu.user_id in ({$this->uid})
|
|
))";
|
|
|
|
// 不可见
|
|
$whereOr .= " or ( p.privacy = 4 and not exists (
|
|
select 1 from {$prefix}posts_privacy_users peu
|
|
where peu.posts_id = p.id
|
|
and peu.type = 2 and peu.user_id = {$this->uid}
|
|
))";
|
|
return $whereOr;
|
|
}
|
|
|
|
// 我的朋友圈列表
|
|
public function myPosts()
|
|
{
|
|
$user_id = $this->uid;
|
|
// 好有朋友圈
|
|
$friendUserId = $this->request->param('friend_user_id', '');
|
|
|
|
$whereAnd = " ( p.status = 1 and p.delete_time = 0";
|
|
$whereOr = '';
|
|
|
|
if (!empty($friendUserId)) {
|
|
// 验证是否为当前用户的好友
|
|
if (!is_numeric($friendUserId)) {
|
|
return warning(lang('system.error'));
|
|
}
|
|
$friendIds = Friend::getFriendIds($this->uid);
|
|
if (!in_array($friendUserId, $friendIds)) {
|
|
return warning(lang('system.forbidden'));
|
|
}
|
|
$user_id = $friendUserId;
|
|
|
|
$whereOr .= ' and ( p.privacy = 1 ';
|
|
$whereOr = $this->getPostsWhereOr($whereOr);
|
|
$whereOr .= ')';
|
|
} else {
|
|
$whereAnd .= ' and p.privacy in (1,2,3,4)';
|
|
}
|
|
$whereAnd .= " and p.user_id = {$user_id} )";
|
|
|
|
$where = $whereAnd . $whereOr;
|
|
|
|
$field = 'p.id,p.content,p.location,p.address,p.type,p.user_id,p.create_time,p.privacy,p.avatar';
|
|
$order = 'create_time desc';
|
|
$model = new PostsModel();
|
|
|
|
$list = $this->paginate($model->alias('p')->where($where)->field($field)->order($order));
|
|
$data = [];
|
|
if ($list) {
|
|
$data = $list->toArray()['data'];
|
|
foreach ($data as &$item) {
|
|
|
|
$src = '';
|
|
if (empty($item['avatar'])) {
|
|
$item['files'] = PostsFile::getPostsFile($item['id']);
|
|
if (strpos($item['type'], '2') !== false && count($item['files']) > 1) {
|
|
$imageFileArr = array_column($item['files'], 'src');
|
|
$src = PostsModel::createPostsAvatar($item['id'], $imageFileArr);
|
|
}
|
|
} else {
|
|
$src = $item['avatar'];
|
|
}
|
|
if ($src) {
|
|
$item['files'][] = ['file_id' => 0, 'type' => 1, 'src' => $src];
|
|
}
|
|
|
|
unset($data['avatar']);
|
|
}
|
|
}
|
|
return success('', $data,$list->total(),$list->currentPage());
|
|
}
|
|
|
|
public function details()
|
|
{
|
|
$posts_id = $this->request->param('posts_id');
|
|
$friendUserId = $this->request->param('friend_user_id', '');
|
|
if (empty($posts_id)) {
|
|
return warning(lang('system.error'));
|
|
}
|
|
|
|
$where = [
|
|
['id', '=', $posts_id],
|
|
['status', '=', 1],
|
|
['delete_time', '=', 0]
|
|
];
|
|
if (!empty($friendUserId)) {
|
|
// 验证是否为当前用户的好友
|
|
if (!is_numeric($friendUserId)) {
|
|
return warning(lang('system.error'));
|
|
}
|
|
$friendIds = Friend::getFriendIds($this->uid);
|
|
if (!in_array($friendUserId, $friendIds)) {
|
|
return warning(lang('system.error'));
|
|
}
|
|
$where[] = ['user_id', '=', $friendUserId];
|
|
$where[] = ['privacy', 'in', [1,2,4]];
|
|
} else {
|
|
$where[] = ['user_id', '=', $this->uid];
|
|
$where[] = ['privacy', 'in', [1,2,3,4]];
|
|
}
|
|
$field = 'id,content,location,address,type,user_id,create_time,privacy';
|
|
$data = (new PostsModel())->where($where)->field($field)->find();
|
|
if (!$data) {
|
|
return warning(lang('system.error'));
|
|
}
|
|
|
|
$data['files'] = PostsFile::getPostsFile($data['id']);
|
|
|
|
$friendIds = Friend::getFriendIds($this->uid);
|
|
$friendIds[] = $this->uid;
|
|
|
|
$likesData = Likes::getPostsLikes($data['id'], $this->uid, $friendIds);
|
|
$data['likes'] = $likesData['likes'];
|
|
$data['is_like'] = $likesData['is_like'];
|
|
|
|
$data['comment'] = Comment::getPostsComment($data['id'], $this->uid, $friendIds);
|
|
|
|
$data['user'] = $this->getFriendUserInfo($data['user_id']);
|
|
|
|
return success('', $data);
|
|
}
|
|
|
|
// 删除帖子
|
|
public function del()
|
|
{
|
|
try {
|
|
$posts_id = $this->request->param('posts_id');
|
|
if (empty($posts_id)) {
|
|
throw new \Exception('');
|
|
}
|
|
|
|
$existsWhere = [
|
|
'id' => $posts_id,
|
|
'user_id' => $this->uid,
|
|
'delete_time' => 0
|
|
];
|
|
$exists = (new PostsModel())->where($existsWhere)->find();
|
|
if (!$exists) {
|
|
throw new \Exception('');
|
|
}
|
|
|
|
PostsModel::update(['delete_time' => time()], ['id' => $posts_id]);
|
|
return success(lang('system.success'));
|
|
} catch (\Exception $e) {
|
|
return warning(lang('system.error'));
|
|
}
|
|
}
|
|
|
|
// 添加帖子
|
|
public function add()
|
|
{
|
|
$content = $this->request->param('content', '');
|
|
$privacy = $this->request->param('privacy', '');
|
|
$location = $this->request->param('location', '');
|
|
$address = $this->request->param('address', '');
|
|
$video_file = $this->request->param('video_file', '');
|
|
$poster_file = $this->request->param('poster_file', '');
|
|
$imgArr = $this->request->param('img_arr', []);
|
|
$posts_id = $this->request->param('posts_id', '');
|
|
$user_ids = $this->request->param('user_ids', []);
|
|
$status = $this->request->param('status', '1');
|
|
|
|
if (!in_array($status, ['1','2'])) {
|
|
return error(lang('system.error'));
|
|
}
|
|
|
|
$privacy_user_arr = $this->privacyUserArr;
|
|
if (in_array($privacy, $privacy_user_arr)) {
|
|
if (empty($user_ids) || !is_array($user_ids)) {
|
|
return error(lang('posts.user_empty'));
|
|
}
|
|
}
|
|
|
|
$type = '';
|
|
if (!empty($content)) {
|
|
$type = '1';
|
|
}
|
|
if (!empty($imgArr)) {
|
|
if (is_array($imgArr) && count($imgArr) > 9) {
|
|
return error(lang('posts.img_max_length'));
|
|
}
|
|
$type .= '2';
|
|
} elseif (!empty($video_file)) {
|
|
$type .= '3';
|
|
}
|
|
$exists = [];
|
|
if ($posts_id) {
|
|
$existsWhere = [
|
|
'id' => $posts_id,
|
|
'status' => 2,
|
|
'user_id' => $this->uid
|
|
];
|
|
$exists = (new PostsModel())->where($existsWhere)->find()->toArray();
|
|
if (!$exists) {
|
|
return error(lang('posts.exists'));
|
|
}
|
|
}
|
|
|
|
Db::startTrans();
|
|
try {
|
|
$info = [
|
|
'user_id' => $this->uid,
|
|
'type' => $type,
|
|
'content' => $content,
|
|
'privacy' => $privacy,
|
|
'location' => $location ?? '',
|
|
'address' => $address ?? '',
|
|
'status' => $status
|
|
];
|
|
if ($posts_id) {
|
|
$info['update_time'] = time();
|
|
PostsModel::update($info,['id' => $posts_id]);
|
|
PostsFile::update(['delete_time' => time()],['posts_id' => $posts_id]);
|
|
|
|
if (in_array($exists['privacy'], $privacy_user_arr)) {
|
|
(new PostsPrivacyUsers())->where(['posts_id' => $posts_id])->delete();
|
|
}
|
|
} else {
|
|
$info['create_time'] = time();
|
|
$posts_id = (new PostsModel())->insertGetId($info);
|
|
}
|
|
|
|
$fileSaveArr = [];
|
|
if ($imgArr) {
|
|
foreach ($imgArr as $key => $img_url) {
|
|
$fileSaveArr = $this->addPostsFileData(
|
|
$img_url,
|
|
$posts_id,
|
|
$fileSaveArr,
|
|
$key + 1
|
|
);
|
|
}
|
|
PostsModel::createAvatar($posts_id);
|
|
} elseif ($video_file && $poster_file) {
|
|
$fileSaveArr = $this->addPostsFileData(
|
|
$video_file,
|
|
$posts_id,
|
|
$fileSaveArr,
|
|
1,
|
|
2
|
|
);
|
|
$fileSaveArr = $this->addPostsFileData(
|
|
$poster_file,
|
|
$posts_id,
|
|
$fileSaveArr,
|
|
2
|
|
);
|
|
}
|
|
|
|
if ($imgArr || ($video_file && $poster_file)) {
|
|
if (empty($fileSaveArr)) {
|
|
throw new \Exception(lang('system.error'));
|
|
}
|
|
}
|
|
|
|
if ($fileSaveArr) {
|
|
(new PostsFile())->saveAll($fileSaveArr);
|
|
}
|
|
if (!empty($user_ids) && in_array($info['privacy'], $privacy_user_arr)) {
|
|
$user_type = $info['privacy'] == 2 ? 1 : 2;
|
|
$privacy_users = [];
|
|
foreach ($user_ids as $user_id) {
|
|
if (!is_numeric($user_id)) {
|
|
throw new \Exception(lang('system.error'));
|
|
}
|
|
$privacy_users[] = [
|
|
'posts_id' => $posts_id,
|
|
'user_id' => $user_id,
|
|
'type' => $user_type
|
|
];
|
|
}
|
|
if ($privacy_users) {
|
|
(new PostsPrivacyUsers())->saveAll($privacy_users);
|
|
}
|
|
}
|
|
|
|
Db::commit();
|
|
return $status == 2 ? success('') : success(lang('posts.submit'));
|
|
} catch (\Exception $e) {
|
|
Db::rollback();
|
|
return warning(lang('system.error'));
|
|
}
|
|
}
|
|
|
|
// 添加图片视频数据处理
|
|
protected function addPostsFileData($url, $posts_id, $data, $sort = 1, $type = 1)
|
|
{
|
|
$imgUrl = str_replace($this->url, '', $url);
|
|
$whereFile = ['src' => $imgUrl, 'user_id' => $this->uid, 'delete_time' => 0];
|
|
$img_file_id = File::where($whereFile)->value('file_id');
|
|
if ($img_file_id) {
|
|
$data[] = [
|
|
'posts_id' => $posts_id,
|
|
'type' => $type,
|
|
'file_id' => $img_file_id,
|
|
'sort' => $sort
|
|
];
|
|
}
|
|
return $data;
|
|
}
|
|
|
|
// 获取上传草稿帖子数据
|
|
public function getLastPosts()
|
|
{
|
|
$existsWhere = ['user_id' => $this->uid, 'status' => 2, 'delete_time' => 0];
|
|
$field = 'id as posts_id,content,type,location,address as location_address,privacy';
|
|
$data = PostsModel::where($existsWhere)->field($field)->find();
|
|
if ($data) {
|
|
$data['files'] = PostsFile::getPostsFile($data['posts_id']);
|
|
$privacy_user =[];
|
|
if (in_array($data['privacy'], $this->privacyUserArr)) {
|
|
$PrivacyUsers = PostsPrivacyUsers::where(['posts_id' => $data['posts_id']])->column('user_id');
|
|
foreach ($PrivacyUsers as $user_id) {
|
|
$privacy_user[] = $this->getFriendUserInfo($user_id);
|
|
}
|
|
}
|
|
$data['privacy_user'] = $privacy_user;
|
|
}
|
|
return success('', $data);
|
|
}
|
|
|
|
// 点赞帖子
|
|
public function like()
|
|
{
|
|
$posts_id = $this->request->param('posts_id');
|
|
if (empty($posts_id)) {
|
|
return error(lang('system.fail'));
|
|
}
|
|
$reply_user_id = PostsModel::where('id', $posts_id)->value('user_id');
|
|
if (empty($reply_user_id)) {
|
|
return error(lang('system.fail'));
|
|
}
|
|
|
|
$info = [
|
|
'user_id' => $this->uid,
|
|
'type' => 1,
|
|
'relevance_id' => $posts_id
|
|
];
|
|
$exists_id = Likes::where($info)->value('id');
|
|
if ($exists_id) {
|
|
(new Likes())->where('id', $exists_id)->delete();
|
|
|
|
PostsNotice::optionNotice($posts_id, $exists_id, $reply_user_id, 1, 'del');
|
|
$this->wsSendMsg($reply_user_id, 0, 'postsNotice');
|
|
return success(lang('posts.cancel_like'));
|
|
}
|
|
|
|
$info['create_time'] = time();
|
|
$id = (new Likes())->insertGetId($info);
|
|
|
|
if ($reply_user_id != $this->uid) {
|
|
PostsNotice::optionNotice($posts_id, $id, $reply_user_id);
|
|
// 向作者好友推送新的消息
|
|
$this->wsSendMsg($reply_user_id, 0, 'postsNotice');
|
|
}
|
|
|
|
return success(lang('posts.success_like'));
|
|
}
|
|
|
|
/**
|
|
* @param int $user_id // 推送数据
|
|
* @param int $id // 数据$id
|
|
* @param string $type // 推送类型 postsComment 评论 postsLikes 点赞 postsNotice 提醒
|
|
* @return void
|
|
*/
|
|
protected function wsSendMsg(int $user_id, int $id, string $type = 'postsComment')
|
|
{
|
|
$userIds = [];
|
|
$data = [];
|
|
switch ($type) {
|
|
case 'postsComment' :
|
|
$comment = (new Comment())->where('id', $id)->field('id,content,user_id,reply_user_id')->find();
|
|
$data = Comment::dataOption($comment, $this->uid);
|
|
break;
|
|
case 'postsLikes' :
|
|
$data = Likes::where('id', $id)->field('user_id')->find();
|
|
$friend = Friend::getFriendName($this, $data['user_id']);
|
|
$data['nickname'] = $friend['nickname'];
|
|
$data['avatar'] = $friend['avatar'];
|
|
break;
|
|
case 'postsNotice' :
|
|
$count = PostsNotice::where(['user_id' => $this->uid, 'is_read' => 0])->count();
|
|
$data['count'] = $count ?? 0;
|
|
$userIds[] = $user_id;
|
|
break;
|
|
}
|
|
if (in_array($type, ['postsComment', 'postsLikes'])) {
|
|
$userIds = Friend::getFriendIds($user_id);
|
|
// 不推送给当前用户
|
|
// $key = array_search($this->uid, $userIds);
|
|
// if ($key !== false) {
|
|
// unset($userIds[$key]);
|
|
// }
|
|
}
|
|
wsSendMsg($userIds,$type,$data);
|
|
}
|
|
|
|
// 评论帖子
|
|
public function comment()
|
|
{
|
|
$posts_id = $this->request->param('posts_id');
|
|
if (empty($posts_id)) {
|
|
return error(lang('system.fail'));
|
|
}
|
|
$content = $this->request->param('content');
|
|
$content = trim($content);
|
|
if (empty($content)) {
|
|
return error(lang('system.fail'));
|
|
}
|
|
|
|
$pid = $this->request->param('pid', 0);
|
|
$reply_user_id = 0;
|
|
if (!empty($pid)) {
|
|
$reply_user_id = Comment::where('id', $pid)->value('user_id');
|
|
}
|
|
|
|
$info = [
|
|
'user_id' => $this->uid,
|
|
'content' => $content,
|
|
'type' => 1,
|
|
'relevance_id' => $posts_id,
|
|
'reply_user_id' => $reply_user_id,
|
|
'pid' => $pid,
|
|
'create_time' => time()
|
|
];
|
|
$id = (new Comment())->insertGetId($info);
|
|
if (!$reply_user_id) {
|
|
$reply_user_id = PostsModel::where('id', $posts_id)->value('user_id');
|
|
}
|
|
if ($reply_user_id != $this->uid) {
|
|
PostsNotice::optionNotice($posts_id, $id, $reply_user_id, 2);
|
|
$this->wsSendMsg($reply_user_id, 0, 'postsNotice');
|
|
}
|
|
return success(lang('system.success'));
|
|
}
|
|
|
|
// 删除评论
|
|
public function delComment()
|
|
{
|
|
$posts_id = $this->request->param('posts_id');
|
|
if (empty($posts_id)) {
|
|
return error(lang('system.fail'));
|
|
}
|
|
$comment_id = $this->request->param('comment_id');
|
|
if (empty($comment_id)) {
|
|
return error(lang('system.fail'));
|
|
}
|
|
|
|
$existsWhere = [
|
|
'id' => $comment_id,
|
|
'user_id' => $this->uid,
|
|
'type' => 1,
|
|
'relevance_id' => $posts_id
|
|
];
|
|
|
|
$exists = (new Comment())->where($existsWhere)->find();
|
|
if (!$exists) {
|
|
return error(lang('system.fail'));
|
|
}
|
|
// 提醒用户取消删除提醒
|
|
$reply_user_id = $exists->reply_user_id;
|
|
$exists->delete_time = time();
|
|
$exists->save();
|
|
// 删除用户提醒
|
|
if (!$reply_user_id) {
|
|
$reply_user_id = PostsModel::where('id', $posts_id)->value('user_id');
|
|
}
|
|
if ($reply_user_id) {
|
|
PostsNotice::optionNotice($posts_id, $exists['id'], $reply_user_id, 2, 'del');
|
|
$this->wsSendMsg($reply_user_id, 0, 'postsNotice');
|
|
}
|
|
|
|
return success(lang('system.success'));
|
|
}
|
|
|
|
// 提醒消息列表
|
|
public function getNoticeList()
|
|
{
|
|
|
|
$model = new PostsNotice();
|
|
$where = [
|
|
['user_id', '=', $this->uid]
|
|
];
|
|
$field = '*';
|
|
$order = 'is_read asc';
|
|
|
|
$list = $this->paginate($model->where($where)->field($field)->order($order));
|
|
$data = [];
|
|
if ($list) {
|
|
$data = $list->toArray()['data'];
|
|
foreach ($data as &$item) {
|
|
|
|
// 第一张图 或是视频
|
|
$fileWhere = [
|
|
'posts_id' => $item['posts_id'],
|
|
'delete_time' => 0
|
|
];
|
|
$files = PostsFile::where($fileWhere)
|
|
->field('file_id,type')
|
|
->order('sort asc')
|
|
->find();
|
|
|
|
$item['file'] = [];
|
|
if ($files) {
|
|
$filesWhere = ['file_id' => $files['file_id'], 'delete_time' => 0];
|
|
$files['src'] = File::where($filesWhere)->value('src');
|
|
$item['file'] = $files;
|
|
}
|
|
// 标记已读
|
|
if (!$item['is_read']) {
|
|
PostsNotice::read($item['id']);
|
|
}
|
|
if ($item['type'] == 2) {
|
|
$commentWhere = [
|
|
'id' => $item['relevance_id'],
|
|
'delete_time' => 0,
|
|
'type' => 1
|
|
];
|
|
$comment = Comment::where($commentWhere)->field('content,reply_user_id,user_id')->find();
|
|
$item['content'] = $comment['content'] ?? lang('posts.comment_del');
|
|
$item['reply_user'] = [];
|
|
$item['option_user'] = [];
|
|
if ($comment['reply_user_id']) {
|
|
$item['reply_user'] = $this->getFriendUserInfo($comment['reply_user_id']);
|
|
}
|
|
if ($comment['user_id']) {
|
|
$item['option_user'] = $this->getFriendUserInfo($comment['user_id']);
|
|
}
|
|
}
|
|
if ($item['type'] == 1) {
|
|
$likesWhere = [
|
|
'id' => $item['relevance_id'],
|
|
'type' => 1
|
|
];
|
|
$Likes = Likes::where($likesWhere)->field('user_id')->find();
|
|
if ($Likes['user_id']) {
|
|
$item['option_user'] = $this->getFriendUserInfo($Likes['user_id']);
|
|
}
|
|
}
|
|
// 用户信息
|
|
$item['user'] = $this->getFriendUserInfo($item['user_id']);
|
|
// 评论回复
|
|
//unset($item['is_read']);
|
|
}
|
|
}
|
|
return success('', $data,$list->total(),$list->currentPage());
|
|
}
|
|
|
|
// 获取未读消息数量
|
|
public function getNoticeCount()
|
|
{
|
|
$uid = $this->uid;
|
|
|
|
$count = PostsNotice::where(['user_id' => $uid, 'is_read' => 0])->count();
|
|
|
|
return success('', ['count' => $count ?? 0]);
|
|
}
|
|
}
|