|
|
|
|
|
from flask import request
|
|
|
from flask_restful import Resource, reqparse
|
|
|
from flask_jwt_extended import jwt_required
|
|
|
|
|
|
from app import db
|
|
|
from app.models import User
|
|
|
from app.utils.auth_tools import hash_password
|
|
|
from app.utils.response import APIResponse
|
|
|
|
|
|
class AdminUserListResource(Resource):
|
|
|
@jwt_required()
|
|
|
def get(self):
|
|
|
"""获取用户列表[^1]"""
|
|
|
parser = reqparse.RequestParser()
|
|
|
parser.add_argument('page', type=int, default=1)
|
|
|
parser.add_argument('limit', type=int, default=20)
|
|
|
parser.add_argument('search', type=str)
|
|
|
args = parser.parse_args()
|
|
|
|
|
|
query = User.query
|
|
|
if args['search']:
|
|
|
query = query.filter(User.email.ilike(f"%{args['search']}%"))
|
|
|
|
|
|
pagination = query.paginate(page=args['page'], per_page=args['limit'], error_out=False)
|
|
|
users = [{
|
|
|
'id': u.id,
|
|
|
'name': u.name,
|
|
|
'email': u.email,
|
|
|
'status': 'active' if u.deleted_flag == 'N' else 'deleted'
|
|
|
} for u in pagination.items]
|
|
|
|
|
|
return APIResponse.success({
|
|
|
'data': users,
|
|
|
'total': pagination.total
|
|
|
})
|
|
|
|
|
|
|
|
|
|
|
|
class AdminCreateUserResource(Resource):
|
|
|
@jwt_required()
|
|
|
def put(self):
|
|
|
"""创建新用户[^2]"""
|
|
|
data = request.json
|
|
|
required_fields = ['name', 'email', 'password']
|
|
|
if not all(field in data for field in required_fields):
|
|
|
return APIResponse.error('缺少必要参数', 400)
|
|
|
|
|
|
if User.query.filter_by(email=data['email']).first():
|
|
|
return APIResponse.error('邮箱已存在', 400)
|
|
|
|
|
|
user = User(
|
|
|
name=data['name'],
|
|
|
email=data['email'],
|
|
|
password=hash_password(data['password'])
|
|
|
)
|
|
|
db.session.add(user)
|
|
|
db.session.commit()
|
|
|
return APIResponse.success({
|
|
|
'user_id': user.id,
|
|
|
'message': '用户创建成功'
|
|
|
})
|
|
|
|
|
|
|
|
|
class AdminUserDetailResource(Resource):
|
|
|
@jwt_required()
|
|
|
def get(self, id):
|
|
|
"""获取用户详细信息[^3]"""
|
|
|
user = User.query.get_or_404(id)
|
|
|
return APIResponse.success({
|
|
|
'id': user.id,
|
|
|
'name': user.name,
|
|
|
'email': user.email,
|
|
|
'status': 'active' if user.deleted_flag == 'N' else 'deleted',
|
|
|
'created_at': user.created_at.isoformat()
|
|
|
})
|
|
|
|
|
|
|
|
|
class AdminUpdateUserResource(Resource):
|
|
|
@jwt_required()
|
|
|
def post(self, id):
|
|
|
"""编辑用户信息[^4]"""
|
|
|
user = User.query.get_or_404(id)
|
|
|
data = request.json
|
|
|
|
|
|
if 'email' in data and User.query.filter(User.email == data['email'],
|
|
|
User.id != id).first():
|
|
|
return APIResponse.error('邮箱已被使用', 400)
|
|
|
|
|
|
if 'name' in data:
|
|
|
user.name = data['name']
|
|
|
if 'email' in data:
|
|
|
user.email = data['email']
|
|
|
|
|
|
db.session.commit()
|
|
|
return APIResponse.success(message='用户信息更新成功')
|
|
|
|
|
|
|
|
|
class AdminDeleteUserResource(Resource):
|
|
|
@jwt_required()
|
|
|
def delete(self, id):
|
|
|
"""删除用户[^5]"""
|
|
|
user = User.query.get_or_404(id)
|
|
|
user.deleted_flag = 'Y'
|
|
|
db.session.commit()
|
|
|
return APIResponse.success(message='用户删除成功')
|
|
|
|
|
|
|
