oauth/lib/Client.php

<?php
# Oauth Client
namespace Oauth\Lib;

use Dever;
use Dever\Session\Oper as Save;

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

	/**
	 * @desc save
	 * @var object
	 */
	private $save = null;

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

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

	public function __construct()
	{
		$this->initSave();
		$this->initRequest();
		$this->initAccount();
		$this->initRefer();
		$this->initConfig();
	}

	private function initSave()
	{
		$this->save = 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->save->get('oauth_account');
		$this->save->add('oauth_account', $this->account);
	}

	private function initRefer()
	{
		$this->refer = (isset($this->request['refer']) && $this->request['refer']) ? $this->request['refer'] : $this->save->get('oauth_refer');
		$this->save->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()
	{
		$id = Dever::id();
		$this->save->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 = '')
	{
		if ((isset($this->request['js']) && $this->request['js'])) {
			$this->_js = false;
		}
		if ($this->_js == true && $url) {
			return $this->output($url);
		} else {
			$id = $this->save->get('oauth_id');
			if (isset($this->config['token']['param'])) {
				if (!$this->save->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);

					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;
				}
			}
			
			# 进入绑定流程吧
			$this->bind($data);
		}
	}
	
	/**
	 * @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'];
		
		$get = $this->request();
		
		$id = false;
		
		if(isset($get['id']) && $get['id'] > 0)
		{
			$id = $get['id'];
		}
		
		$this->_update($data, $id);
		
		# 跳转吧，从哪来去哪吧
		if($this->refer)
		{
			$refer = base64_decode($this->refer);
			Dever::location($refer);
		}
	}
	
	/**
	 * @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));
	}
}