tanhui/application/api/controller/Operation.php

<?php

// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: http://demo.thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------

namespace app\api\controller;

use app\api\controller\Base;
use think\Db;
use think\Model;
/**
 * @title 操作管理（关注，评论，点赞，收藏。。。）
 * @controller Operation
 * @group member
 */
class Operation extends Base
{
    function initialize()
    {
        $this->check_login();
    }
    /**
     * @title 关注/取消关注
     * @desc 关注/取消关注
     * @author QGF
     * @url /api/Operation/attention
     * @method GET
     * @tag 关注/取消关注
     * @header name:Authorization require:1 desc:Token
     * @param name:user_id type:int require:1 default:-- desc:被关注/取消关注的用户ID/媒体ID（详情返回的user_id字段）
     * @param name:operation_type type:int require:1 default:-- desc:操作类型（0：取消关注，1：关注）
     */
    public function attention(){
        $uid = $this->uid;
        $user_id = input('user_id');
        $type = input('operation_type');
        if(empty($user_id) || !isset($type)){
            $this->error('参数错误');
        }
        if($uid == $user_id){
            $this->error('不能操作自己');
        }
        $attention = Db::name('store_attention')->where('user_id',$uid)->where('from_user_id',$user_id)->find();
        $msg = '关注成功';
        if($type == 0){    //取消关注
            if(empty($attention['status'])){
                $this->error('没关注无需取消');
            }
            Db::name('store_attention')->where('user_id',$uid)->where('from_user_id',$user_id)->update(array('status'=>0));
            $msg = '取消成功';
        }else{
            if(!empty($attention['status'])){
                $this->error('已关注无需继续关注');
            }
            if($attention['id']){
                Db::name('store_attention')->where('user_id',$uid)->where('from_user_id',$user_id)->update(array('status'=>1));
            }else{
                $data = array(
                    'user_id' => $uid,
                    'from_user_id' => $user_id,
                    'type' => user_type($user_id),
                    'status' => 1
                );
                Db::name('store_attention')->insert($data);
            }
        }
        $this->success($msg);
    }
    /**
     * @title 提交评论
     * @desc 提交评论
     * @author QGF
     * @url /api/Operation/submit_comment
     * @method GET
     * @tag 提交评论
     * @header name:Authorization require:1 desc:Token
     * @param name:type type:int require:1 default:-- desc:类型（1：新闻，2：咨询）
     * @param name:id type:int require:1 default:-- desc:新闻ID或咨询ID
     * @param name:content type:string require:1 default:-- desc:评论内容
     */
    public function submit_comment(){
        $uid = $this->uid;
        $type = input('type');
        $id = input('id');
        $content = input('content');
        if(empty($type) || empty($id) || empty($content)){
            $this->error('参数错误');
        }
        $table_nme = $type==1?'store_goods':'store_consult';
        $type_name = $type==1?'新闻':'咨询';
        $info = Db::name($table_nme)->field('user_id,title')->where('id',$id)->where('status',1)->where('is_deleted',0)->find();
        if(empty($info)){
            $this->error($type_name.'信息有误');
        }
        if($uid == $info['user_id']){
            $this->error('不能操作自己');
        }
        $comment_info = Db::name('store_comment')->field('id')->where('user_id',$uid)->where('forum_id',$id)->where('type',1)->where('forum_type',$type)->find();
        if(!empty($comment_info)){
            $this->error('已评论过该'.$type_name);
        }
        $comment_data = array(
            'user_id' => $uid,
            'from_user_id' => $info['user_id'],
            'forum_id' => $id,
            'content' => $content,
            'forum_type' => $type,
            'type' => 1
        );
        Db::name('store_comment')->insert($comment_data);
        $comment_id = Db::name('store_comment')->getLastInsID();
        Db::name('store_comment')->where('id',$comment_id)->update(array('root_comment_id'=>$comment_id));
        $user_type = user_type($info['user_id']);
        if($user_type == 1){       //用户发表的咨询有评论的会给发表者发送信息通知
            $user_name = Db::name('store_member')->where('id',$uid)->value('name');
            $news_data = array(
                'user_id' => $info['user_id'],  //获得这个消息的会员
                'content' => $user_name.'评论了你发表的['.$info['title'].']咨询',
                'comment_user_id' => $uid,
                'type' => 2,
            );
            Db::name('store_news')->insert($news_data);
        }
        $this->success('评论成功');
    }
    /**
     * @title 回复评论
     * @desc 回复评论
     * @author QGF
     * @url /api/Operation/reply_comment
     * @method GET
     * @tag 回复评论
     * @header name:Authorization require:1 desc:Token
     * @param name:comment_id type:int require:1 default:-- desc:要回复的评论ID
     * @param name:content type:string require:1 default:-- desc:评论内容
     */
    public function reply_comment(){
        $uid = $this->uid;
        $comment_id = input('comment_id');//要回复的评论ID
        $content = input('content');//回复评论的内容
        if(empty($content) || empty($comment_id)){
            $this->error('参数错误');
        }
        $comment = Db::name('store_comment')->field('forum_id,user_id,root_comment_id,forum_type')->where('id',$comment_id)->find();
        if(empty($comment)){
            $this->error('要回复的评论信息有误');
        }
        if($comment['user_id'] == $uid){
            $this->error('不能回复自己的评论');
        }
        //判断要是否回复过次评论了
        $reply_comment = Db::name('store_comment')->field('id')->where('user_id',$uid)->where('type',2)->where('comment_id',$comment_id)->find();
        if(!empty($reply_comment)){
            $this->error('已回复过此评论');
        }
        $root_comment_id = $comment['root_comment_id']?$comment['root_comment_id']:$comment_id;
        $comment_data = array(
            'forum_id' => $comment['forum_id'],
            'user_id' => $uid,
            'from_user_id' => $comment['user_id'],
            'content' => $content,
            'comment_id' => $comment_id,
            'forum_type' => $comment['forum_type'],
            'root_comment_id' => $root_comment_id,
            'type' => 2
        );
        Db::name('store_comment')->insert($comment_data);
        //回复的谁给谁消息通知
        $user_name = Db::name('store_member')->where('id',$uid)->value('name');
        $news_data = array(
            'user_id' => $comment['user_id'],  //获得这个消息的会员
            'content' => $user_name.'回复的你的评论',
            'comment_user_id' => $uid,
            'type' => 2,
        );
        Db::name('store_news')->insert($news_data);
        $this->success('回复评论成功');
    }
    /**
     * @title 点赞/取消点赞
     * @desc 点赞/取消点赞
     * @author QGF
     * @url /api/Operation/like
     * @method GET
     * @tag 点赞/取消点赞
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:新闻或咨询ID
     * @param name:operation_type type:int require:1 default:-- desc:操作类型（0：取消点赞，1：点赞）
     * @param name:type type:int require:1 default:-- desc:信息类型（1：新闻，2：咨询）
     */
    public function like(){
        $uid = $this->uid;
        $id = input('id');
        $operation_type = input('operation_type');
        $type = input('type');
        if(empty($id) || !isset($operation_type) || empty($type)){
            $this->error('参数错误');
        }
        $table_nme = $type==1?'store_goods':'store_consult';
        $type_name = $type==1?'新闻':'咨询';
        $info = Db::name($table_nme)->field('user_id')->where('id',$id)->where('status',1)->where('is_deleted',0)->find();
        if(empty($info)){
            $this->error($type_name.'信息有误');
        }
        if($uid == $info['user_id']){
            $this->error('不能操作自己');
        }
        $like = Db::name('store_like')->where('user_id',$uid)->where('forum_id',$id)->where('user_id',$uid)->find();
        $msg = '点赞成功';
        if($operation_type == 0){    //取消关注
            if(empty($like['status'])){
                $this->error('没点赞无需取消');
            }
            Db::name('store_like')->where('user_id',$uid)->where('forum_id',$id)->update(array('status'=>0));
            $msg = '取消成功';
        }else{
            if(!empty($like['status'])){
                $this->error('已点赞无需继续点赞');
            }
            if($like['id']){
                Db::name('store_like')->where('user_id',$uid)->where('forum_id',$id)->where('type',$type)->update(array('status'=>1));
            }else{
                $data = array(
                    'user_id' => $uid,
                    'from_user_id' => $info['user_id'],
                    'forum_id' => $id,
                    'type' => $type,
                    'status' => 1
                );
                Db::name('store_like')->insert($data);
            }
        }
        $this->success($msg);
    }
    /**
     * @title 收藏/取消收藏
     * @desc 收藏/取消收藏
     * @author QGF
     * @url /api/Operation/collect
     * @method GET
     * @tag 收藏/取消收藏
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:新闻或咨询ID
     * @param name:operation_type type:int require:1 default:-- desc:操作类型（0：取消收藏，1：收藏）
     * @param name:type type:int require:1 default:-- desc:信息类型（1：新闻，2：咨询）
     */
    public function collect(){
        $uid = $this->uid;
        $id = input('id');
        $operation_type = input('operation_type');
        $type = input('type');
        if(empty($id) || !isset($operation_type) || empty($type)){
            $this->error('参数错误');
        }
        $table_nme = $type==1?'store_goods':'store_consult';
        $type_name = $type==1?'新闻':'咨询';
        $info = Db::name($table_nme)->field('user_id')->where('id',$id)->where('status',1)->where('is_deleted',0)->find();
        if(empty($info)){
            $this->error($type_name.'信息有误');
        }
        if($uid == $info['user_id']){
            $this->error('不能操作自己');
        }
        $collect = Db::name('store_collect')->where('user_id',$uid)->where('forum_id',$id)->where('type',$type)->find();
        $msg = '收藏成功';
        if($operation_type == 0){    //取消收藏
            if(empty($collect['status'])){
                $this->error('没收藏无需取消');
            }
            Db::name('store_collect')->where('user_id',$uid)->where('forum_id',$id)->where('type',$type)->update(array('status'=>0));
            $msg = '取消成功';
        }else{
            if(!empty($collect['status'])){
                $this->error('已收藏无需继续点赞');
            }
            if($collect['id']){
                Db::name('store_collect')->where('user_id',$uid)->where('forum_id',$id)->where('type',$type)->update(array('status'=>1));
            }else{
                $data = array(
                    'user_id' => $uid,
                    'from_user_id' => $info['user_id'],
                    'forum_id' => $id,
                    'type' => $type,
                    'status' => 1
                );
                Db::name('store_collect')->insert($data);
            }
        }
        $this->success($msg);
    }
    /**
     * @title 转发
     * @desc 转发（转发成功调用此接口）
     * @author QGF
     * @url /api/Operation/transpond
     * @method GET
     * @tag 转发
     * @header name:Authorization require:1 desc:Token
     * @param name:id type:int require:1 default:-- desc:新闻或咨询ID
     * @param name:type type:int require:1 default:-- desc:信息类型（1：新闻，2：咨询）
     */
    public function transpond(){
        $uid = $this->uid;
        $id = input('id');
        $type = input('type');
        if(empty($id) || empty($type)){
            $this->error('参数错误');
        }
        $table_nme = $type==1?'store_goods':'store_consult';
        $type_name = $type==1?'新闻':'咨询';
        $info = Db::name($table_nme)->field('user_id')->where('id',$id)->where('status',1)->where('is_deleted',0)->find();
        if(empty($info)){
            $this->error($type_name.'信息有误');
        }
        if($uid == $info['user_id']){
            $this->error('不能操作自己');
        }
        $data = array(
            'user_id' => $uid,
            'forum_id' => $id,
            'type' => $type
        );
        Db::name('store_transpond')->insert($data);
        $this->success('操作成功');
    }
}