213 lines
6.5 KiB
PHP
213 lines
6.5 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | ThinkCMF [ WE CAN DO IT MORE SIMPLE ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2013-2014 http://www.thinkcmf.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Author: Tuolaji <479923197@qq.com>
|
||
// +----------------------------------------------------------------------
|
||
/**
|
||
* 功 能：结合ThinkSDK完成腾讯,新浪微博,人人等用户的第三方登录
|
||
* 修改日期：2013-12-11
|
||
*/
|
||
|
||
namespace Api\Controller;
|
||
|
||
use Common\Controller\HomebaseController;
|
||
|
||
class OauthController extends HomebaseController {
|
||
|
||
public function _initialize() {}
|
||
|
||
// 第三方登录地址
|
||
public function login($type = null){
|
||
empty($type) && $this->error('参数错误');
|
||
session('login_http_referer',$_SERVER["HTTP_REFERER"]);
|
||
//加载ThinkOauth类并实例化一个对象
|
||
$sns = \ThinkOauth::getInstance($type);
|
||
//跳转到授权页面
|
||
redirect($sns->getRequestCodeURL());
|
||
}
|
||
|
||
// 第三方登录授权回调地址
|
||
public function callback($type = null, $code = null){
|
||
|
||
(empty($type)) && $this->error('参数错误');
|
||
|
||
if(empty($code)){
|
||
redirect(__ROOT__."/");
|
||
}
|
||
|
||
//加载ThinkOauth类并实例化一个对象
|
||
$sns = \ThinkOauth::getInstance($type);
|
||
|
||
//腾讯微博需传递的额外参数
|
||
$extend = null;
|
||
if($type == 'tencent'){
|
||
$extend = array('openid' => I("get.openid"), 'openkey' => I("get.openkey"));
|
||
}
|
||
//请妥善保管这里获取到的Token信息，方便以后API调用
|
||
//调用方法，实例化SDK对象的时候直接作为构造函数的第二个参数传入
|
||
//如： $qq = ThinkOauth::getInstance('qq', $token);
|
||
$token = $sns->getAccessToken($code , $extend);
|
||
//获取当前登录用户信息
|
||
if(is_array($token)){
|
||
$user_info = A('Type', 'Event')->$type($token);
|
||
$session_oauth_bang=session('oauth_bang');
|
||
if(!empty($session_oauth_bang)){
|
||
$this->_bang_handle($user_info, $type, $token);
|
||
}else{
|
||
$this->_login_handle($user_info, $type, $token);
|
||
}
|
||
}else{
|
||
$this->success('登录失败！',$this->_get_login_redirect());
|
||
}
|
||
}
|
||
|
||
// 第三方账号绑定
|
||
public function bang($type=""){
|
||
if(sp_is_user_login()){
|
||
empty($type) && $this->error('参数错误');
|
||
//加载ThinkOauth类并实例化一个对象
|
||
import("ThinkOauth");
|
||
$sns = \ThinkOauth::getInstance($type);
|
||
//跳转到授权页面
|
||
session('oauth_bang',1);
|
||
redirect($sns->getRequestCodeURL());
|
||
}else{
|
||
$this->error("您还没有登录！");
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取登录跳转地址
|
||
*/
|
||
private function _get_login_redirect(){
|
||
$session_login_http_referer=session('login_http_referer');
|
||
return empty($session_login_http_referer)?__ROOT__."/":$session_login_http_referer;
|
||
}
|
||
|
||
/**
|
||
* 处理绑定第三方账号
|
||
*/
|
||
private function _bang_handle($user_info, $type, $token){
|
||
|
||
$current_uid=sp_get_current_userid();
|
||
$oauth_user_model = M('OauthUser');
|
||
$type=strtolower($type);
|
||
$find_oauth_user = $oauth_user_model->where(array("from"=>$type,"openid"=>$token['openid']))->find();
|
||
$need_bang=true;
|
||
if($find_oauth_user){
|
||
|
||
if($find_oauth_user['uid']==$current_uid){
|
||
$this->error("您之前已经绑定过此账号！",U('user/profile/bang'));exit;
|
||
}else{
|
||
$this->error("该帐号已被本站其他账号绑定！",U('user/profile/bang'));exit;
|
||
}
|
||
|
||
}
|
||
|
||
if($need_bang){
|
||
|
||
if($current_uid){
|
||
//第三方用户表中创建数据
|
||
$new_oauth_user_data = array(
|
||
'from' => $type,
|
||
'name' => $user_info['name'],
|
||
'head_img' => $user_info['head'],
|
||
'create_time' =>date("Y-m-d H:i:s"),
|
||
'uid' => $current_uid,
|
||
'last_login_time' => date("Y-m-d H:i:s"),
|
||
'last_login_ip' => get_client_ip(0,true),
|
||
'login_times' => 1,
|
||
'status' => 1,
|
||
'access_token' => $token['access_token'],
|
||
'expires_date' => (int)(time()+$token['expires_in']),
|
||
'openid' => $token['openid'],
|
||
);
|
||
$new_oauth_user_id=$oauth_user_model->add($new_oauth_user_data);
|
||
if($new_oauth_user_id){
|
||
$this->success("绑定成功！",U('user/profile/bang'));
|
||
}else{
|
||
$this->error("绑定失败！",U('user/profile/bang'));
|
||
}
|
||
}else{
|
||
$this->error("绑定失败！",U('user/profile/bang'));
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* 处理第三方登陆
|
||
*/
|
||
private function _login_handle($user_info, $type, $token){
|
||
$oauth_user_model = M('OauthUser');
|
||
$type=strtolower($type);
|
||
$find_oauth_user = $oauth_user_model->where(array("from"=>$type,"openid"=>$token['openid']))->find();
|
||
$return = array();
|
||
$local_username="";
|
||
$need_register=true;
|
||
if($find_oauth_user){
|
||
$find_user = M('Users')->where(array("id"=>$find_oauth_user['uid']))->find();
|
||
if($find_user){
|
||
$need_register=false;
|
||
if($find_user['user_status'] == '0'){
|
||
$this->error('您可能已经被列入黑名单，请联系网站管理员！');exit;
|
||
}else{
|
||
session('user',$find_user);
|
||
redirect($this->_get_login_redirect());
|
||
}
|
||
}else{
|
||
$need_register=true;
|
||
}
|
||
}
|
||
|
||
if($need_register){
|
||
//本地用户中创建对应一条数据
|
||
$new_user_data = array(
|
||
'user_nicename' => $user_info['name'],
|
||
'avatar' => $user_info['head'],
|
||
'last_login_time' => date("Y-m-d H:i:s"),
|
||
'last_login_ip' => get_client_ip(0,true),
|
||
'create_time' => date("Y-m-d H:i:s"),
|
||
'user_status' => '1',
|
||
"user_type" => '2',//会员
|
||
);
|
||
$users_model=M("Users");
|
||
$new_user_id = $users_model->add($new_user_data);
|
||
|
||
if($new_user_id){
|
||
//第三方用户表中创建数据
|
||
$new_oauth_user_data = array(
|
||
'from' => $type,
|
||
'name' => $user_info['name'],
|
||
'head_img' => $user_info['head'],
|
||
'create_time' =>date("Y-m-d H:i:s"),
|
||
'uid' => $new_user_id,
|
||
'last_login_time' => date("Y-m-d H:i:s"),
|
||
'last_login_ip' => get_client_ip(0,true),
|
||
'login_times' => 1,
|
||
'status' => 1,
|
||
'access_token' => $token['access_token'],
|
||
'expires_date' => (int)(time()+$token['expires_in']),
|
||
'openid' => $token['openid'],
|
||
);
|
||
$new_oauth_user_id=$oauth_user_model->add($new_oauth_user_data);
|
||
if($new_oauth_user_id){
|
||
$new_user_data['id']=$new_user_id;
|
||
session('user',$new_user_data);
|
||
redirect($this->_get_login_redirect());
|
||
}else{
|
||
$users_model->where(array("id"=>$new_user_id))->delete();
|
||
$this->error("登陆失败",$this->_get_login_redirect());
|
||
}
|
||
}else{
|
||
$this->error("登陆失败",$this->_get_login_redirect());
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
} |