319 lines
9.5 KiB
PHP
319 lines
9.5 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | Niucloud-admin 企业快速开发的saas管理平台
|
||
// +----------------------------------------------------------------------
|
||
// | 官方网址：https://www.niucloud-admin.com
|
||
// +----------------------------------------------------------------------
|
||
// | niucloud团队 版权所有 开源版本可自由商用
|
||
// +----------------------------------------------------------------------
|
||
// | Author: Niucloud Team
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\service\admin\user;
|
||
|
||
|
||
use app\dict\sys\AppTypeDict;
|
||
use app\dict\sys\UserDict;
|
||
use app\model\sys\SysUser;
|
||
use app\model\sys\SysUserRole;
|
||
use app\service\admin\auth\LoginService;
|
||
use core\base\BaseAdminService;
|
||
use core\exception\AdminException;
|
||
use core\exception\CommonException;
|
||
use Exception;
|
||
use think\db\exception\DbException;
|
||
use think\facade\Db;
|
||
use think\Model;
|
||
|
||
/**
|
||
* 用户服务层
|
||
* Class BaseService
|
||
* @package app\service
|
||
*/
|
||
class UserService extends BaseAdminService
|
||
{
|
||
public function __construct()
|
||
{
|
||
parent::__construct();
|
||
$this->model = new SysUser();
|
||
}
|
||
|
||
/**
|
||
* 用户列表
|
||
* @param array $where
|
||
* @return array
|
||
*/
|
||
public function getPage(array $where)
|
||
{
|
||
return $this->getPageList($this->model, $where, 'uid,username,head_img,real_name,last_ip,last_time,login_count,status', 'uid desc',['status_name']);
|
||
}
|
||
|
||
|
||
/**
|
||
* 用户详情
|
||
* @param int $uid
|
||
* @return array
|
||
*/
|
||
public function getInfo(int $uid){
|
||
$where = array(
|
||
['uid', '=', $uid],
|
||
);
|
||
$field = 'uid, username, head_img, real_name, last_ip, last_time, create_time, login_count, status, delete_time, update_time';
|
||
$user = $this->model->where($where)->field($field)->append(['status_name'])->findOrEmpty();
|
||
return $user->toArray();
|
||
}
|
||
|
||
/**
|
||
* 获取用户列表
|
||
* @param array $where
|
||
* @return array
|
||
*/
|
||
public function getUserAdminPage(array $where)
|
||
{
|
||
$site_id = $this->site_id;
|
||
$field = 'id,SysUserRole.uid,site_id,role_ids,SysUserRole.create_time,is_admin,SysUserRole.status';
|
||
$order = 'SysUserRole.create_time desc';
|
||
$search_model = (new SysUserRole())
|
||
->field($field)
|
||
->order($order)
|
||
->with('userinfo')
|
||
->hasWhere('userinfo', function ($query) use ($where, $site_id) {
|
||
$condition = [
|
||
['SysUserRole.site_id', '=', $site_id ]
|
||
];
|
||
if (!empty($where['username'])) $condition[] = ['username', 'like', "%{$where['username']}%"];
|
||
if (!empty($where['realname'])) $condition[] = ['realname', 'like', "%{$where['realname']}%"];
|
||
$query->where($condition);
|
||
})
|
||
->append(['status_name']);
|
||
|
||
return $this->pageQuery($search_model, function ($item, $key) {
|
||
if (!empty($item->role_ids)) {
|
||
$item->role_array = (new UserRoleService())->getRoleByUserRoleIds($item->role_ids, $this->site_id);
|
||
} else {
|
||
$item->role_array = [];
|
||
}
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 获取用户信息
|
||
* @param int $uid
|
||
* @return array
|
||
*/
|
||
public function getUserAdminInfo(int $uid)
|
||
{
|
||
$field = 'id,uid,site_id,role_ids,create_time,is_admin,status';
|
||
$info = (new SysUserRole())->where([ ['uid', '=', $uid], ['site_id', '=', $this->site_id ] ])
|
||
->field($field)
|
||
->with('userinfo')
|
||
->findOrEmpty()
|
||
->toArray();
|
||
|
||
if (!empty($info)) {
|
||
if (!empty($info['role_ids'])) {
|
||
$info['role_array'] = (new UserRoleService())->getRoleByUserRoleIds($info['role_ids'], $this->site_id);
|
||
} else {
|
||
$info['role_array'] = [];
|
||
}
|
||
}
|
||
return $info;
|
||
}
|
||
|
||
/**
|
||
* 添加用户（添加用户，不添加站点）
|
||
* @param array $data
|
||
* @return bool
|
||
* @throws Exception
|
||
*/
|
||
public function add(array $data){
|
||
$user_data = [
|
||
'username' => $data['username'],
|
||
'head_img' => $data['head_img'],
|
||
'status' => $data['status'],
|
||
'real_name' => $data['real_name'],
|
||
'password' => create_password($data['password'])
|
||
];
|
||
$user = $this->model->create($user_data);
|
||
return $user?->uid;
|
||
}
|
||
|
||
/**
|
||
* 添加对应站点用户(添加站点，同时添加站点用户,用于添加站点以及站点添加站点用户)
|
||
* @param $data
|
||
* @param $site_id
|
||
* @return bool
|
||
*/
|
||
public function addSiteUser($data, $site_id)
|
||
{
|
||
Db::startTrans();
|
||
try {
|
||
if (isset($data['uid']) && !empty($data['uid'])) {
|
||
$uid = $data['uid'];
|
||
$user = $this->model->where([ ['uid', '=', $uid] ])->field('uid')->findOrEmpty();
|
||
if ($user->isEmpty()) {
|
||
Db::commit();
|
||
throw new AdminException('USER_NOT_EXIST');
|
||
}
|
||
} else {
|
||
//添加用户
|
||
$uid = $this->add($data);
|
||
}
|
||
$role_ids = $data['role_ids'] ?? [];
|
||
$is_admin = $data['is_admin'] ?? 0;
|
||
//创建用户站点管理权限
|
||
(new UserRoleService())->add($uid, ['role_ids' => $role_ids, 'is_admin' => $is_admin], $site_id);
|
||
Db::commit();
|
||
return $uid;
|
||
} catch ( Exception $e) {
|
||
Db::rollback();
|
||
throw new AdminException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 更新对应站点用户
|
||
* @param $uid
|
||
* @param $data
|
||
* @param $site_id
|
||
* @return true
|
||
*/
|
||
public function editSiteUser($uid, $data, $site_id)
|
||
{
|
||
Db::startTrans();
|
||
try {
|
||
//添加用户
|
||
$this->edit($uid, $data);
|
||
$role_ids = $data['role_ids'] ?? [];
|
||
$is_admin = $data['is_admin'] ?? 0;
|
||
//创建用户站点管理权限
|
||
(new UserRoleService())->edit($site_id, $uid, $role_ids);
|
||
Db::commit();
|
||
return true;
|
||
} catch ( Exception $e) {
|
||
Db::rollback();
|
||
throw new AdminException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 检测用户名是否重复
|
||
* @param $username
|
||
* @return bool
|
||
* @throws DbException
|
||
*/
|
||
public function checkUsername($username)
|
||
{
|
||
$count = $this->model->where([['username', '=', $username]])->count();
|
||
if($count > 0)
|
||
{
|
||
return true;
|
||
}
|
||
else return false;
|
||
}
|
||
|
||
/**
|
||
* 用户模型对象
|
||
* @param int $uid
|
||
* @return SysUser|array|mixed|Model
|
||
*/
|
||
public function find(int $uid){
|
||
|
||
$user = $this->model->findOrEmpty($uid);
|
||
if ($user->isEmpty())
|
||
throw new AdminException('USER_NOT_EXIST');
|
||
return $user;
|
||
}
|
||
|
||
/**
|
||
* 编辑用户
|
||
* @param int $uid
|
||
* @param array $data
|
||
* @return true
|
||
*/
|
||
public function edit(int $uid, array $data){
|
||
$user = $this->find($uid);
|
||
$user_data = [
|
||
];
|
||
$is_off_status = false;
|
||
if(isset($data['status'])){
|
||
$this->statusChange($uid, $data['status']);
|
||
if($data['status'] == UserDict::OFF)
|
||
$is_off_status = true;
|
||
}
|
||
if(isset($data['head_img'])){
|
||
$user_data['head_img'] = $data['head_img'];
|
||
}
|
||
if(isset($data['real_name'])){
|
||
$user_data['real_name'] = $data['real_name'];
|
||
}
|
||
|
||
$password = $data['password'] ?? '';
|
||
$is_change_password = false;
|
||
if(!empty($password) && !check_password($password, $user->password)){
|
||
$user_data['password'] = create_password($password);
|
||
$is_change_password = true;
|
||
}
|
||
if(empty($user_data))
|
||
return true;
|
||
//更新用户信息
|
||
$user->save($user_data);
|
||
//更新权限 禁用用户 修改密码 都会清理token
|
||
if($is_off_status || $is_change_password){
|
||
LoginService::clearToken($uid);
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 改变用户状态
|
||
* @param $uid
|
||
* @param $status
|
||
* @return true
|
||
*/
|
||
public function statusChange($uid, $status) {
|
||
(new SysUserRole())->where([ ['uid', '=', $uid], ['site_id', '=', $this->uid] ])->update(['status' => $status]);
|
||
LoginService::clearToken($uid);
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 删除
|
||
* @param int $uid
|
||
* @return true
|
||
*/
|
||
public function del(int $uid){
|
||
$where = [
|
||
['uid', '=', $uid],
|
||
['site_id', '=', $this->site_id]
|
||
];
|
||
(new SysUserRole())->where($where)->delete();
|
||
return true;
|
||
|
||
}
|
||
|
||
/**
|
||
* 通过账号获取管理员信息
|
||
* @param string $username
|
||
* @return SysUser|array|mixed|Model
|
||
*/
|
||
public function getUserInfoByUsername(string $username){
|
||
return $this->model->where([['username', '=',$username]])->findOrEmpty();
|
||
}
|
||
|
||
/**
|
||
* 获取全部用户列表（用于平台整体用户管理）
|
||
* @param array $where
|
||
* @return array
|
||
*/
|
||
public function getUserAllPage(array $where)
|
||
{
|
||
$field = 'uid, username, head_img';
|
||
return $this->model->withSearch(['username', 'realname', 'create_time'], $where)
|
||
->field($field)
|
||
->order('uid desc')
|
||
->select()
|
||
->toArray();
|
||
}
|
||
}
|