s-num lines-num-new">
- read_messages = SystemMessageReadInfo.objects.filter(user_id=user_id, status=True)
|
|
11
|
|
- read_message_ids = [msg.msg_id for msg in read_messages]
|
|
12
|
|
- r.setexjson(SYSTEM_MESSAGE_READ_INFO % user_id, r.REDIS_EXPIRED_ONE_MONTH, read_message_ids)
|
|
13
|
|
- return read_message_ids
|
|
14
|
|
-
|
|
15
|
|
-
|
|
16
|
|
-def get_system_message_read_info(user_id):
|
|
17
|
|
- """ 获取系统消息读取信息 """
|
|
18
|
|
- return r.getjson(SYSTEM_MESSAGE_READ_INFO % user_id, default='[]') or set_system_message_read_info(user_id)
|
|
19
|
|
-
|
|
20
|
|
-
|
|
21
|
|
-def set_system_message_delete_info(user_id):
|
|
22
|
|
- """ 设置系统消息删除信息 """
|
|
23
|
|
- from message.models import SystemMessageDeleteInfo
|
|
24
|
|
- deleted_messages = SystemMessageDeleteInfo.objects.filter(user_id=user_id, status=True)
|
|
25
|
|
- deleted_message_ids = [msg.msg_id for msg in deleted_messages]
|
|
26
|
|
- r.setexjson(SYSTEM_MESSAGE_DELETED_INFO % user_id, r.REDIS_EXPIRED_ONE_MONTH, deleted_message_ids)
|
|
27
|
|
- return deleted_message_ids
|
|
28
|
|
-
|
|
29
|
|
-
|
|
30
|
|
-def get_system_message_delete_info(user_id):
|
|
31
|
|
- """ 获取系统消息删除信息 """
|
|
32
|
|
- return r.getjson(SYSTEM_MESSAGE_DELETED_INFO % user_id, default='[]') or set_system_message_delete_info(user_id)
|
|
|
|
@@ -1,20 +0,0 @@
|
|
1
|
|
-# -*- coding: utf-8 -*-
|
|
2
|
|
-
|
|
3
|
|
-from utils.redis.connect import r
|
|
4
|
|
-from utils.redis.rkeys import BOX_PROGRAM_VERSION_INFO
|
|
5
|
|
-
|
|
6
|
|
-
|
|
7
|
|
-def set_box_program_version():
|
|
8
|
|
- """ 设置 BOX 程序版本信息 """
|
|
9
|
|
- from operation.models import BoxProgramVersionInfo
|
|
10
|
|
- try:
|
|
11
|
|
- bpverion = BoxProgramVersionInfo.objects.filter(status=True)[0].data
|
|
12
|
|
- except IndexError:
|
|
13
|
|
- bpverion = {}
|
|
14
|
|
- r.setjson(BOX_PROGRAM_VERSION_INFO, bpverion)
|
|
15
|
|
- return bpverion
|
|
16
|
|
-
|
|
17
|
|
-
|
|
18
|
|
-def get_box_program_version():
|
|
19
|
|
- """ 获取 BOX 程序版本信息 """
|
|
20
|
|
- return r.getjson(BOX_PROGRAM_VERSION_INFO) or set_box_program_version()
|
|
|
|
@@ -1,27 +0,0 @@
|
|
1
|
|
-# -*- coding: utf-8 -*-
|
|
2
|
|
-
|
|
3
|
|
-from django.core.serializers.json import DjangoJSONEncoder
|
|
4
|
|
-
|
|
5
|
|
-from utils.redis.connect import r
|
|
6
|
|
-from utils.redis.rkeys import LENSMAN_PHOTO_ORDER_RECORD
|
|
7
|
|
-
|
|
8
|
|
-
|
|
9
|
|
-def set_lensman_order_record(porder):
|
|
10
|
|
- """ 设置摄影师照片购买记录 """
|
|
11
|
|
- r.setexjson(LENSMAN_PHOTO_ORDER_RECORD % (porder.photo_id, porder.user_id), r.REDIS_EXPIRED_ONE_MONTH, porder.porder_info, cls=DjangoJSONEncoder)
|
|
12
|
|
- return porder.porder_info
|
|
13
|
|
-
|
|
14
|
|
-
|
|
15
|
|
-def set_lensman_order_record_by_id(photo_id, user_id):
|
|
16
|
|
- """ 设置摄影师照片购买记录 """
|
|
17
|
|
- from group.models import GroupPhotoOrderInfo
|
|
18
|
|
- try:
|
|
19
|
|
- porder = GroupPhotoOrderInfo.objects.get(photo_id=photo_id, user_id=user_id)
|
|
20
|
|
- except GroupPhotoOrderInfo.DoesNotExist:
|
|
21
|
|
- return {}
|
|
22
|
|
- return set_lensman_order_record(porder)
|
|
23
|
|
-
|
|
24
|
|
-
|
|
25
|
|
-def get_lensman_order_record(photo_id, user_id):
|
|
26
|
|
- """ 获取摄影师照片购买记录 """
|
|
27
|
|
- return r.getjson(LENSMAN_PHOTO_ORDER_RECORD % (photo_id, user_id)) or set_lensman_order_record_by_id(photo_id, user_id)
|
|
|
|
@@ -1,27 +0,0 @@
|
|
1
|
|
-# -*- coding: utf-8 -*-
|
|
2
|
|
-
|
|
3
|
|
-from utils.redis.connect import r
|
|
4
|
|
-from utils.redis.rkeys import LENSMAN_PHOTO_PRICE_FIXED
|
|
5
|
|
-
|
|
6
|
|
-
|
|
7
|
|
-def set_lensman_price_fixed(user_id):
|
|
8
|
|
- """ 设置摄影师价格设定 """
|
|
9
|
|
- from account.models import LensmanInfo
|
|
10
|
|
- try:
|
|
11
|
|
- lensman = LensmanInfo.objects.get(lensman_id=user_id)
|
|
12
|
|
- except LensmanInfo.DoesNotExist:
|
|
13
|
|
- lensman = None
|
|
14
|
|
-
|
|
15
|
|
- price_fixed = {
|
|
16
|
|
- 'nomark': (lensman and lensman.nomark) or 299,
|
|
17
|
|
- 'origin': (lensman and lensman.origin) or 999,
|
|
18
|
|
- }
|
|
19
|
|
-
|
|
20
|
|
- r.setjson(LENSMAN_PHOTO_PRICE_FIXED % user_id, price_fixed)
|
|
21
|
|
-
|
|
22
|
|
- return price_fixed
|
|
23
|
|
-
|
|
24
|
|
-
|
|
25
|
|
-def get_lensman_price_fixed(user_id):
|
|
26
|
|
- """ 获取摄影师价格设定 """
|
|
27
|
|
- return r.getjson(LENSMAN_PHOTO_PRICE_FIXED % user_id) or set_lensman_price_fixed(user_id)
|
|
|
|
@@ -1,19 +0,0 @@
|
|
1
|
|
-# -*- coding: utf-8 -*-
|
|
2
|
|
-
|
|
3
|
|
-from utils.redis.connect import r
|
|
4
|
|
-from utils.redis.rkeys import TOUR_GUIDE_GROUP_USER_OWN
|
|
5
|
|
-
|
|
6
|
|
-
|
|
7
|
|
-def set_tour_guide_own_group(user_id, group_id):
|
|
8
|
|
- """ 设置导游拥有的旅行团 """
|
|
9
|
|
- r.set(TOUR_GUIDE_GROUP_USER_OWN % user_id, group_id)
|
|
10
|
|
-
|
|
11
|
|
-
|
|
12
|
|
-def get_tour_guide_own_group(user_id):
|
|
13
|
|
- """ 获取导游拥有的旅行团 """
|
|
14
|
|
- return r.get(TOUR_GUIDE_GROUP_USER_OWN % user_id)
|
|
15
|
|
-
|
|
16
|
|
-
|
|
17
|
|
-def del_tour_guide_own_group(user_id):
|
|
18
|
|
- """ 删除导游拥有的旅行团 """
|
|
19
|
|
- return r.delete(TOUR_GUIDE_GROUP_USER_OWN % user_id)
|
|
|
|
@@ -1,14 +0,0 @@
|
|
1
|
|
-# -*- coding: utf-8 -*-
|
|
2
|
|
-
|
|
3
|
|
-from utils.redis.connect import r
|
|
4
|
|
-from utils.redis.rkeys import TOUR_GUIDE_GROUP_USER_BELONG
|
|
5
|
|
-
|
|
6
|
|
-
|
|
7
|
|
-def set_tour_user_belong_group(user_id, group_id):
|
|
8
|
|
- """ 设置旅行团成员所属的旅行团 """
|
|
9
|
|
- r.set(TOUR_GUIDE_GROUP_USER_BELONG % user_id, group_id)
|
|
10
|
|
-
|
|
11
|
|
-
|
|
12
|
|
-def get_tour_user_belong_group(user_id):
|
|
13
|
|
- """ 获取旅行团成员所属的旅行团 """
|
|
14
|
|
- return r.get(TOUR_GUIDE_GROUP_USER_BELONG % user_id)
|
|
|
|
@@ -1,22 +0,0 @@
|
|
1
|
|
-# -*- coding: utf-8 -*-
|
|
2
|
|
-
|
|
3
|
|
-from django_curtail_uuid import CurtailUUID
|
|
4
|
|
-
|
|
5
|
|
-from photo.models import UUIDInfo
|
|
6
|
|
-from utils.redis.connect import r
|
|
7
|
|
-from utils.redis.rkeys import UUID_LIST
|
|
8
|
|
-
|
|
9
|
|
-
|
|
10
|
|
-def generate_uuid():
|
|
11
|
|
- uuid = CurtailUUID.uuid(UUIDInfo)
|
|
12
|
|
- UUIDInfo.objects.create(uuid=uuid)
|
|
13
|
|
- return uuid
|
|
14
|
|
-
|
|
15
|
|
-
|
|
16
|
|
-def generate_uuids(num=1000):
|
|
17
|
|
- uuids = [generate_uuid() for i in range(num)]
|
|
18
|
|
- r.rpush(UUID_LIST, *uuids)
|
|
19
|
|
-
|
|
20
|
|
-
|
|
21
|
|
-def update_uuids(lensman_id, uuids):
|
|
22
|
|
- UUIDInfo.objects.filter(uuid__in=uuids).update(lensman_id=lensman_id, status=False)
|