|
|
<?php
|
|
|
namespace Base\Service;
|
|
|
|
|
|
use Base\Tool\TaskClient;
|
|
|
use Think\Log;
|
|
|
use Base\Tool\Redis;
|
|
|
use Base\Tool\IPTool;
|
|
|
|
|
|
/**
|
|
|
*
|
|
|
* @todo 未完成
|
|
|
*/
|
|
|
class UserService
|
|
|
{
|
|
|
public function loginSdk($params)
|
|
|
{
|
|
|
if ($this->loginLimit($params)) {
|
|
|
$this->resetLoginLimit();
|
|
|
return ['status' => false, 'message' => '登录人数过多，请稍后再试'];
|
|
|
}
|
|
|
$account = $params['account'] ?? '';
|
|
|
$password = $params['password'] ?? '';
|
|
|
$gameId = $params['game_id'] ?? 0;
|
|
|
$sdkVersion = $params['sdk_version'];
|
|
|
$deviceNum = $params['unique_code'] ?? '';
|
|
|
$clientIp = get_client_ip();
|
|
|
|
|
|
$game = M('game', 'tab_')->where(['id' => $gameId])->find();
|
|
|
$result = $this->doLogin($account, $password, $game, ['client_ip' => $clientIp, 'device_num' => $deviceNum]);
|
|
|
if (!$result['status']) {
|
|
|
$this->resetLoginLimit();
|
|
|
return ['status' => false, 'message' => $result['message']];
|
|
|
}
|
|
|
$user = $result['data']['user'];
|
|
|
|
|
|
$noticeCount = $this->getNoticeCount($user, $game);
|
|
|
$this->addUserPlay($user, $game, $clientIp);
|
|
|
$this->dispatchLoginEvent([
|
|
|
'game_id' => $game['id'],
|
|
|
'user_id' => $user['id'],
|
|
|
'login_time' => time(),
|
|
|
'sdk_version' => $sdkVersion,
|
|
|
'client_ip' => $clientIp,
|
|
|
'device_number' => $deviceNum,
|
|
|
]);
|
|
|
|
|
|
$smallList = [];
|
|
|
$smallList[] = [
|
|
|
'is_platform' => $user['is_platform'],
|
|
|
'user_id' => $user['id'],
|
|
|
'account' => $user['account'],
|
|
|
'user_account' => $user['account']
|
|
|
];
|
|
|
|
|
|
$data = [
|
|
|
'status' => 200,
|
|
|
'return_code' => 'success',
|
|
|
'return_msg' => '登录成功',
|
|
|
'user_id' => $user['id'],
|
|
|
'account' => $user['account'],
|
|
|
'nickname' => $user['nickname'] ? $user['nickname'] : $user['account'],
|
|
|
'sex' => $user['sex'] ? $user['sex'] : 0,
|
|
|
'is_platform' => $user['is_platform'],
|
|
|
'token' => $result['data']['token'],
|
|
|
'user_token' => $result['data']['user_token'],
|
|
|
'OTP_token' => think_encrypt(json_encode(array('uid' => $user['id'], 'time' => time())), 1),
|
|
|
'is_uc' => 0,
|
|
|
'is_open_small_account' => C('IS_OPEN_SMALL_ACCOUNT'),
|
|
|
'url' => 'http://' . str_replace(array('http://'), '', C('WEB_SITE')) . '/mobile.php',
|
|
|
'small_list' => $smallList,
|
|
|
'ios_packagename' => C('WEB_IOS_PACKAGENAME'),
|
|
|
'android_packagename' => C('WEB_AND_PACKAGENAME'),
|
|
|
'site_status' => C('SDK_SITE_STATUS'),
|
|
|
'head_img' => !empty($user['head_img']) ? $user['head_img'] : '',
|
|
|
'unread_count' => $noticeCount,
|
|
|
'notice_count' => $noticeCount,
|
|
|
'request_count' => 0,
|
|
|
];
|
|
|
|
|
|
$this->doUserSource($data['user_id'], $gameId, $params['promote_id'] ?? 0, $deviceNum, $sdkVersion, $clientIp);
|
|
|
|
|
|
$this->resetLoginLimit();
|
|
|
return ['status' => true, 'message' => '登录成功', 'data' => $data];
|
|
|
}
|
|
|
|
|
|
protected function isBan($ip, $deviceNum)
|
|
|
{
|
|
|
$ban = M('device_bans','tab_')->field(['id'])->where(['tag' => ['in', [$ip, $deviceNum]]])->limit(1)->find();
|
|
|
if (empty($ban)) {
|
|
|
return false;
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
protected function doLogin($account, $password, $game, $params = [])
|
|
|
{
|
|
|
$clientIp = $params['client_ip'] ?? get_client_ip();
|
|
|
$deviceNum = $params['device_num'] ?? '';
|
|
|
|
|
|
if ($this->isBan($clientIp, $deviceNum)) {
|
|
|
Log::write(date('Y-m-d H:i:s') . ' account:' . $account . ' clientIp:' . $clientIp . ' deviceNum:' . $deviceNum, 'INFO', '', C('LOG_PATH')."login_ban.log");
|
|
|
return ['status' => false, 'message' => '设备已被禁用'];
|
|
|
}
|
|
|
|
|
|
$user = M('user', 'tab_')->where(['account' => $account])->find();
|
|
|
|
|
|
/* 获取用户数据 */
|
|
|
if (empty($user) || $user['lock_status'] != 1 || $user['check_status'] != 1) {
|
|
|
return ['status' => false, 'message' => '账号或密码错误'];
|
|
|
}
|
|
|
if ($this->password($password, UC_AUTH_KEY) !== $user['password']) {
|
|
|
return ['status' => false, 'message' => '密码错误'];
|
|
|
}
|
|
|
|
|
|
$testingUser = M('testing_user', 'tab_')->where(['user_id' => $user['id']])->find();
|
|
|
if ($testingUser) {
|
|
|
if ($testingUser['verify_status'] != 1) {
|
|
|
return ['status' => false, 'message' => '该账号不可使用！'];
|
|
|
}
|
|
|
if ($testingUser['status'] == 3) {
|
|
|
return ['status' => false, 'message' => '该账号已被禁用！'];
|
|
|
}
|
|
|
if ($this->isIpWarning($user, $clientIp)) {
|
|
|
M('testing_user', 'tab_')->where(['user_id' => $user['id']])->save([
|
|
|
'status' => 2,
|
|
|
'update_time' => time()
|
|
|
]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$result = $this->getLoginToken($user, $game, $password);
|
|
|
if (!$result) {
|
|
|
return ['status' => false, 'message' => '系统异常'];
|
|
|
}
|
|
|
[$token, $userToken] = $result;
|
|
|
|
|
|
$userData = [];
|
|
|
if (!$user['device_number']) {
|
|
|
$userData['device_number'] = $deviceNum;
|
|
|
}
|
|
|
$userData['login_time'] = NOW_TIME;
|
|
|
$userData['login_ip'] = $clientIp;
|
|
|
$userData['last_login_ip'] = $clientIp;
|
|
|
$userData['last_device_number'] = $deviceNum;
|
|
|
|
|
|
if(!$user['fgame_id']) {
|
|
|
$userData['fgame_id'] = $game['id'];
|
|
|
$userData['fgame_name'] = $game['game_name'];
|
|
|
}
|
|
|
$userData['token'] = $token;
|
|
|
$status = M('user', 'tab_')->where(['id' => $user['id']])->save($userData);
|
|
|
if (!$status) {
|
|
|
return ['status' => false, 'message' => '登录异常'];
|
|
|
}
|
|
|
|
|
|
$this->addUserLoginRecord($user, $game, $clientIp, $deviceNum);
|
|
|
$this->addUserGameLoginRecord($user, $game, $clientIp, $deviceNum);
|
|
|
|
|
|
if (!$user['device_type']) {
|
|
|
$this->oaDeviceTypeUpdate($user, $game);
|
|
|
}
|
|
|
|
|
|
$data = [
|
|
|
'user' => $user,
|
|
|
'token' => $token,
|
|
|
'user_token' => $userToken,
|
|
|
];
|
|
|
return ['status' => true, 'message' => '登录成功', 'data' => $data];
|
|
|
}
|
|
|
|
|
|
protected function doUserSource($uid, $gameId, $promoteId, $deviceNum, $sdkVersion, $clientIp) {
|
|
|
$find = M('user_source', 'tab_')->where([
|
|
|
'user_id' => $uid,
|
|
|
'game_id' => $gameId,
|
|
|
'promote_id' => $promoteId
|
|
|
])->find();
|
|
|
|
|
|
if (!$find) {
|
|
|
M('user_source', 'tab_')->add([
|
|
|
'user_id' => $uid,
|
|
|
'game_id' => $gameId,
|
|
|
'promote_id' => $promoteId,
|
|
|
'device_num' => $deviceNum,
|
|
|
'sdk_version' => $sdkVersion,
|
|
|
'ip' => $clientIp,
|
|
|
'create_time' => time()
|
|
|
]);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @deprecated
|
|
|
*/
|
|
|
protected function isDeviceError($user, $testResource, $deviceNum)
|
|
|
{
|
|
|
if ($testResource && $user['device_number'] && $deviceNum && $user['device_number'] != $deviceNum) {
|
|
|
return true;
|
|
|
}
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @deprecated
|
|
|
*/
|
|
|
protected function deviceErrorLog($user, $testResource, $deviceNum){
|
|
|
$data = [];
|
|
|
$data['user_id'] = $user['id'];
|
|
|
$data['user_account'] = $testResource['user_account'];
|
|
|
$data['server_id'] = $testResource['server_id'];
|
|
|
$data['server_name'] = $testResource['server_name'];
|
|
|
$data['game_id'] = $testResource['game_id'];
|
|
|
$data['game_name'] = $testResource['game_name'];
|
|
|
$data['nickname'] = $testResource['role_name'];
|
|
|
$data['promote_id'] = $testResource['promote_id'];
|
|
|
$data['promote_account'] = $testResource['promote_account'];
|
|
|
$data['type'] = 2;
|
|
|
$data['detail'] = '登录设备号异常，本次异常设备号：' . $deviceNum . '，历史登录设备号：' . $user['device_number'];
|
|
|
$data['create_time'] = NOW_TIME;
|
|
|
M('protect_log','tab_')->add($data);
|
|
|
}
|
|
|
|
|
|
protected function isIpWarning($user, $clientIp)
|
|
|
{
|
|
|
$newResult = IPTool::getIpInfo($clientIp);
|
|
|
$oldResult = IPTool::getIpInfo($user['login_ip']);
|
|
|
if (
|
|
|
$newResult['country_id'] == $oldResult['country_id'] &&
|
|
|
$newResult['region_id'] == $oldResult['region_id'] &&
|
|
|
$newResult['city_id'] == $oldResult['city_id']
|
|
|
) {
|
|
|
return false;
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* @deprecated
|
|
|
*/
|
|
|
protected function ipWarningLog($user, $testResource, $clientIp){
|
|
|
$data = [];
|
|
|
$data['user_id'] = $user['id'];
|
|
|
$data['user_account'] = $testResource['user_account'];
|
|
|
$data['server_id'] = $testResource['server_id'];
|
|
|
$data['server_name'] = $testResource['server_name'];
|
|
|
$data['game_id'] = $testResource['game_id'];
|
|
|
$data['game_name'] = $testResource['game_name'];
|
|
|
$data['nickname'] = $testResource['role_name'];
|
|
|
$data['promote_id'] = $testResource['promote_id'];
|
|
|
$data['promote_account'] =$testResource['promote_account'];
|
|
|
$data['type'] = 1;
|
|
|
$data['detail'] = '登录IP异常，本次异常IP：' . $clientIp . '，历史登录IP：' . $user['login_ip'];
|
|
|
$data['create_time'] = NOW_TIME;
|
|
|
M('protect_log','tab_')->add($data);
|
|
|
}
|
|
|
|
|
|
protected function generateToken($userId, $account, $password){
|
|
|
$str = $userId . $account . $password . NOW_TIME . sp_random_string(7);
|
|
|
$token = md5($str);
|
|
|
return $token;
|
|
|
}
|
|
|
|
|
|
protected function getLoginToken($user, $game, $password)
|
|
|
{
|
|
|
$token = $this->generateToken($user['id'], $user['account'], $password);
|
|
|
$userToken = $this->generateToken($user['id'], $user['account'], $password) . uniqid() . rand(1000, 9999);
|
|
|
$record = M('user_token','tab_')->where(['user_id' => $user['id'], 'game_id' => $game['id']])->find();
|
|
|
if (!$record) {
|
|
|
$status = M('user_token', 'tab_')->add([
|
|
|
'user_id' => $user['id'],
|
|
|
'game_id' => $game['id'],
|
|
|
'relation_game_id' => $game['relation_game_id'],
|
|
|
'user_token' => $userToken,
|
|
|
'login_cnt' => 1,
|
|
|
'create_time' => time(),
|
|
|
'update_time' => time()
|
|
|
]);
|
|
|
|
|
|
if (!$status) {
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
$status = M('user_token', 'tab_')->where([
|
|
|
'user_id' => $user['id'],
|
|
|
'relation_game_id' => $game['relation_game_id']
|
|
|
])->save([
|
|
|
'user_token' => $userToken,
|
|
|
'login_cnt' => $record['login_cnt'] + 1,
|
|
|
'update_time' => time()
|
|
|
]);
|
|
|
} else {
|
|
|
$status = M('user_token', 'tab_')->where([
|
|
|
'user_id' => $user['id'],
|
|
|
'game_id|relation_game_id' => $game['relation_game_id']
|
|
|
])->save([
|
|
|
'user_token' => $userToken,
|
|
|
'login_cnt' => $record['login_cnt'] + 1,
|
|
|
'update_time' => time()
|
|
|
]);
|
|
|
if ($status === false) {
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
return [$token, $userToken];
|
|
|
}
|
|
|
|
|
|
public function oaDeviceTypeUpdate($user, $game)
|
|
|
{
|
|
|
$gameServer = substr($game['game_name'], -10, 9);
|
|
|
if($gameServer == '安卓版'){
|
|
|
$arr['device_type'] = 'Android';
|
|
|
} elseif($gameServer == '苹果版') {
|
|
|
$arr['device_type'] = 'IOS';
|
|
|
}
|
|
|
$arr['time'] = time();
|
|
|
$arr['account'] = $user['account'];
|
|
|
ksort($arr);
|
|
|
reset($arr);
|
|
|
$sign = md5(http_build_query($arr) . C('GET_INFO_KEY'));
|
|
|
$arr['sign'] = $sign;
|
|
|
$reData = curl_post('http://oa.76ba.com/api/wanmeng/deviceTypeUpdate', $arr);
|
|
|
}
|
|
|
|
|
|
protected function addUserLoginRecord($user, $game, $clientIp, $deviceNum){
|
|
|
$data = [
|
|
|
'user_id' => $user['id'],
|
|
|
'user_account' => $user['account'],
|
|
|
'user_nickname' => $user['nickname'],
|
|
|
'game_id' => $game['id'],
|
|
|
'promote_id' => $user['promote_id'],
|
|
|
'game_name' => $game['game_name'],
|
|
|
'sdk_version' => $game['sdk_version'],
|
|
|
'type' => 1,
|
|
|
'server_id' => null,
|
|
|
'server_name' => null,
|
|
|
'login_time' => NOW_TIME,
|
|
|
'login_ip' => $clientIp,
|
|
|
'lpuid' => $user['puid'],
|
|
|
];
|
|
|
return M('user_login_record','tab_')->add($data);
|
|
|
}
|
|
|
|
|
|
protected function addUserGameLoginRecord($user, $game, $clientIp, $deviceNum){
|
|
|
$data = [
|
|
|
'user_id' => $user['id'],
|
|
|
'user_account' => $user['account'],
|
|
|
'user_nickname' => $user['nickname'],
|
|
|
'game_id' => $game['id'],
|
|
|
'promote_id' => $user['promote_id'],
|
|
|
'game_name' => $game['game_name'],
|
|
|
'sdk_version' => $game['sdk_version'],
|
|
|
'type' => 1,
|
|
|
'server_id' => null,
|
|
|
'server_name' => null,
|
|
|
'login_time' => NOW_TIME,
|
|
|
'login_ip' => $clientIp,
|
|
|
'lpuid' => $user['puid'],
|
|
|
];
|
|
|
return M('user_game_login_record','tab_')->add($data);
|
|
|
}
|
|
|
|
|
|
protected function dispatchLoginEvent($params)
|
|
|
{
|
|
|
try {
|
|
|
$client = new TaskClient();
|
|
|
$client->post('/game-event/login', $params);
|
|
|
} catch(\Exception $e) {
|
|
|
|
|
|
}
|
|
|
}
|
|
|
|
|
|
protected function addUserPlay($user, $game, $clientIp)
|
|
|
{
|
|
|
$map = [];
|
|
|
$map['game_id'] = $game['id'];
|
|
|
$map['user_id'] = $user['id'];
|
|
|
$map['sdk_version'] = $game['sdk_version'];
|
|
|
$userPlay = M('user_play', 'tab_')->where($map)->find();
|
|
|
if (empty($userPlay)) {
|
|
|
$data = [];
|
|
|
$data['user_id'] = $user['id'];
|
|
|
$data['user_account'] = $user['account'];
|
|
|
$data['user_nickname'] = $user['nickname'];
|
|
|
$data['game_id'] = $game['id'];
|
|
|
$data['game_appid'] = $game['game_appid'];
|
|
|
$data['game_name'] = $game['game_name'];
|
|
|
$data['server_id'] = 0;
|
|
|
$data['server_name'] = '';
|
|
|
$data['role_id'] = 0;
|
|
|
$data['parent_id'] = $user['parent_id'];
|
|
|
$data['parent_name'] = $user['parent_name'];
|
|
|
$data['role_name'] = '';
|
|
|
$data['role_level'] = 0;
|
|
|
$data['bind_balance'] = 0;
|
|
|
$data['promote_id'] = $user['promote_id'];
|
|
|
$data['promote_account'] = $user['promote_account'];
|
|
|
$data['play_time'] = time();
|
|
|
$data['play_ip'] = $clientIp;
|
|
|
$data['sdk_version'] = $game['sdk_version'];
|
|
|
$data['ppuid'] = $user['puid'] == '' ? 0 : $user['puid'];
|
|
|
$data['check_time'] = time();
|
|
|
$data['create_time'] = time();
|
|
|
M('user_play', 'tab_')->add($data);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
protected function getNoticeCount($user, $game)
|
|
|
{
|
|
|
$noticeCount = 0;
|
|
|
$time = time();
|
|
|
$noticeIds = M('notice', 'tab_')
|
|
|
->where('start_time < ' . $time . ' AND game_id = ' . $game['id']. ' AND (end_time = 0 OR end_time >' . $time . ')')
|
|
|
->getField('id',true);
|
|
|
if(!empty($noticeIds))
|
|
|
{
|
|
|
$noticeCount += count($noticeIds);
|
|
|
$where['notice_id'] = ['in', implode(',', $noticeIds)];
|
|
|
$where['user_id'] = $user['id'];
|
|
|
$where['is_read'] = 1;
|
|
|
$noticeReadCount = M('notice_read', 'tab_')->where($where)->count();
|
|
|
$noticeCount -= $noticeReadCount;
|
|
|
}
|
|
|
return $noticeCount;
|
|
|
}
|
|
|
|
|
|
protected function loginLimit($params)
|
|
|
{
|
|
|
$isLoginLimit = intval(C('LOGIN_LIMIT_OPEN', null, 1));
|
|
|
if ($isLoginLimit == 0) {
|
|
|
return false;
|
|
|
}
|
|
|
$loginLimitNum = C('LOGIN_LIMIT_NUM', null, 300);
|
|
|
$count = Redis::incr(Redis::KEY_LOGIN_LIMIT);
|
|
|
if ($count >= $loginLimitNum) {
|
|
|
Log::write('login_limit:' . date('Y-m-d H:i:s') . ' ---- ' . $count, 'INFO', '', C('LOG_PATH')."login_limit.log");
|
|
|
return true;
|
|
|
}
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
protected function resetLoginLimit()
|
|
|
{
|
|
|
$isLoginLimit = intval(C('LOGIN_LIMIT_OPEN', null, 1));
|
|
|
if ($isLoginLimit != 0) {
|
|
|
Redis::decr(Redis::KEY_LOGIN_LIMIT);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public function password($str, $key = 'ThinkUCenter'){
|
|
|
return '' === $str ? '' : md5(sha1($str) . $key);
|
|
|
}
|
|
|
} |