<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/12/17
 * Time: 9:41
 */

namespace app\api\controller;


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

/**
 * 个人中心模块
 */
class Userinfo extends Api
{
    /**
     * @ApiTitle    (修改用户头像)
     * @ApiSummary  (修改用户头像)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/updthumbnail)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="thumbnail", type="string", required=true, description="头像")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
        },
        })
     */
    public function updthumbnail()
    {
        $user_id = $this->getUserId();
        $thumbnail = $this->request->param('thumbnail');
        if(empty($thumbnail)){
            $this->error('缺少必要参数');
        }
        $data = Db::name('user')
            ->where('id',$user_id)
            ->update(['avatar'=>$thumbnail]);
        if(empty($data)){
            $this->error('sql运行失败');
        }else{
            $this->success('修改成功');
        }
    }

    /**
     * @ApiTitle    (修改用户昵称)
     * @ApiSummary  (修改用户昵称)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/updnickname)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="nickname", type="string", required=true, description="昵称")
     *
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {
    },
    })
     */
    public function updnickname()
    {
        $user_id = $this->getUserId();
        $nickname = $this->request->param('nickname');
        if(empty($nickname)){
            $this->error('缺少必要参数');
        }

        Db::startTrans();
        $data = Db::name('user')
            ->where('id',$user_id)
            ->update(['nickname'=>$nickname]);
        $res = Db::name('third')
            ->where('user_id',$user_id)
            ->update(['nickname'=>$nickname]);

        if($data && $res){
            Db::commit();
            $this->success('修改成功');
        }else{
            Db::rollback();
            $this->error('sql运行失败');
        }
    }

    /**
     * @ApiTitle    (绑定用户手机号)
     * @ApiSummary  (绑定用户手机号)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/updmobile)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="mobile", type="string", required=true, description="手机号")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
        },
        })
     */
    public function updmobile()
    {
        $user_id = $this->getUserId();
        $mobile = $this->request->param('mobile');
        if(empty($mobile)){
            $this->error('缺少必要参数');
        }
        $data = Db::name('user')
            ->where('id',$user_id)
            ->update(['mobile'=>$mobile]);
        if(empty($data)){
            $this->error('sql运行失败');
        }else{
            $this->success('修改成功');
        }
    }

    /**
     * @ApiTitle    (收货地址列表)
     * @ApiSummary  (收货地址列表)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/get_all)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id":"id",//收货地址id
            "user_id":"user_id",//用户id
            "name":"name",//姓名
            "mobile":"mobile",//手机号
            "province":"province",//省
            "city":"city",//市
            "county":"county",//区/县
            "address":"address",//详细地址
    }
    })
     */
    public function get_all(){
        $user_id = $this->getUserId();
        $where['user_id'] = ['eq',$user_id];
        $data = Db::name('address')->where($where)->order('id desc')->select();
        $this->success('SUCCESS',$data);
    }
    /**
     * @ApiTitle    (单个收货地址)
     * @ApiSummary  (单个收货地址)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/get_one)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="take_id", type="int", required=true, description="收货地址id")
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
            "id":"id",//收货地址id
            "user_id":"user_id",//用户id
            "name":"name",//姓名
            "mobile":"mobile",//手机号
            "province":"province",//省
            "city":"city",//市
            "county":"county",//区/县
            "address":"address",//详细地址
    }
    })
     */
    public function get_one(){
        $user_id = $this->getUserId();
        $take_id = $this->request->param('take_id',0,'intval');
        if(empty($take_id)){
            $this->error('缺少必要参数');
        }
        $where['user_id'] = ['eq',$user_id];
        $where['id'] = ['eq',$take_id];
        $data = Db::name('address')->where($where)->find();
        $this->success('SUCCESS',$data);
    }
    /**
     * @ApiTitle    (新增收货地址)
     * @ApiSummary  (新增收货地址)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/create_take)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="name", type="string", required=true, description="姓名")
     * @ApiParams   (name="mobile", type="string", required=true, description="手机号")
     * @ApiParams   (name="province", type="string", required=true, description="省")
     * @ApiParams   (name="city", type="string", required=true, description="市")
     * @ApiParams   (name="county", type="string", required=true, description="区/县")
     * @ApiParams   (name="address", type="string", required=true, description="详细地址")
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {

        }
        })
     */
    public function create_take(){
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $validate = new \think\Validate([
            'name' => 'require',
            'mobile' => 'require',
            'province' => 'require',
            'city' => 'require',
            'county' => 'require',
            'address' => 'require',
        ]);
        if (!$validate->check($param)) {
            $this->error($validate->getError());
        }
        $param['createtime'] = time();
        $param['updatetime'] = time();
        $param['user_id'] = $user_id;
        $result = Db::name('address')->insert($param);
        if(empty($result)){
            $this->error('sql执行失败');
        }
        $this->success('SUCCESS');
    }
    /**
     * @ApiTitle    (更新收货地址)
     * @ApiSummary  (更新收货地址)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/update_take)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="take_id", type="string", required=true, description="收货地址id")
     * @ApiParams   (name="name", type="string", required=true, description="姓名")
     * @ApiParams   (name="mobile", type="string", required=true, description="手机号")
     * @ApiParams   (name="province", type="string", required=true, description="省")
     * @ApiParams   (name="city", type="string", required=true, description="市")
     * @ApiParams   (name="county", type="string", required=true, description="区/县")
     * @ApiParams   (name="address", type="string", required=true, description="详细地址")
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {

        }
    })
     */
    public function update_take(){
        $user_id = $this->getUserId();
        $param = $this->request->param();
        $validate = new Validate([
            'take_id' => 'require',
            'name' => 'require',
            'mobile' => 'require',
            'province' => 'require',
            'city' => 'require',
            'county' => 'require',
            'address' => 'require',
        ]);
        if (!$validate->check($param)) {
            $this->error($validate->getError());
        }
        $where['user_id'] = ['eq',$user_id];
        $where['id'] = ['eq',$param['take_id']];
        unset($param['take_id']);
        $param['updatetime'] = time();
        $result = Db::name('address')->where($where)->update($param);
        if(empty($result)){
            $this->error('sql执行失败');
        }
        $this->success('SUCCESS');
    }
    /**
     * @ApiTitle    (删除收货地址)
     * @ApiSummary  (删除收货地址)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/delete_take)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="take_id", type="string", required=true, description="收货地址id")
     * @ApiReturn({
    "code": 1,
    "msg": "SUCCESS",
    "time": "1553839125",
    "data": {

    }
    })
     */
    public function delete_take(){
        $user_id = $this->getUserId();
        $take_id = $this->request->param('take_id',0,'intval');
        $where['id'] = ['eq',$take_id];
        $where['user_id'] = ['eq',$user_id];
        $result = Db::name('address')->where($where)->delete();
        if(empty($result)){
            $this->error('sql执行失败');
        }else{
            $this->success('SUCCESS');
        }
    }

    /**
     * @ApiTitle    (生成用户邀请好友二维码)
     * @ApiSummary  (生成用户邀请好友二维码)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/userinfo/imgcode)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="route", type="string", required=true, description="页面路径跟参数")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "SUCCESS",
        "time": "1553839125",
        "data": {
        },
        })
     */
    public function imgcode()
    {
        $domain_name = $this->request->domain();//域名
        $user_id = $this->getUserId();
        $url = $this->request->param('route');
        $url .= $url.'?user_id='.$user_id;
        if(empty($url)){
            $this->error('缺少必要参数');
        }
        $savePath = './../public/upload/poster/';
        if (!file_exists($savePath)){
            mkdir($savePath, 0777,true);
        }
        if(!file_exists("./upload/qrcode/code_$user_id.jpg")){
            $code = $this->getusercode($user_id,$url);
        }else{
            $code = "qrcode/code_$user_id.jpg";
        }
        $data = $domain_name.'/upload/'.$code;
        $this->success('SUCCESS',$data);
    }
    public function getusercode($user_id,$url){
        $savePath = './../public/upload/get_code/';
        $filename = "code_$user_id.jpg";
        if(!file_exists($savePath.$filename)){
            $access_token = $this->get_access_token();
            $qrcode = $this->imgShare($user_id,$access_token,$url);
        }elsE{
            $qrcode = "qrcode/code_".$user_id.".jpg";
        }
        return $qrcode;
    }
    public function imgShare($user_id,$access_token,$path){
        $url = "https://api.weixin.qq.com/wxa/getwxacode?access_token=".$access_token;
        $post['path'] = $path;
        $post['width'] = 280;
        $result = $this->curl($url, json_encode($post));
        $array = json_decode($result, true);
        if($array['errmsg']) {
            return false;
        }
        // 分享二维码保存到用户数据
        if (!file_exists(ROOT_PATH . 'public' . DS . 'upload/qrcode/')) {
            mkdir(ROOT_PATH . 'public' . DS . 'upload/qrcode/', 0777, true);
        }
        $filename = "code_".$user_id.".jpg";
        $furl = ROOT_PATH . 'public' . DS . 'upload/qrcode/'.$filename;
        file_put_contents($furl, $result);
        return "qrcode/".$filename;
    }
    protected function curl($url, $post = null, $header = null) {
        // 初始化
        $curl = curl_init();
        // 设置抓取的url
        curl_setopt($curl, CURLOPT_URL, $url);
        // 请求头
        if($header) {
            curl_setopt($curl,CURLOPT_HTTPHEADER,$header);
        }
        // 设置头文件的信息作为数据流输出
        curl_setopt($curl, CURLOPT_HEADER, 0);
        curl_setopt($curl, CURLOPT_NOBODY, 0);
        curl_setopt($curl, CURLOPT_TIMEOUT, 500);
        // 设置获取的信息以文件流的形式返回，而不是直接输出。
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        if($post) {
            curl_setopt($curl, CURLOPT_POST, 1);
            //把POST的变量加上
            curl_setopt($curl, CURLOPT_POSTFIELDS, $post);
        }
        // 执行命令
        $data = curl_exec($curl);
        if (curl_errno($curl)) {
            $data = curl_error($curl);
        }
        return $data;
    }
    //获取access_token
    public function get_access_token()
    {
        $app_id = config('app_id');
        $app_secret = config('app_secret');
        $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid='.$app_id.'&secret='.$app_secret;
        $res = $this->http_get($url);
        $json_arr = json_decode($res,true);
        $token = $json_arr['access_token'];
        return $token;
    }
    //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;
    }
    //curl post请求
    public function http_post($url,$data){
        $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_POST, true); // 发送一个常规的Post请求
        curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data)); // Post提交的数据包
        curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
        curl_setopt($curl, CURLOPT_HEADER, false); // 开启header
        //curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);//请求头部
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); // 获取的信息以文件流的形式返回
        $result = curl_exec($curl); //执行操作
        curl_close($curl);
        return $result;
    }
}