kge/application/api/controller/Topicdongtai.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use app\common\library\Keyworld;
use think\Exception;

/**
 * 圈子动态
 */
class Topicdongtai extends Api
{
    protected $noNeedLogin = [];
    protected $noNeedRight = ['*'];

    //发布动态
    public function addone(){
        $content = input('content','');
        $images = input('images','');
        $topic_id = input('topic_id',0);
        if(!$content && !$images){
            $this->error(__('Invalid parameters'));
        }

        //关键字替换
        $content = Keyworld::sensitive($content);

        $data = [
            'topic_id' => $topic_id,
            'user_id' => $this->auth->id,
            'content' => $content,
            'images' => $images,
            'type'  => input('type',1),
            'createtime' => time(),
            'updatetime' => time(),
        ];


        Db::startTrans();
        $id = Db::name('topic_dongtai')->insertGetId($data);
        //圈子新增一个贴
        $rs = Db::name('topic_hub')->where('id',$topic_id)->setInc('t_number');

        //发布首条动态，完成任务
        $count = Db::name('topic_dongtai')->where('user_id',$this->auth->id)->count();
        if($count == 1){
            \app\common\model\TaskLog::tofinish($this->auth->id,16);
        }


        Db::commit();

        $this->success('发布成功',$id);
    }

    //自己看列表
    //某用户的帖子列表
    public function my_lists(){

        $uid = input('uid',$this->auth->id);
        if (empty($uid)) {
            $uid = $this->auth->id;
        }
        $list = Db::name('topic_dongtai')->alias('dt')
            ->join('user','dt.user_id = user.id','LEFT')
            ->join('topic_hub topic','dt.topic_id = topic.id','LEFT')
            ->field('dt.*,user.nickname,user.avatar,user.gender,topic.name as topic_name')
            ->where('dt.user_id',$uid)
            ->order('dt.id desc')->autopage()->select();
        $list = list_domain_image($list,['images','avatar']);

        if(!empty($list)){
            foreach($list as $key => &$val){

                //追加点赞
                $val['isgood'] = $this->is_good($val['id'],$this->auth->id);

                //创建视频缩略图
                $val['images_thumb'] = '';
                if ($val['type'] == 2) {
                    /*$images_url = explode('.', $val['images']);
                    unset($images_url[count($images_url) - 1]);
                    $val['images_thumb'] = join('.', $images_url) . '_0.jpg';*/
                    $val['images_thumb'] = $val['images'].'?x-oss-process=video/snapshot,t_1000,m_fast';
                }

                //时间
                $val['createtime_text'] = get_last_time($val['createtime']);

                //关注
                $val['is_follow'] = $this->is_follow($this->auth->id,$val['user_id']);

                //评论
                $val['answernumber'] = Db::name('topic_dongtai_answer')->where(['dt_id'=>$val['id'],'level'=>1])->count();
            }
        }

        $this->success('success',$list);
    }

    //动态删除
    public function delete(){

        $id = input('id',0);
        $where['id'] = $id;
        $where['user_id'] = $this->auth->id;
        $dongtai = Db::name('topic_dongtai')->field('id,topic_id')->where($where)->find();
        if (empty($dongtai)) {
            $this->error('未找到动态信息');
        }
        Db::startTrans();
        $delRes = Db::name('topic_dongtai')->where('id',$id)->where('user_id',$this->auth->id)->delete();
        if (!$delRes) {
            Db::rollback();
            $this->error('动态删除失败');
        }
        //圈子新增一个贴
        if (!empty($dongtai['topic_id'])) {
            $res = Db::name('topic_hub')->where('id',$dongtai['topic_id'])->setDec('t_number');
            if (!$res) {
                Db::rollback();
                $this->error('更新话题数量失败');
            }
        }
        //删除对应的评论，
        Db::name('topic_dongtai_answer')->where('dt_id',$id)->delete();
        //点赞，
        Db::name('topic_dongtai_good')->where('dt_id',$id)->delete();
        //评论点赞
        Db::name('topic_answer_good')->where('dt_id',$id)->delete();

        Db::commit();
        $this->success('删除成功');

    }

    //是否点赞
    private function is_good($dt_id,$uid){
        $where = [
            'dt_id' => $dt_id,
            'user_id'  => $uid,
        ];
        $check = Db::name('topic_dongtai_good')->where($where)->find();
        if($check){
            return 1;
        }else{
            return 0;
        }
    }
    //回复是否点赞
    private function answer_is_good($answer_id,$uid){
        $where = [
            'answer_id' => $answer_id,
            'user_id'  => $uid,
        ];
        $check = Db::name('topic_answer_good')->where($where)->find();
        if($check){
            return 1;
        }else{
            return 0;
        }
    }


    //详情
    public function info(){
        $id = input('id');

        $info = Db::name('topic_dongtai')->alias('dt')
            ->join('user','dt.user_id = user.id','LEFT')
            ->join('topic_hub topic','dt.topic_id = topic.id','LEFT')
            ->field('dt.*,user.nickname,user.avatar,user.gender,topic.name as topic_name')
            ->where('dt.id',$id)->find();
        $info = info_domain_image($info,['images','avatar']);


        if($info){
            //是否点赞过
            $info['isgood'] = $this->is_good($id,$this->auth->id);

            //创建视频缩略图
            $info['images_thumb'] = '';
            if ($info['type'] == 2) {
                $images_url = explode('.', $info['images']);
                unset($images_url[count($images_url) - 1]);
                $info['images_thumb'] = join('.', $images_url) . '_0.jpg';
            }

            //时间
            $info['createtime_text'] = get_last_time($info['createtime']);

            //关注
            $info['is_follow'] = $this->is_follow($this->auth->id,$info['user_id']);

            //评论
            $info['answernumber'] = Db::name('topic_dongtai_answer')->where(['dt_id'=>$id,'level'=>1])->count();
        }

        $this->success('success',$info);
    }

    //点赞
    public function good(){
        $id = input('id');

        $where = [
            'dt_id' => $id,
            'user_id'  => $this->auth->id,
        ];
        $check = Db::name('topic_dongtai_good')->where($where)->find();
        $dt_user_id = Db::name('topic_dongtai')->where('id',$id)->value('user_id');

        if($check){
            Db::name('topic_dongtai_good')->where($where)->delete();
            $down = Db::name('topic_dongtai')->where('id',$id)->setDec('goodnum');
            $this->success('已取消点赞');
        }else{

            Db::startTrans();
            $where['createtime'] = time();
            $rs = Db::name('topic_dongtai_good')->insertGetId($where);
            if(!$rs){
                Db::rollback();
                $this->error('点赞失败');
            }
            $up = Db::name('topic_dongtai')->where('id',$id)->setInc('goodnum');
            if($up === false){
                Db::rollback();
                $this->error('点赞失败');
            }

            //系统消息
            if($dt_user_id != $this->auth->id){
            $msg_id = \app\common\model\Message::addMessage($dt_user_id,'动态点赞','有人赞了你的动态','dongtai_good',$id);
            }

            Db::commit();
            $this->success('点赞成功');
        }
    }

    //评论
    public function answer(){
        $id = input('id',0);
        $content = input('content','');
        $to_user_id = input('to_user_id',0);
        $level = input('level',1);  //回复类型:1=层主回复楼主,2=层中回复
        $floor = input('floor',0);

        if(empty($content) || empty($id)){
            $this->error();
        }

        //关键字替换
        $content = Keyworld::sensitive($content);

        //判断
        if($level == 2 && $floor == 0){
            $this->error('楼层错误');
        }

        //回复楼主，最新楼层
        if($level == 1 || $floor == 0){
            $to_user_id = 0;
            $floor = 1;  //默认一楼

            $last_floor = Db::name('topic_dongtai_answer')->where(['dt_id'=>$id,'level'=>1])->order('floor desc')->value('floor');
            if($last_floor){
                $floor = $last_floor + 1;
            }
        }

        //判断user_id
        if($to_user_id){
            $to_user = Db::name('user')->where('id',$to_user_id)->value('id');
            if(empty($to_user)){
                $this->error('被回复的用户不存在');
            }
        }

        //data
        $data = [
            'dt_id' => $id,
            'floor' => $floor,
            'user_id' => $this->auth->id,
            'content' => $content,
            'to_user_id' => $to_user_id,
            'level' => $level,
            'createtime' => time(),
            'updatetime' => time(),
        ];

        Db::startTrans();
        $rs = Db::name('topic_dongtai_answer')->insertGetId($data);

        Db::name('topic_dongtai')->where('id',$id)->setInc('answernum');

        //系统消息
        if($level == 1){
            //发给动态用户
            $msg_user_id = Db::name('topic_dongtai')->where('id',$id)->value('user_id');
            $msg_title = '动态评论';
            $msg_content = '有人评论了你的动态';
            $infotype_id = $rs;
        }else{
            //发给层主
            $answer_info = Db::name('topic_dongtai_answer')->where(['dt_id'=>$id,'level'=>1,'floor'=>$floor])->find();
            $msg_user_id = $answer_info['user_id'];
            $msg_title = '动态评论点评';
            $msg_content = '有人点评了你的动态评论';
            $infotype_id = $answer_info['id'];
        }
        if($msg_user_id != $this->auth->id){
            $msg_id = \app\common\model\Message::addMessage($msg_user_id,$msg_title,$msg_content,'dongtai_answer',$infotype_id);
        }

        Db::commit();
        $this->success('评价成功');
    }

    //对评论点赞
    public function answer_good(){
        $dt_id = input('dt_id',0);
        $answer_id = input('answer_id',0);

        $where = [
            'dt_id'     => $dt_id,
            'answer_id' => $answer_id,
            'user_id'   => $this->auth->id,
        ];
        $check = Db::name('topic_answer_good')->where($where)->find();

        if($check){
            Db::name('topic_answer_good')->where($where)->delete();
            Db::name('topic_dongtai_answer')->where('id',$answer_id)->setDec('goodnum');
            $this->success('已取消点赞');
        }

        Db::startTrans();
        $where['createtime'] = time();
        $rs = Db::name('topic_answer_good')->insertGetId($where);
        $up = Db::name('topic_dongtai_answer')->where('id',$answer_id)->setInc('goodnum');

        if($rs && $up !== false){
            Db::commit();
            $this->success('点赞成功');
        }
        Db::rollback();
        $this->error('点赞失败');
    }

    //举报枚举
   /* public function report_enum(){
        $arr = [
            '侮辱谩骂',
            '色情低俗',
            '整治敏感',
            '违法违规',
            '其他',
        ];
        $this->success(1,$arr);
    }

    //举报
    public function report(){
        $field = ['dt_id','type','content','images'];
        $data = request_post_hub($field);

        $check = Db::name('topic_dongtai')->where('id',$data['dt_id'])->find();

        $data['user_id']    = $this->auth->id;
        $data['ruser_id']    = $check['user_id'];
        $data['createtime'] = time();

        Db::name('topic_dongtai_report')->insertGetId($data);
        $this->success('举报成功');
    }*/

    //不感兴趣，屏蔽某条
    public function screen(){
        $data = [
            'user_id' => $this->auth->id,
            'dt_id'   => input('dt_id',0),
        ];
        $check = Db::name('topic_dongtai_screen')->where($data)->find();
        if($check){
            $this->success('操作成功');
        }

        Db::name('topic_dongtai_screen')->insertGetId($data);

        $this->success('操作成功');
    }

    //评论列表
    public function answer_list(){
        $dt_id = input('dt_id',0);
        //楼
        $floor_list = Db::name('topic_dongtai_answer')
            ->alias('a')
            ->field('a.*,user.nickname,user.avatar,user.gender')
            ->join('user','a.user_id = user.id','LEFT')
            ->where(['a.dt_id'=>$dt_id,'a.level'=>1])->order('a.id desc')->autopage()->select();
        $floor_list = list_domain_image($floor_list,['avatar']);

        //追加子评论
        if(!empty($floor_list)){
            foreach($floor_list as $key => &$val){
                //下面几条子回复，字符串
                $val['childremark'] = '';

                $map = [
                    'a.dt_id' => $dt_id,
                    'a.floor' => $val['floor'],
                    'a.level' => 2,
                ];
                $number = Db::name('topic_dongtai_answer')->alias('a')->where($map)->count();
                if($number > 0){
                    $answer_info = Db::name('topic_dongtai_answer')
                        ->alias('a')
                        ->field('user.nickname')
                        ->join('user','a.user_id = user.id','LEFT')
                        ->where($map)->order('a.id desc')->find();

                    $val['childremark'] = $answer_info['nickname'].'...等人,共'.$number.'条回复';
                }

                //时间处理
                $val['createtime_text'] = get_last_time($val['createtime']);

                //回复是否已赞
                $val['is_good'] = $this->answer_is_good($val['id'],$this->auth->id);
            }
        }

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

    //单独某一层的详细
    public function answer_info(){
        $answer_id = input('answer_id');

        //楼
        $floor_info = Db::name('topic_dongtai_answer')
            ->alias('a')
            ->field('a.*,user.nickname,user.avatar,user.gender')
            ->join('user','a.user_id = user.id','LEFT')
            ->where(['a.id'=>$answer_id])->find();
        $floor_info = info_domain_image($floor_info,['avatar']);
        $floor_info['createtime_text'] = get_last_time($floor_info['createtime']);
        //回复是否已赞
        $floor_info['is_good'] = $this->answer_is_good($answer_id,$this->auth->id);
        $floor_info['answernumber'] = Db::name('topic_dongtai_answer')->where(['dt_id'=>$floor_info['dt_id'],'floor'=>$floor_info['floor'],'level'=>2])->count();

        //层
        $floors = $floor_info['floor'];
        $child_lists = Db::name('topic_dongtai_answer')->alias('a')
            ->field('a.*,user.nickname,user.avatar,user.gender,tuser.nickname as to_nickname,tuser.avatar as to_avatar,tuser.gender as to_gender')
            ->join('user','a.user_id = user.id','LEFT')
            ->join('user tuser','a.to_user_id = tuser.id','LEFT')
            ->where(['a.dt_id'=>$floor_info['dt_id'],'a.floor'=>$floors,'a.level'=>2])->order('a.id desc')->autopage()->select();
        $child_lists = list_domain_image($child_lists,['avatar','to_avatar']);
        if(!empty($child_lists)){
            foreach($child_lists as $key => &$answer){
                $answer['is_good'] = $this->answer_is_good($answer['id'],$this->auth->id);
                $answer['createtime_text'] = get_last_time($answer['createtime']);
            }
        }

        //合并
        $floor_info['child'] = $child_lists;

        $this->success('success',$floor_info);

    }

    //某个圈子里的动态列表，最新，推荐，关注
    public function topic_list(){
        $where = [];
        $topic_id = input('topic_id',0);
        if($topic_id){
            $where['dt.topic_id'] = $topic_id;
        }

        $order = input('orderby','new');
        $orderby  = 'dt.id desc';
        if($order == 'hot'){
            $orderby = 'dt.goodnum desc';
        }


        if($order == 'follow'){
            $follow_user_ids = Db::name('user_follow')->where(['uid'=>$this->auth->id])->column('follow_uid');
            $where['dt.user_id'] = ['IN',$follow_user_ids];
        }
////
        //排除屏蔽的
        $screen_ids = Db::name('topic_dongtai_screen')->where('user_id',$this->auth->id)->column('dt_id');
        if(!empty($screen_ids)){
            $where['dt.id'] = ['NOTIN',$screen_ids];
        }
        //排除黑名单的
        $where2 = [];
        $black_ids = Db::name('user_blacklist')->where('user_id',$this->auth->id)->column('black_user_id');
        if(!empty($black_ids)){
            $where2['dt.user_id'] = ['NOTIN',$black_ids];
        }

        //
        $list = Db::name('topic_dongtai')->alias('dt')
            ->join('user','dt.user_id = user.id','LEFT')
            ->join('topic_hub topic','dt.topic_id = topic.id','LEFT')
            ->field('dt.*,user.nickname,user.avatar,user.gender,topic.name as topic_name')
            ->where($where)
            ->where($where2)
            ->order($orderby)->autopage()->select();
        $list = list_domain_image($list,['images','avatar']);

        if(!empty($list)){
            foreach($list as $key => &$val){

                //追加点赞
                $val['isgood'] = $this->is_good($val['id'],$this->auth->id);

                //创建视频缩略图
                $val['images_thumb'] = '';
                if ($val['type'] == 2) {
                    $images_url = explode('.', $val['images']);
                    unset($images_url[count($images_url) - 1]);
                    $val['images_thumb'] = join('.', $images_url) . '_0.jpg';
                }

                //时间
                $val['createtime_text'] = get_last_time($val['createtime']);

                //关注
                $val['is_follow'] = $this->is_follow($this->auth->id,$val['user_id']);

                //评论
                $val['answernumber'] = Db::name('topic_dongtai_answer')->where(['dt_id'=>$val['id'],'level'=>1])->count();
            }
        }



        $this->success('success',$list);
    }

    ////////////////////////////////////////////////////////////

    //消息-互动消息-评论
    //谁评论了我的动态
    public function msg_answer(){
        $map = [
            'dt.user_id' => $this->auth->id,
            'a.level'    => 1,
        ];
        $list = Db::name('topic_dongtai_answer')->alias('a')
            ->field('a.id,a.createtime,user.nickname,user.gender,user.avatar')
            ->join('topic_dongtai dt','a.dt_id = dt.id','LEFT')
            ->join('user','a.user_id = user.id','LEFT')
            ->where($map)->order('a.id desc')->autopage()->select();
        $list = list_domain_image($list,['avatar']);
        if(!empty($list)){
            foreach($list as $key => &$val){
                //时间
                $val['createtime_text'] = get_last_time($val['createtime']);
            }
        }

        //自动全部已读
        Db::name('topic_dongtai_answer')->alias('a')
            ->join('topic_dongtai dt','a.dt_id = dt.id','LEFT')
            ->where($map)->update(['a.is_read'=>1]);

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


    //消息-互动消息-获赞
    //谁赞了我的动态
    public function msg_good(){
        $map = [
            'dt.user_id' => $this->auth->id,
        ];
        $list = Db::name('topic_dongtai_good')->alias('g')
            ->field('g.id,g.createtime,user.nickname,user.gender,user.avatar')
            ->join('topic_dongtai dt','g.dt_id = dt.id','LEFT')
            ->join('user','g.user_id = user.id','LEFT')
            ->where($map)->order('g.id desc')->autopage()->select();
        $list = list_domain_image($list,['avatar']);
        if(!empty($list)){
            foreach($list as $key => &$val){
                //时间
                $val['createtime_text'] = get_last_time($val['createtime']);
            }
        }

        //自动全部已读
        Db::name('topic_dongtai_good')->alias('g')
            ->join('topic_dongtai dt','g.dt_id = dt.id','LEFT')
            ->where($map)->update(['g.is_read'=>1]);

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

////////////////////
    //我的评论
    public function my_answer(){
        $map = [
            'a.user_id' => $this->auth->id,
            'a.level'    => 1,
        ];
        $list = Db::name('topic_dongtai_answer')->alias('a')
            ->field('a.id,a.createtime,a.content,a.dt_id,
            dt.images,dt.content as dt_content,dt.type as dt_type,dtuser.nickname as dtuser_nickname,dtuser.username as dtuser_username,user.username,
            user.nickname,user.avatar,user.gender,user.birthday,user.attribute,uw.vip_endtime')
            ->join('topic_dongtai dt','a.dt_id = dt.id','LEFT')
            ->join('user dtuser','dt.user_id = dtuser.id','LEFT')
            ->join('user user','a.user_id = user.id','LEFT')
            ->join('user_wallet uw','user.id = uw.user_id','LEFT')
            ->where($map)->order('a.id desc')->autopage()->select();
        $list = list_domain_image($list,['avatar']);
        if(!empty($list)){
            foreach($list as $key => &$val){

                //用户年龄
                $val['age'] = birthtime_to_age($val['birthday']);
                unset($val['birthday']);

                //用户vip
                $val['is_vip'] = $val['vip_endtime'] > time() ? 1 : 0;
                unset($val['vip_endtime']);

            }
        }

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

    //删除我的某个评论
    public function delete_answer(){
        $id = input('id',0);
        if(!$id){
            $this->error();
        }

        Db::startTrans();
        $info = Db::name('topic_dongtai_answer')->where('id',$id)->where('user_id',$this->auth->id)->find();
        if(!$info){
            $this->error('不存在的动态评论');
        }

        if($info['level'] == 1){


            //楼层内都删
            $louceng_id = Db::name('topic_dongtai_answer')->where('dt_id',$info['dt_id'])->where('level',2)->where('floor',$info['floor'])->column('id');
            if(!empty($louceng_id)){
                Db::name('topic_dongtai')->where('id',$info['dt_id'])->setDec('answernum',count($louceng_id));//回复数减1
                Db::name('topic_dongtai_answer')->where('id','IN',$louceng_id)->delete();//评论删掉
                Db::name('topic_answer_good')->where('answer_id','IN',$louceng_id)->delete();//评论点赞删掉
            }

        }

        Db::name('topic_dongtai')->where('id',$info['dt_id'])->setDec('answernum');//回复数减1
        Db::name('topic_dongtai_answer')->where('id',$id)->delete();  //评论删掉
        Db::name('topic_answer_good')->where('answer_id',$id)->delete();//评论点赞删掉

        Db::commit();

        $this->success();
    }


    //我点赞的动态
    public function my_good(){


        $where = ['good.user_id'=>$this->auth->id];


        $list = Db::name('topic_dongtai')->alias('dt')
            ->join('user','dt.user_id = user.id','LEFT')
            ->join('user_wallet uw','user.id = uw.user_id','LEFT')
            ->join('topic_dongtai_good good','dt.id = good.dt_id','LEFT')
            ->field('dt.*,dt.id as dt_id,user.username,user.nickname,user.avatar,user.gender,user.birthday,user.attribute,uw.vip_endtime')
            ->where($where)
            ->order('dt.id desc')->autopage()->select();
        $list = list_domain_image($list,['images','audio_file','avatar']);

        if(!empty($list)){
            foreach($list as $key => &$val){
                $val['aite'] = json_decode($val['aite'],true);

                //用户年龄
                $val['age'] = birthtime_to_age($val['birthday']);
                unset($val['birthday']);

                //用户vip
                $val['is_vip'] = $val['vip_endtime'] > time() ? 1 : 0;
                unset($val['vip_endtime']);

                //追加点赞
                $val['isgood'] = $this->is_good($val['id'],$this->auth->id);

                //时间
                $val['createtime_text'] = get_last_time($val['createtime']);

                //关注
                $val['is_follow'] = $this->is_follow($this->auth->id,$val['user_id']);

                //收藏
                $val['is_collect'] = $this->is_collect($val['id'],$this->auth->id);

                //拉黑
                $val['is_black'] = $this->is_black($this->auth->id,$val['user_id']);

                //层主评论数量
                $val['answernumber'] = Db::name('topic_dongtai_answer')->where(['dt_id'=>$val['id'],'level'=>1])->count();

                //话题
                $ids_str = $val['topic_ids'];
                if($ids_str){
                    $val['topic_text'] = Db::name('topic_hub')->where('id','IN',$val['topic_ids'])->orderRaw('field(id,'.$ids_str.')')->column('name');
                }else{
                    $val['topic_text'] = [];
                }
            }
        }

        $this->success('success',$list);
    }



}