Overtrue\Socialite\Providers\CorpWechatProvider

Complexity

Total Complexity

15

Size/Duplication

Total Lines	193
Duplicated Lines	6.74 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getAuthUrl()	0	8	1
A	buildAuthUrlFromBase()	0	6	1
A	getCodeFields()	13	13	2
A	getTokenUrl()	0	4	1
A	getUserByToken()	0	17	2
A	mapUserToObject()	0	13	1
A	getTokenFields()	0	19	2
A	getAccessToken()	0	22	2
A	getLongiveAccessToken()	0	9	1
A	removeCallback()	0	10	2

<?php

/*
 * This file is part of the overtrue/socialite.
 *
 * (c) overtrue <i@overtrue.me>
 *
 * This source file is subject to the MIT license that is bundled
 * with this source code in the file LICENSE.
 */

namespace Overtrue\Socialite\Providers;

use Overtrue\Socialite\AccessToken;
use Overtrue\Socialite\AccessTokenInterface;
use Overtrue\Socialite\InvalidArgumentException;
use Overtrue\Socialite\ProviderInterface;
use Overtrue\Socialite\User;

/**
 * Class WeChatProvider.
 *
 * @link http://mp.weixin.qq.com/wiki/9/01f711493b5a02f24b04365ac5d8fd95.html [WeChat - 公众平台OAuth文档]
 * @link https://open.weixin.qq.com/cgi-bin/showdocument?action=dir_list&t=resource/res_list&verify=1&id=open1419316505&token=&lang=zh_CN [网站应用微信登录开发指南]
 */
class CorpWechatProvider extends AbstractProvider implements ProviderInterface
{
    /**
     * The base url of WeChat API.
     *
     * @var string
     */
    protected $user_baseinfo_api = 'https://qyapi.weixin.qq.com/cgi-bin/user/getuserinfo';
    protected $user_info_api = 'https://qyapi.weixin.qq.com/cgi-bin/user/get';
    protected $access_api_url = 'https://qyapi.weixin.qq.com/cgi-bin/gettoken';

    /**
     * {@inheritdoc}.
     */
    protected $openId;

    /**
     * {@inheritdoc}.
     */
    protected $scopes = ['snsapi_base'];

    /**
     * Indicates if the session state should be utilized.
     *
     * @var bool
     */
    protected $stateless = true;

    /**
     * {@inheritdoc}.
     */
    protected function getAuthUrl($state)
    {
        $path = 'oauth2/authorize';

        $url = "https://open.weixin.qq.com/connect/{$path}";
        // dd($url);

67% of this comment could be valid code. Did you maybe forget this after debugging?

        return $this->buildAuthUrlFromBase($url, $state);
    }

    /**
     * {@inheritdoc}.
     */
    protected function buildAuthUrlFromBase($url, $state)
    {
        $query = http_build_query($this->getCodeFields($state), '', '&', $this->encodingType);
        $url = $url.'?'.$query.'#wechat_redirect';
        return $url;
    }

    /**
     * {@inheritdoc}.
     */
    protected function getCodeFields($state = null)

This method seems to be duplicated in your project.

    {

        $result = array_merge([
            'appid' => $this->clientId,
            'redirect_uri' => $this->redirectUrl,
            'response_type' => 'code',
            'scope' => $this->formatScopes($this->scopes, $this->scopeSeparator),
            'state' => $state ?: md5(time()),
        ], $this->parameters);

        return $result;
    }

    /**
     * 获取 access token的路径.
     */
    protected function getTokenUrl()
    {
        return $this->access_api_url;
    }

    /**
     * {@inheritdoc}.
     */
    protected function getUserByToken(AccessTokenInterface $token)
    {


        if (empty($token['UserId'])) {
            throw new InvalidArgumentException('UserId of AccessToken is required.');
        }

        $response = $this->getHttpClient()->get($this->user_info_api, [
            'query' => [
                'access_token' => $token->getToken(),
                'userid' => $token['UserId'],
            ],
        ]);

        return json_decode($response->getBody(), true);
    }

    /**
     * {@inheritdoc}.
     */
    protected function mapUserToObject(array $user)
    {
        return new User([
            'userid' => $this->arrayItem($user, 'userid'),
            'name' => $this->arrayItem($user, 'name'),
            'avatar' => $this->arrayItem($user, 'avatar'),
            'mobile' => $this->arrayItem($user, 'mobile'),
            'department' => $this->arrayItem($user, 'department'),
            'gender' => $this->arrayItem($user, 'gender'),
            'email' => $this->arrayItem($user, 'email'),
            'status' => $this->arrayItem($user, 'status'),
        ]);
    }

    /**
     * 构建access_token 的参数列表, 分为两种情况一种是 获取access token, 另一种是直接获取userid
     */
    protected function getTokenFields($code = false)
    {
        //参数列表: 
        // https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=id&corpsecret=secrect

        if(!$code){
            $token_fields = [
                'corpid' => $this->clientId,
                'corpsecret' => $this->clientSecret,
            ];    
        }else{
            $token_fields = [
                'access_token'=>$this->config['longlive_access_token'],
                'code'=>$code,
            ];    
        }
     
        return $token_fields;
    }

    /**
     * 原始微信oauth 应该是返回 access token + openid
     * 企业号因为用的是7200秒的, 所以需要支持从外部去获取access_token 不会冲突  要返回 userid 
     */
    public function getAccessToken($code)
    {

        //没有指定则自己获取
        if(!$this->config['longlive_access_token']){
            $this->config['longlive_access_token'] = $this->getLongiveAccessToken();
        }
        $param = $this->getTokenFields($code);
        // dd($param);

67% of this comment could be valid code. Did you maybe forget this after debugging?

        $get_token_url = $this->user_baseinfo_api;
        $response = $this->getHttpClient()->get($get_token_url, [
            'query' => $param,
        ]);

        $content = $response->getBody()->getContents();
        $content = json_decode($content,true);
        $content['access_token'] =  $this->config['longlive_access_token'];

        $token = $this->parseAccessToken($content);
        return $token;

    }
    // !!应该尽量不要调用, 除非 单独与overture/wechat使用, 否则同时获取accesstoken, 会冲突
    public function getLongiveAccessToken($forse_refresh = false){

The parameter $forse_refresh is not used and could be removed.

        $get_token_url = $this->getTokenUrl();
        $response = $this->getHttpClient()->get($get_token_url, [
            'query' => $this->getTokenFields(),
        ]);
        $content = $response->getBody()->getContents();
        $token = $this->parseAccessToken($content);
        return $token['access_token'];
    }

   

    /**
     * Remove the fucking callback parentheses.
     *
     * @param mixed $response
     *
     * @return string
     */
    protected function removeCallback($response)
    {
        if (strpos($response, 'callback') !== false) {
            $lpos = strpos($response, '(');
            $rpos = strrpos($response, ')');
            $response = substr($response, $lpos + 1, $rpos - $lpos - 1);
        }

        return $response;
    }
}