<?php

namespace app\api\controller;

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

/**
 * 登录接口
 */
class User extends Api
{
    protected $noNeedLogin = '*';
    protected $noNeedRight = '*';

//    public function _initialize()
//    {
//        parent::_initialize();
//    }

    /**
     * @ApiTitle    (获取sessionKey和openid)
     * @ApiSummary  (获取sessionKey和openid)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/getSessionKey)
     * @ApiParams   (name="code", type="string", required=true, description="小程序code")
     * @ApiReturn({
        "code": 1,
        "msg": "获取成功",
        "time": "1553839125",
        "data": {
            "session_key": "session_key",//token
            "openid": "openid",//openid
        },
        })
     */
    public function getSessionKey()
    {
        $validate = new Validate([
            'code' => 'require',
        ]);

        $validate->message([
            'code.require' => '缺少参数code!',
        ]);

        $data = $this->request->param();
        if (!$validate->check($data)) {
            $this->error(['code' => '40003', 'msg' => $validate->getError()]);
        }

        $code = $data['code'];
        $appId = config('app_id');
        $appSecret = config('app_secret');

        $response = "https://api.weixin.qq.com/sns/jscode2session?appid=$appId&secret=$appSecret&js_code=$code&grant_type=authorization_code";
        $response = $this->http_get($response);
        $response = json_decode($response, true);
        if(!empty($response['errcode'])) {
            $this->error('操作失败',$response['errcode']);
        }
        $this->success('获取成功',$response);
    }
    //curl  get请求
    public function http_get($url){
        $curl = curl_init();//启动一个CURL会话
        curl_setopt($curl, CURLOPT_URL,$url);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
        curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
        curl_setopt($curl, CURLOPT_HEADER, false);//不开启header
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
        $result = curl_exec($curl); //执行操作
        curl_close($curl);
        return $result;
    }

    /**
     * @ApiTitle    (小程序登录注册)
     * @ApiSummary  (小程序登录注册)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/login)
     * @ApiParams   (name="openid", type="string", required=true, description="openid")
     * @ApiParams   (name="session_key", type="string", required=true, description="session_key")
     * @ApiParams   (name="encrypted_data", type="string", required=true, description="encrypted_data")
     * @ApiParams   (name="iv", type="string", required=true, description="iv")
     * @ApiReturn({
        "code": 1,
        "msg": "登陆成功",
        "time": "1553839125",
        "data": {
            "token": "token",//登录唯一标识
        },
        })
     */
    public function login()
    {
        $validate = new Validate([
            'openid' => 'require',
            'session_key' => 'require',
            'encrypted_data' => 'require',
            'iv' => 'require',
        ]);

        $validate->message([
            'openid.require' => '缺少参数openid!',
            'session_key.require' => '缺少参数session_key!',
            'encrypted_data.require' => '缺少参数encrypted_data!',
            'iv.require' => '缺少参数iv!',
        ]);

        $data = $this->request->param();
        if (!$validate->check($data)) {
            $this->error(['code' => '40003', 'msg' => $validate->getError()]);
        }

        $appId = config('app_id');

        $openid = $data['openid'];
        $sessionKey = $data['session_key'];

        $pc = new WXBizDataCrypt($appId, $sessionKey);
        $errCode = $pc->decryptData($data['encrypted_data'], $data['iv'], $wxUserData);

        if ($errCode != 0) {
            $this->error('检验数据失败!', ['errCode' => $errCode, 'param' => $data]);
        }

        $findThirdPartyUser = Db::name("third")
            ->where('openid', $openid)
            ->where('app_id', $appId)
            ->find();

        $currentTime = time();
        $ip = $this->request->ip(0, true);

        $wxUserData['sessionKey'] = $sessionKey;
        unset($wxUserData['watermark']);

        if ($findThirdPartyUser) {
            $token = generate_user_token($findThirdPartyUser['user_id']);

            $userData = [
                'loginip' => $ip,
                'logintime' => $currentTime,
                'login_times' => Db::raw('login_times+1'),
                'more' => json_encode($wxUserData)
            ];

            if (isset($wxUserData['unionId'])) {
                $userData['union_id'] = $wxUserData['unionId'];
            }

            Db::name("third")
                ->where('openid', $openid)
                ->where('app_id', $appId)
                ->update($userData);
            $this->success("登录成功!", ['token' => $token]);
        } else {
            Db::startTrans();
            $userId = Db::name("user")->insertGetId([
                'status'     => 'normal',
                'id_num'     => date('Ymd').str_pad(mt_rand(1, 99999),5,'0',STR_PAD_LEFT).'8',
                'gender'     => $wxUserData['gender'],
                'nickname'   => $wxUserData['nickName'],
                'avatar'     => $wxUserData['avatarUrl'],
                'joinip'     => $ip,
                'jointime'   => $currentTime,
                'createtime' => $currentTime,
                'updatetime' => $currentTime,
                'loginip'    => $ip,
                'logintime'  => $currentTime,
            ]);
            $row = Db::name("third")->insert([
                'openid'          => $openid,
                'user_id'         => $userId,
                'nickname'        => $wxUserData['nickName'],
                'app_id'          => $appId,
                'loginip'         => $ip,
                'union_id'        => '',
                'logintime'       => $currentTime,
                'createtime'      => $currentTime,
                'login_times'     => 1,
                'more'            => json_encode($wxUserData)
            ]);

            if ($userId && $row) {
                Db::commit();
                $token = generate_user_token($userId);
                $this->success("登录成功!", ['token' => $token]);
            } else {
                Db::rollback();
                $this->error('登录失败');
            }

        }

    }
    /**
     * @ApiTitle    (通过code获取token)
     * @ApiSummary  (通过code获取token)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/getToken)
     * @ApiParams   (name="code", type="string", required=true, description="code")
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    "token": "token",//登录唯一标识
    },
    })
     */
    public function getToken(){
        $validate = new Validate([
            'code'           => 'require',
        ]);

        $validate->message([
            'code.require'           => '缺少参数code!',
        ]);

        $data = $this->request->param();
        if (!$validate->check($data)) {
            $this->error(['code'=>'40003','msg'=>$validate->getError()]);
        }

        $code      = $data['code'];
        $appId     = config('app_id');
        $appSecret = config('app_secret');

        $response = Http::sendRequest("https://api.weixin.qq.com/sns/jscode2session?appid=$appId&secret=$appSecret&js_code=$code&grant_type=authorization_code");

        if (!empty($response['errcode'])) {
            $this->error('操作失败:',$response['errcode']);
        }

        $third = Db::name('third')->where(['openid'=>json_decode($response['msg'],true)['openid']])->find();
        if(empty($third)){
            $this->error('查无此人');
        }
        $user_token = Db::name('user_token')->where('user_id',$third['user_id'])->find();
        $data['token'] = $user_token['token'];
        $this->success('SUCCESS',$data);
    }
    /**
     * @ApiTitle    (用户信息)
     * @ApiSummary  (用户信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/member)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    "id": "id",//用户id
    "nickname": "nickname",//用户昵称
    "avatar": "avatar",//头像
     "is_ren"://是否认证过(1认证过2没有认证过)
     "is_have"://是否有农场(1入驻过2未入驻)
    },
    })
     */
    public function member(){
        $this->success('SUCCESS',$this->user);
    }

    /**
     * @ApiTitle    (个人中心)
     * @ApiSummary  (个人中心)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/info)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id": "id",//用户id
            "score": //用户积分
            "identity": //身份
        },
        })
     */
    public function info()
    {
        $user_id = $this->getUserId();
        $data = Db::name('user')
            ->where('id',$user_id)
            ->field('id,score,identity,nickname,avatar')
            ->find();

        $farm = Db::name('farm')
            ->where('user_id',$user_id)
            ->find();
        if(!empty($farm)){
            $data['is_have'] = 1;
            $is_ren = Db::name('attestation')
                ->where('user_id',$user_id)
                ->find();
            if(!empty($is_ren)){
                if($is_ren['status'] == 1){
                    $data['is_ren'] = 1;
                }else{
                    $data['is_ren'] = 2;
                }
            }else{
                $data['is_ren'] = 0;
            }
            $this->success('success',$data);
        }else{
            $data['is_have'] = 2;
            $is_ren = Db::name('attestation')
                ->where('user_id',$user_id)
                ->find();
            if(!empty($is_ren)){
                $data['is_ren'] = 1;
            }else{
                $data['is_ren'] = 2;
            }
            $this->success('success',$data);
        }
    }



    /**
     * @ApiTitle    (邻居家的余粮)
     * @ApiSummary  (邻居家的余粮)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/user/residue)
     * @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,
    "farm_id":农场ID
    'project_name'://项目名称,
    "image"://项目图片
    'farm_name'://农场名称,
    "avatar"://头像
    'look_num'://浏览量,
    "good_num"://点赞量
    'thumbnail'://图片
    "address"://项目地址
    "status"://是否点过赞(1已经点过2没有点过)
    "hong_status"://0未授权1已经授权
    'createtime'://创建时间
    }
    })
     */
    public function residue()
    {
        $token = $this->request->header('token');
        $page = $this->request->param('page',1,'intval');
        $pageNum = $this->request->param('pageNum',6,'intval');

        //判断用户是否登录
        if($token){
            $user_id = $this->getUserId();
            $nong = Db::name('farm')
                ->where('user_id',$user_id)
                ->find();
            if(empty($nong)){
                $data = Db::name('project')
                    ->field('id,farm_id,project_name,address,image,good_num')
                    ->order('good_num desc,id desc')
                    ->page($page,$pageNum)
                    ->select();
                foreach ($data as &$v){
                    $v['image'] = 'http://q2ugvq3qf.bkt.clouddn.com'.$v['image'];
                    $zan = Db::name('good')
                        ->where('project_id',$v['id'])
                        ->where('user_id',$user_id)
                        ->find();
                    if($zan){
                        $v['statu'] = 1;
                    }else{
                        $v['statu'] = 2;
                    }
                    $farm = Db::name('farm')
                        ->alias('a')
                        ->join('user b','a.user_id = b.id')
                        ->field('a.name,b.avatar')
                        ->where('a.id',$v['farm_id'])
                        ->find();
                    $v['avatar'] = $farm['avatar'];
                    $v['farm_name'] = $farm['name'];
                    $v['hong_status'] = 1;
                }
                $this->success('success',$data);
            }else{
                $data = Db::name('project')
                    ->field('id,farm_id,project_name,address,image,good_num,province')
                    ->whereLike('province',"%$nong[province]%")
                    ->order('good_num desc,id desc')
                    ->page($page,$pageNum)
                    ->select();
                foreach ($data as &$v){
                    $v['image'] = 'http://q2ugvq3qf.bkt.clouddn.com'.$v['image'];
                    $zan = Db::name('good')
                        ->where('project_id',$v['id'])
                        ->where('user_id',$user_id)
                        ->find();
                    if($zan){
                        $v['statu'] = 1;
                    }else{
                        $v['statu'] = 2;
                    }
                    $farm = Db::name('farm')
                        ->alias('a')
                        ->join('user b','a.user_id = b.id')
                        ->field('a.name,b.avatar')
                        ->where('a.id',$v['farm_id'])
                        ->find();
                    $v['avatar'] = $farm['avatar'];
                    $v['farm_name'] = $farm['name'];
                    $v['hong_status'] = 1;
                }
                $this->success('success',$data);
            }
        }else {
            $data = Db::name('project')
                ->field('id,farm_id,project_name,address,image,good_num')
                ->order('good_num desc,id desc')
                ->page($page, $pageNum)
                ->select();
            foreach ($data as &$v) {
                $v['image'] = 'http://q2ugvq3qf.bkt.clouddn.com' . $v['image'];
                $farm = Db::name('farm')
                    ->alias('a')
                    ->join('user b', 'a.user_id = b.id')
                    ->field('a.name,b.avatar')
                    ->where('a.id', $v['farm_id'])
                    ->find();
                $v['avatar'] = $farm['avatar'];
                $v['farm_name'] = $farm['name'];
                $v['hong_status'] = 0;
            }
            $this->success('success', $data);
        }
    }

}