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'); 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['createtime_text'] = get_last_time($val['createtime']); //关注 $val['is_follow'] = $this->is_follow($val['user_id'],$this->auth->id); //评论 $val['answernumber'] = Db::name('topic_dongtai_answer')->where(['dt_id'=>$val['id'],'level'=>1])->count(); } } $this->success('success',$list); } //动态删除 public function delete(){ try { $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)) { throw new Exception('未找到动态信息'); } $delRes = Db::name('topic_dongtai')->where('id',$id)->where('user_id',$this->auth->id)->delete(); if (!$delRes) { throw new Exception('动态删除失败'); } //圈子新增一个贴 if (!empty($dongtai['topic_id'])) { $res = Db::name('topic_hub')->where('id',$dongtai['topic_id'])->setDec('t_number'); if (!$res) { throw new Exception('更新话题数量失败'); } } $this->success('删除成功'); } catch (Exception $e) { $this->error($e->getMessage()); } } //是否点赞 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; } } //是否关注 private function is_follow($user_id,$fans_id){ $where = [ 'user_id' => $user_id, 'fans_id' => $fans_id, ]; $check = Db::name('user_fans_follow')->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($info['user_id'],$this->auth->id); //评论 $info['answernumber'] = Db::name('topic_dongtai_answer')->where(['dt_id'=>$id,'level'=>1])->count(); //$info['answer'] = $this->answer_list($id); } $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(); if($check){ $this->error('已经赞过了'); } Db::startTrans(); $where['createtime'] = time(); $rs = Db::name('topic_dongtai_good')->insertGetId($where); $up = Db::name('topic_dongtai')->where('id',$id)->setInc('goodnum'); if($rs && $up !== false){ \app\common\model\TaskLog::tofinish($this->auth->id,"VpXtablCsZ",1); Db::commit(); $this->success('点赞成功'); } Db::rollback(); $this->error('点赞失败'); } //评论 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'); 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){ $this->error('已经赞过了'); } 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(){ $topic_id = input('topic_id',0); $order = input('orderby','new'); $orderby = 'dt.id desc'; if($order == 'hot'){ $orderby = 'dt.goodnum desc'; } $where = []; if($topic_id){ $where['dt.topic_id'] = $topic_id; } if($order == 'follow'){ $follow_user_ids = Db::name('user_fans_follow')->where(['fans_id'=>$this->auth->id])->column('user_id'); $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($val['user_id'],$this->auth->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']); } } $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']); } } $this->success(1,$list); } }