# coding=utf-8
import datetime
import pymongo
from bson.objectid import ObjectId

from django.shortcuts import render

from rest_framework.views import APIView

from django.conf import settings

from judger.result import result
from judger_controller.tasks import judge
from account.decorators import login_required
from problem.models import Problem
from utils.shortcuts import serializer_invalid_response, error_response, success_response
from .serializers import  CreateSubmissionSerializer


def _create_mondodb_connection():
        mongodb_setting = settings.DATABASES["mongodb"]
        connection = pymongo.MongoClient(host=mongodb_setting["HOST"], port=mongodb_setting["PORT"])
        return connection["oj"]["oj_submission"]


class SubmissionnAPIView(APIView):
    @login_required
    def post(self, request):
        """
        提交代码
        ---
        request_serializer: CreateSubmissionSerializer
        """
        serializer = CreateSubmissionSerializer(data=request.data)
        if serializer.is_valid():
            data = serializer.data
            # data["language"] = int(data["language"])
            data["user_id"] = request.user.id
            data["result"] = result["waiting"]
            data["create_time"] = datetime.datetime.now()
            try:
                problem = Problem.objects.get(id=data["problem_id"])
            except Problem.DoesNotExist:
                return error_response(u"题目不存在")
            mongodb_setting = settings.DATABASES["mongodb"]
            connection = pymongo.MongoClient(host=mongodb_setting["HOST"], port=mongodb_setting["PORT"])
            collection = connection["oj"]["oj_submission"]
            submission_id = str(collection.insert_one(data).inserted_id)
            judge.delay(submission_id, problem.time_limit, problem.memory_limit, problem.test_case_id)
            return success_response({"submission_id": submission_id})
        else:
            return serializer_invalid_response(serializer)

    @login_required
    def get(self, request):
        submission_id = request.GET.get("submission_id", None)
        if not submission_id:
            return error_response(u"参数错误")
        submission = _create_mondodb_connection().find_one({"_id": ObjectId(submission_id), "user_id": request.user.id})
        if submission:
            response_data = {"result": submission["result"]}
            if submission["result"] == 0:
                response_data["accepted_answer_info"] = submission["accepted_answer_info"]
            return success_response(response_data)
        else:
            return error_response(u"提交不存在")


def problem_my_submissions_list_page(request, problem_id):
    collection = _create_mondodb_connection()
    submissions = collection.find({"problem_id": int(problem_id), "user_id": request.user.id},
                                  projection=["result", "accepted_answer_info", "create_time"],
                                  sort=[["create_time", -pymongo.ASCENDING]])
    return render(request, "oj/problem/my_solutions_list.html", {"submissions": submissions})


def my_submission(request, solution_id):
    return render(request, "oj/problem/my_solution.html")