|
|
@@ -11,15 +11,16 @@ from utils.redis.rkeys import GROUP_LAST_PHOTO_PK
|
11
|
11
|
r = settings.REDIS_CACHE
|
12
|
12
|
|
13
|
13
|
|
14
|
|
-def retrieve_redis_data():
|
15
|
|
- # 群组/群组照片相关
|
|
14
|
+def retrieve_last_pk():
|
|
15
|
+ """ 群组最后一张照片PK """
|
16
|
16
|
groups = GroupInfo.objects.filter(status=True)
|
17
|
17
|
for group in groups:
|
18
|
18
|
group_photo = GroupPhotoInfo.objects.filter(group_id=group.group_id).last()
|
19
|
|
- # 设置群组最后一张照片PK
|
20
|
19
|
r.set(GROUP_LAST_PHOTO_PK % group.group_id, group_photo and group_photo.pk or -1)
|
21
|
20
|
|
22
|
|
- # 群组用户相关
|
|
21
|
+
|
|
22
|
+def retrieve_group_user_status():
|
|
23
|
+ """ 群组用户状态 """
|
23
|
24
|
group_users = GroupUserInfo.objects.filter(status=True)
|
24
|
25
|
for group_user in group_users:
|
25
|
26
|
group_id, user_id = group_user.group_id, group_user.user_id
|
|
|
@@ -31,3 +32,8 @@ def retrieve_redis_data():
|
31
|
32
|
r.sadd(GROUP_USERS_APPLYING_SET % group_id, user_id)
|
32
|
33
|
elif group_user.user_status == GroupUserInfo.REFUSED:
|
33
|
34
|
r.sadd(GROUP_USERS_REFUSED_SET % group_id, user_id)
|
|
35
|
+
|
|
36
|
+
|
|
37
|
+def retrieve_redis_data():
|
|
38
|
+ retrieve_last_pk()
|
|
39
|
+ retrieve_group_user_status()
|