Conflicts:
	contest/views.py
This commit is contained in:
sxw@401
2015-09-17 13:25:38 +08:00
8 changed files with 25 additions and 49 deletions

View File

@@ -437,6 +437,7 @@ def contest_rank_page(request, contest_id):
result[i]["username"] = user.username result[i]["username"] = user.username
result[i]["real_name"] = user.real_name result[i]["real_name"] = user.real_name
result[i]["total_time"] = get_the_formatted_time(submissions.filter(ac=True).aggregate(total_time=Sum("total_time"))["total_time"]) result[i]["total_time"] = get_the_formatted_time(submissions.filter(ac=True).aggregate(total_time=Sum("total_time"))["total_time"])
result = sorted(result, cmp=_cmp, reverse=True) result = sorted(result, cmp=_cmp, reverse=True)
r.set("contest_rank_" + contest_id, json.dumps(list(result))) r.set("contest_rank_" + contest_id, json.dumps(list(result)))
else: else:
@@ -451,5 +452,5 @@ def contest_rank_page(request, contest_id):
{"contest": contest, "contest_problems": contest_problems, {"contest": contest, "contest_problems": contest_problems,
"result": result, "result": result,
"auto_refresh": request.GET.get("auto_refresh", None) == "true", "auto_refresh": request.GET.get("auto_refresh", None) == "true",
"show_real_name": result.GET.get("show_real_name", None) == "true", "show_real_name": request.GET.get("show_real_name", None) == "true",
"real_time_rank": contest.real_time_rank}) "real_time_rank": contest.real_time_rank})

View File

@@ -22,7 +22,6 @@ from utils.shortcuts import serializer_invalid_response, error_response, success
from submission.models import Submission from submission.models import Submission
from .serializers import CreateContestSubmissionSerializer from .serializers import CreateContestSubmissionSerializer
from submission.serializers import SubmissionSerializer from submission.serializers import SubmissionSerializer
from oj.settings import REDIS_CACHE
class ContestSubmissionAPIView(APIView): class ContestSubmissionAPIView(APIView):
@@ -78,21 +77,7 @@ def contest_problem_my_submissions_list_page(request, contest_id, contest_proble
{"submissions": submissions, "problem": contest_problem}) {"submissions": submissions, "problem": contest_problem})
def get_formatted_datetime(date_time): @check_user_contest_permission
date_time = timezone.localtime(date_time)
result = str(date_time.minute)
if date_time.minute < 10:
result = "0" + result
result = str(date_time.hour) + ":" + result
if date_time.hour < 10:
result = "0" + result
result = str(date_time.day) + u"" + result
result = str(date_time.month) + u"" + result
result = str(date_time.year) + u"" + result
return result
@login_required
def contest_problem_submissions_list_page(request, contest_id, page=1): def contest_problem_submissions_list_page(request, contest_id, page=1):
""" """
单个比赛中的所有提交(包含自己和别人,自己可查提交结果,其他人不可查) 单个比赛中的所有提交(包含自己和别人,自己可查提交结果,其他人不可查)
@@ -101,33 +86,16 @@ def contest_problem_submissions_list_page(request, contest_id, page=1):
contest = Contest.objects.get(id=contest_id) contest = Contest.objects.get(id=contest_id)
except Contest.DoesNotExist: except Contest.DoesNotExist:
return error_page(request, u"比赛不存在") return error_page(request, u"比赛不存在")
# 以下是本场比赛中所有的提交
r = redis.Redis(host=REDIS_CACHE["host"], port=REDIS_CACHE["port"], db=REDIS_CACHE["db"]) submissions = Submission.objects.filter(contest_id=contest_id).\
if contest.real_time_rank: values("id", "contest_id", "problem_id", "result", "create_time",
# 更新submissions缓存 "accepted_answer_time", "language", "user_id").order_by("-create_time")
submissions = Submission.objects.filter(contest_id=contest_id). \
values("id", "contest_id", "problem_id", "result", "create_time", "accepted_answer_time", "language",
"user_id").order_by("-create_time") # 封榜的时候只能看到自己的提交
# 把datetime类型转换为string if not contest.real_time_rank:
for submission in submissions: if not (request.user.admin_type == SUPER_ADMIN or request.user == contest.created_by):
submission["create_time"] = get_formatted_datetime(submission["create_time"]) submissions = submissions.filter(user_id=request.user.id)
r.set("contest_submissions_" + contest_id, json.dumps(list(submissions)))
else:
# 已封榜
submissions = r.get("contest_submissions_" + contest_id)
if submissions:
submissions = json.loads(submissions)
time = datetime.strptime(submissions[0]["create_time"].encode("utf8"),
'%Y\xe5\xb9\xb4%m\xe6\x9c\x88%d\xe6\x97\xa5 %H:%M')
time = time.replace(tzinfo=pytz.timezone('Asia/Shanghai'))
else:
submissions = []
time = contest.start_time
# 除了缓存里的还要加上封榜以后自己的提交
self_submissions = Submission.objects.filter(contest_id=int(contest_id), user_id=request.user.id, create_time__gte=time). \
values("id", "contest_id", "problem_id", "result", "create_time", "accepted_answer_time", "language",
"user_id").order_by("-create_time")
submissions = list(self_submissions) + submissions
language = request.GET.get("language", None) language = request.GET.get("language", None)
filter = None filter = None

View File

@@ -4,9 +4,10 @@
此文件包含 celery 的部分配置,但是 celery 并不是运行在docker 中的,所以本配置文件中的 redis和 MySQL 的地址就应该是 此文件包含 celery 的部分配置,但是 celery 并不是运行在docker 中的,所以本配置文件中的 redis和 MySQL 的地址就应该是
运行 redis 和 MySQL 的 docker 容器的地址了。怎么获取这个地址见帮助文档。测试用例的路径和源代码路径同理。 运行 redis 和 MySQL 的 docker 容器的地址了。怎么获取这个地址见帮助文档。测试用例的路径和源代码路径同理。
""" """
import os
# 这个redis 是 celery 使用的,包括存储队列信息还有部分统计信息 # 这个redis 是 celery 使用的,包括存储队列信息还有部分统计信息
redis_config = { redis_config = {
"host": "192.168.42.23", "host": os.environ.get("REDIS_PORT_6379_TCP_ADDR"),
"port": 6379, "port": 6379,
"db": 0 "db": 0
} }
@@ -30,7 +31,7 @@ log_dir = "/root/log/"
# 存储提交信息的数据库,是 celery 使用的,与 oj.settings/local_settings 等区分,那是 web 服务器访问的地址 # 存储提交信息的数据库,是 celery 使用的,与 oj.settings/local_settings 等区分,那是 web 服务器访问的地址
submission_db = { submission_db = {
"host": "192.168.42.32", "host": os.environ.get("submission_db_host"),
"port": 3306, "port": 3306,
"db": "oj_submission", "db": "oj_submission",
"user": "root", "user": "root",

View File

@@ -11,7 +11,7 @@ from settings import docker_config, source_code_dir, test_case_dir, log_dir, sub
@app.task @app.task
def judge(submission_id, time_limit, memory_limit, test_case_id): def judge(submission_id, time_limit, memory_limit, test_case_id):
try: try:
command = "%s run -t -i --privileged --rm " \ command = "%s run --privileged --rm " \
"--link mysql " \ "--link mysql " \
"-v %s:/var/judger/test_case/ " \ "-v %s:/var/judger/test_case/ " \
"-v %s:/var/judger/code/ " \ "-v %s:/var/judger/code/ " \

View File

@@ -25,7 +25,6 @@ from contest_submission.views import contest_problem_my_submissions_list_page
urlpatterns = [ urlpatterns = [
url(r'^install/$', "install.views.install"),
url("^$", "account.views.page_jump", name="page_jump_api"), url("^$", "account.views.page_jump", name="page_jump_api"),
url(r'^docs/', include('rest_framework_swagger.urls')), url(r'^docs/', include('rest_framework_swagger.urls')),
url(r'^admin/$', TemplateView.as_view(template_name="admin/admin.html"), name="admin_spa_page"), url(r'^admin/$', TemplateView.as_view(template_name="admin/admin.html"), name="admin_spa_page"),

View File

@@ -24,6 +24,7 @@ import logging
logger = logging.getLogger("app_info") logger = logging.getLogger("app_info")
def problem_page(request, problem_id): def problem_page(request, problem_id):
try: try:
problem = Problem.objects.get(id=problem_id, visible=True) problem = Problem.objects.get(id=problem_id, visible=True)

View File

@@ -41,4 +41,5 @@ label {
pre { pre {
font-family: "Consolas", "Bitstream Vera Sans Mono", "Courier New", Courier, monospace; font-family: "Consolas", "Bitstream Vera Sans Mono", "Courier New", Courier, monospace;
background-color: white;
} }

View File

@@ -1,5 +1,6 @@
# coding=utf-8 # coding=utf-8
import json import json
import logging
import redis import redis
from django.shortcuts import render from django.shortcuts import render
@@ -21,6 +22,9 @@ from .models import Submission
from .serializers import CreateSubmissionSerializer, SubmissionSerializer, SubmissionhareSerializer from .serializers import CreateSubmissionSerializer, SubmissionSerializer, SubmissionhareSerializer
logger = logging.getLogger("app_info")
class SubmissionAPIView(APIView): class SubmissionAPIView(APIView):
@login_required @login_required
def post(self, request): def post(self, request):
@@ -44,7 +48,8 @@ class SubmissionAPIView(APIView):
try: try:
judge.delay(submission.id, problem.time_limit, problem.memory_limit, problem.test_case_id) judge.delay(submission.id, problem.time_limit, problem.memory_limit, problem.test_case_id)
except Exception: except Exception as e:
logger.error(e)
return error_response(u"提交判题任务失败") return error_response(u"提交判题任务失败")
# 修改用户解题状态 # 修改用户解题状态
problems_status = json.loads(request.user.problems_status) problems_status = json.loads(request.user.problems_status)