2015-08-09 04:57:59 +00:00
|
|
|
|
# coding=utf-8
|
|
|
|
|
from django.shortcuts import render
|
2015-08-11 06:47:19 +00:00
|
|
|
|
from django.db import IntegrityError
|
2015-08-09 04:57:59 +00:00
|
|
|
|
|
|
|
|
|
from rest_framework.views import APIView
|
|
|
|
|
|
2015-08-29 10:21:03 +00:00
|
|
|
|
from utils.shortcuts import error_response, serializer_invalid_response, success_response, paginate, error_page
|
2015-08-09 04:57:59 +00:00
|
|
|
|
from account.models import REGULAR_USER, ADMIN, SUPER_ADMIN
|
2015-08-09 11:06:55 +00:00
|
|
|
|
from account.decorators import login_required
|
2015-08-09 04:57:59 +00:00
|
|
|
|
|
2015-08-09 11:06:55 +00:00
|
|
|
|
from .models import Group, JoinGroupRequest, UserGroupRelation
|
2015-08-09 04:57:59 +00:00
|
|
|
|
from .serializers import (CreateGroupSerializer, EditGroupSerializer,
|
2015-08-11 11:14:41 +00:00
|
|
|
|
CreateJoinGroupRequestSerializer, GroupSerializer,
|
|
|
|
|
GroupMemberSerializer, EditGroupMemberSerializer,
|
|
|
|
|
JoinGroupRequestSerializer, PutJoinGroupRequestSerializer)
|
2015-08-29 10:21:03 +00:00
|
|
|
|
from announcement.models import Announcement
|
|
|
|
|
from django.core.paginator import Paginator
|
|
|
|
|
from django.db.models import Q
|
2015-08-09 04:57:59 +00:00
|
|
|
|
|
|
|
|
|
|
2015-08-09 11:59:25 +00:00
|
|
|
|
class GroupAPIViewBase(object):
|
2015-08-09 14:05:22 +00:00
|
|
|
|
def get_group(self, request, group_id):
|
2015-08-09 11:59:25 +00:00
|
|
|
|
"""
|
|
|
|
|
根据group_id查询指定的小组的信息,结合判断用户权限
|
|
|
|
|
管理员可以查询所有的小组,其他用户查询自己创建的自傲组
|
|
|
|
|
"""
|
|
|
|
|
if request.user.admin_type == SUPER_ADMIN:
|
2015-08-10 04:24:36 +00:00
|
|
|
|
group = Group.objects.get(id=group_id, visible=True)
|
2015-08-09 11:59:25 +00:00
|
|
|
|
else:
|
2015-08-10 04:24:36 +00:00
|
|
|
|
group = Group.objects.get(id=group_id, visible=True, admin=request.user)
|
2015-08-09 11:59:25 +00:00
|
|
|
|
return group
|
2015-08-29 10:21:03 +00:00
|
|
|
|
|
2015-08-09 14:05:22 +00:00
|
|
|
|
def get_groups(self, request):
|
2015-08-09 11:59:25 +00:00
|
|
|
|
"""
|
|
|
|
|
如果是超级管理员,就返回全部的小组
|
|
|
|
|
如果是管理员,就返回他创建的全部小组
|
|
|
|
|
"""
|
|
|
|
|
if request.user.admin_type == SUPER_ADMIN:
|
|
|
|
|
groups = Group.objects.filter(visible=True)
|
|
|
|
|
else:
|
|
|
|
|
groups = Group.objects.filter(admin=request.user, visible=True)
|
2015-08-10 04:24:36 +00:00
|
|
|
|
return groups
|
2015-08-09 11:59:25 +00:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class GroupAdminAPIView(APIView, GroupAPIViewBase):
|
2015-08-09 04:57:59 +00:00
|
|
|
|
def post(self, request):
|
|
|
|
|
"""
|
|
|
|
|
创建小组的api
|
|
|
|
|
---
|
|
|
|
|
request_serializer: CreateGroupSerializer
|
2015-08-09 12:05:10 +00:00
|
|
|
|
response_serializer: GroupSerializer
|
2015-08-09 04:57:59 +00:00
|
|
|
|
"""
|
|
|
|
|
serializer = CreateGroupSerializer(data=request.data)
|
|
|
|
|
if serializer.is_valid():
|
|
|
|
|
data = serializer.data
|
2015-08-11 06:47:19 +00:00
|
|
|
|
try:
|
|
|
|
|
group = Group.objects.create(name=data["name"],
|
|
|
|
|
description=data["description"],
|
|
|
|
|
join_group_setting=data["join_group_setting"],
|
|
|
|
|
admin=request.user)
|
|
|
|
|
except IntegrityError:
|
|
|
|
|
return error_response(u"小组名已经存在")
|
2015-08-09 04:57:59 +00:00
|
|
|
|
return success_response(GroupSerializer(group).data)
|
|
|
|
|
else:
|
|
|
|
|
return serializer_invalid_response(serializer)
|
|
|
|
|
|
|
|
|
|
def put(self, request):
|
|
|
|
|
"""
|
|
|
|
|
修改小组信息的api
|
|
|
|
|
---
|
|
|
|
|
request_serializer: EditGroupSerializer
|
2015-08-09 12:05:10 +00:00
|
|
|
|
response_serializer: GroupSerializer
|
2015-08-09 04:57:59 +00:00
|
|
|
|
"""
|
|
|
|
|
serializer = EditGroupSerializer(data=request.data)
|
|
|
|
|
if serializer.is_valid():
|
|
|
|
|
data = serializer.data
|
|
|
|
|
try:
|
2015-08-09 11:59:25 +00:00
|
|
|
|
group = self.get_group(request, data["group_id"])
|
2015-08-09 04:57:59 +00:00
|
|
|
|
except Group.DoesNotExist:
|
|
|
|
|
return error_response(u"小组不存在")
|
2015-08-11 06:47:19 +00:00
|
|
|
|
try:
|
|
|
|
|
group.name = data["name"]
|
|
|
|
|
group.description = data["description"]
|
|
|
|
|
group.join_group_setting = data["join_group_setting"]
|
|
|
|
|
group.save()
|
|
|
|
|
except IntegrityError:
|
|
|
|
|
return error_response(u"小组名已经存在")
|
|
|
|
|
|
2015-08-09 04:57:59 +00:00
|
|
|
|
return success_response(GroupSerializer(group).data)
|
|
|
|
|
else:
|
|
|
|
|
return serializer_invalid_response(serializer)
|
|
|
|
|
|
|
|
|
|
def get(self, request):
|
|
|
|
|
"""
|
2015-08-09 12:05:10 +00:00
|
|
|
|
查询小组列表或者单个小组的信息,查询单个小组需要传递group_id参数,否则返回全部
|
2015-08-09 11:06:55 +00:00
|
|
|
|
---
|
|
|
|
|
response_serializer: GroupSerializer
|
2015-08-09 04:57:59 +00:00
|
|
|
|
"""
|
|
|
|
|
group_id = request.GET.get("group_id", None)
|
2015-08-12 14:59:50 +00:00
|
|
|
|
# 根据 id 查询小组信息
|
2015-08-09 04:57:59 +00:00
|
|
|
|
if group_id:
|
|
|
|
|
try:
|
2015-08-09 11:59:25 +00:00
|
|
|
|
group = self.get_group(request, group_id)
|
2015-08-09 04:57:59 +00:00
|
|
|
|
return success_response(GroupSerializer(group).data)
|
|
|
|
|
except Group.DoesNotExist:
|
|
|
|
|
return error_response(u"小组不存在")
|
|
|
|
|
else:
|
2015-08-09 11:59:25 +00:00
|
|
|
|
groups = self.get_groups(request)
|
2015-08-12 14:59:50 +00:00
|
|
|
|
# 搜索小组
|
2015-08-11 11:14:41 +00:00
|
|
|
|
if request.GET.get("keyword", None):
|
|
|
|
|
groups = groups.filter(name__contains=request.GET["keyword"])
|
2015-08-12 14:59:50 +00:00
|
|
|
|
# 只返回我创建的小组 适用于超级管理员
|
|
|
|
|
if request.GET.get("my_group", None):
|
|
|
|
|
groups = groups.filter(admin=request.user)
|
|
|
|
|
# 只返回指定用户的小组 适用于管理员
|
|
|
|
|
elif request.GET.get("admin_id", None):
|
|
|
|
|
groups = groups.filter(admin__id=request.GET["admin_id"])
|
2015-08-09 11:06:55 +00:00
|
|
|
|
return paginate(request, groups, GroupSerializer)
|
2015-08-29 10:21:03 +00:00
|
|
|
|
|
|
|
|
|
|
2015-08-09 11:59:25 +00:00
|
|
|
|
class GroupMemberAdminAPIView(APIView, GroupAPIViewBase):
|
|
|
|
|
def get(self, request):
|
2015-08-09 12:05:10 +00:00
|
|
|
|
"""
|
|
|
|
|
查询小组成员的api,需要传递group_id参数
|
|
|
|
|
---
|
|
|
|
|
response_serializer: GroupMemberSerializer
|
|
|
|
|
"""
|
2015-08-09 11:59:25 +00:00
|
|
|
|
group_id = request.GET.get("group_id", None)
|
|
|
|
|
if not group_id:
|
|
|
|
|
return error_response(u"参数错误")
|
|
|
|
|
try:
|
|
|
|
|
group = self.get_group(request, group_id)
|
|
|
|
|
except Group.DoesNotExist:
|
|
|
|
|
return error_response(u"小组不存在")
|
2015-08-29 10:21:03 +00:00
|
|
|
|
|
2015-08-09 11:59:25 +00:00
|
|
|
|
return paginate(request, UserGroupRelation.objects.filter(group=group), GroupMemberSerializer)
|
2015-08-29 10:21:03 +00:00
|
|
|
|
|
2015-08-09 11:59:25 +00:00
|
|
|
|
def put(self, request):
|
2015-08-09 12:05:10 +00:00
|
|
|
|
"""
|
|
|
|
|
删除小组成员的api接口
|
|
|
|
|
---
|
|
|
|
|
request_serializer: EditGroupMemberSerializer
|
|
|
|
|
"""
|
2015-08-09 11:59:25 +00:00
|
|
|
|
serializer = EditGroupMemberSerializer(data=request.data)
|
|
|
|
|
if serializer.is_valid():
|
|
|
|
|
try:
|
2015-08-10 04:24:36 +00:00
|
|
|
|
group = self.get_group(request, serializer.data["group_id"])
|
2015-08-09 11:59:25 +00:00
|
|
|
|
except Group.DoesNotExist:
|
|
|
|
|
return error_response(u"小组不存在")
|
|
|
|
|
user_id_list = serializer.data["members"]
|
2015-08-10 04:24:36 +00:00
|
|
|
|
UserGroupRelation.objects.filter(group=group, user__id__in=user_id_list).delete()
|
2015-08-09 11:59:25 +00:00
|
|
|
|
return success_response(u"删除成功")
|
|
|
|
|
else:
|
|
|
|
|
return serializer_invalid_response(serializer)
|
|
|
|
|
|
|
|
|
|
|
2015-08-09 11:06:55 +00:00
|
|
|
|
def join_group(user, group):
|
2015-08-11 06:47:19 +00:00
|
|
|
|
try:
|
|
|
|
|
UserGroupRelation.objects.create(user=user, group=group)
|
|
|
|
|
return True
|
|
|
|
|
except IntegrityError:
|
|
|
|
|
return False
|
|
|
|
|
|
2015-08-09 11:06:55 +00:00
|
|
|
|
|
|
|
|
|
class JoinGroupAPIView(APIView):
|
2015-08-11 11:14:41 +00:00
|
|
|
|
# @login_required
|
2015-08-09 11:06:55 +00:00
|
|
|
|
def post(self, request):
|
2015-08-09 12:05:10 +00:00
|
|
|
|
"""
|
|
|
|
|
加入某个小组的api
|
|
|
|
|
---
|
2015-08-11 11:14:41 +00:00
|
|
|
|
request_serializer: CreateJoinGroupRequestSerializer
|
2015-08-09 12:05:10 +00:00
|
|
|
|
"""
|
2015-08-11 11:14:41 +00:00
|
|
|
|
serializer = CreateJoinGroupRequestSerializer(data=request.data)
|
2015-08-09 11:06:55 +00:00
|
|
|
|
if serializer.is_valid():
|
|
|
|
|
data = serializer.data
|
|
|
|
|
try:
|
2015-08-10 04:24:36 +00:00
|
|
|
|
group = Group.objects.get(id=data["group_id"])
|
2015-08-11 06:47:19 +00:00
|
|
|
|
except Group.DoesNotExist:
|
2015-08-09 11:06:55 +00:00
|
|
|
|
return error_response(u"小组不存在")
|
|
|
|
|
if group.join_group_setting == 0:
|
2015-08-11 06:47:19 +00:00
|
|
|
|
if join_group(request.user, group):
|
|
|
|
|
return success_response(u"你已经成功的加入该小组")
|
|
|
|
|
else:
|
|
|
|
|
return error_response(u"你已经是小组成员了")
|
2015-08-09 11:06:55 +00:00
|
|
|
|
elif group.join_group_setting == 1:
|
2015-09-03 12:25:09 +00:00
|
|
|
|
if not data["message"]:
|
|
|
|
|
return error_response(u"message : 该字段是必填项。")
|
2015-08-11 11:14:41 +00:00
|
|
|
|
try:
|
|
|
|
|
JoinGroupRequest.objects.get(user=request.user, group=group, status=False)
|
|
|
|
|
return error_response(u"你已经提交过申请了,请等待审核")
|
|
|
|
|
except JoinGroupRequest.DoesNotExist:
|
|
|
|
|
JoinGroupRequest.objects.create(user=request.user, group=group, message=data["message"])
|
2015-08-09 11:06:55 +00:00
|
|
|
|
return success_response(u"申请提交成功,请等待审核")
|
|
|
|
|
elif group.join_group_setting == 2:
|
|
|
|
|
return error_response(u"该小组不允许任何人加入")
|
|
|
|
|
else:
|
|
|
|
|
return serializer_invalid_response(serializer)
|
2015-08-29 10:21:03 +00:00
|
|
|
|
|
2015-08-09 11:06:55 +00:00
|
|
|
|
def get(self, request):
|
2015-08-09 12:05:10 +00:00
|
|
|
|
"""
|
2015-08-12 07:17:27 +00:00
|
|
|
|
搜索小组的api,需要传递keyword参数
|
2015-08-09 12:05:10 +00:00
|
|
|
|
---
|
|
|
|
|
response_serializer: GroupSerializer
|
|
|
|
|
"""
|
2015-08-09 11:13:48 +00:00
|
|
|
|
keyword = request.GET.get("keyword", None)
|
|
|
|
|
if not keyword:
|
|
|
|
|
return error_response(u"参数错误")
|
2015-08-09 11:59:25 +00:00
|
|
|
|
# 搜索包含这个关键词的 没有解散的 而且允许加入的小组
|
2015-08-09 11:13:48 +00:00
|
|
|
|
groups = Group.objects.filter(name__contains=keyword, visible=True, join_group_setting__lte=2)
|
|
|
|
|
return paginate(request, groups, GroupSerializer)
|
2015-08-11 11:14:41 +00:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class JoinGroupRequestAdminAPIView(APIView, GroupAPIViewBase):
|
|
|
|
|
def get(self, request):
|
|
|
|
|
"""
|
|
|
|
|
返回管理的群的加群请求
|
|
|
|
|
---
|
|
|
|
|
response_serializer: JoinGroupRequestSerializer
|
|
|
|
|
"""
|
|
|
|
|
requests = JoinGroupRequest.objects.filter(group=Group.objects.filter(admin=request.user, visible=True),
|
|
|
|
|
status=False)
|
|
|
|
|
return paginate(request, requests, JoinGroupRequestSerializer)
|
|
|
|
|
|
|
|
|
|
def put(self, request):
|
|
|
|
|
"""
|
|
|
|
|
同意或者拒绝加入小组请求
|
|
|
|
|
---
|
|
|
|
|
request_serializer: PutJoinGroupRequestSerializer
|
|
|
|
|
"""
|
|
|
|
|
serializer = PutJoinGroupRequestSerializer(data=request.data)
|
|
|
|
|
if serializer.is_valid():
|
|
|
|
|
data = serializer.data
|
|
|
|
|
try:
|
2015-08-21 10:16:34 +00:00
|
|
|
|
join_request = JoinGroupRequest.objects.get(id=data["request_id"], group__admin=request.user,
|
|
|
|
|
status=False)
|
2015-08-11 11:14:41 +00:00
|
|
|
|
except JoinGroupRequest.DoesNotExist:
|
2015-08-12 07:17:27 +00:00
|
|
|
|
return error_response(u"请求不存在")
|
2015-08-11 11:14:41 +00:00
|
|
|
|
|
|
|
|
|
join_request.status = True
|
|
|
|
|
join_request.save()
|
|
|
|
|
if data["status"]:
|
|
|
|
|
if join_group(join_request.user, join_request.group):
|
2015-08-31 12:52:18 +00:00
|
|
|
|
join_request.accepted = True
|
|
|
|
|
join_request.save()
|
2015-08-11 11:14:41 +00:00
|
|
|
|
return success_response(u"加入成功")
|
|
|
|
|
else:
|
|
|
|
|
return error_response(u"加入失败,已经在本小组内")
|
|
|
|
|
else:
|
|
|
|
|
return success_response(u"已拒绝")
|
|
|
|
|
|
|
|
|
|
else:
|
|
|
|
|
return serializer_invalid_response(serializer)
|
2015-08-29 10:21:03 +00:00
|
|
|
|
|
2015-08-31 12:52:18 +00:00
|
|
|
|
|
2015-08-29 10:21:03 +00:00
|
|
|
|
@login_required
|
|
|
|
|
def group_list_page(request, page=1):
|
|
|
|
|
groups = Group.objects.filter(visible=True, join_group_setting__lte=2)
|
|
|
|
|
# 搜索的情况
|
|
|
|
|
keyword = request.GET.get("keyword", None)
|
|
|
|
|
if keyword:
|
|
|
|
|
groups = groups.filter(Q(name__contains=keyword) | Q(description__contains=keyword))
|
|
|
|
|
|
|
|
|
|
paginator = Paginator(groups, 20)
|
|
|
|
|
try:
|
|
|
|
|
current_page = paginator.page(int(page))
|
|
|
|
|
except Exception:
|
|
|
|
|
return error_page(request, u"不存在的页码")
|
|
|
|
|
|
|
|
|
|
previous_page = next_page = None
|
|
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
previous_page = current_page.previous_page_number()
|
|
|
|
|
except Exception:
|
|
|
|
|
pass
|
|
|
|
|
next_page = None
|
|
|
|
|
try:
|
|
|
|
|
next_page = current_page.next_page_number()
|
|
|
|
|
except Exception:
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
return render(request, "oj/group/group_list.html", {
|
2015-09-11 15:10:54 +00:00
|
|
|
|
"groups": groups,
|
2015-08-29 10:21:03 +00:00
|
|
|
|
"contests": current_page, "page": int(page),
|
|
|
|
|
"previous_page": previous_page, "next_page": next_page,
|
2015-09-11 15:10:54 +00:00
|
|
|
|
"keyword": keyword
|
2015-08-29 10:21:03 +00:00
|
|
|
|
})
|
2015-08-31 12:52:18 +00:00
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@login_required
|
|
|
|
|
def group_page(request, group_id):
|
|
|
|
|
try:
|
|
|
|
|
group = Group.objects.get(id=group_id, visible=True)
|
|
|
|
|
except Group.DoesNotExist:
|
|
|
|
|
return error_page(request, u"小组不存在")
|
|
|
|
|
return render(request, "oj/group/group.html", {"group": group})
|
|
|
|
|
|
2015-09-03 12:25:09 +00:00
|
|
|
|
|
2015-08-31 12:52:18 +00:00
|
|
|
|
@login_required
|
|
|
|
|
def application_list_page(request, group_id):
|
|
|
|
|
try:
|
|
|
|
|
group = Group.objects.get(id=group_id, visible=True)
|
|
|
|
|
except Group.DoesNotExist:
|
|
|
|
|
return error_page(request, u"小组不存在")
|
|
|
|
|
applications = JoinGroupRequest.objects.filter(user=request.user, group=group)
|
|
|
|
|
return render(request, "oj/group/my_application_list.html",
|
|
|
|
|
{"group": group, "applications": applications})
|
|
|
|
|
|
2015-09-03 12:25:09 +00:00
|
|
|
|
|
2015-08-31 12:52:18 +00:00
|
|
|
|
@login_required
|
|
|
|
|
def application_page(request, request_id):
|
|
|
|
|
try:
|
|
|
|
|
application = JoinGroupRequest.objects.get(user=request.user, pk=request_id)
|
|
|
|
|
except JoinGroupRequest.DoesNotExist:
|
|
|
|
|
return error_page(request, u"申请不存在")
|
|
|
|
|
return render(request, "oj/group/my_application.html",
|
2015-09-03 12:25:09 +00:00
|
|
|
|
{"application": application})
|