www.gusucode.com > Ectouch手机端网购商城系统PHP版源码程序 > ectouch/plugins/integrates/ucenter.php
<?php
/**
* ECTouch Open Source Project
* ============================================================================
* Copyright (c) 2012-2014 http://ectouch.cn All rights reserved.
* ----------------------------------------------------------------------------
* Licensed ( http://www.ectouch.cn/docs/license.txt )
* ----------------------------------------------------------------------------
*/
/* 访问控制 */
defined('IN_ECTOUCH') or die('Deny Access');
/* 模块的基本信息 */
if (isset($set_modules) && $set_modules == TRUE) {
$i = (isset($modules)) ? count($modules) : 0;
/* 会员数据整合插件的代码必须和文件名保持一致 */
$modules[$i]['code'] = 'ucenter';
/* 被整合的第三方程序的名称 */
$modules[$i]['name'] = 'UCenter';
/* 被整合的第三方程序的版本 */
$modules[$i]['version'] = '1.x';
/* 插件的作者 */
$modules[$i]['author'] = 'ECSHOP TEAM';
/* 插件作者的官方网站 */
$modules[$i]['website'] = 'http://www.ecshop.com';
/* 插件的初始的默认值 */
$modules[$i]['default']['db_host'] = 'localhost';
$modules[$i]['default']['db_user'] = 'root';
$modules[$i]['default']['prefix'] = 'uc_';
$modules[$i]['default']['cookie_prefix'] = 'xnW_';
return;
}
require_once (ROOT_PATH . 'plugins/integrates/integrate.php');
/**
* UCenter 会员数据处理类
*/
class ucenter extends integrate
{
/**
* 构造函数
*
* @param unknown $cfg
*/
function __construct($cfg)
{
/* 使用默认数据库连接 */
parent::__construct(array());
$this->user_table = 'users';
$this->field_id = 'user_id';
$this->field_name = 'user_name';
$this->field_pass = 'password';
$this->field_email = 'email';
$this->field_gender = 'sex';
$this->field_bday = 'birthday';
$this->field_reg_date = 'reg_time';
$this->need_sync = false;
$this->is_ecshop = 1;
/* 初始化UC需要常量 */
if (! defined('UC_CONNECT') && isset($cfg['uc_id']) && isset($cfg['db_host']) && isset($cfg['db_user']) && isset($cfg['db_name'])) {
if (strpos($cfg['db_pre'], '`' . $cfg['db_name'] . '`') === 0) {
$db_pre = $cfg['db_pre'];
} else {
$db_pre = '`' . $cfg['db_name'] . '`.' . $cfg['db_pre'];
}
define('UC_CONNECT', isset($cfg['uc_connect']) ? $cfg['uc_connect'] : '');
define('UC_DBHOST', isset($cfg['db_host']) ? $cfg['db_host'] : '');
define('UC_DBUSER', isset($cfg['db_user']) ? $cfg['db_user'] : '');
define('UC_DBPW', isset($cfg['db_pass']) ? $cfg['db_pass'] : '');
define('UC_DBNAME', isset($cfg['db_name']) ? $cfg['db_name'] : '');
define('UC_DBCHARSET', isset($cfg['db_charset']) ? $cfg['db_charset'] : '');
define('UC_DBTABLEPRE', $db_pre);
define('UC_DBCONNECT', '0');
define('UC_KEY', isset($cfg['uc_key']) ? $cfg['uc_key'] : '');
define('UC_API', isset($cfg['uc_url']) ? $cfg['uc_url'] : '');
define('UC_CHARSET', isset($cfg['uc_charset']) ? $cfg['uc_charset'] : '');
define('UC_IP', isset($cfg['uc_ip']) ? $cfg['uc_ip'] : '');
define('UC_APPID', isset($cfg['uc_id']) ? $cfg['uc_id'] : '');
define('UC_PPP', '20');
}
}
/**
* 用户登录函数
*
* @access public
* @param string $username
* @param string $password
*
* @return void
*/
function login($username, $password, $remember = null)
{
list ($uid, $uname, $pwd, $email, $repeat) = uc_call("uc_user_login", array(
$username,
$password
));
$uname = addslashes($uname);
if ($uid > 0) {
// 检查用户是否存在,不存在直接放入用户表
$result = model('Base')->model->query("SELECT user_id,ec_salt FROM " . model('Base')->model->pre . "users WHERE user_name='$username'");
$result = reset($result);
$name_exist = $result['user_id'];
if (empty($result['ec_salt'])) {
$user_exist = model('Base')->model->query("SELECT user_id FROM " . model('Base')->model->pre . "users WHERE user_name='$username' AND password = '" . MD5($password) . "'");
$user_exist = $this->getOne($user_exist);
if (! empty($user_exist)) {
$ec_salt = rand(1, 9999);
model('Base')->model->query("UPDATE " . model('Base')->model->pre . "users SET `password`='" . MD5(MD5($password) . $ec_salt) . "',`ec_salt`='" . $ec_salt . "' WHERE user_id = '" . $uid . "'");
}
} else {
$user_exist = model('Base')->model->query("SELECT user_id FROM " . model('Base')->model->pre . "users WHERE user_name='$username' AND password = '" . MD5(MD5($password) . $result['ec_salt']) . "'");
$user_exist = $this->getOne($user_exist);
}
if (empty($user_exist)) {
if (empty($name_exist)) {
$reg_date = time();
$ip = real_ip();
$password = $this->compile_password(array(
'password' => $password
));
model('Base')->model->query("INSERT INTO " . model('Base')->model->pre . "users (`user_id`, `email`, `user_name`, `password`, `reg_time`, `last_login`, `last_ip`) VALUES ('$uid', '$email', '$uname', '$password', '$reg_date', '$reg_date', '$ip')");
} else {
if (empty($result['ec_salt'])) {
$result['ec_salt'] = 0;
}
model('Base')->model->query("UPDATE " . model('Base')->model->pre . "users SET `password`='" . MD5(MD5($password) . $result['ec_salt']) . "',`ec_salt`='" . $result['ec_salt'] . "' WHERE user_id = '" . $uid . "'");
}
}
$this->set_session($uname);
$this->set_cookie($uname);
$this->ucdata = uc_call("uc_user_synlogin", array(
$uid
));
return true;
} elseif ($uid == - 1) {
$this->error = ERR_INVALID_USERNAME;
return false;
} elseif ($uid == - 2) {
$this->error = ERR_INVALID_PASSWORD;
return false;
} else {
return false;
}
}
/**
* 用户退出
*
* @access public
* @param
*
*
*
* @return void
*/
function logout()
{
$this->set_cookie(); // 清除cookie
$this->set_session(); // 清除session
$this->ucdata = uc_call("uc_user_synlogout"); // 同步退出
return true;
}
/* 添加用户 */
function add_user($username, $password, $email, $gender = -1, $bday = 0, $reg_date = 0, $md5password = '')
{
/* 检测用户名 */
if ($this->check_user($username)) {
$this->error = ERR_USERNAME_EXISTS;
return false;
}
$uid = uc_call("uc_user_register", array(
$username,
$password,
$email
));
if ($uid <= 0) {
if ($uid == - 1) {
$this->error = ERR_INVALID_USERNAME;
return false;
} elseif ($uid == - 2) {
$this->error = ERR_USERNAME_NOT_ALLOW;
return false;
} elseif ($uid == - 3) {
$this->error = ERR_USERNAME_EXISTS;
return false;
} elseif ($uid == - 4) {
$this->error = ERR_INVALID_EMAIL;
return false;
} elseif ($uid == - 5) {
$this->error = ERR_EMAIL_NOT_ALLOW;
return false;
} elseif ($uid == - 6) {
$this->error = ERR_EMAIL_EXISTS;
return false;
} else {
return false;
}
} else {
// 注册成功，插入用户表
$reg_date = time();
$ip = real_ip();
$password = $this->compile_password(array(
'password' => $password
));
model('Base')->model->query("INSERT INTO " . model('Base')->model->pre . "users (`user_id`, `email`, `user_name`, `password`, `reg_time`, `last_login`, `last_ip`) VALUES ('$uid', '$email', '$username', '$password', '$reg_date', '$reg_date', '$ip')");
return true;
}
}
/**
* 检查指定用户是否存在及密码是否正确
*
* @access public
* @param string $username
* 用户名
*
* @return int
*/
function check_user($username, $password = null)
{
$userdata = uc_call("uc_user_checkname", array(
$username
));
if ($userdata == 1) {
return false;
} else {
return true;
}
}
/**
* 检测Email是否合法
*
* @access public
* @param string $email
* 邮箱
*
* @return blob
*/
function check_email($email)
{
if (! empty($email)) {
$email_exist = uc_call('uc_user_checkemail', array(
$email
));
if ($email_exist == 1) {
return false;
} else {
$this->error = ERR_EMAIL_EXISTS;
return true;
}
}
return true;
}
/* 编辑用户信息 */
function edit_user($cfg, $forget_pwd = '0')
{
$real_username = $cfg['username'];
$cfg['username'] = addslashes($cfg['username']);
$set_str = '';
$valarr = array(
'email' => 'email',
'gender' => 'sex',
'bday' => 'birthday'
);
foreach ($cfg as $key => $val) {
if ($key == 'username' || $key == 'password' || $key == 'old_password') {
continue;
}
$set_str .= $valarr[$key] . '=' . "'$val',";
}
$set_str = substr($set_str, 0, - 1);
if (! empty($set_str)) {
$sql = "UPDATE " . model('Base')->model->pre . "users SET $set_str WHERE user_name = '$cfg[username]'";
model('Base')->model->query($sql);
$flag = true;
}
// 判断 email 是否进行修改
$data = uc_call("uc_get_user", array(
$cfg['username'],
'0'
));
list ($uid, $username, $email) = $data;
if ($cfg['email'] != $email && !empty($cfg['email'])) {
if ($this->check_email($cfg['email'])) {
$this->error = ERR_EMAIL_EXISTS;
return false;
} else {
$ucresult = uc_call("uc_user_edit", array(
$cfg['username'],
'',
'',
$cfg['email'],
1
));
if ($ucresult > 0) {
$flag = true;
} elseif ($ucresult == - 4) {
// echo 'Email 格式有误';
$this->error = ERR_INVALID_EMAIL;
return false;
} elseif ($ucresult == - 5) {
// echo 'Email 不允许注册';
$this->error = ERR_INVALID_EMAIL;
return false;
} elseif ($ucresult == - 6) {
// echo '该 Email 已经被注册';
$this->error = ERR_EMAIL_EXISTS;
return false;
} elseif ($ucresult < 0) {
return false;
}
}
}
if (! empty($cfg['old_password']) && ! empty($cfg['password']) && $forget_pwd == 0) {
$ucresult = uc_call("uc_user_edit", array(
$real_username,
$cfg['old_password'],
$cfg['password'],
''
));
if ($ucresult > 0) {
return true;
} else {
$this->error = ERR_INVALID_PASSWORD;
return false;
}
} elseif (! empty($cfg['password']) && $forget_pwd == 1) {
$ucresult = uc_call("uc_user_edit", array(
$real_username,
'',
$cfg['password'],
'',
'1'
));
if ($ucresult > 0) {
$flag = true;
}
}
return true;
}
/**
* 获取指定用户的信息
*
* @access public
* @param
*
*
*
* @return void
*/
function get_profile_by_name($username)
{
// $username = addslashes($username);
$sql = "SELECT user_id, user_name, email, sex, reg_time FROM " . model('Base')->model->pre . "users WHERE user_name='$username'";
$row = model('Base')->model->query($sql);
$row = reset($row);
return $row;
}
/**
* 检查cookie是正确，返回用户名
*
* @access public
* @param
*
*
*
* @return void
*/
function check_cookie()
{
return '';
}
/**
* 根据登录状态设置cookie
*
* @access public
* @param
*
*
*
* @return void
*/
function get_cookie()
{
$id = $this->check_cookie();
if ($id) {
if ($this->need_sync) {
$this->sync($id);
}
$this->set_session($id);
return true;
} else {
return false;
}
}
/**
* 设置cookie
*
* @access public
* @param
*
*
*
* @return void
*/
function set_cookie($username = '', $remember = null)
{
if (empty($username)) {
/* 摧毁cookie */
$time = time() - 3600;
setcookie("ECS[user_id]", '', $time, $this->cookie_path);
setcookie("ECS[password]", '', $time, $this->cookie_path);
} else {
/* 设置cookie */
$time = time() + 3600 * 24 * 30;
setcookie("ECS[username]", stripslashes($username), $time, $this->cookie_path, $this->cookie_domain);
$sql = "SELECT user_id, password FROM " . model('Base')->model->pre . "users WHERE user_name='$username' LIMIT 1";
$row = model('Base')->model->query($sql);
$row = reset($row);
if ($row) {
setcookie("ECS[user_id]", $row['user_id'], $time, $this->cookie_path, $this->cookie_domain);
setcookie("ECS[password]", $row['password'], $time, $this->cookie_path, $this->cookie_domain);
}
}
}
/**
* 设置指定用户SESSION
*
* @access public
* @param
*
*
*
* @return void
*/
function set_session($username = '')
{
if (empty($username)) {
ECTouch::sess()->destroy_session();
} else {
$sql = "SELECT user_id, password, email FROM " . model('Base')->model->pre . "users WHERE user_name='$username' LIMIT 1";
$row = model('Base')->model->query($sql);
$row = reset($row);
if ($row) {
$_SESSION['user_id'] = $row['user_id'];
$_SESSION['user_name'] = $username;
$_SESSION['email'] = $row['email'];
}
}
}
/**
* 获取指定用户的信息
*
* @access public
* @param
*
*
*
* @return void
*/
function get_profile_by_id($id)
{
$sql = "SELECT user_id, user_name, email, sex, birthday, reg_time FROM " . model('Base')->model->pre . "users WHERE user_id='$id'";
$row = model('Base')->model->query($sql);
$row = reset($row);
return $row;
}
function get_user_info($username)
{
return $this->get_profile_by_name($username);
}
/**
* 删除用户
*
* @access public
* @param
*
*
*
* @return void
*/
function remove_user($id)
{
if (is_array($id)) {
$post_id = array();
foreach ($id as $val) {
$post_id[] = $val;
}
} else {
$post_id = $id;
}
/* 如果需要同步或是ecshop插件执行这部分代码 */
$sql = "SELECT user_id FROM " . model('Base')->model->pre . "users WHERE ";
$sql .= (is_array($post_id)) ? db_create_in($post_id, 'user_name') : "user_name='" . $post_id . "' LIMIT 1";
$array = model('Base')->model->query($sql);
foreach ($array as $key => $val) {
$col[] = $val[0];
}
if ($col) {
$sql = "UPDATE " . model('Base')->model->pre . "users SET parent_id = 0 WHERE " . db_create_in($col, 'parent_id'); // 将删除用户的下级的parent_id 改为0
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "users WHERE " . db_create_in($col, 'user_id'); // 删除用户
model('Base')->model->query($sql);
/* 删除用户订单 */
$sql = "SELECT order_id FROM " . model('Base')->model->pre . "order_info WHERE " . db_create_in($col, 'user_id');
model('Base')->model->query($sql);
$array = model('Base')->model->query($sql);
foreach ($array as $key => $val) {
$col_order_id[] = $val[0];
}
if ($col_order_id) {
$sql = "DELETE FROM " . model('Base')->model->pre . "order_info WHERE " . db_create_in($col_order_id, 'order_id');
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "order_goods WHERE " . db_create_in($col_order_id, 'order_id');
model('Base')->model->query($sql);
}
$sql = "DELETE FROM " . model('Base')->model->pre . "booking_goods WHERE " . db_create_in($col, 'user_id'); // 删除用户
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "collect_goods WHERE " . db_create_in($col, 'user_id'); // 删除会员收藏商品
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "feedback WHERE " . db_create_in($col, 'user_id'); // 删除用户留言
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "user_address WHERE " . db_create_in($col, 'user_id'); // 删除用户地址
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "user_bonus WHERE " . db_create_in($col, 'user_id'); // 删除用户红包
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "user_account WHERE " . db_create_in($col, 'user_id'); // 删除用户帐号金额
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "tag WHERE " . db_create_in($col, 'user_id'); // 删除用户标记
model('Base')->model->query($sql);
$sql = "DELETE FROM " . model('Base')->model->pre . "account_log WHERE " . db_create_in($col, 'user_id'); // 删除用户日志
model('Base')->model->query($sql);
}
if (isset($this->ecshop) && $this->ecshop) {
/* 如果是ecshop插件直接退出 */
return;
}
$sql = "DELETE FROM " . model('Base')->model->pre . "users WHERE ";
if (is_array($post_id)) {
$sql .= db_create_in($post_id, 'user_name');
} else {
$sql .= "user_name='" . $post_id . "' LIMIT 1";
}
model('Base')->model->query($sql);
}
/**
* 获取论坛有效积分及单位
*
* @access public
* @param
*
*
*
* @return void
*/
function get_points_name()
{
return 'ucenter';
}
/**
* 返回getOne的数据
*
* @param unknown $array
* @return mixed
*/
function getOne($array)
{
$array = reset($array);
return $array[0];
}
}
?>