td class="lines-code">
- 'photos': curinfo.get('photos', ''),
|
230
|
|
- 'group_id': group_id,
|
|
231
|
|
- 'group': get_group_info(group_id),
|
|
232
|
|
- 'user_id': user_id,
|
|
233
|
|
- 'users': get_group_users_info(group_id, user_id),
|
|
234
|
|
- })
|
|
235
|
|
-
|
|
236
|
|
-
|
|
237
|
|
-@logit
|
|
238
|
179
|
def group_lock_api(request):
|
|
239
|
180
|
""" 群组锁定 """
|
|
240
|
181
|
group_id = request.POST.get('group_id', '')
|
|
|
|
@@ -287,169 +228,6 @@ def group_unlock_api(request):
|
|
287
|
228
|
|
|
288
|
229
|
|
|
289
|
230
|
@logit
|
|
290
|
|
-def group_remove_api(request):
|
|
291
|
|
- """ 成员移除 """
|
|
292
|
|
- group_id = request.POST.get('group_id', '')
|
|
293
|
|
- admin_id = request.POST.get('admin_id', '')
|
|
294
|
|
- user_id = request.POST.get('user_id', '')
|
|
295
|
|
-
|
|
296
|
|
- # 群组校验
|
|
297
|
|
- try:
|
|
298
|
|
- group = GroupInfo.objects.get(group_id=group_id)
|
|
299
|
|
- except GroupInfo.DoesNotExist:
|
|
300
|
|
- return response(GroupStatusCode.GROUP_NOT_FOUND)
|
|
301
|
|
-
|
|
302
|
|
- # 权限校验
|
|
303
|
|
- if group.admin_id != admin_id or group.admin_id == user_id: # 管理员也不允许将自己移除
|
|
304
|
|
- return response(GroupStatusCode.NO_REMOVE_PERMISSION)
|
|
305
|
|
-
|
|
306
|
|
- # 群组用户校验
|
|
307
|
|
- try:
|
|
308
|
|
- group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)
|
|
309
|
|
- except GroupUserInfo.DoesNotExist:
|
|
310
|
|
- return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)
|
|
311
|
|
-
|
|
312
|
|
- # 群组用户移除
|
|
313
|
|
- group_user.user_status = GroupUserInfo.DELETED
|
|
314
|
|
- group_user.deleted_at = tc.utc_datetime()
|
|
315
|
|
- group_user.save()
|
|
316
|
|
-
|
|
317
|
|
- # Redis 群组数据缓存更新
|
|
318
|
|
- group_users = set_group_users_info(group)
|
|
319
|
|
-
|
|
320
|
|
- # Redis 群组删除集合缓存
|
|
321
|
|
- r.srem(GROUP_USERS_PASSED_SET % group_id, user_id)
|
|
322
|
|
- r.sadd(GROUP_USERS_DELETED_SET % group_id, user_id)
|
|
323
|
|
-
|
|
324
|
|
- return response(200, 'Remove Success', u'用户移除成功', {
|
|
325
|
|
- 'group_id': group_id,
|
|
326
|
|
- 'users': group_users,
|
|
327
|
|
- })
|
|
328
|
|
-
|
|
329
|
|
-
|
|
330
|
|
-@logit
|
|
331
|
|
-def group_quit_api(request):
|
|
332
|
|
- """ 成员退出 """
|
|
333
|
|
- group_id = request.POST.get('group_id', '')
|
|
334
|
|
- user_id = request.POST.get('user_id', '')
|
|
335
|
|
-
|
|
336
|
|
- # 群组校验
|
|
337
|
|
- try:
|
|
338
|
|
- group = GroupInfo.objects.get(group_id=group_id)
|
|
339
|
|
- except GroupInfo.DoesNotExist:
|
|
340
|
|
- return response(GroupStatusCode.GROUP_NOT_FOUND)
|
|
341
|
|
-
|
|
342
|
|
- # 权限校验
|
|
343
|
|
- if group.admin_id == user_id: # 管理员也不允许自己退出
|
|
344
|
|
- return response(GroupStatusCode.NO_QUIT_PERMISSION)
|
|
345
|
|
-
|
|
346
|
|
- # 群组用户校验
|
|
347
|
|
- try:
|
|
348
|
|
- group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.PASSED)
|
|
349
|
|
- except GroupUserInfo.DoesNotExist:
|
|
350
|
|
- return response(GroupUserStatusCode.GROUP_USER_NOT_FOUND)
|
|
351
|
|
-
|
|
352
|
|
- # 群组用户移除
|
|
353
|
|
- group_user.user_status = GroupUserInfo.QUIT
|
|
354
|
|
- group_user.quit_at = tc.utc_datetime()
|
|
355
|
|
- group_user.save()
|
|
356
|
|
-
|
|
357
|
|
- # Redis 群组数据缓存更新
|
|
358
|
|
- group_users = set_group_users_info(group)
|
|
359
|
|
-
|
|
360
|
|
- # Redis 群组删除集合缓存
|
|
361
|
|
- r.srem(GROUP_USERS_PASSED_SET % group_id, user_id)
|
|
362
|
|
- r.sadd(GROUP_USERS_QUIT_SET % group_id, user_id)
|
|
363
|
|
-
|
|
364
|
|
- return response(200, 'Quit Success', u'用户退出成功', {
|
|
365
|
|
- 'group_id': group_id,
|
|
366
|
|
- 'users': group_users,
|
|
367
|
|
- })
|
|
368
|
|
-
|
|
369
|
|
-
|
|
370
|
|
-@logit
|
|
371
|
|
-def group_pass_api(request):
|
|
372
|
|
- """ 申请通过 """
|
|
373
|
|
- group_id = request.POST.get('group_id', '')
|
|
374
|
|
- admin_id = request.POST.get('admin_id', '')
|
|
375
|
|
- user_id = request.POST.get('user_id', '')
|
|
376
|
|
-
|
|
377
|
|
- # 群组校验
|
|
378
|
|
- try:
|
|
379
|
|
- group = GroupInfo.objects.get(group_id=group_id)
|
|
380
|
|
- except GroupInfo.DoesNotExist:
|
|
381
|
|
- return response(GroupStatusCode.GROUP_NOT_FOUND)
|
|
382
|
|
-
|
|
383
|
|
- # 权限校验
|
|
384
|
|
- if group.admin_id != admin_id:
|
|
385
|
|
- return response(GroupStatusCode.NO_PASS_PERMISSION)
|
|
386
|
|
-
|
|
387
|
|
- # 群组用户校验
|
|
388
|
|
- try:
|
|
389
|
|
- group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.APPLYING)
|
|
390
|
|
- except GroupUserInfo.DoesNotExist:
|
|
391
|
|
- return response(GroupStatusCode.JOIN_REQUEST_NOT_FOUND)
|
|
392
|
|
-
|
|
393
|
|
- # 群组用户通过
|
|
394
|
|
- group_user.user_status = GroupUserInfo.PASSED
|
|
395
|
|
- group_user.passed_at = tc.utc_datetime()
|
|
396
|
|
- group_user.save()
|
|
397
|
|
-
|
|
398
|
|
- # Redis 群组数据缓存更新
|
|
399
|
|
- group_users = set_group_users_info(group)
|
|
400
|
|
-
|
|
401
|
|
- # Redis 群组通过集合缓存
|
|
402
|
|
- r.srem(GROUP_USERS_APPLYING_SET % group_id, user_id)
|
|
403
|
|
- r.sadd(GROUP_USERS_PASSED_SET % group_id, user_id)
|
|
404
|
|
-
|
|
405
|
|
- return response(200, 'Pass Success', u'申请通过成功', {
|
|
406
|
|
- 'group_id': group_id,
|
|
407
|
|
- 'users': group_users,
|
|
408
|
|
- })
|
|
409
|
|
-
|
|
410
|
|
-
|
|
411
|
|
-@logit
|
|
412
|
|
-def group_refuse_api(request):
|
|
413
|
|
- """ 申请拒绝 """
|
|
414
|
|
- group_id = request.POST.get('group_id', '')
|
|
415
|
|
- admin_id = request.POST.get('admin_id', '')
|
|
416
|
|
- user_id = request.POST.get('user_id', '')
|
|
417
|
|
-
|
|
418
|
|
- # 群组校验
|
|
419
|
|
- try:
|
|
420
|
|
- group = GroupInfo.objects.get(group_id=group_id)
|
|
421
|
|
- except GroupInfo.DoesNotExist:
|
|
422
|
|
- return response(GroupStatusCode.GROUP_NOT_FOUND)
|
|
423
|
|
-
|
|
424
|
|
- # 权限校验
|
|
425
|
|
- if group.admin_id != admin_id:
|
|
426
|
|
- return response(GroupStatusCode.NO_REFUSE_PERMISSION)
|
|
427
|
|
-
|
|
428
|
|
- # 群组用户校验
|
|
429
|
|
- try:
|
|
430
|
|
- group_user = GroupUserInfo.objects.get(group_id=group_id, user_id=user_id, user_status=GroupUserInfo.APPLYING)
|
|
431
|
|
- except GroupUserInfo.DoesNotExist:
|
|
432
|
|
- return response(GroupStatusCode.JOIN_REQUEST_NOT_FOUND)
|
|
433
|
|
-
|
|
434
|
|
- # 群组用户拒绝
|
|
435
|
|
- group_user.user_status = GroupUserInfo.REFUSED
|
|
436
|
|
- group_user.refused_at = tc.utc_datetime()
|
|
437
|
|
- group_user.save()
|
|
438
|
|
-
|
|
439
|
|
- # Redis 群组数据缓存更新
|
|
440
|
|
- group_users = set_group_users_info(group)
|
|
441
|
|
-
|
|
442
|
|
- # Redis 群组拒绝集合缓存
|
|
443
|
|
- r.srem(GROUP_USERS_APPLYING_SET % group_id, user_id)
|
|
444
|
|
- r.sadd(GROUP_USERS_REFUSED_SET % group_id, user_id)
|
|
445
|
|
-
|
|
446
|
|
- return response(200, 'Refuse Success', u'申请拒绝成功', {
|
|
447
|
|
- 'group_id': group_id,
|
|
448
|
|
- 'users': group_users,
|
|
449
|
|
- })
|
|
450
|
|
-
|
|
451
|
|
-
|
|
452
|
|
-@logit
|
|
453
|
231
|
def group_data_api(request):
|
|
454
|
232
|
""" 群组数据, 评论数, 点赞数 """
|
|
455
|
233
|
group_id = request.POST.get('group_id', '')
|