add global userinfo get function(based on unionid)

Author: realtimebus

src/filters.php

@@ -24,11 +24,17 @@
             if (Input::has('code')) {
                 //获取openid
                 try {
-                    get_access_token(Input::get('code'));
+                    $accessToken = get_access_token(Input::get('code'));
                 } catch (Exception $e) {
                     Log::error($e->getMessage());
                     return '获取token错误';
                 }
+                try {
+                    $userinfo = get_global_userinfo($accessToken['openid']);
+                    Session::put('wechat_userinfo', $userinfo);
+                } catch (Exception $e) {
+                    Log::error($e->getMessage());
+                }
                 return Redirect::intended(Request::fullUrl());
             } else {
                 try {
@@ -64,11 +70,19 @@
             }
 
             try {
-                get_userinfo($token['access_token'], $token['openid']);
+                $userinfo = get_userinfo($token['access_token'], $token['openid']);
             } catch (Exception $e) {
                 Log::error($e->getMessage());
                 return '获取userinfo错误';
             }
+            try {
+                $globalUserinfo = get_global_userinfo($token['openid']);
+                $userinfo = array_merge($userinfo, $globalUserinfo);
+            } catch (Exception $e) {
+                Log::error($e->getMessage());
+                $userinfo['subscribe'] = 0;
+            }
+            Session::put('wechat_userinfo', $userinfo);
             return Redirect::intended(Request::fullUrl());
         } else {
             try {

src/helpers.php

@@ -11,6 +11,7 @@
 use Xjchen\WechatFilter\WechatConfigRequiredException;
 use Xjchen\WechatFilter\GetAccessTokenException;
 use Xjchen\WechatFilter\GetUserinfoException;
+use Carbon\Carbon;
 
 if (!function_exists('get_code_url')) {
 
@@ -30,6 +31,23 @@ function get_code_url($appid, $redirect_uri, $scope='snsapi_userinfo')
     }
 }
 
+if (!function_exists('get_global_access_token_url')) {
+
+    /**
+     * 生成获取access_token的url
+     *
+     * @param $appid
+     * @param $secret
+     * @return mixed
+     */
+    function get_global_access_token_url($appid, $secret)
+    {
+        $template_url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET';
+        $url = str_replace(['APPID', 'APPSECRET'], [$appid, $secret], $template_url);
+        return $url;
+    }
+}
+
 if (!function_exists('get_code_redirect')) {
 
     /**
@@ -67,6 +85,23 @@ function get_access_token_url($appid, $secret, $code)
     }
 }
 
+if (!function_exists('get_global_userinfo_url')) {
+    /**
+     * 生成获取userinfo的url
+     *
+     * @param $access_token
+     * @param $openid
+     * @param string $lang
+     * @return mixed
+     */
+    function get_global_userinfo_url($access_token, $openid, $lang='zh_CN')
+    {
+        $template_url = 'https://api.weixin.qq.com/cgi-bin/user/info?access_token=ACCESS_TOKEN&openid=OPENID&lang=zh_CN';
+        $url = str_replace(['ACCESS_TOKEN', 'OPENID', 'LANG'], [$access_token, $openid, $lang], $template_url);
+        return $url;
+    }
+}
+
 if (!function_exists('get_userinfo_url')) {
     /**
      * 生成获取userinfo的url
@@ -103,14 +138,71 @@ function curl_get_wrapper($url, $return_json=true)
             throw new CurlGetException($error);
         } else {
             if ($return_json) {
-                return json_decode($curl->response, true);
+                return json_decode($curl->raw_response, true);
             } else {
-                return $curl->response;
+                return $curl->raw_response;
             }
         }
     }
 }
 
+if (!function_exists('get_global_access_token')) {
+    /**
+     * 获取global_access_token数组
+     *
+     * @return mixed|null
+     * @throws CurlGetException
+     * @throws GetAccessTokenException
+     * @throws WechatConfigRequiredException
+     */
+    function get_global_access_token()
+    {
+        if (Cache::has('global_access_token')) {
+            return Cache::get('global_access_token');
+        }
+        $appid = Config::get('wechat.appid', '');
+        $secret = Config::get('wechat.secret', '');
+        if (!$appid or !$secret) {
+            throw new WechatConfigRequiredException('get_global_access_token中缺少appid或secret');
+        }
+        $getAccessTokenUrl = get_global_access_token_url($appid, $secret);
+        $result = curl_get_wrapper($getAccessTokenUrl);
+        if (isset($result['errcode'])) {
+            throw new GetAccessTokenException('get_global_access_token get access token error: '.json_encode($result));
+        }
+        $expiresAt = Carbon::now()->addMinutes(($result['expires_in']/60)-1);
+        Cache::put('global_access_token', $result['access_token'], $expiresAt);
+        return $result['access_token'];
+    }
+}
+
+if (!function_exists('get_global_userinfo')) {
+
+    /**
+     * 获取userinfo
+     *
+     * @param $openid
+     * @param string $lang
+     * @return mixed|null
+     * @throws CurlGetException
+     * @throws GetUserinfoException
+     */
+
+    function get_global_userinfo($openid, $lang='zh_CN')
+    {
+        $access_token = get_global_access_token();
+        $getUserinfoUrl = get_global_userinfo_url($access_token, $openid, $lang);
+        $result = curl_get_wrapper($getUserinfoUrl);
+        if (isset($result['errcode'])) {
+            throw new GetUserinfoException('get_global_userinfo error: '.json_encode($result));
+        }
+        Session::put('global_wechat_userinfo', $result);
+        return $result;
+    }
+}
+
+
+
 if (!function_exists('get_access_token')) {
     /**
      * 获取access_token数组