100 lines
2.5 KiB
PHP
100 lines
2.5 KiB
PHP
<?php
|
|
/*
|
|
* @Author: TaoLer <317927823@qq.com>
|
|
* @Date: 2021-12-06 16:04:50
|
|
* @LastEditTime: 2022-08-16 12:12:11
|
|
* @LastEditors: TaoLer
|
|
* @Description: 优化版
|
|
* @FilePath: \TaoLer\app\index\controller\Message.php
|
|
* Copyright (c) 2020~2022 https://www.aieok.com All rights reserved.
|
|
*/
|
|
namespace app\index\controller;
|
|
|
|
use app\common\controller\BaseController;
|
|
use think\facade\Session;
|
|
use think\facade\Request;
|
|
use think\facade\Db;
|
|
use app\common\model\Message as MessageModel;
|
|
use app\common\model\MessageTo;
|
|
use taoler\com\Message as MessageApi;
|
|
|
|
class Message extends BaseController
|
|
{
|
|
//消息数目
|
|
public function nums()
|
|
{
|
|
$messgeto = new MessageTo();
|
|
$num = $messgeto->getMsgNum($this->uid);
|
|
if($num){
|
|
$res = ['status' =>0,'count' => $num, 'msg' => 'ok'];
|
|
} else {
|
|
$res = ['status' =>0,'count' => 0, 'msg' => 'no message'];
|
|
}
|
|
return json($res);
|
|
}
|
|
|
|
//消息查询
|
|
public function find()
|
|
{
|
|
$msg = MessageApi::receveMsg($this->uid);
|
|
|
|
$count = count($msg);
|
|
$res = [];
|
|
if($count){
|
|
$res = ['status'=>0,'msg'=>'','count'=>$count];
|
|
foreach ($msg as $k => $v){
|
|
$res['rows'][] = ['id'=>$v['id'],'name'=>$v['name'],'title'=>$v['title'],'content'=>$v['content'],'time'=>date("Y-m-d H:i",$v['create_time']),'link'=>$v['link'],'read'=>$v['is_read'] ? '已读':'未读','type'=>$v['message_type']];
|
|
|
|
}
|
|
} else {
|
|
$res = ['status'=>0,'msg'=>'message find error','rows'=>''];;
|
|
}
|
|
return json($res);
|
|
}
|
|
|
|
//读消息
|
|
public function read()
|
|
{
|
|
$id =input('id');
|
|
if($id){
|
|
$msg = MessageTo::field('id,message_id')
|
|
->with(['messages' => function($query){
|
|
$query->field('id,content');
|
|
}])
|
|
->where('id',$id)
|
|
->find();
|
|
//改变读状态
|
|
if($msg->is_read == 0){
|
|
$result = $msg->update(['id'=>$id,'is_read'=>1]);
|
|
if($result){
|
|
$res=['status' =>0,'content'=>$msg['messages']['content']];
|
|
return json($res);
|
|
}
|
|
}
|
|
} else {
|
|
return json(['status' =>0, 'url'=>(string) url('User/message')]);
|
|
}
|
|
}
|
|
|
|
//消息删除
|
|
public function remove()
|
|
{
|
|
$uid = $this->uid;
|
|
|
|
$id = Request::only(['id']);
|
|
if($id['id'] == 'true'){
|
|
//删除所有此用户消息
|
|
$msg = Db::name('message_to')->where(['receve_id'=>$uid,'delete_time'=>0])->useSoftDelete('delete_time',time())->delete();
|
|
} else {
|
|
//删除单条消息
|
|
$msg = Db::name('message_to')->where('id',$id['id'])->useSoftDelete('delete_time',time())->delete();
|
|
}
|
|
|
|
if($msg){
|
|
$res = ['status'=>0];
|
|
}
|
|
return $res;
|
|
|
|
}
|
|
|
|
} |