oauth/lib/Client.php

<?php
# Oauth Client
namespace Oauth\Lib;

use Dever;
use Dever\Session\Oper as Save;
use Passport\Lib\Base;

class Client extends Base
{
	/**
	 * @desc account
	 * @var int
	 */
	private $account = 1;

	/**
	 * @desc save
	 * @var object
	 */
	protected $session = null;

	/**
	 * @desc passport
	 * @var object
	 */
	protected $passport = null;

	/**
	 * @desc request
	 * @var array
	 */
	private $request = null;

	/**
	 * @desc config
	 * @var array
	 */
	private $config = null;

	public function __construct()
	{
		parent::__construct();
		$this->initPassport();
		$this->initSave();
		$this->initRequest();
		$this->initAccount();
		$this->initSource();
		$this->initSourceType();
		$this->initRefer();
		$this->initConfig();
	}

	private function initPassport()
	{
		$this->passport = Dever::load('passport/lib/base');
	}

	private function initSave()
	{
		$this->session = new Save(DEVER_PROJECT, 'session');
	}

	private function initRequest()
	{
		$this->request = Dever::input();
	}

	private function initAccount()
	{
		$this->account = (isset($this->request['account']) && $this->request['account']) ? $this->request['account'] : $this->session->get('oauth_account');
		$this->session->add('oauth_account', $this->account);
	}

	private function initSystem()
	{
		$this->system = (isset($this->request['system']) && $this->request['system']) ? $this->request['system'] : $this->session->get('oauth_system');
		$this->session->add('oauth_system', $this->system);
	}

	private function initSourceType()
	{
		$this->source_type = (isset($this->request['source_type']) && $this->request['source_type']) ? $this->request['source_type'] : $this->session->get('oauth_source_type');
		$this->session->add('oauth_source_type', $this->source_type);
	}

	private function initSource()
	{
		$this->source = (isset($this->request['source']) && $this->request['source']) ? $this->request['source'] : $this->session->get('oauth_source');
		$this->session->add('oauth_source', $this->source);
	}

	private function initRefer()
	{
		$this->refer = (isset($this->request['refer']) && $this->request['refer']) ? $this->request['refer'] : $this->session->get('oauth_refer');
		$this->session->add('oauth_refer', $this->refer);
	}

	private function initConfig()
	{
		$this->config = Dever::db('oauth/account')->one($this->account);
		if (!$this->config) {
			Dever::alert('账户错误');
		}
		$this->config += Dever::config($this->config['type'])->cAll;
	}

	/**
	 * @desc oauth请求
	 */
	public function auth()
	{
		$info = $this->info();
		if ($info) {
			if ($this->refer) {
				$refer = urldecode($this->refer);
				Dever::location($refer);
			} else {
				return true;
			}
		}
		$id = Dever::id();
		$this->session->add('oauth_id', $id);
		$this->param('auth', 'appid', $this->config['appid']);
		$this->param('auth', 'redirect_uri', Dever::url('request.callback?account=' . $this->account, 'oauth'));
		$this->param('auth', 'state', $id);
		$this->param('auth', 'response_type');
		$this->param('auth', 'scope');
		
		//print_r($this->config['auth']);die;

		$url = $this->config['auth']['url'] . '?' . http_build_query($this->config['auth']['param']);

		Dever::location($url);
	}
	
	/**
	 * @desc oauth请求 callback
	 */
	public function callback($url = '')
	{
		$this->js = true;
		if ((isset($this->request['js']) && $this->request['js'])) {
			$this->js = false;
		}
		if ($this->js == true && $url) {
			return $this->output($url);
		} else {
			$id = $this->session->get('oauth_id');
			if (isset($this->config['token']['param'])) {
				if (!$this->session->get('oauth_refresh')) {
					$this->param('token', 'code');
					$this->param('token', 'appid', $this->config['appid']);
					$this->param('token', 'secret', $this->config['appsecret']);
					$this->param('token', 'grant_type');

					$result = Dever::curl($this->config['token']['url'], $this->config['token']['param']);

					$result = Dever::json_decode($result);

					if (isset($result['errmsg'])) {
						Dever::alert($result['errmsg']);
					}

					parse_str(http_build_query($result), $this->request);

					$this->response('token', 'access_token');
					$this->response('token', 'expires_in');
					$this->response('token', 'refresh_token');
					$this->response('token', 'openid');
					$this->response('token', 'unionid');
					$this->response('token', 'scope');
					$this->response('token', 'errcode');
					$this->response('token', 'errmsg');

				} else {
					# 由于refresh token是长期有效的，所以这里无需再次获取了。之后通过这个refresh获取access token就行了
					return;
				}
			}
			
			if (isset($this->config['token']['response']) && $this->config['token']['response']) {
				# 进入绑定流程吧
				return $this->bind();
			}
		}
		Dever::alert('登录失败');
	}
	
	/**
	 * @desc 重新获取token 暂时不用
	 * @author leo(suwi.bin)
	 * @date 2012-08-27
	 */
	protected function refresh()
	{
		$data = $this->request;
		$state = false;
		if(isset($data['token_refresh']) && $data['token_refresh'])
		{
			$this->param('refresh', 'refresh_token',		 $data['token_refresh']);
			$this->param('refresh', 'client_id',			 $this->_config['id']);
			$this->param('refresh', 'client_secret',		 $this->_config['key']);
			$return = json_decode($this->_curl('post', $this->param['refresh']), true);
			if(isset($return['error']))
			{
				Dever::alert('参数错误');
			}
			if(isset($return['access_token']) && $return['access_token'])
			{
				$update['token_code'] = $return['access_token'];
				$update['token_type'] = $return['token_type'];
				$update['token_time'] = $return['expires_in'];
				$state = $this->update($update, $data['id']);
			}
		}
		return $state;
	}
	
	/**
	 * @desc 绑定数据
	 */
	private function bind()
	{
		$data = $this->config['token']['response'];

		if (!$data) {
			Dever::alert('错误的数据');
		}
		
		$get = $this->request;
		
		$id = false;
		
		if (isset($get['id']) && $get['id'] > 0) {
			$id = $get['id'];
		}
		
		$user = $this->update($data, $id);
		# 跳转吧，从哪来去哪吧
		if ($this->refer) {
			$refer = urldecode($this->refer);
			Dever::location($refer);
		} else {
			$result = $user;
	        $result['uid'] = $user['id'];
	        $result['signature'] = Dever::login($user['id']);
	        return $result;
		}
	}

	/**
	 * @desc 绑定数据
	 */
	private function update($data, $id)
	{
		$uid = false;
        $info = Dever::load('passport/wechat-one', array('option_openid' => $data['openid']));

        $this->param('user', 'access_token', $data['access_token']);
		$this->param('user', 'openid', $data['openid']);

		$userinfo = Dever::json_decode(Dever::curl($this->config['user']['url'], $this->config['user']['param']));
		if (!$userinfo) {
			return;
		}
		
        //$user['bind'] = 1;
        $user['temp'] = 2;
        $user['username'] = Dever::emoji($userinfo['nickname']);
        if ($userinfo['headimgurl']) {
            //$update['set_avatar'] = $this->sessionAvatar($pic);
          	$user['avatar'] = $userinfo['headimgurl'];
        }
        
        if ($userinfo['city']) {
            $user['city'] = $userinfo['city'];
        }

        if ($userinfo['province']) {
            $user['province'] = $userinfo['province'];
        }

        if ($userinfo['country']) {
            $user['country'] = $userinfo['country'];
        }

        if ($userinfo['country'] && $userinfo['province'] && $userinfo['city']) {
        	$user['area'] = $userinfo['country'] .','. $userinfo['province'] .','. $userinfo['city'];
    	}

        if (!$info) {
            if (isset($data['unionid']) && $data['unionid']) {
                $info = Dever::load('passport/wechat-one', array('unionid' => $data['unionid']));
                if (!$info) {
                    $uid = false;
                } else {
                    $uid = $info['uid'];
                }
                $wechat['unionid'] = $data['unionid'];
            }
            if (!$uid) {
            	$user['source_type'] = 'service';
            	if ($this->system) {
					$user['system_id'] = $this->system;
	            }
	            if ($this->source_type) {
					$user['source_type'] = $this->source_type;
	            }
                $uid = Dever::load('passport/user-insert', $user);
            } else {
                $user['where_id'] = $uid;
                Dever::load('passport/user-update', $user);
            }

            $wechat['access_token'] = $data['access_token'];
            $wechat['openid'] = $data['openid'];
            $wechat['expires_in'] = $data['expires_in'];
            $wechat['refresh_token'] = $data['refresh_token'];
            $wechat['account_id'] = $this->account;
            if ($this->system) {
				$wechat['system_id'] = $this->system;
            }
            
            $wechat['uid'] = $uid;
            $wechat['type'] = 2;
            if ($this->source_type == 'ios') {
            	$wechat['type'] = 3;
            } elseif ($this->source_type == 'android') {
            	$wechat['type'] = 4;
            }
            $id = Dever::load('passport/wechat-insert', $wechat);

            if (Dever::project('source') && isset($this->source) && $this->source && $this->source > 0) {
            	Dever::load('source/lib/core')->saveUser($id, $uid, $this->source, 'oauth', $this->account);
            }
        } else {
            $uid = $info['uid'];
            if (isset($data['unionid']) && $data['unionid']) {
                $wechat['unionid'] = $data['unionid'];
                # 判断用户是否存在，是否需要合并
                $wechat['uid'] = $this->passport->combine($uid, $data['unionid']);
            }
            
            $wechat['access_token'] = $data['access_token'];
            $wechat['openid'] = $data['openid'];
            $wechat['expires_in'] = $data['expires_in'];
            $wechat['refresh_token'] = $data['refresh_token'];
            $wechat['where_id'] = $info['id'];
            $wechat['account_id'] = $this->account;
            if ($this->system) {
            	$wechat['system_id'] = $this->system;
            }
            $id = $info['id'];
            Dever::load('passport/wechat-update', $wechat);

            $user['where_id'] = $uid;
            Dever::load('passport/user-update', $user);
        }

        $this->passport->createUsername($uid, $user['username']);

        $user = Dever::load('passport/user-one', $uid);

        $this->save($user);

        return $user;
	}
	
	/**
	 * @desc 输出js内容
	 */
	private function output($url)
	{
		$html = 
		'<script>   
			var params = {}, queryString = location.hash.substring(1),
			regex = /([^&=]+)=([^&]*)/g, m;
			while (m = regex.exec(queryString))
			{
				params[decodeURIComponent(m[1])] = decodeURIComponent(m[2]);
			}

			location.href="'.$url.'&js=false&" + queryString;
		</script>';
		echo $html;die;
	}
	
	/**
	 * @desc 请求参数
	 */
	private function param($type, $key, $value = false)
	{
		$this->compatible($this->config[$type]['param'], $key, $value);
	}

	/**
	 * @desc 响应参数
	 */
	private function response($type, $key, $value = false)
	{
		$this->compatible($this->config[$type]['response'], $key, $value);
	}

	/**
	 * @desc 兼容处理
	 */
	private function compatible(&$param, $key, $value = false)
	{
		$default = false;
		if (isset($param[$key]) && is_array($param[$key])) {
			$nkey = $param[$key][0];
			$default = $param[$key][1];
			unset($param[$key]);
			$key = $nkey;
		} else {
			$default = $param[$key];
		}
		return $param[$key] = ($value ? $value : (isset($this->request[$key]) ? $this->request[$key] : $default));
	}
}