youxiangjie/application/api/controller/Wechatwebopenid.php

<?php

namespace app\api\controller;

use app\api\model\UsersModel;
use think\Controller;

/**
 * 微信公众号网页授权
 */
class Wechatwebopenid extends Controller
{
    /**
     * 获取回调地址
     */
    public function unity_url()
    {
        $data['url'] = config('site.httpurl') . '/api/Wechatwebopenid/insertcode';
        $data['appid'] = "wxa372e8ef8a6f0e1d";
        return json(['data' => $data, 'code' => 200]);
    }

    /**
     * 接受code
     * @ApiInternal // 生成接口时忽略此方法
     */
    public function insertcode()
    {
        $code = input('code');
        $user_id = input('state');
        $appid = "wxa372e8ef8a6f0e1d";
        $secret = "6b8033de3f71eef386a3abdfc5ba5fd4";
        $access_token = $this->getAccess_token($code, $appid, $secret);
        if (isset($access_token['errcode'])) {
            if ($access_token['errcode'] == 40029) {
                return json(['code' => 100, 'msg' => '网络错误101']);
            }
        }
        halt($access_token);
        if (isset($access_token['openid'])) {
            $data = array(
                'user_openid' => $access_token['openid'],
            );
            $upd = UsersModel::where('user_id', $user_id)->update($data);
            if ($upd) {
                return json(['code' => 200, 'msg' => '授权成功']);
            } else {
                return json(['code' => 100, 'msg' => '网络错误104']);
            }
        } else {
            return json(['code' => 100, 'msg' => '网络错误104']);
        }
        // 一下为获取用户详细信息的接口
//        return json();
//        //防止过期。刷新token
//        $refresh_token = $this->refresh_token($appid, $access_token['refresh_token']);
//        if (isset($refresh_token['errcode'])) {
//            if ($refresh_token['errcode'] == 40029) {
//                return json(['code' => 100, 'msg' => '网络错误102']);
//            }
//        }
//        //拉取用户信息
//        $userInfo = $this->userInfo($refresh_token['access_token'], $appid);
//        if (isset($userInfo['errcode'])) {
//            if ($userInfo['errcode'] == 40003) {
//                return json(['code' => 100, 'msg' => '网络错误103']);
//            }
//        }
//        $data = array(
//            'user_openid'  => $userInfo['openid'],
//            'user_unionid' => $userInfo['unionid'],
//        );
//        //$upd = UsersModel::where('user_unionid', $userInfo['unionid'])->update($data);

    }

    /**
     * 调取微信授权
     */
    public function toWeChat()
    {

        $data['url'] = config('site.httpurl') . '/api/Wechatwebopenid/insertcode';
        $data['appid'] = "wxa372e8ef8a6f0e1d";
        $user_id = 16;
        //设置请求之地
        $toWeChat = 'https://open.weixin.qq.com/connect/oauth2/authorize?appid=' . $data['appid'] . '&redirect_uri=' . $data['url'] . '&response_type=code&scope=snsapi_base&state=' . $user_id . '#wechat_redirect';
        $this->redirect($toWeChat, 302);
        $ch = curl_init();                                //初始化CURL句柄
        curl_setopt($ch, CURLOPT_URL, $toWeChat);         //设置请求的URL
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-type:application/json'));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);    //设为TRUE把curl_exec()结果转化为字串，而不是直接输出
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "GET"); //设置请求方式
        curl_setopt($ch, CURLOPT_POSTFIELDS, false);    //设置提交的字符串
        $output = curl_exec($ch);
        curl_close($ch);
        return json_decode($output, true);
    }

    /**
     * 通过code换取网页授权access_token
     * @ApiInternal // 生成接口时忽略此方法
     */
    public function getAccess_token($code, $appid, $secret)
    {
        //设置请求之地
        $access_token_url = 'https://api.weixin.qq.com/sns/oauth2/access_token?appid=' . $appid . '&secret=' . $secret . '&code=' . $code . '&grant_type=authorization_code';
        $ch = curl_init();                                //初始化CURL句柄
        curl_setopt($ch, CURLOPT_URL, $access_token_url); //设置请求的URL
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-type:application/json'));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);    //设为TRUE把curl_exec()结果转化为字串，而不是直接输出
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "GET"); //设置请求方式
        curl_setopt($ch, CURLOPT_POSTFIELDS, false);    //设置提交的字符串
        $output = curl_exec($ch);
        curl_close($ch);
        return json_decode($output, true);
    }

    /**
     * 防止过期刷新token
     * @ApiInternal // 生成接口时忽略此方法
     */
    public function refresh_token($appid, $refresh_token)
    {
        //设置请求之地
        $refresh_token = 'https://api.weixin.qq.com/sns/oauth2/refresh_token?appid=' . $appid . '&grant_type=refresh_token&refresh_token=' . $refresh_token;
        $ch = curl_init();                                //初始化CURL句柄
        curl_setopt($ch, CURLOPT_URL, $refresh_token);    //设置请求的URL
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-type:application/json'));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);    //设为TRUE把curl_exec()结果转化为字串，而不是直接输出
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "GET"); //设置请求方式
        curl_setopt($ch, CURLOPT_POSTFIELDS, false);    //设置提交的字符串
        $output = curl_exec($ch);
        curl_close($ch);
        return json_decode($output, true);
    }

    /**
     * 拉取用户信息
     * @ApiInternal // 生成接口时忽略此方法
     */
    public function userInfo($access_token, $appid)
    {
        //设置请求之地
        $userInfo = 'https://api.weixin.qq.com/sns/userinfo?access_token=' . $access_token . '&openid=' . $appid . '&lang=zh_CN';
        $ch = curl_init();                                //初始化CURL句柄
        curl_setopt($ch, CURLOPT_URL, $userInfo);         //设置请求的URL
        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-type:application/json'));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);    //设为TRUE把curl_exec()结果转化为字串，而不是直接输出
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "GET"); //设置请求方式
        curl_setopt($ch, CURLOPT_POSTFIELDS, false);    //设置提交的字符串
        $output = curl_exec($ch);
        curl_close($ch);
        return json_decode($output, true);
    }
}