304 lines
10 KiB
Python
304 lines
10 KiB
Python
from django.db.models import Q
|
|
from django.utils import timezone
|
|
|
|
from utils.api import APIView, validate_serializer
|
|
|
|
from problemset.models import (
|
|
ProblemSet,
|
|
ProblemSetProblem,
|
|
ProblemSetBadge,
|
|
ProblemSetProgress,
|
|
ProblemSetSubmission,
|
|
UserBadge,
|
|
)
|
|
from problemset.serializers import (
|
|
ProblemSetSerializer,
|
|
ProblemSetListSerializer,
|
|
ProblemSetProblemSerializer,
|
|
ProblemSetBadgeSerializer,
|
|
ProblemSetProgressSerializer,
|
|
UserBadgeSerializer,
|
|
JoinProblemSetSerializer,
|
|
UpdateProgressSerializer,
|
|
)
|
|
|
|
from submission.models import Submission
|
|
from problem.models import Problem
|
|
|
|
|
|
class ProblemSetAPI(APIView):
|
|
"""题单API - 用户端"""
|
|
|
|
def get(self, request):
|
|
"""获取题单列表"""
|
|
problem_sets = ProblemSet.objects.filter(visible=True).exclude(status="draft")
|
|
|
|
# 过滤条件
|
|
keyword = request.GET.get("keyword", "").strip()
|
|
if keyword:
|
|
problem_sets = problem_sets.filter(
|
|
Q(title__icontains=keyword) | Q(description__icontains=keyword)
|
|
)
|
|
|
|
difficulty = request.GET.get("difficulty")
|
|
if difficulty:
|
|
problem_sets = problem_sets.filter(difficulty=difficulty)
|
|
|
|
status_filter = request.GET.get("status")
|
|
if status_filter:
|
|
problem_sets = problem_sets.filter(status=status_filter)
|
|
|
|
# 排序
|
|
sort = request.GET.get("sort")
|
|
if sort:
|
|
problem_sets = problem_sets.order_by(sort)
|
|
else:
|
|
problem_sets = problem_sets.order_by("-create_time")
|
|
|
|
data = self.paginate_data(request, problem_sets, ProblemSetListSerializer)
|
|
return self.success(data)
|
|
|
|
|
|
class ProblemSetDetailAPI(APIView):
|
|
"""题单详情API - 用户端"""
|
|
|
|
def get(self, request, problem_set_id):
|
|
"""获取题单详情"""
|
|
try:
|
|
problem_set = (
|
|
ProblemSet.objects.filter(id=problem_set_id, visible=True)
|
|
.exclude(status="draft")
|
|
.get()
|
|
)
|
|
except ProblemSet.DoesNotExist:
|
|
return self.error("题单不存在")
|
|
|
|
serializer = ProblemSetSerializer(problem_set, context={"request": request})
|
|
return self.success(serializer.data)
|
|
|
|
|
|
class ProblemSetProblemAPI(APIView):
|
|
"""题单题目API - 用户端"""
|
|
|
|
def get(self, request, problem_set_id):
|
|
"""获取题单中的题目列表"""
|
|
try:
|
|
problem_set = (
|
|
ProblemSet.objects.filter(id=problem_set_id, visible=True)
|
|
.exclude(status="draft")
|
|
.get()
|
|
)
|
|
except ProblemSet.DoesNotExist:
|
|
return self.error("题单不存在")
|
|
|
|
problems = ProblemSetProblem.objects.filter(problemset=problem_set).order_by(
|
|
"order"
|
|
)
|
|
serializer = ProblemSetProblemSerializer(
|
|
problems, many=True, context={"request": request}
|
|
)
|
|
return self.success(serializer.data)
|
|
|
|
|
|
class ProblemSetProgressAPI(APIView):
|
|
"""题单进度API"""
|
|
|
|
@validate_serializer(JoinProblemSetSerializer)
|
|
def post(self, request):
|
|
"""加入题单"""
|
|
data = request.data
|
|
try:
|
|
problem_set = (
|
|
ProblemSet.objects.filter(id=data["problemset_id"], visible=True)
|
|
.exclude(status="draft")
|
|
.get()
|
|
)
|
|
except ProblemSet.DoesNotExist:
|
|
return self.error("题单不存在")
|
|
|
|
if ProblemSetProgress.objects.filter(
|
|
problemset=problem_set, user=request.user
|
|
).exists():
|
|
return self.error("已经加入该题单")
|
|
|
|
# 创建进度记录
|
|
progress = ProblemSetProgress.objects.create(
|
|
problemset=problem_set, user=request.user
|
|
)
|
|
progress.update_progress()
|
|
|
|
return self.success("成功加入题单")
|
|
|
|
def get(self, request, problem_set_id):
|
|
"""获取题单进度"""
|
|
try:
|
|
problem_set = (
|
|
ProblemSet.objects.filter(id=problem_set_id, visible=True)
|
|
.exclude(status="draft")
|
|
.get()
|
|
)
|
|
except ProblemSet.DoesNotExist:
|
|
return self.error("题单不存在")
|
|
|
|
try:
|
|
progress = ProblemSetProgress.objects.get(
|
|
problemset=problem_set, user=request.user
|
|
)
|
|
except ProblemSetProgress.DoesNotExist:
|
|
return self.error("未加入该题单")
|
|
|
|
serializer = ProblemSetProgressSerializer(progress)
|
|
return self.success(serializer.data)
|
|
|
|
@validate_serializer(UpdateProgressSerializer)
|
|
def put(self, request):
|
|
"""更新进度"""
|
|
data = request.data
|
|
try:
|
|
problem_set = (
|
|
ProblemSet.objects.filter(id=data["problemset_id"], visible=True)
|
|
.exclude(status="draft")
|
|
.get()
|
|
)
|
|
except ProblemSet.DoesNotExist:
|
|
return self.error("题单不存在")
|
|
|
|
try:
|
|
progress = ProblemSetProgress.objects.get(
|
|
problemset=problem_set, user=request.user
|
|
)
|
|
except ProblemSetProgress.DoesNotExist:
|
|
return self.error("未加入该题单")
|
|
|
|
# 更新详细进度
|
|
problem_id = str(data["problem_id"])
|
|
|
|
# 获取该题目在题单中的分值
|
|
try:
|
|
problemset_problem = ProblemSetProblem.objects.get(
|
|
problemset=problem_set, problem_id=problem_id
|
|
)
|
|
problem_score = problemset_problem.score
|
|
except ProblemSetProblem.DoesNotExist:
|
|
problem_score = 0
|
|
|
|
progress.progress_detail[problem_id] = {
|
|
"score": problem_score, # 题单中设置的分值
|
|
"submit_time": data.get("submit_time", timezone.now().isoformat()),
|
|
}
|
|
|
|
# 更新进度
|
|
progress.update_progress()
|
|
|
|
# 只有当提供了submission_id时才创建ProblemSetSubmission记录
|
|
if "submission_id" in data and data["submission_id"]:
|
|
try:
|
|
submission = Submission.objects.get(id=data["submission_id"])
|
|
problem = Problem.objects.get(id=problem_id)
|
|
|
|
has_accepted = ProblemSetSubmission.objects.filter(
|
|
problemset=problem_set,
|
|
user=request.user,
|
|
problem=problem,
|
|
).exists()
|
|
if not has_accepted:
|
|
ProblemSetSubmission.objects.create(
|
|
problemset=problem_set,
|
|
user=request.user,
|
|
submission=submission,
|
|
problem=problem,
|
|
)
|
|
except Submission.DoesNotExist:
|
|
# 如果提交记录不存在，记录错误但不中断流程
|
|
pass
|
|
|
|
# 检查是否获得奖章
|
|
self._check_badges(progress)
|
|
|
|
return self.success("进度已更新")
|
|
|
|
def _check_badges(self, progress):
|
|
"""检查是否获得奖章"""
|
|
badges = ProblemSetBadge.objects.filter(problemset=progress.problemset)
|
|
|
|
for badge in badges:
|
|
if UserBadge.objects.filter(user=progress.user, badge=badge).exists():
|
|
continue
|
|
|
|
if badge.condition_type == "all_problems":
|
|
if progress.completed_problems_count == progress.total_problems_count:
|
|
UserBadge.objects.create(user=progress.user, badge=badge)
|
|
elif badge.condition_type == "problem_count":
|
|
if progress.completed_problems_count >= badge.condition_value:
|
|
UserBadge.objects.create(user=progress.user, badge=badge)
|
|
elif badge.condition_type == "score":
|
|
if progress.total_score >= badge.condition_value:
|
|
UserBadge.objects.create(user=progress.user, badge=badge)
|
|
|
|
|
|
class UserProgressAPI(APIView):
|
|
"""用户进度API"""
|
|
|
|
def get(self, request):
|
|
"""获取用户的题单进度列表"""
|
|
progress_list = ProblemSetProgress.objects.filter(user=request.user).order_by(
|
|
"-join_time"
|
|
)
|
|
serializer = ProblemSetProgressSerializer(progress_list, many=True)
|
|
return self.success(serializer.data)
|
|
|
|
|
|
class UserBadgeAPI(APIView):
|
|
"""用户奖章API"""
|
|
|
|
def get(self, request):
|
|
"""获取用户的奖章列表"""
|
|
badges = UserBadge.objects.filter(user=request.user).order_by("-earned_time")
|
|
serializer = UserBadgeSerializer(badges, many=True)
|
|
return self.success(serializer.data)
|
|
|
|
|
|
class ProblemSetBadgeAPI(APIView):
|
|
"""题单奖章API - 用户端"""
|
|
|
|
def get(self, request, problem_set_id):
|
|
"""获取题单的奖章列表"""
|
|
try:
|
|
problem_set = (
|
|
ProblemSet.objects.filter(id=problem_set_id, visible=True)
|
|
.exclude(status="draft")
|
|
.get()
|
|
)
|
|
except ProblemSet.DoesNotExist:
|
|
return self.error("题单不存在")
|
|
|
|
badges = ProblemSetBadge.objects.filter(problemset=problem_set)
|
|
serializer = ProblemSetBadgeSerializer(badges, many=True)
|
|
return self.success(serializer.data)
|
|
|
|
|
|
class ProblemSetUserProgressAPI(APIView):
|
|
"""题单用户进度列表API"""
|
|
|
|
def get(self, request, problem_set_id: int):
|
|
"""获取题单的用户进度列表"""
|
|
try:
|
|
problem_set = (
|
|
ProblemSet.objects.filter(id=problem_set_id, visible=True)
|
|
.exclude(status="draft")
|
|
.get()
|
|
)
|
|
except ProblemSet.DoesNotExist:
|
|
return self.error("题单不存在")
|
|
|
|
# 获取所有参与该题单的用户进度
|
|
progresses = ProblemSetProgress.objects.filter(problemset=problem_set).order_by(
|
|
"-is_completed", "-progress_percentage", "join_time"
|
|
)
|
|
|
|
try:
|
|
serializer = ProblemSetProgressSerializer(progresses, many=True)
|
|
return self.success(serializer.data)
|
|
except Exception as e:
|
|
return self.error(f"序列化错误: {str(e)}")
|