-from utils.redis.rkeys import (GROUP_LAST_PHOTO_PK, GROUP_PHOTO_WATCHER_SET, GROUP_USERS_APPLYING_SET,

-                               GROUP_USERS_DELETED_SET, GROUP_USERS_PASSED_SET, GROUP_USERS_QUIT_SET,

-                               GROUP_USERS_REFUSED_SET, LENSMAN_PHOTO_HAGGLE_TIMES, LENSMAN_PHOTO_PRICE)

-def group_join_api(request):

-    """ 申请加群 """

-    group_id = request.POST.get('group_id', '')

-    user_id = request.POST.get('user_id', '')

-    nickname = request.POST.get('nickname', '')

-

-    # 用户校验

-    try:

-        user = UserInfo.objects.get(user_id=user_id)

-    except UserInfo.DoesNotExist:

-        return response(UserStatusCode.USER_NOT_FOUND)

-

-    # 群组校验

-    try:

-        group = GroupInfo.objects.get(group_id=group_id)

-    except GroupInfo.DoesNotExist:

-        return response(GroupStatusCode.GROUP_NOT_FOUND)

-

-    # 群组锁定校验

-    if group.group_lock:

-        return response(GroupStatusCode.GROUP_HAS_LOCKED)

-

-    # 群组用户记录创建，若记录不存在，则创建，若记录已存在，则更新

-    group_user, created = GroupUserInfo.objects.get_or_create(

-        group_id=group_id,

-        user_id=user_id,

-    )

-    if group_user.user_status != GroupUserInfo.PASSED:

-        group_user.current_id = -1 if group.group_from == GroupInfo.SESSION_GROUP else int(r.get(GROUP_LAST_PHOTO_PK % group_id) or -1)

-        group_user.nickname = nickname or user.final_nickname

-        group_user.avatar = user.avatar

-        # group_user.admin = False  # Admin Field Default False, Should Not Assign

-        group_user.user_status = GroupUserInfo.PASSED

-        group_user.passed_at = tc.utc_datetime()

-        group_user.save()

-

-    # Redis 群组用户数据缓存

-    set_group_users_info(group)

-

-    # Redis 群组通过集合缓存

-    r.srem(GROUP_USERS_REFUSED_SET % group_id, user_id)

-    r.srem(GROUP_USERS_DELETED_SET % group_id, user_id)

-    r.srem(GROUP_USERS_QUIT_SET % group_id, user_id)

-    r.sadd(GROUP_USERS_PASSED_SET % group_id, user_id)

-

-    curinfo = get_current_photos(group_id, user_id, group_user.current_id)

-

-    return response(200, 'Apply Success', u'申请成功', {

-        'current_id': curinfo.get('current_id', ''),

-        'photos': curinfo.get('photos', ''),

-        'group_id': group_id,

-        'group': get_group_info(group_id),

-        'user_id': user_id,

-        'users': get_group_users_info(group_id, user_id),

-    })

-

-

-@logit

-def group_remove_api(request):

-    """ 成员移除 """

-    group_id = request.POST.get('group_id', '')

-    admin_id = request.POST.get('admin_id', '')

-    user_id = request.POST.get('user_id', '')

-

-    # 群组校验

-    try:

-        group = GroupInfo.objects.get(group_id=group_id)

-    except GroupInfo.DoesNotExist:

-        return response(GroupStatusCode.GROUP_NOT_FOUND)

-

-    # 权限校验

-    if group.admin_id != admin_id or group.admin_id == user_id:  # 管理员也不允许将自己移除

-        return response(GroupStatusCode.NO_REMOVE_PERMISSION)

-

-    # 群组用户校验

-    try:

-        group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)

-    except GroupUserInfo.DoesNotExist:

-        return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)

-

-    # 群组用户移除

-    group_user.user_status = GroupUserInfo.DELETED

-    group_user.deleted_at = tc.utc_datetime()

-    group_user.save()

-

-    # Redis 群组数据缓存更新

-    group_users = set_group_users_info(group)

-

-    # Redis 群组删除集合缓存

-    r.srem(GROUP_USERS_PASSED_SET % group_id, user_id)

-    r.sadd(GROUP_USERS_DELETED_SET % group_id, user_id)

-

-    return response(200, 'Remove Success', u'用户移除成功', {

-        'group_id': group_id,

-        'users': group_users,

-    })

-

-

-@logit

-def group_quit_api(request):

-    """ 成员退出 """

-    group_id = request.POST.get('group_id', '')

-    user_id = request.POST.get('user_id', '')

-

-    # 群组校验

-    try:

-        group = GroupInfo.objects.get(group_id=group_id)

-    except GroupInfo.DoesNotExist:

-        return response(GroupStatusCode.GROUP_NOT_FOUND)

-

-    # 权限校验

-    if group.admin_id == user_id:  # 管理员也不允许自己退出

-        return response(GroupStatusCode.NO_QUIT_PERMISSION)

-

-    # 群组用户校验

-    try:

-        group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)

-    except GroupUserInfo.DoesNotExist:

-        return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)

-

-    # 群组用户移除

-    group_user.user_status = GroupUserInfo.QUIT

-    group_user.quit_at = tc.utc_datetime()

-    group_user.save()

-

-    # Redis 群组数据缓存更新

-    group_users = set_group_users_info(group)

-

-    # Redis 群组删除集合缓存

-    r.srem(GROUP_USERS_PASSED_SET % group_id, user_id)

-    r.sadd(GROUP_USERS_QUIT_SET % group_id, user_id)

-

-    return response(200, 'Quit Success', u'用户退出成功', {

-        'group_id': group_id,

-        'users': group_users,

-    })

-

-

-@logit

-def group_pass_api(request):

-    """ 申请通过 """

-    group_id = request.POST.get('group_id', '')

-    admin_id = request.POST.get('admin_id', '')

-    user_id = request.POST.get('user_id', '')

-

-    # 群组校验

-    try:

-        group = GroupInfo.objects.get(group_id=group_id)

-    except GroupInfo.DoesNotExist:

-        return response(GroupStatusCode.GROUP_NOT_FOUND)

-

-    # 权限校验

-    if group.admin_id != admin_id:

-        return response(GroupStatusCode.NO_PASS_PERMISSION)

-

-    # 群组用户校验

-    try:

-        group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.APPLYING)

-    except GroupUserInfo.DoesNotExist:

-        return response(GroupStatusCode.JOIN_REQUEST_NOT_FOUND)

-

-    # 群组用户通过

-    group_user.user_status = GroupUserInfo.PASSED

-    group_user.passed_at = tc.utc_datetime()

-    group_user.save()

-

-    # Redis 群组数据缓存更新

-    group_users = set_group_users_info(group)

-

-    # Redis 群组通过集合缓存

-    r.srem(GROUP_USERS_APPLYING_SET % group_id, user_id)

-    r.sadd(GROUP_USERS_PASSED_SET % group_id, user_id)

-

-    return response(200, 'Pass Success', u'申请通过成功', {

-        'group_id': group_id,

-        'users': group_users,

-    })

-

-

-@logit

-def group_refuse_api(request):

-    """ 申请拒绝 """

-    group_id = request.POST.get('group_id', '')

-    admin_id = request.POST.get('admin_id', '')

-    user_id = request.POST.get('user_id', '')

-

-    # 群组校验

-    try:

-        group = GroupInfo.objects.get(group_id=group_id)

-    except GroupInfo.DoesNotExist:

-        return response(GroupStatusCode.GROUP_NOT_FOUND)

-

-    # 权限校验

-    if group.admin_id != admin_id:

-        return response(GroupStatusCode.NO_REFUSE_PERMISSION)

-

-    # 群组用户校验

-    try:

-        group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.APPLYING)

-    except GroupUserInfo.DoesNotExist:

-        return response(GroupStatusCode.JOIN_REQUEST_NOT_FOUND)

-

-    # 群组用户拒绝

-    group_user.user_status = GroupUserInfo.REFUSED

-    group_user.refused_at = tc.utc_datetime()

-    group_user.save()

-

-    # Redis 群组数据缓存更新

-    group_users = set_group_users_info(group)

-

-    # Redis 群组拒绝集合缓存

-    r.srem(GROUP_USERS_APPLYING_SET % group_id, user_id)

-    r.sadd(GROUP_USERS_REFUSED_SET % group_id, user_id)

-

-    return response(200, 'Refuse Success', u'申请拒绝成功', {

-        'group_id': group_id,

-        'users': group_users,

-    })

-

-

-@logit