<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/12/18
 * Time: 11:12
 */

namespace app\api\controller;


use app\common\controller\Api;
use fast\Http;
use think\Db;
use think\Validate;

/**
 * 项目模块
 */
class Project extends Api
{
    /**
     * @ApiTitle    (农场管理中农场信息)
     * @ApiSummary  (农场管理中农场信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/farm)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id":"id",//农场id
            "name"://农场名称
            "avatar"://头像
            "score":"",//累计公分
        }
        })
     */
    public function farm()
    {
        $user_id = $this->getUserId();
        $farm = Db::name('farm')
            ->alias('a')
            ->join('user r','a.user_id = r.id')
            ->where('a.user_id',$user_id)
            ->field('a.id,a.name,r.avatar,r.score')
            ->find();
        $this->success('success',$farm);
    }

    /**
     * @ApiTitle    (项目列表)
     * @ApiSummary  (项目列表)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/get_all)
     *
     * @ApiParams   (name="farm_id", type="int", required=false, description="农场id")
     * @ApiParams   (name="page", type="inter", required=false, description="当前页(默认1)")
     * @ApiParams   (name="pageNum", type="inter", required=false, description="每页显示数据个数（默认10）")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id":"id",//项目id
            "project_name"://项目名称
            "image":"image",//项目封面图
            "content"://项目简介
            "look_num":"look_num",//浏览量
            "good_num":"good_num",//点赞量
            "status"://项目状态（0培育中1将收获2已收获）
            "createtime":"createtime",//创建时间
            "shou"://授权   0不显示1授权2已授权
        }
        })
     */
    public function get_all()
    {
        $token = $this->request->header('token');
        if(empty($token)){
            $page = $this->request->param('page',1,'intval');
            $pageNum = $this->request->param('pageNum',10,'intval');
            $farm_id = $this->request->param('farm_id');
            if(empty($farm_id)){
                $this->error('缺少必要参数');
            }
            $data = Db::name('project')
                ->where('farm_id',$farm_id)
                ->field('id,project_name,image,content,look_num,good_num,status,createtime')
                ->order('id desc')
                ->page($page,$pageNum)
                ->select();
            foreach ($data as &$v){
                $v['image'] = 'http://q2ugvq3qf.bkt.clouddn.com'.$v['image'];
                $v['createtime'] = date('Y-m-d',$v['createtime']);
            }
            $this->success('success',$data);
        }else{
            $user_id = $this->getUserId();
            $shen = Db::name('user')->where('id',$user_id)->field('id,identity')->find();
            if($shen['identity'] == 1 || $shen['identity'] == 2 || $shen['identity'] == 5){
                $page = $this->request->param('page',1,'intval');
                $pageNum = $this->request->param('pageNum',10,'intval');
                $farm_id = $this->request->param('farm_id');
                if(empty($farm_id)){
                    $this->error('缺少必要参数');
                }
                $data = Db::name('project')
                    ->where('farm_id',$farm_id)
                    ->field('id,project_name,image,content,look_num,good_num,status,createtime')
                    ->order('id desc')
                    ->page($page,$pageNum)
                    ->select();
                foreach ($data as &$v){
                    $v['shou'] = 0;
                    $v['image'] = 'http://q2ugvq3qf.bkt.clouddn.com'.$v['image'];
                    $v['createtime'] = date('Y-m-d',$v['createtime']);
                }
                $this->success('success',$data);
            }else{
                $page = $this->request->param('page',1,'intval');
                $pageNum = $this->request->param('pageNum',10,'intval');
                $farm_id = $this->request->param('farm_id');
                if(empty($farm_id)){
                    $this->error('缺少必要参数');
                }
                $data = Db::name('project')
                    ->where('farm_id',$farm_id)
                    ->field('id,project_name,image,content,look_num,good_num,status,createtime')
                    ->order('id desc')
                    ->page($page,$pageNum)
                    ->select();
                foreach ($data as &$v){
                    $impower = Db::name('impower')->where('project_id',$v['id'])->find();
                    if(!empty($impower)){
                        $v['shou'] = 1;
                    }else{
                        $v['shou'] = 2;
                    }
                    $v['image'] = 'http://q2ugvq3qf.bkt.clouddn.com'.$v['image'];
                    $v['createtime'] = date('Y-m-d',$v['createtime']);
                }
                $this->success('success',$data);
            }
        }

    }

    /**
     * @ApiTitle    (添加项目)
     * @ApiSummary  (添加项目)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/getadd)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="farm_id", type="int", required=false, description="农场id")
     * @ApiParams   (name="image", type="int", required=false, description="产品图片")
     * @ApiParams   (name="project_name", type="string", required=false, description="项目名称")
     * @ApiParams   (name="name", type="int", required=false, description="产品名称")
     * @ApiParams   (name="content", type="string", required=false, description="项目简介")
     * @ApiParams   (name="address", type="string", required=false, description="产品位置")
     * @ApiParams   (name="province", type="string", required=false, description="省份信息")
     * @ApiParams   (name="city", type="string", required=false, description="市区信息")
     * @ApiParams   (name="county", type="string", required=false, description="区县信息")
     * @ApiParams   (name="lng", type="string", required=false, description="经度")
     * @ApiParams   (name="lat", type="string", required=false, description="纬度")
     * @ApiParams   (name="status", type="int", required=false, description="项目状态（0培育中1将收获2已收获）")
     * @ApiParams   (name="estimate", type="string", required=false, description="预估产量")
     * @ApiParams   (name="estimate_time", type="string", required=false, description="预估成熟期")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
        }
        })
     */
    public function getadd()
    {
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $validate = new Validate([
            'farm_id' => 'require',
            'image' => 'require',
            'project_name' => 'require',
            'name'=>'require',
            'content'=>'require',
            'province'=>'require',
            'city' => 'require',
            'county' => 'require',
            'address' => 'require',
            'lng'=>'require',
            'lat'=>'require',
            'estimate'=>'require',
            'estimate_time'=>'require',
            'status'=>'require'
        ]);
        if (!$validate->check($param)) {
            $this->error($validate->getError());
        }
        $http = 'http://q2ugvq3qf.bkt.clouddn.com';
        $param['image'] = str_replace($http,'',$param['image']);
        $param['createtime'] = time();
        $data = Db::name('project')->insertGetId($param);
        $common = new Common();
        $url = 'pages/ShopDetail/ShopDetail?id='.$data;
        $thumbnail = $common->imgcode($data,$url);
        Db::name('project')->where('id',$data)->update(['thumbnail'=>$thumbnail]);

        //修改农场项目数
        $project_num = Db::name('farm')->where('id',$param['farm_id'])->field('id,project_num')->find();
        $project_num = $project_num['project_num'] + 1;
        Db::name('farm')->where('id',$param['farm_id'])->update(['project_num'=>$project_num]);
        if($data){
            $this->success('添加成功',$data);
        }else{
            $this->error('添加失败');
        }
    }

    /**
     * @ApiTitle    (项目详情)
     * @ApiSummary  (项目详情)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/detail)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="id", type="int", required=false, description="项目id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "images"://项目banner
            "project_name"://项目名称
            "status"://项目状态（0培育中1将收获2已收获）
            "content"://项目简介
            "look_num":"look_num",//浏览量
            "good_num":"good_num",//点赞量
            "farm_name"://农场名称
            "farm_content"://农场简介
            "is_guan"://是否关注(1否2是)
            "is_zan"://是否点过赞(1否2是)
            "farm_id"://农场ID
            "nong_name"://农场主名字
            "name"://作物名称
            "farm_address":农场位置
            "estimate"://预估产值
            "estimate_time"://预估成熟期
            "company_name"://企业名称
            "lng"://经度
            "lat"://纬度
            }
        })
     */
    public function detail()
    {
        $token = $this->request->header('token');
        if(empty($token)){
            $id = $this->request->param('id');
            if(empty($id)){
                $this->error('缺少必要参数');
            }
            $data = Db::name('project')
                ->where('id',$id)
                ->find();
            $look_num = $data['look_num']+1;
            Db::name('project')->where('id',$id)->update(['look_num'=>$look_num]);
            $data['image'] = explode(',',$data['image']);
            foreach ($data['image'] as &$val){
                $val = 'http://q2ugvq3qf.bkt.clouddn.com'.$val;
            }
            $data['images'] = explode(',',$data['images']);
            foreach ($data['images'] as &$v){
                $v = 'http://q2ugvq3qf.bkt.clouddn.com'.$v;
            }
            //查出项目对应的农场名称以及农场简介
            $farm = Db::name('farm')
                ->alias('a')
                ->join('user b','a.user_id = b.id')
                ->where('a.id',$data['farm_id'])
                ->field('a.id,a.name,a.content,a.province,a.city,a.address,a.user_id,b.avatar')
                ->find();
            $data['farm_address'] = $farm['address'];
            $data['avatar'] = $farm['avatar'];
            $data['farm_id'] = $farm['id'];
            $data['farm_name'] = $farm['name'];
            $data['farm_content'] = $farm['content'];

            //查看用户对该项目是否点过赞  默认都为未点赞
            $data['is_zan'] = 1;

            //查看用户是否关注过该农场   默认都为未关注
            $data['is_guan'] = 1;

            $user = Db::name('user')->where('id',$farm['user_id'])->field('identity')->find();
            if($user['identity'] == 3){
                $company = Db::name('company')
                    ->where('user_id',$farm['user_id'])
                    ->field('company_name,name')
                    ->find();
                $data['nong_name'] = $company['name'];
                $data['company_name'] = $company['company_name'];
            }else{
                $company = Db::name('personage')
                    ->where('user_id',$farm['user_id'])
                    ->field('id,name')
                    ->find();
                $data['nong_name'] = $company['name'];
                $data['company_name'] = '';
            }
            $this->success('success',$data);
        }
        $user_id = $this->getUserId();
        $id = $this->request->param('id');
        if(empty($id)){
            $this->error('缺少必要参数');
        }
        $data = Db::name('project')
            ->where('id',$id)
            ->find();
        $look_num = $data['look_num']+1;
        Db::name('project')->where('id',$id)->update(['look_num'=>$look_num]);
        $data['image'] = explode(',',$data['image']);
        foreach ($data['image'] as &$val){
            $val = 'http://q2ugvq3qf.bkt.clouddn.com'.$val;
        }
        $data['images'] = explode(',',$data['images']);
        foreach ($data['images'] as &$v){
            $v = 'http://q2ugvq3qf.bkt.clouddn.com'.$v;
        }
        //查出项目对应的农场名称以及农场简介
        $farm = Db::name('farm')
            ->alias('a')
            ->join('user b','a.user_id = b.id')
            ->where('a.id',$data['farm_id'])
            ->field('a.id,a.name,a.content,a.province,a.city,a.address,a.user_id,b.avatar')
            ->find();
        $data['farm_address'] = $farm['address'];
        $data['avatar'] = $farm['avatar'];
        $data['farm_id'] = $farm['id'];
        $data['farm_name'] = $farm['name'];
        $data['farm_content'] = $farm['content'];

        //查看用户对该项目是否点过赞
        $is_zan = Db::name('good')
            ->where('user_id',$user_id)
            ->where('project_id',$id)
            ->find();
        if(empty($is_zan)){
            $data['is_zan'] = 1;
        }else{
            $data['is_zan'] = 2;
        }

        //查看用户是否关注过该农场
        $guan = Db::name('guanzhu')
            ->where('user_id',$user_id)
            ->where('farm_id',$farm['id'])
            ->find();
        if(empty($guan)){
            $data['is_guan'] = 1;
        }else{
            $data['is_guan'] = 2;
        }
        $user = Db::name('user')->where('id',$farm['user_id'])->field('identity')->find();
        if($user['identity'] == 3){
            $company = Db::name('company')
                ->where('user_id',$farm['user_id'])
                ->field('company_name,name')
                ->find();
            $data['nong_name'] = $company['name'];
            $data['company_name'] = $company['company_name'];
        }else{
            $company = Db::name('personage')
                ->where('user_id',$farm['user_id'])
                ->field('id,name')
                ->find();
            $data['nong_name'] = $company['name'];
            $data['company_name'] = '';
        }
        $this->success('success',$data);
    }

    /**
     * @ApiTitle    (项目溯源)
     * @ApiSummary  (项目溯源)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/pro_record)
     *
     * @ApiParams   (name="id", type="int", required=false, description="项目id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id"://溯源记录ID
            "image"://产品图片或者视频
            "status"://项目状态（0培育中1将收获2已收获）
            "theme"://溯源主题
            "avatar"://用户头像
            "nickname"://农户昵称
            "content"://溯源记录备注
            "week"://星期
            "weather":天气
            "humidity"://湿度
            "temperature"://温度
            "wind"://风力
            "air"://空气质量
            "createtime":创建时间
        }
        })
     */
    public function pro_record()
    {
        $project_id = $this->request->param('id');
        $data = Db::name('record')
            ->alias('a')
            ->join('user b','a.user_id = b.id')
            ->field('a.*,b.avatar,b.nickname')
            ->where('a.project_id',$project_id)
            ->order('a.createtime desc')
            ->select();
        foreach ($data as &$v){
            $v['image'] = explode(',',$v['image']);
            foreach ($v['image'] as &$val){
                $val = 'http://q2ugvq3qf.bkt.clouddn.com'.$val;
            }
            $v['createtime'] = date('Y-m-d',$v['createtime']);
        }

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

    /**
     * @ApiTitle    (项目点赞)
     * @ApiSummary  (项目点赞)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/good)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="project_id", type="int", required=false, description="项目id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
        }
        })
     */
    public function good(){
        $param['user_id'] = $this->getUserId();
        $param['project_id'] = $this->request->param('project_id');
        if(empty($param['project_id'])){
            $this->error('缺少必要参数');
        }
        $farm = Db::name('project')
            ->where('id',$param['project_id'])
            ->field('id,farm_id,good_num')
            ->find();
        $good_num = $farm['good_num']+1;
        $param['farm_id'] = $farm['farm_id'];
        $param['createtime'] = time();

        //查询是否已经点过赞
        $zan = Db::name('good')
            ->where('user_id',$param['user_id'])
            ->where('project_id',$param['project_id'])
            ->find();
        if(!empty($zan)){
            $this->error('操作频繁');
        }
        Db::startTrans();
        $data = Db::name('good')
            ->insertGetId($param);
        $res = Db::name('project')
            ->where('id',$param['project_id'])
            ->update(['good_num'=>$good_num]);
        if($data && $res){
            Db::commit();
            $this->success('成功');
        }else{
            Db::rollback();
            $this->error('失败');
        }
    }

    /**
     * @ApiTitle    (项目取消点赞)
     * @ApiSummary  (项目取消点赞)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/nogood)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="project_id", type="int", required=false, description="项目id")
     *
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    }
    })
     */
    public function nogood(){
        $param['user_id'] = $this->getUserId();
        $param['project_id'] = $this->request->param('project_id');
        if(empty($param['project_id'])){
            $this->error('缺少必要参数');
        }
        $farm = Db::name('project')
            ->where('id',$param['project_id'])
            ->field('id,farm_id,good_num')
            ->find();
        $good_num = $farm['good_num']-1;
        $param['farm_id'] = $farm['farm_id'];
        $where['user_id'] = ['eq',$param['user_id']];
        $where['project_id'] = ['eq',$param['project_id']];
        $where['farm_id'] = ['eq',$param['farm_id']];
        Db::startTrans();
        $data = Db::name('good')
            ->where($where)
            ->delete();
        $res = Db::name('project')
            ->where('id',$param['project_id'])
            ->update(['good_num'=>$good_num]);
        if($data && $res){
            Db::commit();
            $this->success('成功');
        }else{
            Db::rollback();
            $this->error('失败');
        }
    }

    /**
     * @ApiTitle    (农场关注)
     * @ApiSummary  (农场关注)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/guanzhu)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="farm_id", type="int", required=false, description="农场id")
     *
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    }
    })
     */
    public function guanzhu()
    {
        $param['user_id'] = $this->getUserId();

        $identity = Db::name('user')->where('id',$param['user_id'])->field('id,identity')->find();
        if($identity['identity'] == 4 || $identity['identity'] == 1){
            $param['farm_id'] = $this->request->param('farm_id');
            if(empty($param['farm_id'])){
                $this->error('缺少必要参数');
            }
            $is_guan = Db::name('guanzhu')
                ->where('user_id',$param['user_id'])
                ->where('farm_id',$param['farm_id'])
                ->find();
            if(!empty($is_guan)){
                $this->error('操作频繁');
            }
            $param['createtime'] = time();
            //将农场的粉丝数加一
            $fun_num = Db::name('farm')
                ->where('id',$param['farm_id'])
                ->field('id,fun_num')
                ->find();
            $fun_num = $fun_num['fun_num'] + 1;
            Db::startTrans();
            $data = Db::name('guanzhu')
                ->insertGetId($param);
            $res = Db::name('farm')
                ->where('id',$param['farm_id'])
                ->update(['fun_num'=>$fun_num]);
            if($data && $res){
                Db::commit();
                $this->success('成功');
            }else{
                Db::rollback();
                $this->error('失败');
            }
        }
        $param['farm_id'] = $this->request->param('farm_id');
        if(empty($param['farm_id'])){
            $this->error('缺少必要参数');
        }
        $is_guan = Db::name('guanzhu')
            ->where('user_id',$param['user_id'])
            ->where('farm_id',$param['farm_id'])
            ->find();
        if(!empty($is_guan)){
            $this->error('操作频繁');
        }
        $param['createtime'] = time();
        $fun_num = Db::name('farm')
            ->where('id',$param['farm_id'])
            ->field('id,fun_num')
            ->find();
        $fun_num = $fun_num['fun_num'] + 1;

        //将用户的关注数加1
        $info = Db::name('farm')
            ->where('user_id',$param['user_id'])
            ->find();

        $attention_num = $info['attention_num'] + 1;

        Db::startTrans();
        $atte = Db::name('farm')
            ->where('user_id',$param['user_id'])
            ->update(['attention_num'=>$attention_num]);
        $data = Db::name('guanzhu')
            ->insertGetId($param);
        $res = Db::name('farm')
            ->where('id',$param['farm_id'])
            ->update(['fun_num'=>$fun_num]);
        if($data && $res && $atte){
            Db::commit();
            $this->success('成功');
        }else{
            Db::rollback();
            $this->error('失败');
        }
    }

    /**
     * @ApiTitle    (农场取消关注)
     * @ApiSummary  (农场取消关注)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/noguan)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="farm_id", type="int", required=false, description="农场id")
     *
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    }
    })
     */
    public function noguan()
    {
        $param['user_id'] = $this->getUserId();
        $identity = Db::name('user')->where('id',$param['user_id'])->field('id,identity')->find();

        //判断其身份
        if($identity['identity']==1 || $identity['identity']==4){
            //如果身份是游客或者是政府
            $param['farm_id'] = $this->request->param('farm_id');
            if(empty($param['farm_id'])){
                $this->error('缺少必要参数');
            }
            $is_guan = Db::name('guanzhu')
                ->where('user_id',$param['user_id'])
                ->where('farm_id',$param['farm_id'])
                ->find();
            if(empty($is_guan)){
                $this->error('操作频繁');
            }
            $fun_num = Db::name('farm')
                ->where('id',$param['farm_id'])
                ->field('id,fun_num')
                ->find();
            $fun_num = $fun_num['fun_num'] - 1;

            $where['user_id'] = $param['user_id'];
            $where['farm_id'] = $param['farm_id'];

            Db::startTrans();
            $data = Db::name('guanzhu')
                ->where($where)
                ->delete();
            $res = Db::name('farm')
                ->where('id',$param['farm_id'])
                ->update(['fun_num'=>$fun_num]);
            if($data && $res){
                Db::commit();
                $this->success('成功');
            }else{
                Db::rollback();
                $this->error('失败');
            }
        }
        $param['farm_id'] = $this->request->param('farm_id');
        if(empty($param['farm_id'])){
            $this->error('缺少必要参数');
        }
        $is_guan = Db::name('guanzhu')
            ->where('user_id',$param['user_id'])
            ->where('farm_id',$param['farm_id'])
            ->find();
        if(empty($is_guan)){
            $this->error('操作频繁');
        }
        $fun_num = Db::name('farm')
            ->where('id',$param['farm_id'])
            ->field('id,fun_num')
            ->find();
        $fun_num = $fun_num['fun_num'] - 1;

        //将用户的关注数减1
        $info = Db::name('farm')
            ->where('user_id',$param['user_id'])
            ->find();

        $attention_num = $info['attention_num'] - 1;
        $where['user_id'] = $param['user_id'];
        $where['farm_id'] = $param['farm_id'];

        Db::startTrans();
        $atte = Db::name('farm')
            ->where('user_id',$param['user_id'])
            ->update(['attention_num'=>$attention_num]);
        $data = Db::name('guanzhu')
            ->where($where)
            ->delete();
        $res = Db::name('farm')
            ->where('id',$param['farm_id'])
            ->update(['fun_num'=>$fun_num]);
        if($data && $res && $atte){
            Db::commit();
            $this->success('成功');
        }else{
            Db::rollback();
            $this->error('失败');
        }
    }

    /**
     * @ApiTitle    (我的关注)
     * @ApiSummary  (我的关注)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/myguan)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id"://关注ID
            "avatar"://用户头像
            "user_id"://用户ID
            "farm_id"://农场id
            "createtime"://创建时间
            "name"://农场名称
            "project_num"://项目数量
            "fun_name"://粉丝数量
        }
        })
     */
    public function myguan()
    {

        $user_id = $this->getUserId();
        $data = Db::name('guanzhu')
            ->where('user_id',$user_id)
            ->select();
        foreach ($data as &$v){
            $farm = Db::name('farm')
                ->alias('a')
                ->join('user b','a.user_id = b.id')
                ->where('a.id',$v['farm_id'])
                ->field('a.name,a.project_num,a.fun_num,b.avatar')
                ->find();
            $v['name'] = $farm['name'];
            $v['project_num'] = $farm['project_num'];
            $v['fun_num'] = $farm['fun_num'];
            $v['avatar'] = $farm['avatar'];
        }
        $this->success('success',$data);
    }

    /**
     * @ApiTitle    (我的粉丝)
     * @ApiSummary  (我的粉丝)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/myfun)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
        "id"://关注ID
        "user_avatar"://用户头像
        "user_id"://用户ID
        "farm_id"://农场id
        "name"://农场名称
        "project_num"://项目数量
        "fun_name"://粉丝数量
        "is_guan"://1未关注2已关注
        }
        })
     */
    public function myfun()
    {
        $user_id = $this->getUserId();

        //查出我的农场ID
        $farm = Db::name('farm')
            ->where('user_id',$user_id)
            ->field('id,user_id')
            ->find();
        //查出关注我的农场 对应的 用户ID
        $data = Db::name('guanzhu')
            ->where('farm_id',$farm['id'])
            ->field('id,user_id,farm_id')
            ->select();
        foreach ($data as &$v){
            $identity = Db::name('user')->where('id',$v['user_id'])->field('id,identity')->find();


            //如果用户身份是政府或者游客
            if($identity['identity'] == 1 || $identity['identity'] == 4){
                //判断其身份 如果是游客或者是政府   返回头像跟昵称
                $user = Db::name('user')
                    ->where('id',$v['user_id'])
                    ->field('id,avatar,nickname')
                    ->find();
                $v['user_avatar'] = $user['avatar'];
                $v['nickname'] = $user['nickname'];
                $v['is_guan'] = 1;
                $v['name'] = '';
                $v['project_num'] = '';
                $v['fun_num'] = '';
            }else{
                //查出关注我的用户 自己的农场信息
                $user_farm = Db::name('farm')
                    ->alias('a')
                    ->join('user b','a.user_id = b.id')
                    ->field('a.id,a.name,a.project_num,a.fun_num,b.avatar as user_avatar,b.nickname')
                    ->where('a.user_id',$v['user_id'])
                    ->find();
                $v['name'] = $user_farm['name'];
                $v['project_num'] = $user_farm['project_num'];
                $v['fun_num'] = $user_farm['fun_num'];
                $v['user_avatar'] = $user_farm['user_avatar'];
                $v['nickname'] = $user_farm['nickname'];
                $guanzhu = Db::name('guanzhu')
                    ->where('user_id',$user_id)
                    ->where('farm_id',$user_farm['id'])
                    ->find();
                if(empty($guanzhu)){
                    $v['is_guan'] = 1;
                }else{
                    $v['is_guan'] = 2;
                }
            }
        }
        $this->success('success',$data);
    }

    /**
     * @ApiTitle    (我的溯源码)
     * @ApiSummary  (我的溯源码)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/mycode)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="page", type="inter", required=false, description="当前页(默认1)")
     * @ApiParams   (name="pageNum", type="inter", required=false, description="每页显示数据个数（默认10）")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id"://项目ID
            "image"://项目图片
            "thumbnail"://项目溯源码
            "project_name"://项目名称
            "farm_name"://农场名称
        }
        })
     */
    public function mycode()
    {
        $user_id = $this->getUserId();
        $domain_name = $this->request->domain();//域名
        $page = $this->request->param('page',1,'intval');
        $pageNum = $this->request->param('pageNum',10,'intval');
        //查找出我的农场信息  农场id
        $farm = Db::name('farm')
            ->where('user_id',$user_id)
            ->field('id,name')
            ->find();
        //通过农场ID查出我的项目
        $data = Db::name('project')
            ->where('farm_id',$farm['id'])
            ->field('id,project_name,image,thumbnail')
            ->page($page,$pageNum)
            ->select();
        foreach ($data as &$v){
            $v['image'] = 'http://q2ugvq3qf.bkt.clouddn.com'.$v['image'];
            $v['farm_name'] = $farm['name'];
        }
        $this->success('success',$data);
    }

    /**
     * @ApiTitle    (添加溯源记录)
     * @ApiSummary  (添加溯源记录)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/record)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="farm_id", type="int", required=false, description="农场id")
     * @ApiParams   (name="project_id", type="int", required=false, description="项目id")
     * @ApiParams   (name="image", type="int", required=false, description="产品图片或者视频")
     * @ApiParams   (name="theme", type="string", required=false, description="溯源主题")
     * @ApiParams   (name="status", type="int", required=false, description="项目状态（0培育中1将收获2已收获）")
     * @ApiParams   (name="content", type="string", required=false, description="溯源记录备注")
     *
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    }
    })
     */
    public function record()
    {
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $validate = new Validate([
            'farm_id' => 'require',
            'project_id' => 'require',
            'image'=>'require',
            'theme'=>'require',
            'status'=>'require',
            'content'=>'require',
        ]);
        if (!$validate->check($param)) {
            $this->error($validate->getError());
        }
        $http = 'http://q2ugvq3qf.bkt.clouddn.com';
        $param['image'] = str_replace($http,'',$param['image']);
        //查询出当天当地天气
        $data = Db::name('project')
            ->where('id',$param['project_id'])
            ->find();
        $city = $data['city'];
        $url = 'https://api.jisuapi.com/weather/query?appkey=f37f8b7b60cc27d9&city='.$city;
        $result = Http::get($url);
        $jsonarr = json_decode($result,true);
        $param['user_id'] = $user_id;
        $param['createtime'] = time();
        $param['week'] = $jsonarr['result']['week'];
        $param['weather'] = $jsonarr['result']['weather'];
        $param['wind'] = $jsonarr['result']['windpower'];
        $param['humidity'] = $jsonarr['result']['humidity'].'%';
        $param['air'] = $jsonarr['result']['aqi']['quality'];
        $param['temperature'] = $jsonarr['result']['templow'].'~'.$jsonarr['result']['temphigh'].'度';
        $data = Db::name('record')->insertGetId($param);
        Db::name('project')->where('id',$param['project_id'])->update(['status'=>$param['status']]);
        if(!empty($data)){
            $this->success('添加成功');
        }else{
            $this->error('添加失败');
        }
    }

    /**
     * @ApiTitle    (溯源历史)
     * @ApiSummary  (溯源历史)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/his_record)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id"://溯源记录ID
            "image"://产品图片或者视频
            "status"://项目状态（0培育中1将收获2已收获）
            "theme"://溯源主题
            "avatar"://用户头像
            "nickname"://农户昵称
            "content"://溯源记录备注
            "week"://星期
            "weather":天气
            "humidity"://湿度
            "temperature"://温度
            "wind"://风力
            "air"://空气质量
            "createtime"://创建时间
            "project_id"://项目ID
            "project_image"://项目图片
            "proect_name"://项目名称
            "look_num"://浏览量
            "good_num"://点赞量
            "project_content"://项目简介
        }
    })
     */
    public function his_record(){
        $user_id = $this->getUserId();
        $data = Db::name('record')
            ->alias('a')
            ->join('project b','a.project_id = b.id')
            ->field('a.*,b.id as project_id,b.image as project_image,b.project_name,b.look_num,b.good_num,b.content as project_content')
            ->where('a.user_id',$user_id)
            ->order('a.createtime desc')
            ->select();
        //按用户的查看时间将数据分段
        foreach ($data as &$v){
            $v['create_time'] = date('Y-m-d',$v['createtime']);
            $v['createtime'] = date('H:i:s',$v['createtime']);
        }
        $times = array_values(array_unique(array_column($data,'create_time')));
        rsort($times);
        //将比赛信息放到对应的时间分段
        $arr = [];
        foreach ($times as $t_k=> $t_v){
            $arr[$t_k]['times'] = $t_v;
            $k = 0;
            foreach ($data as $value){
                $k+=0;
                if($t_v == $value['create_time']){
                    $arr[$t_k]['info'][$k] = $value;
                    $k++;
                }
            }
        }
        $this->success('success',$data);
    }

    /**
     * @ApiTitle    (添加项目评论)
     * @ApiSummary  (添加项目评论)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/comment)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="farm_id", type="int", required=false, description="农场id")
     * @ApiParams   (name="project_id", type="int", required=false, description="项目id")
     * @ApiParams   (name="conten", type="int", required=false, description="评论内容")
     *
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    }
    })
     */
    public function comment()
    {
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $validate = new Validate([
            'farm_id' => 'require',
            'project_id' => 'require',
            'content'=>'require',
        ]);
        if (!$validate->check($param)) {
            $this->error($validate->getError());
        }
        $keyword = Db::name('word')
            ->column('name');
        $new_str = str_replace($keyword,"*",$param['content']);
        $count = strpos($new_str,"*");
        if($count != 0){
            $this->error('评论内容含有关键字');
        }
        $param['user_id'] = $user_id;
        $param['createtime'] = time();
        $data = Db::name('comment')
            ->insertGetId($param);
        if(empty($data)){
            $this->error('评论失败');
        }else{
            $this->success('评论成功');
        }
    }

    /**
     * @ApiTitle    (项目评论列表)
     * @ApiSummary  (项目评论列表)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/commentlist)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="farm_id", type="int", required=false, description="农场id")
     * @ApiParams   (name="project_id", type="int", required=false, description="项目id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id"://评论ID
            "avatar"://用户头像
            "nickname"://用户昵称
            "farm_id"://农场id
            "project_id"://项目id
            "user_id"://用户ID
            "content"://评论内容
            "num"://评论个数
            "good_name"://点赞数
            "createtime"://评论时间
            "is_zan"://是否点过赞(1否2是)
        }
        })
     */
    public function commentlist()
    {
        $token = $this->request->header('token');
        if(empty($token)){
            $param = $this->request->param();
            $validate = new Validate([
                'farm_id' => 'require',
                'project_id' => 'require',
            ]);
            if (!$validate->check($param)) {
                $this->error($validate->getError());
            }
            $where['a.farm_id'] = $param['farm_id'];
            $where['a.project_id'] = $param['project_id'];
            $where['a.status'] = 2;
            $data['list'] = Db::name('comment')
                ->alias('a')
                ->join('user b','a.user_id = b.id')
                ->field('a.*,b.avatar,b.nickname,a.createtime')
                ->where($where)
                ->select();
            foreach ($data['list'] as &$v){
                $v['is_zan'] = 1;
                $v['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
            }
            $data['num'] = Db::name('comment')
                ->alias('a')
                ->join('user b','a.user_id = b.id')
                ->field('a.*,b.avatar,b.nickname')
                ->where($where)
                ->count();
            $this->success('success',$data);
        }
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $validate = new Validate([
            'farm_id' => 'require',
            'project_id' => 'require',
        ]);
        if (!$validate->check($param)) {
            $this->error($validate->getError());
        }
        $where['a.farm_id'] = $param['farm_id'];
        $where['a.project_id'] = $param['project_id'];
        $where['a.status'] = 2;
        $data = Db::name('comment')
            ->alias('a')
            ->join('user b','a.user_id = b.id')
            ->field('a.*,b.avatar,b.nickname,a.createtime')
            ->where($where)
            ->select();
        foreach ($data as &$v){
            $good = Db::name('goodcomment')
                ->where('comment_id',$v['id'])
                ->where('user_id',$user_id)
                ->find();
            if(empty($good)){
                $v['is_zan'] = 1;
            }else{
                $v['is_zan'] = 2;
            }
            $v['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
        }
        $this->success('success',$data);

    }

    /**
     * @ApiTitle    (评论点赞接口)
     * @ApiSummary  (评论点赞接口)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/project/goodcomment)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="comment_id", type="int", required=false, description="评论id")
     *
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    }
    })
     */
    public function goodcomment()
    {
        $user_id = $this->getUserId();
        $param['comment_id'] = $this->request->param('comment_id');
        if(empty($param['comment_id'])){
            $this->error('缺少必要参数');
        }
        $param['user_id'] = $user_id;
        $param['createtime'] = time();
        $data = Db::name('goodcomment')
            ->insertGetId($param);
        if(empty($data)){
            $this->error('点赞失败');
        }else{
            $this->success('点赞成功');
        }
    }


}