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($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('点赞失败'); } //系统消息 $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']; } $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']); } } $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); } //////////////////// //我的评论 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); } }