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 = config('site.httpurl') . '/api/Wechatwebopenid/insertcode';
        return json(['data' => $data, 'code' => 200]);
    }

    /**
     * 接受code
     * @ApiInternal // 生成接口时忽略此方法
     */
    public function insertcode()
    {
        $code = input('code');
        $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' => '网络错误']);
            }
        }
        //防止过期。刷新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' => '网络错误']);
            }
        }
        //拉取用户信息
        $userInfo = $this->userInfo($refresh_token['access_token'], $appid);
        if (isset($userInfo['errcode'])) {
            if ($userInfo['errcode'] == 40003) {
                return json(['code' => 100, 'msg' => '网络错误']);
            }
        }
        $data = array(
            'user_openid'  => $userInfo['openid'],
            'user_unionid' => $userInfo['unionid'],
        );
        //$upd = UsersModel::where('user_unionid', $userInfo['unionid'])->update($data);
        $upd = UsersModel::where('user_unionid', $userInfo['unionid'])->update($data);

        if ($upd) {
            return json(['code' => 200, 'msg' => '授权成功']);
        } else {
            return json(['code' => 100, 'msg' => '网络错误']);
        }
    }

    /**
     * 通过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);
    }
}