platform、channel、version
APP_PATCH_INFO = 'app:patch:info:%s:%s:%s' # STRING,APP 补丁信息,platform、version、src
-# BOX 相关
-BOX_PROGRAM_VERSION_INFO = 'box:program:version:info' # STRING,BOX 程序版本信息
+# 用户相关
+PROFILE_INFO = 'profile:info:%s' # STRING,用户信息,user_id
# 小程序相关
MINI_PROGRAM_GIS_LIST = 'tamron:miniprogram:gis:list'
@@ -1,32 +0,0 @@ |
||
| 1 |
-# -*- coding: utf-8 -*- |
|
| 2 |
- |
|
| 3 |
-from utils.redis.connect import r |
|
| 4 |
-from utils.redis.rkeys import SYSTEM_MESSAGE_DELETED_INFO, SYSTEM_MESSAGE_READ_INFO |
|
| 5 |
- |
|
| 6 |
- |
|
| 7 |
-def set_system_message_read_info(user_id): |
|
| 8 |
- """ 设置系统消息读取信息 """ |
|
| 9 |
- from message.models import SystemMessageReadInfo |
|
| 10 |
- 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) |