add async

This commit is contained in:
2025-03-10 18:38:42 +08:00
parent 60932c57f9
commit 515139ad4b
5 changed files with 32 additions and 14 deletions

View File

@@ -20,7 +20,7 @@ router = Router()
@router.post("/register") @router.post("/register")
def user_register(request, payload: UserRegistrationSchema): def user_register(request, payload: UserRegistrationSchema):
if User.objects.filter(username=payload.username).exists(): if User.objects.filter(username=payload.username).exists():
return HttpError(400, "用户已存在") raise HttpError(400, "用户已存在")
User.objects.create_user( User.objects.create_user(
username=payload.username, username=payload.username,
email=payload.email, email=payload.email,
@@ -36,7 +36,7 @@ def user_login(request, payload: UserLoginSchema):
login(request, user) login(request, user)
return {"username": user.username, "role": user.role} return {"username": user.username, "role": user.role}
else: else:
return HttpError(401, "账号密码错误") raise HttpError(401, "账号密码错误")
@router.post("/logout") @router.post("/logout")
@@ -78,7 +78,7 @@ def batch_create(request, payload: BatchUsersIn):
usernames.append(username) usernames.append(username)
existing_users = User.objects.filter(username__in=usernames) existing_users = User.objects.filter(username__in=usernames)
if existing_users.exists(): if existing_users.exists():
return HttpError(400, "有些用户已经存在,创建失败") raise HttpError(400, "有些用户已经存在,创建失败")
for username in usernames: for username in usernames:
digits = [str(random.randint(2, 9)) for _ in range(6)] digits = [str(random.randint(2, 9)) for _ in range(6)]
@@ -102,4 +102,4 @@ def toggle_user_is_active(request, id: int):
"message": f"{user.username} {'解封' if user.is_active else '封号'}成功" "message": f"{user.username} {'解封' if user.is_active else '封号'}成功"
} }
except User.DoesNotExist: except User.DoesNotExist:
return HttpError(404, "查无此人") raise HttpError(404, "查无此人")

View File

@@ -11,12 +11,12 @@ def _require(roles):
@wraps(func) @wraps(func)
def wrapper(request, *args, **kwargs): def wrapper(request, *args, **kwargs):
if not request.user.is_authenticated: if not request.user.is_authenticated:
return HttpError(401, "用户未登录") raise HttpError(401, "用户未登录")
try: try:
if request.user.role not in roles: if request.user.role not in roles:
return HttpError(403, "你没有权限") raise HttpError(403, "你没有权限")
except User.DoesNotExist: except User.DoesNotExist:
return HttpError(404, "用户不存在") raise HttpError(404, "用户不存在")
return func(request, *args, **kwargs) return func(request, *args, **kwargs)
return wrapper return wrapper

View File

@@ -0,0 +1,18 @@
# Generated by Django 5.1.6 on 2025-03-10 10:38
from django.db import migrations, models
class Migration(migrations.Migration):
dependencies = [
('task', '0001_initial'),
]
operations = [
migrations.AlterField(
model_name='task',
name='display',
field=models.IntegerField(db_index=True, unique=True),
),
]

View File

@@ -8,7 +8,7 @@ class Task(TimeStampedModel):
("tutorial", "Tutorial"), ("tutorial", "Tutorial"),
] ]
display = models.IntegerField(unique=True) display = models.IntegerField(unique=True, db_index=True)
title = models.CharField(max_length=100) title = models.CharField(max_length=100)
content = models.TextField() content = models.TextField()
task_type = models.CharField( task_type = models.CharField(

View File

@@ -20,11 +20,11 @@ def get_all_public_display(request):
@router.get("/{display}", response=TutorialAll) @router.get("/{display}", response=TutorialAll)
def get(request, display: int): async def get(request, display: int):
try: try:
return Tutorial.objects.get(display=display) return await Tutorial.objects.aget(display=display)
except Tutorial.DoesNotExist: except Tutorial.DoesNotExist:
return HttpError(404, "此序号无教程") raise HttpError(404, "此序号无教程")
@router.post("/") @router.post("/")
@@ -35,7 +35,7 @@ def create_or_update(request, payload: TutorialIn):
item.title = payload.title item.title = payload.title
item.content = payload.content item.content = payload.content
item.is_public = payload.is_public item.is_public = payload.is_public
item.save() item.asave()
return {"message": "更新成功"} return {"message": "更新成功"}
except Tutorial.DoesNotExist: except Tutorial.DoesNotExist:
Tutorial.objects.create(**payload.dict()) Tutorial.objects.create(**payload.dict())
@@ -48,11 +48,11 @@ def toggle_public(request, display: int):
try: try:
item = Tutorial.objects.get(display=display) item = Tutorial.objects.get(display=display)
item.is_public = not item.is_public item.is_public = not item.is_public
item.save() item.asave()
label = "公开" if item.is_public else "隐藏" label = "公开" if item.is_public else "隐藏"
return {"message": f"{item.display}{item.title}{label}"} return {"message": f"{item.display}{item.title}{label}"}
except Tutorial.DoesNotExist: except Tutorial.DoesNotExist:
return HttpError(404, "此序号无教程") raise HttpError(404, "此序号无教程")
@router.delete("/{display}") @router.delete("/{display}")