367 lines
13 KiB
PHP
367 lines
13 KiB
PHP
<?php
|
||
|
||
namespace app\api\controller;
|
||
|
||
use app\common\model\CompanyAccountModel;
|
||
use think\facade\Env;
|
||
use think\Response;
|
||
|
||
/**
|
||
* 用户控制器
|
||
* Class UserController
|
||
* @package app\frontend\controller
|
||
*/
|
||
class UserController extends BaseController
|
||
{
|
||
/**
|
||
* API客户端类型
|
||
*/
|
||
const CLIENT_TYPE = 'system';
|
||
|
||
/**
|
||
* 构造函数
|
||
*/
|
||
public function __construct()
|
||
{
|
||
parent::__construct();
|
||
}
|
||
|
||
/**
|
||
* 登录
|
||
* @return \think\response\Json
|
||
*/
|
||
public function login()
|
||
{
|
||
// 获取并验证参数
|
||
$params = $this->validateLoginParams();
|
||
if (!is_array($params)) {
|
||
return $params;
|
||
}
|
||
|
||
// 验证账号是否存在
|
||
$existingAccount = CompanyAccountModel::where('userName', $params['username'])->find();
|
||
if (empty($existingAccount)) {
|
||
// 记录登录失败日志
|
||
recordUserLog(0, $params['username'], 'LOGIN', '账号不存在', $params, 500, '账号不存在');
|
||
return errorJson('账号不存在');
|
||
}
|
||
|
||
// 获取验证码会话ID和用户输入的验证码
|
||
$verifySessionId = $this->request->param('verifySessionId', '');
|
||
$verifyCode = $this->request->param('verifyCode', '');
|
||
|
||
// 设置请求头
|
||
$headerData = ['client:' . self::CLIENT_TYPE];
|
||
|
||
// 如果存在验证码信息，添加到请求头
|
||
if (!empty($verifySessionId) && !empty($verifyCode)) {
|
||
$headerData[] = 'verifysessionid:' . $verifySessionId;
|
||
$headerData[] = 'verifycode:' . $verifyCode;
|
||
}
|
||
|
||
$header = setHeader($headerData, '', 'plain');
|
||
|
||
try {
|
||
// 请求登录接口
|
||
$result = requestCurl($this->baseUrl . 'token', $params, 'POST', $header);
|
||
$result_array = handleApiResponse($result);
|
||
|
||
if (is_array($result_array) && isset($result_array['error'])) {
|
||
// 记录登录失败日志
|
||
recordUserLog(0, $params['username'], 'LOGIN', '登录失败', $params, 500, $result_array['error_description']);
|
||
return errorJson($result_array['error_description']);
|
||
}
|
||
|
||
// 获取客户端IP地址
|
||
$ip = $this->request->ip();
|
||
|
||
// 登录成功，更新密码信息和登录信息
|
||
$updateData = [
|
||
'passwordMd5' => md5($params['password']),
|
||
'passwordLocal' => localEncrypt($params['password']),
|
||
'lastLoginIp' => $ip,
|
||
'lastLoginTime' => time()
|
||
];
|
||
|
||
// 更新密码信息
|
||
CompanyAccountModel::where('userName', $params['username'])->update($updateData);
|
||
|
||
// 记录登录成功日志
|
||
recordUserLog($existingAccount['id'], $params['username'], 'LOGIN', '登录成功', [], 200, '登录成功');
|
||
|
||
return successJson($result_array);
|
||
} catch (\Exception $e) {
|
||
// 记录登录异常日志
|
||
recordUserLog(0, $params['username'], 'LOGIN', '登录请求失败', $params, 500, $e->getMessage());
|
||
return errorJson('登录请求失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取新的token
|
||
* @return \think\response\Json
|
||
*/
|
||
public function getNewToken()
|
||
{
|
||
$grant_type = $this->request->param('grant_type', 'refresh_token');
|
||
$refresh_token = $this->request->param('refresh_token', '');
|
||
$authorization = $this->request->header('authorization', '');
|
||
|
||
if (empty($grant_type) || empty($authorization)) {
|
||
return errorJson('参数错误');
|
||
}
|
||
|
||
$params = [
|
||
'grant_type' => $grant_type,
|
||
'refresh_token' => $refresh_token,
|
||
];
|
||
|
||
|
||
|
||
$headerData = ['client:' . self::CLIENT_TYPE];
|
||
$header = setHeader($headerData, $authorization, 'system');
|
||
|
||
try {
|
||
$result = requestCurl($this->baseUrl . 'token', $params, 'POST', $header);
|
||
$result_array = handleApiResponse($result);
|
||
|
||
if (is_array($result_array) && isset($result_array['error'])) {
|
||
recordUserLog(0, '', 'REFRESH_TOKEN', '刷新token失败', $params, 500, $result_array['error_description']);
|
||
return errorJson($result_array['error_description']);
|
||
}
|
||
|
||
recordUserLog(0, '', 'REFRESH_TOKEN', '刷新token成功', $params, 200, '刷新成功');
|
||
return successJson($result_array);
|
||
} catch (\Exception $e) {
|
||
recordUserLog(0, '', 'REFRESH_TOKEN', '刷新token异常', $params, 500, $e->getMessage());
|
||
return errorJson('获取新token失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取商户基本信息
|
||
* @return \think\response\Json
|
||
*/
|
||
public function getAccountInfo()
|
||
{
|
||
$authorization = trim($this->request->header('authorization', ''));
|
||
if (empty($authorization)) {
|
||
return errorJson('缺少授权信息');
|
||
}
|
||
|
||
$headerData = ['client:' . self::CLIENT_TYPE];
|
||
$header = setHeader($headerData, $authorization, 'plain');
|
||
|
||
try {
|
||
$result = requestCurl($this->baseUrl . 'api/Account/self', [], 'GET', $header);
|
||
$response = handleApiResponse($result);
|
||
|
||
if (!empty($response['account'])) {
|
||
$accountData = $response['account'];
|
||
|
||
// 准备数据库字段映射，保持驼峰命名
|
||
$dbData = [
|
||
'accountId' => $accountData['id'],
|
||
'realName' => $accountData['realName'],
|
||
'nickname' => $accountData['nickname'],
|
||
'memo' => $accountData['memo'],
|
||
'avatar' => $accountData['avatar'],
|
||
'userName' => $accountData['userName'],
|
||
'secret' => $accountData['secret'],
|
||
'accountType' => $accountData['accountType'],
|
||
'departmentId' => $accountData['departmentId'],
|
||
'useGoogleSecretKey' => $accountData['useGoogleSecretKey'],
|
||
'hasVerifyGoogleSecret' => $accountData['hasVerifyGoogleSecret'],
|
||
'updateTime' => time()
|
||
];
|
||
|
||
|
||
// 查找是否存在该账户
|
||
$existingAccount = CompanyAccountModel::where('userName', $accountData['userName'])->find();
|
||
if ($existingAccount) {
|
||
// 更新现有记录
|
||
CompanyAccountModel::where('userName', $accountData['userName'])->update($dbData);
|
||
} else {
|
||
// 创建新记录
|
||
$dbData['createTime'] = time();
|
||
CompanyAccountModel::create($dbData);
|
||
}
|
||
return successJson($response['account']);
|
||
}else{
|
||
return successJson($response);
|
||
}
|
||
|
||
|
||
} catch (\Exception $e) {
|
||
recordUserLog(0, '', 'GET_ACCOUNT_INFO', '获取账户信息异常', [], 500, $e->getMessage());
|
||
return errorJson('获取账户信息失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 修改密码
|
||
* @return \think\response\Json
|
||
*/
|
||
public function modifyPwd()
|
||
{
|
||
// 获取并验证参数
|
||
$params = $this->validateModifyPwdParams();
|
||
if (!is_array($params)) {
|
||
return $params;
|
||
}
|
||
|
||
$authorization = trim($this->request->header('authorization', ''));
|
||
if (empty($authorization)) {
|
||
return errorJson('缺少授权信息');
|
||
}
|
||
|
||
$headerData = ['client:' . self::CLIENT_TYPE];
|
||
$header = setHeader($headerData, $authorization, 'plain');
|
||
|
||
try {
|
||
$result = requestCurl($this->baseUrl . 'api/Account/self', $params, 'PUT', $header);
|
||
$response = handleApiResponse($result);
|
||
|
||
if (empty($response)) {
|
||
// 获取当前用户信息
|
||
$currentUser = CompanyAccountModel::where('token', $authorization)->find();
|
||
if ($currentUser) {
|
||
recordUserLog($currentUser['id'], $currentUser['userName'], 'MODIFY_PASSWORD', '修改密码成功', [], 200, '修改成功');
|
||
}
|
||
return successJson(['message' => '修改成功']);
|
||
}
|
||
|
||
recordUserLog(0, '', 'MODIFY_PASSWORD', '修改密码失败', $params, 500, $response);
|
||
return errorJson($response);
|
||
} catch (\Exception $e) {
|
||
recordUserLog(0, '', 'MODIFY_PASSWORD', '修改密码异常', $params, 500, $e->getMessage());
|
||
return errorJson('修改密码失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 登出
|
||
* @return \think\response\Json
|
||
*/
|
||
public function logout()
|
||
{
|
||
$authorization = trim($this->request->header('authorization', ''));
|
||
if (empty($authorization)) {
|
||
return errorJson('缺少授权信息');
|
||
}
|
||
|
||
$headerData = ['client:' . self::CLIENT_TYPE];
|
||
$header = setHeader($headerData, $authorization, 'system');
|
||
|
||
try {
|
||
// 调用外部退出登录接口
|
||
$result = requestCurl($this->baseUrl . 'api/Account/SignOut', [], 'GET', $header);
|
||
return successJson([] , '退出成功');
|
||
} catch (\Exception $e) {
|
||
recordUserLog(0, '', 'LOGOUT', '退出登录异常', [], 500, $e->getMessage());
|
||
return errorJson('退出登录失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取验证码
|
||
* @return \think\response\Json
|
||
*/
|
||
public function getVerifyCode()
|
||
{
|
||
$headerData = ['client:' . self::CLIENT_TYPE];
|
||
$header = setHeader($headerData, '', 'plain');
|
||
|
||
try {
|
||
$result = requestCurl($this->baseUrl . 'api/Account/getVerifyCode', [], 'GET', $header);
|
||
$response = handleApiResponse($result);
|
||
|
||
// 检查返回的数据格式
|
||
if (is_array($response)) {
|
||
// 如果verifyCodeImage和verifySessionId都不为null，返回它们
|
||
if (!empty($response['verifyCodeImage']) && !empty($response['verifySessionId'])) {
|
||
return successJson([
|
||
'verifyCodeImage' => $response['verifyCodeImage'],
|
||
'verifySessionId' => $response['verifySessionId']
|
||
]);
|
||
}
|
||
}
|
||
|
||
// 如果不是预期的格式，返回原始数据
|
||
return successJson($response);
|
||
} catch (\Exception $e) {
|
||
return errorJson('获取验证码失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 验证登录参数
|
||
* @return array|\think\response\Json
|
||
*/
|
||
private function validateLoginParams()
|
||
{
|
||
$username = trim($this->request->param('username', ''));
|
||
$password = trim($this->request->param('password', ''));
|
||
$verifyCode = trim($this->request->param('verifyCode', ''));
|
||
$verifySessionId = trim($this->request->param('verifySessionId', ''));
|
||
|
||
if (empty($username) || empty($password)) {
|
||
return errorJson('用户名和密码不能为空');
|
||
}
|
||
|
||
// 验证密码格式
|
||
$passwordValidation = validateString($password, 'password',['max_length' => 20]);
|
||
if (!$passwordValidation['status']) {
|
||
return errorJson($passwordValidation['message']);
|
||
}
|
||
|
||
// 如果提供了验证码，验证格式
|
||
if (!empty($verifyCode)) {
|
||
if (empty($verifySessionId)) {
|
||
return errorJson('验证码会话ID不能为空');
|
||
}
|
||
// 验证码格式验证（假设是4位数字）
|
||
if (!preg_match('/^\d{4}$/', $verifyCode)) {
|
||
return errorJson('验证码格式不正确');
|
||
}
|
||
}
|
||
|
||
return [
|
||
'grant_type' => 'password',
|
||
'username' => $username,
|
||
'password' => $password,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 验证修改密码参数
|
||
* @return array|\think\response\Json
|
||
*/
|
||
private function validateModifyPwdParams()
|
||
{
|
||
$cPw = trim($this->request->param('cPw', ''));
|
||
$newPw = trim($this->request->param('newPw', ''));
|
||
$oldPw = trim($this->request->param('oldPw', ''));
|
||
|
||
if (empty($cPw) || empty($newPw) || empty($oldPw)) {
|
||
return errorJson('密码参数不完整');
|
||
}
|
||
|
||
if ($newPw !== $cPw) {
|
||
return errorJson('两次输入的新密码不一致');
|
||
}
|
||
|
||
// 验证新密码格式
|
||
$passwordValidation = validateString($newPw, 'password');
|
||
if (!$passwordValidation['status']) {
|
||
return errorJson($passwordValidation['message']);
|
||
}
|
||
|
||
return [
|
||
'cPw' => $cPw,
|
||
'newPw' => $newPw,
|
||
'oldPw' => $oldPw,
|
||
];
|
||
}
|
||
}
|