- verbose_name_plural = _('uuidinfo')
-
- def __unicode__(self):
- return u'{0.pk}'.format(self)
-
- @property
- def data(self):
- return {
- 'pk': self.pk,
- 'uuid': self.uuid,
- 'lensman_id': self.lensman_id,
- }
-
-
-class PhotoUUIDInfo(BaseModelMixin):
- photo_md5 = models.CharField(_(u'photo_md5'), max_length=32, blank=True, null=True, help_text=u'照片唯一标识', db_index=True, unique=True)
-
- photo_path = models.CharField(_(u'photo_path'), max_length=32, blank=True, null=True, help_text=u'照片路径')
- photo_w = models.IntegerField(_(u'photo_w'), default=0, help_text=u'照片宽度')
- photo_h = models.IntegerField(_(u'photo_h'), default=0, help_text=u'照片高度')
-
- photo_watermark_path = models.CharField(_(u'photo_watermark_path'), max_length=32, blank=True, null=True, help_text=u'照片存放路径，Box上传，有水印，服务器添加')
- photo_watermark_w = models.IntegerField(_(u'photo_watermark_w'), default=0, help_text=u'照片水印图宽度')
- photo_watermark_h = models.IntegerField(_(u'photo_watermark_h'), default=0, help_text=u'照片水印图高度')
-
- photo_thumbnail_path = models.CharField(_(u'photo_thumbnail_path'), max_length=32, blank=True, null=True, help_text=u'照片缩略图存放路径')
- photo_thumbnail_w = models.IntegerField(_(u'photo_thumbnail_w'), default=0, help_text=u'照片缩略图宽度')
- photo_thumbnail_h = models.IntegerField(_(u'photo_thumbnail_h'), default=0, help_text=u'照片缩略图高度')
-
- photo_thumbnail2_path = models.CharField(_(u'photo_thumbnail2_path'), max_length=32, blank=True, null=True, help_text=u'照片缩略图存放路径')
- photo_thumbnail2_w = models.IntegerField(_(u'photo_thumbnail2_w'), default=0, help_text=u'照片缩略图宽度')
- photo_thumbnail2_h = models.IntegerField(_(u'photo_thumbnail2_h'), default=0, help_text=u'照片缩略图高度')
-
- class Meta:
- verbose_name = _('photouuidinfo')
- verbose_name_plural = _('photouuidinfo')
-
- def __unicode__(self):
- return u'{0.pk}'.format(self)
-
-
-class PhotosInfo(BaseModelMixin):
- lensman_id = models.CharField(_(u'lensman_id'), max_length=32, blank=True, null=True, help_text=u'摄影师唯一标识', db_index=True)
- session_id = models.CharField(_(u'session_id'), max_length=32, blank=True, null=True, help_text=u'照片组唯一标识', db_index=True)
- photo_id = models.CharField(_(u'photo_id'), max_length=32, blank=True, null=True, help_text=u'照片唯一标识', db_index=True)
- p_photo_path = models.CharField(_(u'p_photo_path'), max_length=32, blank=True, null=True, help_text=u'照片存放路径，Box上传，有水印，服务器添加')
- m_photo_path = models.CharField(_(u'm_photo_path'), max_length=32, blank=True, null=True, help_text=u'照片存放路径，Box上传，无水印')
- l_photo_path = models.CharField(_(u'l_photo_path'), max_length=32, blank=True, null=True, help_text=u'照片存放路径，美化大图')
- r_photo_path = models.CharField(_(u'r_photo_path'), max_length=32, blank=True, null=True, help_text=u'照片存放路径，高清大图')
-
- class Meta:
- verbose_name = _('photosinfo')
- verbose_name_plural = _('photosinfo')
-
- index_together = [
- ['lensman_id', 'session_id'],
- ]
-
- unique_together = (
- ('lensman_id', 'session_id', 'photo_id'),
- )
-
- def __unicode__(self):
- return u'{0.pk}'.format(self)
-
- @property
- def p_photo_url(self):
- return qiniu_file_url(self.p_photo_path, bucket='watermark')
-
- @property
- def m_photo_url(self):
- return qiniu_file_url(self.m_photo_path, bucket='photo')
-
- @property
- def l_photo_url(self):
- return qiniu_file_url(self.l_photo_path, bucket='prettify')
-
- @property
- def r_photo_url(self):
- return qiniu_file_url(self.r_photo_path, bucket='original')
-
- @property
- def data(self):
- return {
- 'pk': self.pk,
- 'user_id': self.lensman_id,
- 'session_id': self.session_id,
- 'photo_id': self.photo_id,
- }
-
- @property
- def detail(self):
- return {
- 'pk': self.pk,
- 'user_id': self.lensman_id,
- 'session_id': self.session_id,
- 'photo_id': self.photo_id,
- 'photo_url': self.p_photo_url,
- }
@@ -1,11 +0,0 @@ |
||
| 1 |
-# -*- coding: utf-8 -*- |
|
| 2 |
- |
|
| 3 |
-from rest_framework import serializers |
|
| 4 |
- |
|
| 5 |
-from photo.models import PhotosInfo |
|
| 6 |
- |
|
| 7 |
- |
|
| 8 |
-class PhotosInfoSerializer(serializers.HyperlinkedModelSerializer): |
|
| 9 |
- class Meta: |
|
| 10 |
- model = PhotosInfo |
|
| 11 |
- fields = ('lensman_id', 'session_id', 'photo_id', 'p_photo_path', 'm_photo_path', 'l_photo_path', 'r_photo_path', 'created_at')
|
@@ -1,61 +0,0 @@ |
||
| 1 |
-{% load staticfiles %}
|
|
| 2 |
- |
|
| 3 |
-<!DOCTYPE html> |
|
| 4 |
-<html lang="zh-CN"> |
|
| 5 |
- <head> |
|
| 6 |
- <meta charset="utf-8"> |
|
| 7 |
- <meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1"> |
|
| 8 |
- <meta name="format-detection" content="telephone=no,email=no,address=no"> |
|
| 9 |
- <meta name="viewport" content="width=device-width,initial-scale=1.0,user-scalable=no"> |
|
| 10 |
- <title>照片详情</title> |
|
| 11 |
- <style> |
|
| 12 |
- body {position:absolute;top:0;right:0;bottom:0;left:0;margin:0;font-family:"Microsoft YaHei","sans-serif","Microsoft Sans Serif","Microsoft JhengHei UI";background:#fff6e6;color:gray}
|
|
| 13 |
- img {width:100%}
|
|
| 14 |
- |
|
| 15 |
- /* For Download Section */ |
|
| 16 |
- .download_section {position:fixed;right:0;bottom:0;left:0;height:55px;padding:5px;background:#f0f0f0;box-sizing:border-box}
|
|
| 17 |
- .kodo_icon {width:45px;height:45px;float:left}
|
|
| 18 |
- .kodo_icon>img {width:100%;height:100%}
|
|
| 19 |
- .kodo_desc {height:45px;padding:5px 0 0 5px;float:left}
|
|
| 20 |
- .kodo_name {padding-top:2px;font-size:14px;text-align:left}
|
|
| 21 |
- .kodo_des {padding-top:2px;font-size:12px;line-height:23px;color:#8f8f8f;text-align:left}
|
|
| 22 |
- .kodo_download {position:relative;top:5px;width:100px;height:35px;line-height:35px;text-align:center;background:#d13621;color:#fff;border-radius:5px;float:right;text-decoration:none}
|
|
| 23 |
- /* For PC */ |
|
| 24 |
- body, .download_section {
|
|
| 25 |
- max-width: 414px !important; |
|
| 26 |
- margin: 0 auto !important; |
|
| 27 |
- } |
|
| 28 |
- </style> |
|
| 29 |
- </head> |
|
| 30 |
- <body> |
|
| 31 |
- <div class="container"> |
|
| 32 |
- <article class="text-center"> |
|
| 33 |
- <img src="{{ photo_url }}">
|
|
| 34 |
- </article> |
|
| 35 |
- </div> |
|
| 36 |
- |
|
| 37 |
- <div id="download_section" class="download_section"> |
|
| 38 |
- <div class="kodo_icon"> |
|
| 39 |
- <img src="{% static 'kodo/img/paiai_96_96.png' %}">
|
|
| 40 |
- </div> |
|
| 41 |
- <div class="kodo_desc"> |
|
| 42 |
- <div class="kodo_name">拍爱</div> |
|
| 43 |
- <div class="kodo_des">即拍即分享</div> |
|
| 44 |
- </div> |
|
| 45 |
- <a href="https://api.pai.ai/op/download" target="_blank" id="kodo_download" class="kodo_download">立即下载</a> |
|
| 46 |
- </div> |
|
| 47 |
- |
|
| 48 |
- <script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/zepto/1.1.6/zepto.min.js"></script> |
|
| 49 |
- <script type="text/javascript" src="//res.wx.qq.com/open/js/jweixin-1.2.0.js"></script> |
|
| 50 |
- <script type="text/javascript" src="{% static 'kodo/js/jswe-0.0.4.js' %}"></script>
|
|
| 51 |
- <script> |
|
| 52 |
- V.initWxData({
|
|
| 53 |
- imgUrl: "http://pai.ai/static/kodo/img/paiai_96_96.png", |
|
| 54 |
- link: window.location.href, |
|
| 55 |
- desc: "我使用拍爱分享了一张美图,你也快来试试吧", |
|
| 56 |
- title: "拍爱", |
|
| 57 |
- timeLine: "" |
|
| 58 |
- }, true); |
|
| 59 |
- </script> |
|
| 60 |
- </body> |
|
| 61 |
-</html> |
@@ -1,63 +0,0 @@ |
||
| 1 |
-{% load staticfiles %}
|
|
| 2 |
- |
|
| 3 |
-<!DOCTYPE html> |
|
| 4 |
-<html lang="zh-CN"> |
|
| 5 |
- <head> |
|
| 6 |
- <meta charset="utf-8"> |
|
| 7 |
- <meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1"> |
|
| 8 |
- <meta name="format-detection" content="telephone=no,email=no,address=no"> |
|
| 9 |
- <meta name="viewport" content="width=device-width,initial-scale=1.0,user-scalable=no"> |
|
| 10 |
- <title>照片列表</title> |
|
| 11 |
- <style> |
|
| 12 |
- body {position:absolute;top:0;right:0;bottom:0;left:0;margin:0;font-family:"Microsoft YaHei","sans-serif","Microsoft Sans Serif","Microsoft JhengHei UI";background:#fff6e6;color:gray}
|
|
| 13 |
- img {width:100%}
|
|
| 14 |
- |
|
| 15 |
- /* For Download Section */ |
|
| 16 |
- .download_section {position:fixed;right:0;bottom:0;left:0;height:55px;padding:5px;background:#f0f0f0;box-sizing:border-box}
|
|
| 17 |
- .kodo_icon {width:45px;height:45px;float:left}
|
|
| 18 |
- .kodo_icon>img {width:100%;height:100%}
|
|
| 19 |
- .kodo_desc {height:45px;padding:5px 0 0 5px;float:left}
|
|
| 20 |
- .kodo_name {padding-top:2px;font-size:14px;text-align:left}
|
|
| 21 |
- .kodo_des {padding-top:2px;font-size:12px;line-height:23px;color:#8f8f8f;text-align:left}
|
|
| 22 |
- .kodo_download {position:relative;top:5px;width:100px;height:35px;line-height:35px;text-align:center;background:#d13621;color:#fff;border-radius:5px;float:right;text-decoration:none}
|
|
| 23 |
- /* For PC */ |
|
| 24 |
- body, .download_section {
|
|
| 25 |
- max-width: 414px !important; |
|
| 26 |
- margin: 0 auto !important; |
|
| 27 |
- } |
|
| 28 |
- </style> |
|
| 29 |
- </head> |
|
| 30 |
- <body> |
|
| 31 |
- <div class="container"> |
|
| 32 |
- <article class="text-center"> |
|
| 33 |
- {% for photo in photos %}
|
|
| 34 |
- <div><img src="{{ photo.p_photo_url }}"></div>
|
|
| 35 |
- {% endfor %}
|
|
| 36 |
- </article> |
|
| 37 |
- </div> |
|
| 38 |
- |
|
| 39 |
- <div id="download_section" class="download_section"> |
|
| 40 |
- <div class="kodo_icon"> |
|
| 41 |
- <img src="{% static 'kodo/img/paiai_96_96.png' %}">
|
|
| 42 |
- </div> |
|
| 43 |
- <div class="kodo_desc"> |
|
| 44 |
- <div class="kodo_name">拍爱</div> |
|
| 45 |
- <div class="kodo_des">即拍即分享</div> |
|
| 46 |
- </div> |
|
| 47 |
- <a href="https://api.pai.ai/op/download" target="_blank" id="kodo_download" class="kodo_download">立即下载</a> |
|
| 48 |
- </div> |
|
| 49 |
- |
|
| 50 |
- <script type="text/javascript" src="//cdnjs.cloudflare.com/ajax/libs/zepto/1.1.6/zepto.min.js"></script> |
|
| 51 |
- <script type="text/javascript" src="//res.wx.qq.com/open/js/jweixin-1.2.0.js"></script> |
|
| 52 |
- <script type="text/javascript" src="{% static 'kodo/js/jswe-0.0.4.js' %}"></script>
|
|
| 53 |
- <script> |
|
| 54 |
- V.initWxData({
|
|
| 55 |
- imgUrl: "http://pai.ai/static/kodo/img/paiai_96_96.png", |
|
| 56 |
- link: window.location.href, |
|
| 57 |
- desc: "我使用拍爱分享了一张美图,你也快来试试吧", |
|
| 58 |
- title: "拍爱", |
|
| 59 |
- timeLine: "" |
|
| 60 |
- }, true); |
|
| 61 |
- </script> |
|
| 62 |
- </body> |
|
| 63 |
-</html> |
@@ -1,4 +0,0 @@ |
||
| 1 |
-from django.test import TestCase |
|
| 2 |
- |
|
| 3 |
- |
|
| 4 |
-# Create your tests here. |
@@ -1,276 +0,0 @@ |
||
| 1 |
-# -*- coding: utf-8 -*- |
|
| 2 |
- |
|
| 3 |
-from django.db import transaction |
|
| 4 |
-from django.shortcuts import render |
|
| 5 |
-from django_curtail_uuid import CurtailUUID |
|
| 6 |
-from django_logit import logit |
|
| 7 |
-from django_response import response |
|
| 8 |
-from ipaddr import client_ip |
|
| 9 |
-from rest_framework import viewsets |
|
| 10 |
-from TimeConvert import TimeConvert as tc |
|
| 11 |
- |
|
| 12 |
-from account.models import LensmanInfo, UserInfo |
|
| 13 |
-from group.models import GroupInfo, GroupPhotoInfo, GroupUserInfo |
|
| 14 |
-from photo.models import PhotosInfo |
|
| 15 |
-from photo.serializers import PhotosInfoSerializer |
|
| 16 |
-from utils.error.errno_utils import LensmanStatusCode, PhotoStatusCode |
|
| 17 |
-from utils.redis.connect import r |
|
| 18 |
-from utils.redis.rgroup import get_group_info, set_group_info, set_group_users_info |
|
| 19 |
-from utils.redis.rkeys import (GROUP_LAST_PHOTO_PK, GROUP_USERS_DELETED_SET, GROUP_USERS_PASSED_SET, |
|
| 20 |
- GROUP_USERS_QUIT_SET, GROUP_USERS_REFUSED_SET, UUID_LIST) |
|
| 21 |
-from utils.redis.rprice import get_lensman_price_fixed |
|
| 22 |
-from utils.redis.ruuid import generate_uuids, update_uuids |
|
| 23 |
-from utils.storage_qiniu_utils import file_save |
|
| 24 |
- |
|
| 25 |
- |
|
| 26 |
-@logit |
|
| 27 |
-def uuid_init(request): |
|
| 28 |
- """ 生成唯一标识 """ |
|
| 29 |
- num = int(request.GET.get('num', 1000))
|
|
| 30 |
- |
|
| 31 |
- # 生成 UUID |
|
| 32 |
- generate_uuids(num) |
|
| 33 |
- |
|
| 34 |
- return response(200, 'UUID Refresh Success', u'UUID 更新成功') |
|
| 35 |
- |
|
| 36 |
- |
|
| 37 |
-# curl -X POST -F user_id=xxxxxxx -F num=100 http://api.pai.ai/uuid |
|
| 38 |
-@logit |
|
| 39 |
-@transaction.atomic |
|
| 40 |
-def uuid(request): |
|
| 41 |
- """ 获取唯一标识 """ |
|
| 42 |
- lensman_id = request.POST.get('user_id', '')
|
|
| 43 |
- num = int(request.POST.get('num', 100))
|
|
| 44 |
- |
|
| 45 |
- # 从 Redis 中 Pop 中指定数量的 UUID |
|
| 46 |
- uuids, succeed, left = r.multi_pop(UUID_LIST, num) |
|
| 47 |
- |
|
| 48 |
- # # 异步更新 UUID 数据库中状态 |
|
| 49 |
- # if uuids: |
|
| 50 |
- # async(update_uuids, lensman_id, uuids) |
|
| 51 |
- # |
|
| 52 |
- # # 当可用 UUID 数量少于 500 时, 异步创建 |
|
| 53 |
- # if left < 500: |
|
| 54 |
- # async(generate_uuids) |
|
| 55 |
- |
|
| 56 |
- return response(200, 'Get UUID Success', u'获取唯一标识成功', uuids) |
|
| 57 |
- |
|
| 58 |
- |
|
| 59 |
-# [How to do a PUT request with curl?](http://stackoverflow.com/questions/13782198/how-to-do-a-put-request-with-curl) |
|
| 60 |
-# Unfortunately, the -T is no substitute for -X PUT if you want to specify parameters with -d or -F. |
|
| 61 |
-# -T sends the content of a file via PUT. To achieve the GET after a redirect, add the parameter --location |
|
| 62 |
-# |
|
| 63 |
-# -F, --form <name=content> |
|
| 64 |
-# (HTTP) This lets curl emulate a filled-in form in which a user has pressed the submit button. This causes curl to POST data |
|
| 65 |
-# using the Content-Type multipart/form-data according to RFC 2388. This enables uploading of binary files etc. To force the |
|
| 66 |
-# 'content' part to be a file, prefix the file name with an @ sign. To just get the content part from a file, prefix the file |
|
| 67 |
-# name with the symbol <. The difference between @ and < is then that @ makes a file get attached in the post as a file upload, |
|
| 68 |
-# while the < makes a text field and just get the contents for that text field from a file. |
|
| 69 |
-# |
|
| 70 |
-# curl -X POST -F user_id=xxxxxxx -F session_id=xxxxxxx -F photo_id=xxxxxxx -F photo=@xxxxxxx.jpg http://api.pai.ai/photos/upload |
|
| 71 |
-@logit |
|
| 72 |
-def upload_photo(request): |
|
| 73 |
- """ 上传图片 """ |
|
| 74 |
- lensman_id = request.POST.get('user_id', '')
|
|
| 75 |
- session_id = request.POST.get('session_id', '')
|
|
| 76 |
- photo_id = request.POST.get('photo_id', '')
|
|
| 77 |
- |
|
| 78 |
- photo = request.FILES.get('photo', '')
|
|
| 79 |
- |
|
| 80 |
- if not (lensman_id and session_id and photo): |
|
| 81 |
- return response(PhotoStatusCode.PARAMS_ERROR) |
|
| 82 |
- |
|
| 83 |
- try: |
|
| 84 |
- LensmanInfo.objects.get(lensman_id=lensman_id) |
|
| 85 |
- except LensmanInfo.DoesNotExist: |
|
| 86 |
- return response(LensmanStatusCode.LENSMAN_NOT_FOUND) |
|
| 87 |
- |
|
| 88 |
- photo_info = file_save(photo, prefix='photo', ext='.jpeg', watermark=True) |
|
| 89 |
- |
|
| 90 |
- photo, created = PhotosInfo.objects.get_or_create( |
|
| 91 |
- lensman_id=lensman_id, |
|
| 92 |
- session_id=session_id, |
|
| 93 |
- photo_id=photo_id, |
|
| 94 |
- p_photo_path=photo_info.photo_watermark_path, |
|
| 95 |
- m_photo_path=photo_info.photo_path, |
|
| 96 |
- ) |
|
| 97 |
- |
|
| 98 |
- return response(200, 'Photo Upload Success', u'照片上传成功', photo.data) |
|
| 99 |
- |
|
| 100 |
- |
|
| 101 |
-@logit |
|
| 102 |
-@transaction.atomic |
|
| 103 |
-def session_join_api(request): |
|
| 104 |
- """ Session 详情 """ |
|
| 105 |
- user_id = request.POST.get('user_id', '')
|
|
| 106 |
- session_id = request.POST.get('session_id', '')
|
|
| 107 |
- lensman_id = request.POST.get('lensman_id', '')
|
|
| 108 |
- nickname = request.POST.get('nickname', '')
|
|
| 109 |
- current_id = -1 |
|
| 110 |
- |
|
| 111 |
- # 摄影师校验 |
|
| 112 |
- try: |
|
| 113 |
- lensman = UserInfo.objects.get(user_id=lensman_id) |
|
| 114 |
- except UserInfo.DoesNotExist: |
|
| 115 |
- return response(LensmanStatusCode.LENSMAN_NOT_FOUND) |
|
| 116 |
- |
|
| 117 |
- # 判断 user_id 是否存在，如果不存在，则直接分配帐户 |
|
| 118 |
- user, user_created = UserInfo.objects.get_or_create(user_id=user_id, defaults={
|
|
| 119 |
- 'user_id': CurtailUUID.uuid(UserInfo, 'user_id'), |
|
| 120 |
- 'user_status': UserInfo.ASSIGN, |
|
| 121 |
- 'assign_ip': client_ip(request), |
|
| 122 |
- 'assign_at': tc.utc_datetime(), |
|
| 123 |
- }) |
|
| 124 |
- user_id = user.user_id |
|
| 125 |
- |
|
| 126 |
- # 判断通过 session_id 创建的群组是否存在，如果不存在，则直接创建 |
|
| 127 |
- group, group_created = GroupInfo.objects.select_for_update().get_or_create(session_id=session_id, group_from=GroupInfo.SESSION_GROUP, defaults={
|
|
| 128 |
- 'group_id': CurtailUUID.uuid(GroupInfo, 'group_id'), |
|
| 129 |
- # 'admin_id': lensman_id, |
|
| 130 |
- 'group_name': lensman.final_nickname, |
|
| 131 |
- 'group_default_avatar': 0, |
|
| 132 |
- }) |
|
| 133 |
- group_id = group.group_id |
|
| 134 |
- |
|
| 135 |
- # Redis 群组数据缓存 |
|
| 136 |
- group_info = set_group_info(group) if group_created else get_group_info(group_id) |
|
| 137 |
- |
|
| 138 |
- # 判断 group_id/user_id 的群组用户是否存在，如果不存在，则直接创建 |
|
| 139 |
- group_user, group_user_created = GroupUserInfo.objects.get_or_create(group_id=group_id, user_id=user_id, defaults={
|
|
| 140 |
- # 'current_id': int(r.get(GROUP_LAST_PHOTO_PK % group_id) or -1), |
|
| 141 |
- 'current_id': current_id, # 通过扫描 session_id 二维码进群的用户，默认可以查看该群组所有照片 |
|
| 142 |
- 'nickname': nickname or user.final_nickname, |
|
| 143 |
- 'avatar': user.avatar, |
|
| 144 |
- # 'admin': group_created, |
|
| 145 |
- 'user_status': GroupUserInfo.PASSED, |
|
| 146 |
- 'passed_at': tc.utc_datetime(), |
|
| 147 |
- }) |
|
| 148 |
- if not group_user_created: |
|
| 149 |
- group_user.current_id = current_id |
|
| 150 |
- group_user.user_status = GroupUserInfo.PASSED |
|
| 151 |
- group_user.save() |
|
| 152 |
- |
|
| 153 |
- # 管理员处理 |
|
| 154 |
- tobe_admin = not GroupUserInfo.objects.filter(admin=True, status=True).exists() |
|
| 155 |
- if tobe_admin: |
|
| 156 |
- group.admin_id = user_id |
|
| 157 |
- group.save() |
|
| 158 |
- group_user.admin = True |
|
| 159 |
- group_user.save() |
|
| 160 |
- |
|
| 161 |
- # Redis 群组用户数据缓存 |
|
| 162 |
- group_users = set_group_users_info(group) |
|
| 163 |
- |
|
| 164 |
- # Redis 群组通过集合缓存 |
|
| 165 |
- r.srem(GROUP_USERS_REFUSED_SET % group_id, user_id) |
|
| 166 |
- r.srem(GROUP_USERS_DELETED_SET % group_id, user_id) |
|
| 167 |
- r.srem(GROUP_USERS_QUIT_SET % group_id, user_id) |
|
| 168 |
- r.sadd(GROUP_USERS_PASSED_SET % group_id, user_id) |
|
| 169 |
- |
|
| 170 |
- # |
|
| 171 |
- if group_created: |
|
| 172 |
- # 获取 Session 照片 |
|
| 173 |
- photos = PhotosInfo.objects.filter(session_id=session_id, status=True) |
|
| 174 |
- |
|
| 175 |
- # 获取摄影师定价 |
|
| 176 |
- price_info = get_lensman_price_fixed(lensman_id) |
|
| 177 |
- |
|
| 178 |
- group_photo = None |
|
| 179 |
- for photo in photos: |
|
| 180 |
- photo_info = file_save(photo_path=photo.p_photo_path, prefix='photo', ext='.jpeg', thumbnail=True) |
|
| 181 |
- |
|
| 182 |
- # 群组照片记录创建 |
|
| 183 |
- group_photo, created = GroupPhotoInfo.objects.get_or_create( |
|
| 184 |
- group_id=group_id, |
|
| 185 |
- user_id=user_id, |
|
| 186 |
- photo_md5=photo_info.photo_md5, |
|
| 187 |
- defaults={
|
|
| 188 |
- 'nickname': user.final_nickname, |
|
| 189 |
- 'avatar': user.avatar, |
|
| 190 |
- 'photo_path': photo_info.photo_watermark_path, |
|
| 191 |
- 'has_watermark': True, |
|
| 192 |
- 'photo_w': photo_info.photo_w, |
|
| 193 |
- 'photo_h': photo_info.photo_h, |
|
| 194 |
- 'photo_thumbnail_path': photo_info.photo_thumbnail_path, |
|
| 195 |
- 'photo_thumbnail_w': photo_info.photo_thumbnail_w, |
|
| 196 |
- 'photo_thumbnail_h': photo_info.photo_thumbnail_h, |
|
| 197 |
- 'photo_thumbnail2_path': photo_info.photo_thumbnail2_path, |
|
| 198 |
- 'photo_thumbnail2_w': photo_info.photo_thumbnail2_w, |
|
| 199 |
- 'photo_thumbnail2_h': photo_info.photo_thumbnail2_h, |
|
| 200 |
- 'photo_from': GroupPhotoInfo.SESSION_GROUP, |
|
| 201 |
- 'session_id': photo.session_id, |
|
| 202 |
- 'lensman_id': photo.lensman_id, |
|
| 203 |
- 'lensman_photo_id': photo.photo_id, |
|
| 204 |
- 'nomark': price_info.get('nomark', 999),
|
|
| 205 |
- 'origin': price_info.get('origin', 999),
|
|
| 206 |
- } |
|
| 207 |
- ) |
|
| 208 |
- |
|
| 209 |
- if group_photo: |
|
| 210 |
- # 设置群组最后一张照片PK |
|
| 211 |
- r.set(GROUP_LAST_PHOTO_PK % group_id, group_photo.pk) |
|
| 212 |
- |
|
| 213 |
- # Redis 群组数据缓存 |
|
| 214 |
- set_group_info(group) |
|
| 215 |
- |
|
| 216 |
- # 获取从 current_id 到 now 的群组照片列表 |
|
| 217 |
- group_photos = GroupPhotoInfo.objects.filter( |
|
| 218 |
- group_id=group_id, |
|
| 219 |
- status=True, |
|
| 220 |
- pk__gt=group_user.current_id, |
|
| 221 |
- ).order_by( |
|
| 222 |
- '-pk' |
|
| 223 |
- ) |
|
| 224 |
- latest_photo = group_photos.first() |
|
| 225 |
- |
|
| 226 |
- return response(200, 'Apply Join Session Group Success', u'申请加入摄影师群成功', {
|
|
| 227 |
- 'current_id': latest_photo and latest_photo.pk or current_id, |
|
| 228 |
- 'photos': [photo.photo_info(user_id) for photo in group_photos], |
|
| 229 |
- 'group_id': group_id, |
|
| 230 |
- 'group': group_info, |
|
| 231 |
- 'user_id': user_id, |
|
| 232 |
- 'users': group_users, |
|
| 233 |
- }) |
|
| 234 |
- |
|
| 235 |
- |
|
| 236 |
-@logit |
|
| 237 |
-def session_detail(request, session_id): |
|
| 238 |
- photos = PhotosInfo.objects.filter(session_id=session_id, status=True) |
|
| 239 |
- return render(request, 'photo/session_detail.html', {'photos': photos})
|
|
| 240 |
- |
|
| 241 |
- |
|
| 242 |
-@logit |
|
| 243 |
-def photo_standard(request, photo_id): |
|
| 244 |
- photo = PhotosInfo.objects.get(photo_id=photo_id) |
|
| 245 |
- return render(request, 'photo/photo_detail.html', {'photo_url': photo.p_photo_url})
|
|
| 246 |
- |
|
| 247 |
- |
|
| 248 |
-@logit |
|
| 249 |
-def photo_standard_api(request, photo_id): |
|
| 250 |
- photo = PhotosInfo.objects.get(photo_id=photo_id) |
|
| 251 |
- return response(200, 'Get Photo Detail Success', u'获取照片详情成功', {
|
|
| 252 |
- 'photo': photo.detail, |
|
| 253 |
- }) |
|
| 254 |
- |
|
| 255 |
- |
|
| 256 |
-@logit |
|
| 257 |
-def photo_medium(request, photo_id): |
|
| 258 |
- photo = PhotosInfo.objects.get(photo_id=photo_id) |
|
| 259 |
- return render(request, 'photo/photo_detail.html', {'photo_url': photo.m_photo_url})
|
|
| 260 |
- |
|
| 261 |
- |
|
| 262 |
-@logit |
|
| 263 |
-def photo_large(request, photo_id): |
|
| 264 |
- photo = PhotosInfo.objects.get(photo_id=photo_id) |
|
| 265 |
- return render(request, 'photo/photo_detail.html', {'photo_url': photo.l_photo_url})
|
|
| 266 |
- |
|
| 267 |
- |
|
| 268 |
-@logit |
|
| 269 |
-def photo_raw(request, photo_id): |
|
| 270 |
- photo = PhotosInfo.objects.get(photo_id=photo_id) |
|
| 271 |
- return render(request, 'photo/photo_detail.html', {'photo_url': photo.r_photo_url})
|
|
| 272 |
- |
|
| 273 |
- |
|
| 274 |
-class PhotoInfoViewSet(viewsets.ModelViewSet): |
|
| 275 |
- queryset = PhotosInfo.objects.all().order_by('-pk')
|
|
| 276 |
- serializer_class = PhotosInfoSerializer |
@@ -99,33 +99,6 @@ class MarketCodeStatusCode(BaseStatusCode): |
||
| 99 | 99 |
""" 一物一码相关错误码 5050xx """ |
| 100 | 100 |
MARKET_CODE_NOT_FOUND = StatusCodeField(505001, 'Market Code Not Found', description=u'一物一码不存在') |
| 101 | 101 |
|
| 102 |
- |
|
| 103 |
-class LensmanStatusCode(BaseStatusCode): |
|
| 104 |
- """ 摄影师相关错误码 4000xx """ |
|
| 105 |
- LENSMAN_NOT_FOUND = StatusCodeField(400001, 'Lensman Not Found', description=u'摄影师不存在') |
|
| 106 |
- # 密码 |
|
| 107 |
- LENSMAN_PASSWORD_ERROR = StatusCodeField(400002, 'Lensman Password Error', description=u'摄影师密码错误') |
|
| 108 |
- # 手机号 |
|
| 109 |
- LENSMAN_PHONE_ALREADY_EXISTS = StatusCodeField(400005, 'Lensman Phone Already Exists', description=u'手机号已经存在') |
|
| 110 |
- # 状态 |
|
| 111 |
- LENSMAN_ALREADY_NOT_UNVERIFIED = StatusCodeField(400010, 'Lensman Already Not Unverified', description=u'摄影师帐号已激活') |
|
| 112 |
- LENSMAN_NOT_ACTIVATED = StatusCodeField(400015, 'Lensman Not Activated', description=u'摄影师帐号未激活') |
|
| 113 |
- # 类别 |
|
| 114 |
- LENSMAN_TYPE_NOT_EXISTS = StatusCodeField(400020, 'Lensman Type Not Exists', description=u'摄影师类别不存在') |
|
| 115 |
- |
|
| 116 |
- |
|
| 117 |
-class TourGuideStatusCode(BaseStatusCode): |
|
| 118 |
- """ 导游相关错误码 4001xx """ |
|
| 119 |
- TOURGUIDE_NOT_FOUND = StatusCodeField(400101, 'Tour Guide Not Found', description=u'导游不存在') |
|
| 120 |
- # 密码 |
|
| 121 |
- TOURGUIDE_PASSWORD_ERROR = StatusCodeField(400102, 'Tour Guide Password Error', description=u'导游密码错误') |
|
| 122 |
- # 手机号 |
|
| 123 |
- TOURGUIDE_PHONE_ALREADY_EXISTS = StatusCodeField(400105, 'Tour Guide Phone Already Exists', description=u'手机号已经存在') |
|
| 124 |
- # 状态 |
|
| 125 |
- TOURGUIDE_ALREADY_NOT_UNVERIFIED = StatusCodeField(400110, 'Tour Guide Already Not Unverified', description=u'导游帐号已激活') |
|
| 126 |
- TOURGUIDE_NOT_ACTIVATED = StatusCodeField(400115, 'Tour Guide Not Activated', description=u'导游帐号未激活') |
|
| 127 |
- |
|
| 128 |
- |
|
| 129 | 102 |
class AdministratorStatusCode(BaseStatusCode): |
| 130 | 103 |
""" 操作员相关错误码 4002xx """ |
| 131 | 104 |
ADMINISTRATOR_NOT_FOUND = StatusCodeField(400201, 'Administrator Not Found', description=u'管理员不存在') |
@@ -177,86 +150,10 @@ class WechatStatusCode(BaseStatusCode): |
||
| 177 | 150 |
UNIONID_NOT_FOUND = StatusCodeField(400702, 'Unionid Not Found', description=u'微信 UNIONID 不存在') |
| 178 | 151 |
OPENID_NOT_FOUND = StatusCodeField(400703, 'OPENID Not Found', description=u'微信 OPENID 不存在') |
| 179 | 152 |
|
| 180 |
- |
|
| 181 |
-class PhotoStatusCode(BaseStatusCode): |
|
| 182 |
- """ 照片相关错误码 4010xx """ |
|
| 183 |
- PARAMS_ERROR = StatusCodeField(401001, 'Params Error', description=u'参数错误') |
|
| 184 |
- |
|
| 185 |
- |
|
| 186 |
-class GroupStatusCode(BaseStatusCode): |
|
| 187 |
- """ 群组/团相关错误码 4020xx """ |
|
| 188 |
- GROUP_NOT_FOUND = StatusCodeField(402001, 'Group Not Found', description=u'群组不存在') |
|
| 189 |
- GROUP_HAS_LOCKED = StatusCodeField(402002, 'Group Has Locked', description=u'群组已锁定') |
|
| 190 |
- # 管理员 |
|
| 191 |
- NOT_GROUP_ADMIN = StatusCodeField(402010, 'Not Group Admin', description=u'非群组管理员') |
|
| 192 |
- NOT_GROUP_SUBADMIN = StatusCodeField(402011, 'Not Group Sub Admin', description=u'非群组协同管理员') |
|
| 193 |
- ADMIN_CANNOT_HANDLE_SELF = StatusCodeField(402012, 'Admin Cannot Handle Self', description=u'群组管理员无法操作自身') |
|
| 194 |
- # 旅行团 |
|
| 195 |
- ONLY_ONE_ACTIVE_GROUP_ALLOWED = StatusCodeField(402040, 'Only One Active Group Allowed', description=u'只能创建一个活跃团') |
|
| 196 |
- ACTIVE_GROUP_NOT_FOUND = StatusCodeField(402041, 'Active Group Not Found', description=u'活跃团不存在') |
|
| 197 |
- GROUP_HAS_ENDED = StatusCodeField(402042, 'Group Has Ended', description=u'群组已结束') |
|
| 198 |
- # 其他 |
|
| 199 |
- GROUP_PHOTO_NOT_EMPTY = StatusCodeField(402099, 'Group Photo Not Empty', description=u'群组照片不为空') |
|
| 200 |
- |
|
| 201 |
- |
|
| 202 |
-class GroupUserStatusCode(BaseStatusCode): |
|
| 203 |
- """ 群组/团用户相关错误码 4021xx """ |
|
| 204 |
- GROUP_USER_NOT_FOUND = StatusCodeField(402101, 'Group User Not Found', description=u'群组用户不存在') |
|
| 205 |
- GROUP_USER_HAS_DELETED = StatusCodeField(402102, 'Group User Has Deleted', description=u'群组用户被移除') |
|
| 206 |
- # 旅行团 |
|
| 207 |
- USER_HAS_NOT_JOIN_GROUP = StatusCodeField(402131, 'User Has Not Join Group', description=u'用户未加入旅行团') |
|
| 208 |
- |
|
| 209 |
- |
|
| 210 |
-class GroupPhotoStatusCode(BaseStatusCode): |
|
| 211 |
- """ 群组照片（飞图）相关错误码 4022xx """ |
|
| 212 |
- GROUP_PHOTO_NOT_FOUND = StatusCodeField(402201, 'Group Photo Not Found', description=u'飞图不存在') |
|
| 213 |
- # 上传 |
|
| 214 |
- DUPLICATE_UPLOAD = StatusCodeField(402210, 'Duplicate Upload', description=u'重复上传') |
|
| 215 |
- # 点赞 |
|
| 216 |
- THUMB_UP_NOT_FOUND = StatusCodeField(402220, 'Thumb Up Not Found', description=u'未点赞') |
|
| 217 |
- DUPLICATE_THUMB_UP = StatusCodeField(402221, 'Duplicate Thumb Up', description=u'重复点赞') |
|
| 218 |
- # 评论 |
|
| 219 |
- COMMENT_CONTENT_EMPTY = StatusCodeField(402230, 'Comment Content Empty', description=u'评论内容为空') |
|
| 220 |
- |
|
| 221 |
- |
|
| 222 | 153 |
class ScreenStatusCode(BaseStatusCode): |
| 223 | 154 |
""" 群组/团相关错误码 4030xx """ |
| 224 | 155 |
QRCODE_NOT_SCAN = StatusCodeField(403001, 'QRCode Not Scan', description=u'二维码未扫描') |
| 225 | 156 |
|
| 226 |
- |
|
| 227 |
-class OrderStatusCode(BaseStatusCode): |
|
| 228 |
- """ 订单／支付相关错误码 4040xx """ |
|
| 229 |
- WX_UNIFIED_ORDER_FAIL = StatusCodeField(404000, 'WX Unified Order Fail', description=u'微信统一下单失败') |
|
| 230 |
- WX_ORDER_NOT_FOUND = StatusCodeField(404001, 'WX Order Not Found', description=u'订单不存在') |
|
| 231 |
- WX_ORDER_NOT_PAY = StatusCodeField(404002, 'WX Order Not Pay', description=u'订单未支付') |
|
| 232 |
- WX_ORDER_PAYING = StatusCodeField(404003, 'WX Order Paying', description=u'订单支付中') |
|
| 233 |
- WX_ORDER_PAY_FAIL = StatusCodeField(404009, 'WX Order Pay Fail', description=u'微信支付失败') |
|
| 234 |
- SIGN_CHECK_FAIL = StatusCodeField(404010, 'Sign Check Fail', description=u'签名校验失败') |
|
| 235 |
- FEE_CHECK_FAIL = StatusCodeField(404011, 'FEE Check Fail', description=u'金额校验失败') |
|
| 236 |
- NO_DETAIL_PERMISSION = StatusCodeField(404015, 'No Detail Permission', description=u'无详情权限') |
|
| 237 |
- WX_ORDER_PAID_ALREADY_EXISTS = StatusCodeField(404020, 'WX Order Paid Already Exists', description=u'照片已购买') |
|
| 238 |
- |
|
| 239 |
- |
|
| 240 |
-class PayStatusCode(BaseStatusCode): |
|
| 241 |
- """ 支付相关错误码 4041xx """ |
|
| 242 |
- |
|
| 243 |
- |
|
| 244 |
-class WithdrawStatusCode(BaseStatusCode): |
|
| 245 |
- """ 提现相关错误码 4042xx """ |
|
| 246 |
- BALANCE_NOT_ENOUGH = StatusCodeField(404200, 'Balance Not Enough', description=u'提现金额不足') |
|
| 247 |
- |
|
| 248 |
- |
|
| 249 |
-class MessageStatusCode(BaseStatusCode): |
|
| 250 |
- """ 消息相关错误码 4090xx """ |
|
| 251 |
- MESSAGE_NOT_FOUND = StatusCodeField(409001, 'Message Not Found', description=u'消息不存在') |
|
| 252 |
- |
|
| 253 |
- |
|
| 254 |
-class TokenStatusCode(BaseStatusCode): |
|
| 255 |
- """ 票据相关错误码 4090xx """ |
|
| 256 |
- TOKEN_NOT_FOUND = StatusCodeField(409901, 'Token Not Found', description=u'票据不存在') |
|
| 257 |
- TOKEN_HAS_EXPIRED = StatusCodeField(409911, 'Token Has Expired', description=u'票据过期，请刷新重扫二维码') |
|
| 258 |
- |
|
| 259 |
- |
|
| 260 | 157 |
class PermissionStatusCode(BaseStatusCode): |
| 261 | 158 |
""" 4099xx 权限相关错误码 """ |
| 262 | 159 |
PERMISSION_DENIED = StatusCodeField(409900, 'Permission Denied', description=u'权限不足') |
@@ -1,22 +0,0 @@ |
||
| 1 |
-# -*- coding: utf-8 -*- |
|
| 2 |
- |
|
| 3 |
-from isoweek import Week |
|
| 4 |
-from TimeConvert import TimeConvert as tc |
|
| 5 |
- |
|
| 6 |
-from utils.redis.connect import r |
|
| 7 |
-from utils.redis.rkeys import TODAY_INCOME, TOTAL_INCOME, WEEK_INCOME, WEEK_SOLD |
|
| 8 |
- |
|
| 9 |
- |
|
| 10 |
-def set_brief_info(uid, ptype, fee, dt=None): |
|
| 11 |
- """ 更新简报信息 """ |
|
| 12 |
- 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()) |
|
| 13 |
- |
|
| 14 |
- # 总收入 |
|
| 15 |
- r.incr(TOTAL_INCOME % (uid, ptype), fee) |
|
| 16 |
- # 周收入 |
|
| 17 |
- r.incr(WEEK_INCOME % (uid, ptype, week), fee) |
|
| 18 |
- # 日收入 |
|
| 19 |
- r.incr(TODAY_INCOME % (uid, ptype, ymd), fee) |
|
| 20 |
- |
|
| 21 |
- # 周售出 |
|
| 22 |
- r.incr(WEEK_SOLD % (uid, ptype, week)) |
@@ -1,58 +0,0 @@ |
||
| 1 |
-# -*- coding: utf-8 -*- |
|
| 2 |
- |
|
| 3 |
-from group.models import GroupInfo, GroupPhotoInfo, GroupUserInfo, PhotoCommentInfo, PhotoThumbUpInfo |
|
| 4 |
-from utils.redis.connect import r |
|
| 5 |
-from utils.redis.rgroup import set_group_photo_data, set_group_users_info |
|
| 6 |
-from utils.redis.rkeys import (GROUP_LAST_PHOTO_PK, GROUP_PHOTO_WATCHER_SET, GROUP_USERS_APPLYING_SET, |
|
| 7 |
- GROUP_USERS_DELETED_SET, GROUP_USERS_PASSED_SET, GROUP_USERS_REFUSED_SET) |
|
| 8 |
- |
|
| 9 |
- |
|
| 10 |
-def retrieve_group_data(): |
|
| 11 |
- """ 群组数据 """ |
|
| 12 |
- groups = GroupInfo.objects.filter(status=True) |
|
| 13 |
- for group in groups: |
|
| 14 |
- # 群组照片 |
|
| 15 |
- set_group_photo_data(group.group_id) |
|
| 16 |
- # 群组用户 |
|
| 17 |
- set_group_users_info(group) |
|
| 18 |
- |
|
| 19 |
- |
|
| 20 |
-def retrieve_last_pk(): |
|
| 21 |
- """ 群组最后一张照片PK """ |
|
| 22 |
- groups = GroupInfo.objects.filter(status=True) |
|
| 23 |
- for group in groups: |
|
| 24 |
- group_photo = GroupPhotoInfo.objects.filter(group_id=group.group_id, status=True).last() |
|
| 25 |
- r.set(GROUP_LAST_PHOTO_PK % group.group_id, group_photo and group_photo.pk or -1) |
|
| 26 |
- |
|
| 27 |
- |
|
| 28 |
-def retrieve_group_user_status(): |
|
| 29 |
- """ 群组用户状态 """ |
|
| 30 |
- group_users = GroupUserInfo.objects.filter(status=True) |
|
| 31 |
- for group_user in group_users: |
|
| 32 |
- group_id, user_id = group_user.group_id, group_user.user_id |
|
| 33 |
- if group_user.user_status == GroupUserInfo.PASSED: |
|
| 34 |
- r.sadd(GROUP_USERS_PASSED_SET % group_id, user_id) |
|
| 35 |
- elif group_user.user_status == GroupUserInfo.DELETED: |
|
| 36 |
- r.sadd(GROUP_USERS_DELETED_SET % group_id, user_id) |
|
| 37 |
- elif group_user.user_status == GroupUserInfo.APPLYING: |
|
| 38 |
- r.sadd(GROUP_USERS_APPLYING_SET % group_id, user_id) |
|
| 39 |
- elif group_user.user_status == GroupUserInfo.REFUSED: |
|
| 40 |
- r.sadd(GROUP_USERS_REFUSED_SET % group_id, user_id) |
|
| 41 |
- |
|
| 42 |
- |
|
| 43 |
-def retrieve_group_photo_watchers(): |
|
| 44 |
- group_photos = GroupPhotoInfo.objects.filter(status=True) |
|
| 45 |
- for group_photo in group_photos: |
|
| 46 |
- photo_comments = PhotoCommentInfo.objects.filter(photo_id=group_photo.photo_id, status=True) |
|
| 47 |
- for photo_comment in photo_comments: |
|
| 48 |
- r.sadd(GROUP_PHOTO_WATCHER_SET % group_photo.pk, photo_comment.user_id) |
|
| 49 |
- photo_thumbups = PhotoThumbUpInfo.objects.filter(photo_id=group_photo.photo_id, status=True) |
|
| 50 |
- for photo_thumbup in photo_thumbups: |
|
| 51 |
- r.sadd(GROUP_PHOTO_WATCHER_SET % group_photo.pk, photo_thumbup.user_id) |
|
| 52 |
- |
|
| 53 |
- |
|
| 54 |
-def retrieve_redis_data(): |
|
| 55 |
- retrieve_group_data() |
|
| 56 |
- retrieve_last_pk() |
|
| 57 |
- retrieve_group_user_status() |
|
| 58 |
- retrieve_group_photo_watchers() |
@@ -1,147 +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 (GROUP_INFO, GROUP_PHOTO_COMMENT_LIST, GROUP_PHOTO_DATA, GROUP_PHOTO_THUMB_UP, |
|
| 7 |
- GROUP_PHOTO_THUMB_UP_LIST, GROUP_PHOTO_WATCHER_SET, GROUP_USERS_INFO, |
|
| 8 |
- GROUP_USERS_KV_INFO) |
|
| 9 |
- |
|
| 10 |
- |
|
| 11 |
-def set_group_info(group): |
|
| 12 |
- """ 设置群组信息 """ |
|
| 13 |
- r.setexjson(GROUP_INFO % group.group_id, r.REDIS_EXPIRED_ONE_MONTH, group.data, cls=DjangoJSONEncoder) |
|
| 14 |
- return group.data |
|
| 15 |
- |
|
| 16 |
- |
|
| 17 |
-def set_group_info_by_id(group_id): |
|
| 18 |
- """ 设置群组信息 """ |
|
| 19 |
- from group.models import GroupInfo |
|
| 20 |
- try: |
|
| 21 |
- group = GroupInfo.objects.get(group_id=group_id) |
|
| 22 |
- except GroupInfo.DoesNotExist: |
|
| 23 |
- return {}
|
|
| 24 |
- return set_group_info(group) |
|
| 25 |
- |
|
| 26 |
- |
|
| 27 |
-def get_group_info(group_id): |
|
| 28 |
- """ 获取群组信息 """ |
|
| 29 |
- return r.getjson(GROUP_INFO % group_id) or set_group_info_by_id(group_id) |
|
| 30 |
- |
|
| 31 |
- |
|
| 32 |
-# 群组用户信息相关 |
|
| 33 |
- |
|
| 34 |
- |
|
| 35 |
-def set_group_users_info(group): |
|
| 36 |
- """ 设置群组用户信息 """ |
|
| 37 |
- group_users = group.users(admin=False) |
|
| 38 |
- |
|
| 39 |
- group_users_data = {
|
|
| 40 |
- 'group_users': group_users, |
|
| 41 |
- 'admin_id': group.admin_id, |
|
| 42 |
- } |
|
| 43 |
- r.setexjson(GROUP_USERS_INFO % group.group_id, r.REDIS_EXPIRED_ONE_MONTH, group_users_data, cls=DjangoJSONEncoder) |
|
| 44 |
- |
|
| 45 |
- group_users_kv_data = {user_info.get('user_id', ''): user_info for user_info in group_users.get('passed', [])}
|
|
| 46 |
- r.setexjson(GROUP_USERS_KV_INFO % group.group_id, r.REDIS_EXPIRED_ONE_MONTH, group_users_kv_data, cls=DjangoJSONEncoder) |
|
| 47 |
- |
|
| 48 |
- return group_users_data, group_users_kv_data |
|
| 49 |
- |
|
| 50 |
- |
|
| 51 |
-def set_group_users_info_by_id(group_id): |
|
| 52 |
- """ 设置群组用户信息 """ |
|
| 53 |
- from group.models import GroupInfo |
|
| 54 |
- try: |
|
| 55 |
- group = GroupInfo.objects.get(group_id=group_id) |
|
| 56 |
- except GroupInfo.DoesNotExist: |
|
| 57 |
- return {}, {}
|
|
| 58 |
- return set_group_users_info(group) |
|
| 59 |
- |
|
| 60 |
- |
|
| 61 |
-def get_group_users_info(group_id, user_id): |
|
| 62 |
- """ 获取群组用户信息 """ |
|
| 63 |
- group_users_data = r.getjson(GROUP_USERS_INFO % group_id) or set_group_users_info_by_id(group_id)[0] |
|
| 64 |
- group_users, admin_id = group_users_data.get('group_users', {}), group_users_data.get('admin_id', '')
|
|
| 65 |
- if group_users and user_id != admin_id: |
|
| 66 |
- [group_users.pop(k) for k in ['applying_count', 'applying']] |
|
| 67 |
- return group_users |
|
| 68 |
- |
|
| 69 |
- |
|
| 70 |
-def get_group_users_kv_info(group_id): |
|
| 71 |
- """ 获取群组用户信息 """ |
|
| 72 |
- return r.getjson(GROUP_USERS_KV_INFO % group_id) or set_group_users_info_by_id(group_id)[1] |
|
| 73 |
- |
|
| 74 |
- |
|
| 75 |
-# 群组照片相关 |
|
| 76 |
- |
|
| 77 |
- |
|
| 78 |
-def set_group_photo_data(group_id): |
|
| 79 |
- """ 设置群组照片数据信息 """ |
|
| 80 |
- from group.models import GroupPhotoInfo |
|
| 81 |
- group_photos = GroupPhotoInfo.objects.filter(group_id=group_id, status=True) |
|
| 82 |
- group_photos = [photo.photo_data for photo in group_photos] |
|
| 83 |
- r.setjson(GROUP_PHOTO_DATA % group_id, group_photos) |
|
| 84 |
- return group_photos |
|
| 85 |
- |
|
| 86 |
- |
|
| 87 |
-def get_group_photo_data(group_id): |
|
| 88 |
- """ 获取群组照片数据信息 """ |
|
| 89 |
- return r.getjson(GROUP_PHOTO_DATA % group_id, default='[]') or set_group_photo_data(group_id) |
|
| 90 |
- |
|
| 91 |
- |
|
| 92 |
-def set_group_photo_thumbup_flag(photo_id, user_id): |
|
| 93 |
- """ 设置群组照片用户点赞标识信息 """ |
|
| 94 |
- r.setex(GROUP_PHOTO_THUMB_UP % (photo_id, user_id), r.REDIS_EXPIRED_ONE_MONTH, True) |
|
| 95 |
- |
|
| 96 |
- |
|
| 97 |
-def del_group_photo_thumbup_flag(photo_id, user_id): |
|
| 98 |
- """ 删除群组照片用户点赞标识信息 """ |
|
| 99 |
- r.delete(GROUP_PHOTO_THUMB_UP % (photo_id, user_id)) |
|
| 100 |
- |
|
| 101 |
- |
|
| 102 |
-def get_group_photo_thumbup_flag(photo_id, user_id): |
|
| 103 |
- """ 获取群组照片用户点赞标识信息 """ |
|
| 104 |
- if r.exists(GROUP_PHOTO_THUMB_UP % (photo_id, user_id)): |
|
| 105 |
- return True |
|
| 106 |
- |
|
| 107 |
- from group.models import PhotoThumbUpInfo |
|
| 108 |
- if PhotoThumbUpInfo.objects.filter(photo_id=photo_id, user_id=user_id, thumbup=True, status=True).exists(): |
|
| 109 |
- set_group_photo_thumbup_flag(photo_id, user_id) |
|
| 110 |
- return True |
|
| 111 |
- |
|
| 112 |
- return False |
|
| 113 |
- |
|
| 114 |
- |
|
| 115 |
-def set_group_photo_comment_list(photo_id): |
|
| 116 |
- """ 设置群组照片用户评论列表 """ |
|
| 117 |
- from group.models import PhotoCommentInfo |
|
| 118 |
- photo_comments = PhotoCommentInfo.objects.filter(photo_id=photo_id, status=True) |
|
| 119 |
- photo_comments = [comment.comment_info for comment in photo_comments] |
|
| 120 |
- r.setjson(GROUP_PHOTO_COMMENT_LIST % photo_id, photo_comments, cls=DjangoJSONEncoder) |
|
| 121 |
- return photo_comments |
|
| 122 |
- |
|
| 123 |
- |
|
| 124 |
-def get_group_photo_comment_list(photo_id): |
|
| 125 |
- """ 获取群组照片用户评论列表 """ |
|
| 126 |
- return r.getjson(GROUP_PHOTO_COMMENT_LIST % photo_id, default='[]') or set_group_photo_comment_list(photo_id) |
|
| 127 |
- |
|
| 128 |
- |
|
| 129 |
-def set_group_photo_thumbup_list(photo_id): |
|
| 130 |
- """ 设置群组照片用户点赞列表 """ |
|
| 131 |
- from group.models import PhotoThumbUpInfo |
|
| 132 |
- photo_thumbups = PhotoThumbUpInfo.objects.filter(photo_id=photo_id, thumbup=True, status=True) |
|
| 133 |
- photo_thumbups = [thumbup.thumbup_info for thumbup in photo_thumbups] |
|
| 134 |
- r.setjson(GROUP_PHOTO_THUMB_UP_LIST % photo_id, photo_thumbups, cls=DjangoJSONEncoder) |
|
| 135 |
- return photo_thumbups |
|
| 136 |
- |
|
| 137 |
- |
|
| 138 |
-def get_group_photo_thumbup_list(photo_id): |
|
| 139 |
- """ 获取群组照片用户点赞列表 """ |
|
| 140 |
- return r.getjson(GROUP_PHOTO_THUMB_UP_LIST % photo_id, default='[]') or set_group_photo_thumbup_list(photo_id) |
|
| 141 |
- |
|
| 142 |
- |
|
| 143 |
-def get_group_photo_watchers(photo_id, discarders=None): |
|
| 144 |
- """ 获取群组照片用户关注列表 """ |
|
| 145 |
- watchers = r.smembers(GROUP_PHOTO_WATCHER_SET % photo_id) |
|
| 146 |
- [watchers.discard(elem) for elem in discarders or []] |
|
| 147 |
- return watchers |
@@ -1,20 +0,0 @@ |
||
| 1 |
-# -*- coding: utf-8 -*- |
|
| 2 |
- |
|
| 3 |
-from utils.redis.connect import r |
|
| 4 |
-from utils.redis.rkeys import GUEST_ENTRANCE_CONTROL_INFO |
|
| 5 |
- |
|
| 6 |
- |
|
| 7 |
-def set_guest_entrance_control(gen): |
|
| 8 |
- """ 设置游客入口控制 """ |
|
| 9 |
- r.setjson(GUEST_ENTRANCE_CONTROL_INFO % gen.src, gen.data) |
|
| 10 |
- return gen.data |
|
| 11 |
- |
|
| 12 |
- |
|
| 13 |
-def get_guest_entrance_control(src=0): |
|
| 14 |
- """ 获取游客入口控制 """ |
|
| 15 |
- return r.getjson(GUEST_ENTRANCE_CONTROL_INFO % src) |
|
| 16 |
- |
|
| 17 |
- |
|
| 18 |
-def delete_guest_entrance_control(src=0): |
|
| 19 |
- """ 删除游客入口控制 """ |
|
| 20 |
- return r.delete(GUEST_ENTRANCE_CONTROL_INFO % src) |
@@ -1,71 +1,12 @@ |
||
| 1 |
-# -*- coding: utf-8 -*- |
|
| 2 |
- |
|
| 3 |
-# 唯一标识相关 |
|
| 4 |
-UUID_LIST = 'uuid:list' # List，唯一标识列表 |
|
| 5 |
- |
|
| 6 |
-# 用户相关 |
|
| 7 |
-PROFILE_INFO = 'profile:info:%s' # STRING，用户信息，user_id |
|
| 8 |
- |
|
| 9 |
-# 导游相关 |
|
| 10 |
-TOUR_GUIDE_GROUP_GEO_INFO = 'tour:guide:group:geo:info:%s' # ZSET，旅游团地理位置信息，group_id |
|
| 11 |
-TOUR_GUIDE_GROUP_GEO_SUBMIT_DT = 'tour:guide:group:geo:submit:dt:%s' # ZSET，旅游团地理位置最后上传时间，group_id |
|
| 12 |
-TOUR_GUIDE_GROUP_CUR_SESSION = 'tour:guide:group:cur:session:%s' # STRING，旅游团当前Session，group_id，导游设置集合时间的时候更新 |
|
| 13 |
-TOUR_GUIDE_GROUP_CUR_GATHER_INFO = 'tour:guide:group:cur:gather:info:%s' # STRING，旅游团当前Session，group_id，导游设置集合时间的时候更新 |
|
| 14 |
-TOUR_GUIDE_GROUP_USER_GEO_LIST = 'tour:guide:group:user:geo:list:%s:%s:%s' # LIST，旅游团当前用户地理位置列表，group_id、session_id、user_id |
|
| 15 |
- |
|
| 16 |
-TOUR_GUIDE_GROUP_USER_OWN = 'tour:guide:group:user:own:%s' # STRING，导游当前拥有的旅行团，user_id，导游创建旅行团的时候更新 |
|
| 17 |
-TOUR_GUIDE_GROUP_USER_BELONG = 'tour:guide:group:user:belong:%s' # STRING，用户当前所属旅行团，user_id，用户加入旅行团的时候更新 |
|
| 18 |
- |
|
| 19 |
-# 群组相关 |
|
| 20 |
-GROUP_INFO = 'group:info:%s' # STRING，群组信息，group_id |
|
| 21 |
- |
|
| 22 |
-# 群组用户相关 |
|
| 23 |
-GROUP_USERS_INFO = 'group:users:info:%s' # STRING，群组用户信息，group_id |
|
| 24 |
-GROUP_USERS_KV_INFO = 'group:users:kv:info:%s' # STRING，群组用户信息，group_id |
|
| 25 |
-GROUP_USERS_APPLYING_SET = 'group:users:applying:set:%s' # SET，群组用户申请集合，group_id |
|
| 26 |
-GROUP_USERS_PASSED_SET = 'group:users:passed:set:%s' # SET，群组用户通过集合，group_id |
|
| 27 |
-GROUP_USERS_REFUSED_SET = 'group:users:refused:set:%s' # SET，群组用户拒绝集合，group_id |
|
| 28 |
-GROUP_USERS_DELETED_SET = 'group:users:deleted:set:%s' # SET，群组用户移除集合，group_id |
|
| 29 |
-GROUP_USERS_QUIT_SET = 'group:users:quit:set:%s' # SET，群组用户退出集合，group_id |
|
| 30 |
- |
|
| 31 |
-# 群组照片相关 |
|
| 32 |
-GROUP_PHOTO_DATA = 'group:photo:data:%s' # STRING，群组数据记录，group_id |
|
| 33 |
-GROUP_PHOTO_THUMB_UP = 'group:photo:thumb:up:%s:%s' # STRING，群组照片用户点赞记录，photo_id、user_id |
|
| 34 |
-GROUP_PHOTO_COMMENT_LIST = 'group:photo:comment:list:%s' # STRING，群组照片用户评论列表，photo_id |
|
| 35 |
-GROUP_PHOTO_THUMB_UP_LIST = 'group:photo:thumb:up:list:%s' # STRING，群组照片用户点赞列表，photo_id |
|
| 36 |
-GROUP_PHOTO_WATCHER_SET = 'group:photo:watcher:set:%s' # SET，群组照片用户关注集合，photo_id，关注即评论点赞 |
|
| 37 |
-GROUP_LAST_PHOTO_PK = 'group:last:photo:pk:%s' # STRING，群组最后一张照片PK，group_id |
|
| 38 |
- |
|
| 39 |
-# 摄影师照片相关 |
|
| 40 |
-LENSMAN_PHOTO_ORDER_RECORD = 'lensman:photo:order:record:%s:%s' # STRING，摄影师照片购买记录，photo_id、user_id |
|
| 41 |
- |
|
| 42 |
-# 摄影师简报相关 |
|
| 43 |
-# 收入 |
|
| 44 |
-TOTAL_INCOME = 'total:income:%s:%s' # STRING，总收入，user_id、photo_type |
|
| 45 |
-WEEK_INCOME = 'week:income:%s:%s:%s' # STRING，周收入，user_id、photo_type、Week.thisweek().isoformat() |
|
| 46 |
-TODAY_INCOME = 'today:income:%s:%s:%s' # STRING，日收入，user_id、photo_type、tc.local_string(format='%Y%m%d') |
|
| 47 |
-# 上传 |
|
| 48 |
-TODAY_UPLOAD_PHOTO_AMOUNT = 'today:upload:photo:amount:%s:%s' # STRING，日上传照片数量，user_id、tc.local_string(format='%Y%m%d') |
|
| 49 |
-# 售出 |
|
| 50 |
-WEEK_SOLD = 'week:sold:%s:%s:%s' # STRING，周售出，user_id、photo_type、Week.thisweek().isoformat() |
|
| 51 |
- |
|
| 52 |
-# 摄影师定价相关 |
|
| 53 |
-LENSMAN_PHOTO_PRICE_FIXED = 'lensman:photo:price:fixed:%s' # STRING，摄影师照片定价(单位:分)，user_id |
|
| 54 |
- |
|
| 55 |
-# 系统消息相关 |
|
| 56 |
-SYSTEM_MESSAGE_READ_INFO = 'system:message:read:info:%s' # STRING，系统消息读取信息，user_id |
|
| 57 |
-SYSTEM_MESSAGE_DELETED_INFO = 'system:message:deleted:info:%s' # STRING，系统消息删除信息，user_id |
|
| 58 |
- |
|
| 59 |
-# 游客入口相关 |
|
| 60 |
-GUEST_ENTRANCE_CONTROL_INFO = 'guest:entrance:control:info:%s' # STRING，游客入口控制信息，src |
|
| 1 |
+# -*- coding: utf-8 -*-' |
|
| 61 | 2 |
|
| 62 | 3 |
# APP 相关 |
| 63 | 4 |
LATEST_APP_INFO = 'latest:app:info:%s' # STRING，最新 APP 信息，src |
| 64 | 5 |
APP_SETTINGS_INFO = 'app:settings:info:%s:%s:%s' # STRING，APP 设置信息，platform、channel、version |
| 65 | 6 |
APP_PATCH_INFO = 'app:patch:info:%s:%s:%s' # STRING，APP 补丁信息，platform、version、src |
| 66 | 7 |
|
| 67 |
-# BOX 相关 |
|
| 68 |
-BOX_PROGRAM_VERSION_INFO = 'box:program:version:info' # STRING，BOX 程序版本信息 |
|
| 8 |
+# 用户相关 |
|
| 9 |
+PROFILE_INFO = 'profile:info:%s' # STRING，用户信息，user_id |
|
| 69 | 10 |
|
| 70 | 11 |
# 小程序相关 |
| 71 | 12 |
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) |