www.gusucode.com > OpenSNS PHP开源社区交友系统 v2.8.1源码程序 > os/Application/User/Model/UcenterMemberModel.class.php
<?php
// +----------------------------------------------------------------------
// | OneThink [ WE CAN DO IT JUST THINK IT ]
// +----------------------------------------------------------------------
// | Copyright (c) 2013 http://www.onethink.cn All rights reserved.
// +----------------------------------------------------------------------
// | Author: 麦当苗儿 <zuojiazi@vip.qq.com> <http://www.zjzit.cn>
// +----------------------------------------------------------------------
namespace User\Model;
use Think\Model;
use Home\Model\MemberModel;
require_once(APP_PATH . '/User/Conf/config.php');
require_once(APP_PATH. '/User/Common/common.php');
/**
* 会员模型
*/
class UcenterMemberModel extends Model
{
/**
* 数据表前缀
* @var string
*/
protected $tablePrefix = UC_TABLE_PREFIX;
/**
* 数据库连接
* @var string
*/
protected $connection = UC_DB_DSN;
/* 用户模型自动验证 */
protected $_validate = array(
/* 验证用户名 */
array('username', 'checkUsernameLength', -1, self::EXISTS_VALIDATE,'callback'), //用户名长度不合法
array('username', 'checkDenyMember', -2, self::EXISTS_VALIDATE, 'callback'), //用户名禁止注册
array('username', 'checkUsername', -20, self::EXISTS_VALIDATE, 'callback'),
array('username', '', -3, self::EXISTS_VALIDATE, 'unique'), //用户名被占用
/* 验证密码 */
array('password', '6,30', -4, self::EXISTS_VALIDATE, 'length'), //密码长度不合法
/* 验证邮箱 */
array('email', 'email', -5, self::EXISTS_VALIDATE), //邮箱格式不正确
array('email', '4,32', -6, self::EXISTS_VALIDATE, 'length'), //邮箱长度不合法
array('email', 'checkDenyEmail', -7, self::EXISTS_VALIDATE, 'callback'), //邮箱禁止注册
array('email', '', -8, self::EXISTS_VALIDATE, 'unique'), //邮箱被占用
/* 验证手机号码 */
array('mobile', '/^(1[3|4|5|8])[0-9]{9}$/', -9, self::EXISTS_VALIDATE), //手机格式不正确 TODO:
array('mobile', 'checkDenyMobile', -10, self::EXISTS_VALIDATE, 'callback'), //手机禁止注册
array('mobile', '', -11, self::EXISTS_VALIDATE, 'unique'), //手机号被占用
);
/* 用户模型自动完成 */
protected $_auto = array(
array('password', 'think_ucenter_md5', self::MODEL_BOTH, 'function', UC_AUTH_KEY),
array('reg_time', NOW_TIME, self::MODEL_INSERT),
array('reg_ip', 'get_client_ip', self::MODEL_INSERT, 'function', 1),
array('update_time', NOW_TIME),
array('status', 'getStatus', self::MODEL_BOTH, 'callback'),
);
/**
* 检测用户名是不是被禁止注册(保留用户名)
* @param string $username 用户名
* @return boolean ture - 未禁用，false - 禁止注册
*/
protected function checkDenyMember($username)
{
$denyName=M("Config")->where(array('name' => 'USER_NAME_BAOLIU'))->getField('value');
if($denyName!=''){
$denyName=explode(',',$denyName);
foreach($denyName as $val){
if(!is_bool(strpos($username,$val))){
return false;
}
}
}
return true;
}
/**
* 检测邮箱是不是被禁止注册
* @param string $email 邮箱
* @return boolean ture - 未禁用，false - 禁止注册
*/
protected function checkDenyEmail($email)
{
return true; //TODO: 暂不限制，下一个版本完善
}
protected function checkUsername($username)
{
//如果用户名中有空格，不允许注册
if (strpos($username, ' ') !== false) {
return false;
}
preg_match("/^[a-zA-Z0-9_]{0,64}$/", $username, $result);
if (!$result) {
return false;
}
return true;
}
/**
* 验证用户名长度
* @param $username
* @return bool
* @author 郑钟良<zzl@ourstu.com>
*/
protected function checkUsernameLength($username)
{
$length = mb_strlen($username, 'utf-8'); // 当前数据长度
if ($length < modC('USERNAME_MIN_LENGTH',2,'USERCONFIG') || $length > modC('USERNAME_MAX_LENGTH',32,'USERCONFIG')) {
return false;
}
return true;
}
/**
* 检测手机是不是被禁止注册
* @param string $mobile 手机
* @return boolean ture - 未禁用，false - 禁止注册
*/
protected function checkDenyMobile($mobile)
{
return true; //TODO: 暂不限制，下一个版本完善
}
/**
* 根据配置指定用户状态
* @return integer 用户状态
*/
protected function getStatus()
{
return true; //TODO: 暂不限制，下一个版本完善
}
/**
* 注册一个新用户
* @param string $username 用户名
* @param string $nickname 昵称
* @param string $password 用户密码
* @param string $email 用户邮箱
* @param string $mobile 用户手机号码
* @return integer 注册成功-用户信息，注册失败-错误编号
*/
public function register($username, $nickname, $password, $email='', $mobile='', $type=1)
{
$data = array(
'username' => $username,
'password' => $password,
'email' => $email,
'mobile' => $mobile,
'type' => $type,
);
//验证手机
if (empty($data['mobile'])) unset($data['mobile']);
if (empty($data['username'])) unset($data['username']);
if (empty($data['email'])) unset($data['email']);
/* 添加用户 */
$usercenter_member = $this->create($data);
if ($usercenter_member) {
$result = D('Common/Member')->registerMember($nickname);
if ($result > 0) {
$usercenter_member['id'] = $result;
$uid = $this->add($usercenter_member);
if ($uid === false) {
//如果注册失败，则回去Memeber表删除掉错误的记录
D('Common/Member')->where(array('uid' => $result))->delete();
}
action_log('reg','ucenter_member',1,1);
return $uid ? $uid : 0; //0-未知错误，大于0-注册成功
} else {
return $result;
}
} else {
return $this->getError(); //错误详情见自动验证注释
}
}
/**
* 用户登录认证
* @param string $username 用户名
* @param string $password 用户密码
* @param integer $type 用户名类型 （1-用户名，2-邮箱，3-手机，4-UID）
* @return integer 登录成功-用户ID，登录失败-错误编号
*/
public function login($username, $password, $type = 1)
{
$map = array();
switch ($type) {
case 1:
$map['username'] = $username;
break;
case 2:
$map['email'] = $username;
break;
case 3:
$map['mobile'] = $username;
break;
case 4:
$map['id'] = $username;
break;
default:
return 0; //参数错误
}
/* 获取用户数据 */
$user = $this->where($map)->find();
$return = check_action_limit('input_password','ucenter_member',$user['id'],$user['id']);
if($return && !$return['state']){
return $return['info'];
}
if (UC_SYNC && $user['id'] != 1) {
return $this->ucLogin($username, $password);
}
if (is_array($user) && $user['status']) {
/* 验证用户密码 */
if (think_ucenter_md5($password, UC_AUTH_KEY) === $user['password']) {
$this->updateLogin($user['id']); //更新用户登录信息
return $user['id']; //登录成功，返回用户ID
} else {
action_log('input_password','ucenter_member',$user['id'],$user['id']);
return -2; //密码错误
}
} else {
return -1; //用户不存在或被禁用
}
}
public function ucLogin($username, $password)
{
include_once './api/uc_client/client.php';
//Ucenter 内数据
$uc_user = uc_user_login($username, $password, 0);
//关联表内数据
$uc_user_ref = get_ucenter_user_ref('', $uc_user['0'], '');
//登录
if ($uc_user_ref['uid'] && $uc_user_ref['uc_uid'] && $uc_user[0] > 0) {
return $uc_user_ref['uid'];
}
//本地帐号信息
$tox_user = $this->getLocal($username, $password);
// 关联表无、UC有、本地无的
if ($uc_user[0] > 0 && !$tox_user['id']) {
$uid = $this->register($uc_user[1], $uc_user[1], $uc_user[2], $uc_user[3], '', 1);
if ($uid <= 0) {
return A('Ucenter/Member')->showRegError($uid);
}
$this->initRoleUser(1, $uid); //初始化角色用户
$result = add_ucenter_user_ref($uid, $uc_user[0], $uc_user[1], $uc_user[3]);
if (!$result) {
return L('_USER_DOES_NOT_EXIST_OR_PASSWORD_ERROR_');
}
return $uid;
}
// 关联表无、UC有、本地有的
if ($uc_user[0] > 0 && $tox_user['id'] > 0) {
$result = add_ucenter_user_ref($tox_user['id'], $uc_user[0], $uc_user[1], $uc_user[3]);
if (!$result) {
return L('_USER_DOES_NOT_EXIST_OR_PASSWORD_ERROR_');
}
return $tox_user['id'];
}
// 关联表无、UC无、本地有
if ($uc_user[0] < 0 && $tox_user['id'] > 0) {
$email = $tox_user['email']?$tox_user['email']:$this->rand_email();
//写入UC
$uc_uid = uc_user_register($tox_user['username'], $password,$email , '', '', get_client_ip());
if ($uc_uid <= 0) {
return L('_UC_ACCOUNT_REGISTRATION_FAILED_PLEASE_CONTACT_THE_ADMINISTRATOR_');
}
//写入关联表
if (M('ucenter_user_link')->where(array('uid' => $tox_user['id']))->find()) {
$result = update_ucenter_user_ref($tox_user['id'], $uc_uid, $tox_user['username'], $email);
} else {
$result = add_ucenter_user_ref($tox_user['id'], $uc_uid, $tox_user['username'], $email);
}
if (!$result) {
return L('_USER_DOES_NOT_EXIST_OR_PASSWORD_ERROR_');
}
return $tox_user['id'];
}
//关联表无、UC无、本地无的
return L('_USERS_DO_NOT_EXIST_');
}
/**
* 初始化角色用户信息
* @param $role_id
* @param $uid
* @return bool
* @author 郑钟良<zzl@ourstu.com>
*/
public function initRoleUser($role_id = 0, $uid)
{
$memberModel = D('Member');
$role = D('Role')->where(array('id' => $role_id))->find();
$user_role = array('uid' => $uid, 'role_id' => $role_id, 'step' => "start");
if ($role['audit']) { //该角色需要审核
$user_role['status'] = 2; //未审核
} else {
$user_role['status'] = 1;
}
$result = D('UserRole')->add($user_role);
if (!$role['audit']) {
//该角色不需要审核
$memberModel->initUserRoleInfo($role_id, $uid);
}
$memberModel->initDefaultShowRole($role_id, $uid);
return $result;
}
public function getLocal($username, $password)
{
$aUsername = $username;
check_username($aUsername, $email, $mobile, $type);
$map = array();
switch ($type) {
case 1:
$map['username'] = $username;
break;
case 2:
$map['email'] = $username;
break;
case 3:
$map['mobile'] = $username;
break;
case 4:
$map['id'] = $username;
break;
default:
return 0; //参数错误
}
/* 获取用户数据 */
$user = $this->where($map)->find();
if (is_array($user) && $user['status']) {
/* 验证用户密码 */
if (think_ucenter_md5($password, UC_AUTH_KEY) === $user['password']) {
return $user; //登录成功，返回用户ID
} else {
return false; //密码错误
}
} else {
return false; //用户不存在或被禁用
}
}
/**
* 用户密码找回认证
* @param string $username 用户名
* @param string $password 用户密码
* @param integer $type 用户名类型 （1-用户名，2-邮箱，3-手机，4-UID）
* @return integer 登录成功-用户ID，登录失败-错误编号
*/
public function lomi($username, $email)
{
$map = array();
$map['username'] = $username;
$map['email'] = $email;
/* 获取用户数据 */
$user = $this->where($map)->find();
if (is_array($user)) {
/* 验证用户 */
//if($user['last_login_time']){
//return $user['last_login_time']; //成功，返回用户最后登录时间
return $user; //成功，返回用户最后登录时间
//}else{
//return $user['reg_time']; //返回用户注册时间
//return -1; //成功，返回用户最后登录时间
//}
} else {
return -2; //用户和邮箱不符
}
}
/**
* 用户密码找回认证2
* @param string $username 用户名
* @param string $password 用户密码
* @param integer $type 用户名类型 （1-用户名，2-邮箱，3-手机，4-UID）
* @return integer 登录成功-用户ID，登录失败-错误编号
*/
public function reset($uid)
{
$map = array();
$map['id'] = $uid;
/* 获取用户数据 */
$user = $this->where($map)->find();
if (is_array($user)) {
return $user; //成功，返回用户数据
} else {
return -2; //用户和邮箱不符
}
}
/**
* 根据IP获取用户最后注册时间
* @param string $uid 用户ID或用户名
* @param boolean $is_username 是否使用用户名查询
* @return array 用户信息
*/
public function infos($regip)
{
$map['reg_ip'] = $regip;
$user = $this->where($map)->max('reg_time');
if ($user) {
return $user;
} else {
return -1; //用户不存在或被禁用
}
}
/**
* 获取用户信息
* @param string $uid 用户ID或用户名
* @param boolean $is_username 是否使用用户名查询
* @return array 用户信息
*/
public function info($uid, $is_username = false)
{
$map = array();
if ($is_username) { //通过用户名获取
$map['username'] = $uid;
} else {
$map['id'] = $uid;
}
$user = $this->where($map)->field('id,username,email,mobile,status')->find();
if (is_array($user) && $user['status'] = 1) {
return array($user['id'], $user['username'], $user['email'], $user['mobile']);
} else {
return -1; //用户不存在或被禁用
}
}
/**
* 检测用户信息
* @param string $field 用户名
* @param integer $type 用户名类型 1-用户名，2-用户邮箱，3-用户电话
* @return integer 错误编号
*/
public function checkField($field, $type = 1)
{
$data = array();
switch ($type) {
case 1:
$data['username'] = $field;
break;
case 2:
$data['email'] = $field;
break;
case 3:
$data['mobile'] = $field;
break;
default:
return 0; //参数错误
}
return $this->create($data) ? 1 : $this->getError();
}
/**
* 更新用户登录信息
* @param integer $uid 用户ID
*/
protected function updateLogin($uid)
{
$data = array(
'id' => $uid,
'last_login_time' => NOW_TIME,
'last_login_ip' => get_client_ip(1),
);
$this->save($data);
}
/**
* 更新用户信息
* @param int $uid 用户id
* @param string $password 密码，用来验证
* @param array $data 修改的字段数组
* @return true 修改成功，false 修改失败
* @author huajie <banhuajie@163.com>
*/
public function updateUserFields($uid, $password, $data)
{
if (empty($uid) || empty($password) || empty($data)) {
$this->error = L('_PARAM_ERROR_25_');
return false;
}
//更新前检查用户密码
if (!$this->verifyUser($uid, $password)) {
$this->error = L('_VERIFY_ERROR_PW_WRONG_');
return false;
}
//更新用户信息
$data = $this->create($data, 2); //指定此处为更新数据
if ($data) {
return $this->where(array('id' => $uid))->save($data);
}
return false;
}
/**
* 重置用户密码
* @param int $uid 用户id
* @param string $password 密码，用来验证
* @param array $data 修改的字段数组
* @return true 修改成功，false 修改失败
* @author huajie <banhuajie@163.com>
*/
public function updateUserFieldss($uid, $data)
{
if (empty($uid) || empty($data)) {
$this->error = L('_PARAM_ERROR_25_');
return false;
}
//更新用户信息
$data = $this->create($data, 2);
if ($data) {
return $this->where(array('id' => $uid))->save($data);
}
return false;
}
/**
* 验证用户密码
* @param int $uid 用户id
* @param string $password_in 密码
* @return true 验证成功，false 验证失败
* @author huajie <banhuajie@163.com>
*/
public function verifyUser($uid, $password_in)
{
$password = $this->getFieldById($uid, 'password');
if (think_ucenter_md5($password_in, UC_AUTH_KEY) === $password) {
return true;
}
return false;
}
/**修改密码
* @param $old_password
* @param $new_password
* @return bool
* @auth 陈一枭
*/
public function changePassword($old_password, $new_password)
{
//检查旧密码是否正确
if (!$this->verifyUser(get_uid(), $old_password)) {
$this->error = -41;
return false;
}
//更新用户信息
$model = $this;
$data = array('password' => $new_password);
$data = $model->create($data);
if (!$data) {
$this->error = $model->getError();
return false;
}
$model->where(array('id' => get_uid()))->save($data);
//返回成功信息
clean_query_user_cache(get_uid(), 'password');//删除缓存
D('user_token')->where('uid=' . get_uid())->delete();
return true;
}
public function getErrorMessage($error_code = null)
{
$error = $error_code == null ? $this->error : $error_code;
switch ($error) {
case -1:
$error = L('_USER_NAME_MUST_BE_IN_LENGTH_').modC('USERNAME_MIN_LENGTH',2,'USERCONFIG').'-'.modC('USERNAME_MAX_LENGTH',32,'USERCONFIG').L('_BETWEEN_CHARACTERS_WITH_EXCLAMATION_');
break;
case -2:
$error = L('_USER_NAME_IS_FORBIDDEN_TO_REGISTER_WITH_EXCLAMATION_');
break;
case -3:
$error = L('_USER_NAME_IS_OCCUPIED_WITH_EXCLAMATION_');
break;
case -4:
$error = L('_PW_LENGTH_6_30_');
break;
case -41:
$error = L('_USERS_OLD_PASSWORD_IS_INCORRECT_');
break;
case -5:
$error = L('_MAILBOX_FORMAT_IS_NOT_CORRECT_WITH_EXCLAMATION_');
break;
case -6:
$error = L('_EMAIL_LENGTH_4_32_');
break;
case -7:
$error = L('_MAILBOX_IS_PROHIBITED_TO_REGISTER_WITH_EXCLAMATION_');
break;
case -8:
$error = L('_MAILBOX_IS_OCCUPIED_WITH_EXCLAMATION_');
break;
case -9:
$error = L('_MOBILE_PHONE_FORMAT_IS_NOT_CORRECT_WITH_EXCLAMATION_');
break;
case -10:
$error = L('_MOBILE_PHONES_ARE_PROHIBITED_FROM_REGISTERING_WITH_EXCLAMATION_');
break;
case -11:
$error = L('_PHONE_NUMBER_IS_OCCUPIED_WITH_EXCLAMATION_');
break;
case -12:
$error = L('_UN_LIMIT_SOME_');
break;
case -31:
$error = L('_THE_NICKNAME_IS_PROHIBITED_');
break;
case -33:
$error = L('_NICKNAME_LENGTH_MUST_BE_IN_').modC('NICKNAME_MIN_LENGTH',2,'USERCONFIG').'-'.modC('NICKNAME_MAX_LENGTH',32,'USERCONFIG').L('_BETWEEN_CHARACTERS_WITH_EXCLAMATION_');
break;
case -32:
$error = L('_THE_NICKNAME_IS_NOT_LEGAL_');
break;
case -30:
$error = L('_THE_NICKNAME_HAS_BEEN_OCCUPIED_');
break;
default:
$error = L('_UNKNOWN_ERROR_');
}
return $error;
}
/**
* addSyncData
* @return mixed
* @author:xjw129xjt(肖骏涛) xjt@ourstu.com
*/
public function addSyncData()
{
$data['email'] = $this->rand_email();
$data['password'] = create_rand(10);
$data['type'] = 2; // 视作用邮箱注册
$data = $this->create($data);
$uid = $this->add($data);
return $uid;
}
protected function rand_email()
{
$email = create_rand(10) . '@ocenter.com';
if ($this->where(array('email' => $email))->select()) {
$this->rand_email();
} else {
return $email;
}
}
}