-# -*- coding: utf-8 -*-

-

-from isoweek import Week

-from TimeConvert import TimeConvert as tc

-

-from utils.redis.connect import r

-from utils.redis.rkeys import TODAY_INCOME, TOTAL_INCOME, WEEK_INCOME, WEEK_SOLD

-

-

-def set_brief_info(uid, ptype, fee, dt=None):

-    """ 更新简报信息 """

-    ymd, week = (tc.local_string(utc_dt=dt, format='%Y%m%d'), Week.withdate(dt)) if dt else (tc.local_string(format='%Y%m%d'), Week.thisweek().isoformat())

-

-    # 总收入

-    r.incr(TOTAL_INCOME % (uid, ptype), fee)

-    # 周收入

-    r.incr(WEEK_INCOME % (uid, ptype, week), fee)

-    # 日收入

-    r.incr(TODAY_INCOME % (uid, ptype, ymd), fee)

-

-    # 周售出

-    r.incr(WEEK_SOLD % (uid, ptype, week))

-# -*- coding: utf-8 -*-

-

-from group.models import GroupInfo, GroupPhotoInfo, GroupUserInfo, PhotoCommentInfo, PhotoThumbUpInfo

-from utils.redis.connect import r

-from utils.redis.rgroup import set_group_photo_data, set_group_users_info

-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_REFUSED_SET)

-

-

-def retrieve_group_data():

-    """ 群组数据 """

-    groups = GroupInfo.objects.filter(status=True)

-    for group in groups:

-        # 群组照片

-        set_group_photo_data(group.group_id)

-        # 群组用户

-        set_group_users_info(group)

-

-

-def retrieve_last_pk():

-    """ 群组最后一张照片PK """

-    groups = GroupInfo.objects.filter(status=True)

-    for group in groups:

-        group_photo = GroupPhotoInfo.objects.filter(group_id=group.group_id, status=True).last()

-        r.set(GROUP_LAST_PHOTO_PK % group.group_id, group_photo and group_photo.pk or -1)

-

-

-def retrieve_group_user_status():

-    """ 群组用户状态 """

-    group_users = GroupUserInfo.objects.filter(status=True)

-    for group_user in group_users:

-        group_id, user_id = group_user.group_id, group_user.user_id

-        if group_user.user_status == GroupUserInfo.PASSED:

-            r.sadd(GROUP_USERS_PASSED_SET % group_id, user_id)

-        elif group_user.user_status == GroupUserInfo.DELETED:

-            r.sadd(GROUP_USERS_DELETED_SET % group_id, user_id)

-        elif group_user.user_status == GroupUserInfo.APPLYING:

-            r.sadd(GROUP_USERS_APPLYING_SET % group_id, user_id)

-        elif group_user.user_status == GroupUserInfo.REFUSED:

-            r.sadd(GROUP_USERS_REFUSED_SET % group_id, user_id)

-

-

-def retrieve_group_photo_watchers():

-    group_photos = GroupPhotoInfo.objects.filter(status=True)

-    for group_photo in group_photos:

-        photo_comments = PhotoCommentInfo.objects.filter(photo_id=group_photo.photo_id, status=True)

-        for photo_comment in photo_comments:

-            r.sadd(GROUP_PHOTO_WATCHER_SET % group_photo.pk, photo_comment.user_id)

-        photo_thumbups = PhotoThumbUpInfo.objects.filter(photo_id=group_photo.photo_id, status=True)

-        for photo_thumbup in photo_thumbups:

-            r.sadd(GROUP_PHOTO_WATCHER_SET % group_photo.pk, photo_thumbup.user_id)

-

-

-def retrieve_redis_data():

-    retrieve_group_data()

-    retrieve_last_pk()

-    retrieve_group_user_status()

-    retrieve_group_photo_watchers()

-# -*- coding: utf-8 -*-

-

-from django.core.serializers.json import DjangoJSONEncoder

-

-from utils.redis.connect import r

-from utils.redis.rkeys import (GROUP_INFO, GROUP_PHOTO_COMMENT_LIST, GROUP_PHOTO_DATA, GROUP_PHOTO_THUMB_UP,

-                               GROUP_PHOTO_THUMB_UP_LIST, GROUP_PHOTO_WATCHER_SET, GROUP_USERS_INFO,

-                               GROUP_USERS_KV_INFO)

-

-

-def set_group_info(group):

-    """ 设置群组信息 """

-    r.setexjson(GROUP_INFO % group.group_id, r.REDIS_EXPIRED_ONE_MONTH, group.data, cls=DjangoJSONEncoder)

-    return group.data

-

-

-def set_group_info_by_id(group_id):

-    """ 设置群组信息 """

-    from group.models import GroupInfo

-    try:

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

-    except GroupInfo.DoesNotExist:

-        return {}

-    return set_group_info(group)

-

-

-def get_group_info(group_id):

-    """ 获取群组信息 """

-    return r.getjson(GROUP_INFO % group_id) or set_group_info_by_id(group_id)

-

-

-# 群组用户信息相关

-

-

-def set_group_users_info(group):

-    """ 设置群组用户信息 """

-    group_users = group.users(admin=False)

-

-    group_users_data = {

-        'group_users': group_users,

-        'admin_id': group.admin_id,

-    }

-    r.setexjson(GROUP_USERS_INFO % group.group_id, r.REDIS_EXPIRED_ONE_MONTH, group_users_data, cls=DjangoJSONEncoder)

-

-    group_users_kv_data = {user_info.get('user_id', ''): user_info for user_info in group_users.get('passed', [])}

-    r.setexjson(GROUP_USERS_KV_INFO % group.group_id, r.REDIS_EXPIRED_ONE_MONTH, group_users_kv_data, cls=DjangoJSONEncoder)

-

-    return group_users_data, group_users_kv_data

-

-

-def set_group_users_info_by_id(group_id):

-    """ 设置群组用户信息 """

-    from group.models import GroupInfo

-    try:

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

-    except GroupInfo.DoesNotExist:

-        return {}, {}

-    return set_group_users_info(group)

-

-

-def get_group_users_info(group_id, user_id):

-    """ 获取群组用户信息 """

-    group_users_data = r.getjson(GROUP_USERS_INFO % group_id) or set_group_users_info_by_id(group_id)[0]

-    group_users, admin_id = group_users_data.get('group_users', {}), group_users_data.get('admin_id', '')

-    if group_users and user_id != admin_id:

-        [group_users.pop(k) for k in ['applying_count', 'applying']]

-    return group_users

-

-

-def get_group_users_kv_info(group_id):

-    """ 获取群组用户信息 """

-    return r.getjson(GROUP_USERS_KV_INFO % group_id) or set_group_users_info_by_id(group_id)[1]

-

-

-# 群组照片相关

-

-

-def set_group_photo_data(group_id):

-    """ 设置群组照片数据信息 """

-    from group.models import GroupPhotoInfo

-    group_photos = GroupPhotoInfo.objects.filter(group_id=group_id, status=True)

-    group_photos = [photo.photo_data for photo in group_photos]

-    r.setjson(GROUP_PHOTO_DATA % group_id, group_photos)

-    return group_photos

-

-

-def get_group_photo_data(group_id):

-    """ 获取群组照片数据信息 """

-    return r.getjson(GROUP_PHOTO_DATA % group_id, default='[]') or set_group_photo_data(group_id)

-

-

-def set_group_photo_thumbup_flag(photo_id, user_id):

-    """ 设置群组照片用户点赞标识信息 """

-    r.setex(GROUP_PHOTO_THUMB_UP % (photo_id, user_id), r.REDIS_EXPIRED_ONE_MONTH, True)

-

-

-def del_group_photo_thumbup_flag(photo_id, user_id):

-    """ 删除群组照片用户点赞标识信息 """

-    r.delete(GROUP_PHOTO_THUMB_UP % (photo_id, user_id))

-

-

-def get_group_photo_thumbup_flag(photo_id, user_id):

-    """ 获取群组照片用户点赞标识信息 """

-    if r.exists(GROUP_PHOTO_THUMB_UP % (photo_id, user_id)):

-        return True

-

-    from group.models import PhotoThumbUpInfo

-    if PhotoThumbUpInfo.objects.filter(photo_id=photo_id, user_id=user_id, thumbup=True, status=True).exists():

-        set_group_photo_thumbup_flag(photo_id, user_id)

-        return True

-

-    return False

-

-

-def set_group_photo_comment_list(photo_id):

-    """ 设置群组照片用户评论列表 """

-    from group.models import PhotoCommentInfo

-    photo_comments = PhotoCommentInfo.objects.filter(photo_id=photo_id, status=True)

-    photo_comments = [comment.comment_info for comment in photo_comments]

-    r.setjson(GROUP_PHOTO_COMMENT_LIST % photo_id, photo_comments, cls=DjangoJSONEncoder)

-    return photo_comments

-

-

-def get_group_photo_comment_list(photo_id):

-    """ 获取群组照片用户评论列表 """

-    return r.getjson(GROUP_PHOTO_COMMENT_LIST % photo_id, default='[]') or set_group_photo_comment_list(photo_id)

-

-

-def set_group_photo_thumbup_list(photo_id):

-    """ 设置群组照片用户点赞列表 """

-    from group.models import PhotoThumbUpInfo

-    photo_thumbups = PhotoThumbUpInfo.objects.filter(photo_id=photo_id, thumbup=True, status=True)

-    photo_thumbups = [thumbup.thumbup_info for thumbup in photo_thumbups]

-    r.setjson(GROUP_PHOTO_THUMB_UP_LIST % photo_id, photo_thumbups, cls=DjangoJSONEncoder)

-    return photo_thumbups

-

-

-def get_group_photo_thumbup_list(photo_id):

-    """ 获取群组照片用户点赞列表 """

-    return r.getjson(GROUP_PHOTO_THUMB_UP_LIST % photo_id, default='[]') or set_group_photo_thumbup_list(photo_id)

-

-

-def get_group_photo_watchers(photo_id, discarders=None):

-    """ 获取群组照片用户关注列表 """

-    watchers = r.smembers(GROUP_PHOTO_WATCHER_SET % photo_id)

-    [watchers.discard(elem) for elem in discarders or []]

-    return watchers

-# -*- coding: utf-8 -*-

-

-from utils.redis.connect import r

-from utils.redis.rkeys import GUEST_ENTRANCE_CONTROL_INFO

-

-

-def set_guest_entrance_control(gen):

-    """ 设置游客入口控制 """

-    r.setjson(GUEST_ENTRANCE_CONTROL_INFO % gen.src, gen.data)

-    return gen.data

-

-

-def get_guest_entrance_control(src=0):

-    """ 获取游客入口控制 """

-    return r.getjson(GUEST_ENTRANCE_CONTROL_INFO % src)

-

-

-def delete_guest_entrance_control(src=0):

-    """ 删除游客入口控制 """

-    return r.delete(GUEST_ENTRANCE_CONTROL_INFO % src)

-# -*- coding: utf-8 -*-

-

-# 唯一标识相关

-UUID_LIST = 'uuid:list'  # List，唯一标识列表

-

-# 用户相关

-PROFILE_INFO = 'profile:info:%s'  # STRING，用户信息，user_id

-

-# 导游相关

-TOUR_GUIDE_GROUP_GEO_INFO = 'tour:guide:group:geo:info:%s'  # ZSET，旅游团地理位置信息，group_id

-TOUR_GUIDE_GROUP_GEO_SUBMIT_DT = 'tour:guide:group:geo:submit:dt:%s'  # ZSET，旅游团地理位置最后上传时间，group_id

-TOUR_GUIDE_GROUP_CUR_SESSION = 'tour:guide:group:cur:session:%s'  # STRING，旅游团当前Session，group_id，导游设置集合时间的时候更新

-TOUR_GUIDE_GROUP_CUR_GATHER_INFO = 'tour:guide:group:cur:gather:info:%s'  # STRING，旅游团当前Session，group_id，导游设置集合时间的时候更新

-TOUR_GUIDE_GROUP_USER_GEO_LIST = 'tour:guide:group:user:geo:list:%s:%s:%s'  # LIST，旅游团当前用户地理位置列表，group_id、session_id、user_id

-

-TOUR_GUIDE_GROUP_USER_OWN = 'tour:guide:group:user:own:%s'  # STRING，导游当前拥有的旅行团，user_id，导游创建旅行团的时候更新

-TOUR_GUIDE_GROUP_USER_BELONG = 'tour:guide:group:user:belong:%s'  # STRING，用户当前所属旅行团，user_id，用户加入旅行团的时候更新

-

-# 群组相关

-GROUP_INFO = 'group:info:%s'  # STRING，群组信息，group_id

-

-# 群组用户相关

-GROUP_USERS_INFO = 'group:users:info:%s'  # STRING，群组用户信息，group_id

-GROUP_USERS_KV_INFO = 'group:users:kv:info:%s'  # STRING，群组用户信息，group_id

-GROUP_USERS_APPLYING_SET = 'group:users:applying:set:%s'  # SET，群组用户申请集合，group_id

-GROUP_USERS_PASSED_SET = 'group:users:passed:set:%s'  # SET，群组用户通过集合，group_id

-GROUP_USERS_REFUSED_SET = 'group:users:refused:set:%s'  # SET，群组用户拒绝集合，group_id

-GROUP_USERS_DELETED_SET = 'group:users:deleted:set:%s'  # SET，群组用户移除集合，group_id

-GROUP_USERS_QUIT_SET = 'group:users:quit:set:%s'  # SET，群组用户退出集合，group_id

-

-# 群组照片相关

-GROUP_PHOTO_DATA = 'group:photo:data:%s'  # STRING，群组数据记录，group_id

-GROUP_PHOTO_THUMB_UP = 'group:photo:thumb:up:%s:%s'  # STRING，群组照片用户点赞记录，photo_id、user_id

-GROUP_PHOTO_COMMENT_LIST = 'group:photo:comment:list:%s'  # STRING，群组照片用户评论列表，photo_id

-GROUP_PHOTO_THUMB_UP_LIST = 'group:photo:thumb:up:list:%s'  # STRING，群组照片用户点赞列表，photo_id

-GROUP_PHOTO_WATCHER_SET = 'group:photo:watcher:set:%s'  # SET，群组照片用户关注集合，photo_id，关注即评论点赞

-GROUP_LAST_PHOTO_PK = 'group:last:photo:pk:%s'  # STRING，群组最后一张照片PK，group_id

-

-# 摄影师照片相关

-LENSMAN_PHOTO_ORDER_RECORD = 'lensman:photo:order:record:%s:%s'  # STRING，摄影师照片购买记录，photo_id、user_id

-

-# 摄影师简报相关

-# 收入

-TOTAL_INCOME = 'total:income:%s:%s'  # STRING，总收入，user_id、photo_type

-WEEK_INCOME = 'week:income:%s:%s:%s'  # STRING，周收入，user_id、photo_type、Week.thisweek().isoformat()

-TODAY_INCOME = 'today:income:%s:%s:%s'  # STRING，日收入，user_id、photo_type、tc.local_string(format='%Y%m%d')

-# 上传

-TODAY_UPLOAD_PHOTO_AMOUNT = 'today:upload:photo:amount:%s:%s'  # STRING，日上传照片数量，user_id、tc.local_string(format='%Y%m%d')

-# 售出

-WEEK_SOLD = 'week:sold:%s:%s:%s'  # STRING，周售出，user_id、photo_type、Week.thisweek().isoformat()

-

-# 摄影师定价相关

-LENSMAN_PHOTO_PRICE_FIXED = 'lensman:photo:price:fixed:%s'  # STRING，摄影师照片定价(单位:分)，user_id

-

-# 系统消息相关

-SYSTEM_MESSAGE_READ_INFO = 'system:message:read:info:%s'  # STRING，系统消息读取信息，user_id

-SYSTEM_MESSAGE_DELETED_INFO = 'system:message:deleted:info:%s'  # STRING，系统消息删除信息，user_id

-

-# 游客入口相关

-GUEST_ENTRANCE_CONTROL_INFO = 'guest:entrance:control:info:%s'  # STRING，游客入口控制信息，src

-# BOX 相关

-BOX_PROGRAM_VERSION_INFO = 'box:program:version:info'  # STRING，BOX 程序版本信息

-# -*- coding: utf-8 -*-

-

-from utils.redis.connect import r

-from utils.redis.rkeys import SYSTEM_MESSAGE_DELETED_INFO, SYSTEM_MESSAGE_READ_INFO

-

-

-def set_system_message_read_info(user_id):

-    """ 设置系统消息读取信息 """

-    from message.models import SystemMessageReadInfo

-    read_messages = SystemMessageReadInfo.objects.filter(user_id=user_id, status=True)

-    read_message_ids = [msg.msg_id for msg in read_messages]

-    r.setexjson(SYSTEM_MESSAGE_READ_INFO % user_id, r.REDIS_EXPIRED_ONE_MONTH, read_message_ids)

-    return read_message_ids

-

-

-def get_system_message_read_info(user_id):

-    """ 获取系统消息读取信息 """

-    return r.getjson(SYSTEM_MESSAGE_READ_INFO % user_id, default='[]') or set_system_message_read_info(user_id)

-

-

-def set_system_message_delete_info(user_id):

-    """ 设置系统消息删除信息 """

-    from message.models import SystemMessageDeleteInfo

-    deleted_messages = SystemMessageDeleteInfo.objects.filter(user_id=user_id, status=True)

-    deleted_message_ids = [msg.msg_id for msg in deleted_messages]

-    r.setexjson(SYSTEM_MESSAGE_DELETED_INFO % user_id, r.REDIS_EXPIRED_ONE_MONTH, deleted_message_ids)

-    return deleted_message_ids

-

-

-def get_system_message_delete_info(user_id):

-    """ 获取系统消息删除信息 """

-    return r.getjson(SYSTEM_MESSAGE_DELETED_INFO % user_id, default='[]') or set_system_message_delete_info(user_id)

-# -*- coding: utf-8 -*-

-

-from utils.redis.connect import r

-from utils.redis.rkeys import BOX_PROGRAM_VERSION_INFO

-

-

-def set_box_program_version():

-    """ 设置 BOX 程序版本信息 """

-    from operation.models import BoxProgramVersionInfo

-    try:

-        bpverion = BoxProgramVersionInfo.objects.filter(status=True)[0].data

-    except IndexError:

-        bpverion = {}

-    r.setjson(BOX_PROGRAM_VERSION_INFO, bpverion)

-    return bpverion

-

-

-def get_box_program_version():

-    """ 获取 BOX 程序版本信息 """

-    return r.getjson(BOX_PROGRAM_VERSION_INFO) or set_box_program_version()

-# -*- coding: utf-8 -*-

-

-from django.core.serializers.json import DjangoJSONEncoder

-

-from utils.redis.connect import r

-from utils.redis.rkeys import LENSMAN_PHOTO_ORDER_RECORD

-

-

-def set_lensman_order_record(porder):

-    """ 设置摄影师照片购买记录 """

-    r.setexjson(LENSMAN_PHOTO_ORDER_RECORD % (porder.photo_id, porder.user_id), r.REDIS_EXPIRED_ONE_MONTH, porder.porder_info, cls=DjangoJSONEncoder)

-    return porder.porder_info

-

-

-def set_lensman_order_record_by_id(photo_id, user_id):

-    """ 设置摄影师照片购买记录 """

-    from group.models import GroupPhotoOrderInfo

-    try:

-        porder = GroupPhotoOrderInfo.objects.get(photo_id=photo_id, user_id=user_id)

-    except GroupPhotoOrderInfo.DoesNotExist:

-        return {}

-    return set_lensman_order_record(porder)

-

-

-def get_lensman_order_record(photo_id, user_id):

-    """ 获取摄影师照片购买记录 """

-    return r.getjson(LENSMAN_PHOTO_ORDER_RECORD % (photo_id, user_id)) or set_lensman_order_record_by_id(photo_id, user_id)

-# -*- coding: utf-8 -*-

-

-from utils.redis.connect import r

-from utils.redis.rkeys import LENSMAN_PHOTO_PRICE_FIXED

-

-

-def set_lensman_price_fixed(user_id):

-    """ 设置摄影师价格设定 """

-    from account.models import LensmanInfo

-    try:

-        lensman = LensmanInfo.objects.get(lensman_id=user_id)

-    except LensmanInfo.DoesNotExist:

-        lensman = None

-

-    price_fixed = {

-        'nomark': (lensman and lensman.nomark) or 299,

-        'origin': (lensman and lensman.origin) or 999,

-    }

-

-    r.setjson(LENSMAN_PHOTO_PRICE_FIXED % user_id, price_fixed)

-

-    return price_fixed

-

-

-def get_lensman_price_fixed(user_id):

-    """ 获取摄影师价格设定 """

-    return r.getjson(LENSMAN_PHOTO_PRICE_FIXED % user_id) or set_lensman_price_fixed(user_id)

-# -*- coding: utf-8 -*-

-

-from utils.redis.connect import r

-from utils.redis.rkeys import TOUR_GUIDE_GROUP_USER_OWN

-

-

-def set_tour_guide_own_group(user_id, group_id):

-    """ 设置导游拥有的旅行团 """

-    r.set(TOUR_GUIDE_GROUP_USER_OWN % user_id, group_id)

-

-

-def get_tour_guide_own_group(user_id):

-    """ 获取导游拥有的旅行团 """

-    return r.get(TOUR_GUIDE_GROUP_USER_OWN % user_id)

-

-

-def del_tour_guide_own_group(user_id):

-    """ 删除导游拥有的旅行团 """

-    return r.delete(TOUR_GUIDE_GROUP_USER_OWN % user_id)

-# -*- coding: utf-8 -*-

-

-from utils.redis.connect import r

-from utils.redis.rkeys import TOUR_GUIDE_GROUP_USER_BELONG

-

-

-def set_tour_user_belong_group(user_id, group_id):

-    """ 设置旅行团成员所属的旅行团 """

-    r.set(TOUR_GUIDE_GROUP_USER_BELONG % user_id, group_id)

-

-

-def get_tour_user_belong_group(user_id):

-    """ 获取旅行团成员所属的旅行团 """

-    return r.get(TOUR_GUIDE_GROUP_USER_BELONG % user_id)

-# -*- coding: utf-8 -*-

-

-from django_curtail_uuid import CurtailUUID

-

-from photo.models import UUIDInfo

-from utils.redis.connect import r

-from utils.redis.rkeys import UUID_LIST

-

-

-def generate_uuid():

-    uuid = CurtailUUID.uuid(UUIDInfo)

-    UUIDInfo.objects.create(uuid=uuid)

-    return uuid

-

-

-def generate_uuids(num=1000):

-    uuids = [generate_uuid() for i in range(num)]

-    r.rpush(UUID_LIST, *uuids)

-

-

-def update_uuids(lensman_id, uuids):

-    UUIDInfo.objects.filter(uuid__in=uuids).update(lensman_id=lensman_id, status=False)