num-old">
+ 'verbose_name': 'KOL 信息',
+ 'verbose_name_plural': 'KOL 信息',
+ },
+ ),
+ ]
@@ -0,0 +1,73 @@ |
||
| 1 |
+# -*- coding: utf-8 -*- |
|
| 2 |
+ |
|
| 3 |
+from django.db import models |
|
| 4 |
+from django.utils.translation import ugettext_lazy as _ |
|
| 5 |
+from django_models_ext import BaseModelMixin, upload_file_path, upload_file_url, upload_path |
|
| 6 |
+from shortuuidfield import ShortUUIDField |
|
| 7 |
+ |
|
| 8 |
+ |
|
| 9 |
+class KOLInfo(BaseModelMixin): |
|
| 10 |
+ kol_id = ShortUUIDField(_('kol_id'), max_length=32, blank=True, null=True, help_text='KOL 唯一标识', db_index=True, unique=True)
|
|
| 11 |
+ # 微信相关 |
|
| 12 |
+ unionid = models.CharField(_('unionid'), max_length=32, blank=True, null=True, help_text='微信 Unionid', db_index=True, unique=True)
|
|
| 13 |
+ openid = models.CharField(_('openid'), max_length=32, blank=True, null=True, help_text='微信 Openid', db_index=True, unique=True)
|
|
| 14 |
+ # 真实相关 |
|
| 15 |
+ name = models.CharField(_('name'), max_length=32, blank=True, null=True, help_text='KOL 姓名')
|
|
| 16 |
+ phone = models.CharField(_('phone'), max_length=11, blank=True, null=True, help_text='KOL 电话', db_index=True)
|
|
| 17 |
+ # 昵称相关 |
|
| 18 |
+ nickname = models.CharField(_('nickname'), max_length=32, blank=True, null=True, help_text='KOL 昵称')
|
|
| 19 |
+ avatar = models.ImageField(_('avatar'), upload_to=upload_path, blank=True, null=True, help_text='KOL 头像')
|
|
| 20 |
+ banner = models.ImageField(_('banner'), upload_to=upload_path, blank=True, null=True, help_text='KOL Banner图')
|
|
| 21 |
+ intro = models.TextField(_('intro'), blank=True, null=True, help_text='KOL 简介')
|
|
| 22 |
+ image = models.ImageField(_('image'), upload_to=upload_path, blank=True, null=True, help_text='KOL 简介图')
|
|
| 23 |
+ fans = models.IntegerField(_('fans'), default=0, help_text='KOL 粉丝数')
|
|
| 24 |
+ # 余额相关 |
|
| 25 |
+ fee = models.IntegerField(_('fee'), default=0, help_text='KOL 余额(分)')
|
|
| 26 |
+ total_fee = models.IntegerField(_('total_fee'), default=0, help_text='KOL 总收入(分)')
|
|
| 27 |
+ |
|
| 28 |
+ class Meta: |
|
| 29 |
+ verbose_name = _('KOL 信息')
|
|
| 30 |
+ verbose_name_plural = _('KOL 信息')
|
|
| 31 |
+ |
|
| 32 |
+ def __unicode__(self): |
|
| 33 |
+ return self.pk |
|
| 34 |
+ |
|
| 35 |
+ @property |
|
| 36 |
+ def final_nickname(self): |
|
| 37 |
+ return self.nickname or self.name |
|
| 38 |
+ |
|
| 39 |
+ @property |
|
| 40 |
+ def avatar_path(self): |
|
| 41 |
+ return upload_file_path(self.avatar) |
|
| 42 |
+ |
|
| 43 |
+ @property |
|
| 44 |
+ def avatar_url(self): |
|
| 45 |
+ return upload_file_url(self.avatar) |
|
| 46 |
+ |
|
| 47 |
+ @property |
|
| 48 |
+ def banner_path(self): |
|
| 49 |
+ return upload_file_path(self.banner) |
|
| 50 |
+ |
|
| 51 |
+ @property |
|
| 52 |
+ def banner_url(self): |
|
| 53 |
+ return upload_file_url(self.banner) |
|
| 54 |
+ |
|
| 55 |
+ @property |
|
| 56 |
+ def image_path(self): |
|
| 57 |
+ return upload_file_path(self.image) |
|
| 58 |
+ |
|
| 59 |
+ @property |
|
| 60 |
+ def image_url(self): |
|
| 61 |
+ return upload_file_url(self.image) |
|
| 62 |
+ |
|
| 63 |
+ @property |
|
| 64 |
+ def data(self): |
|
| 65 |
+ return {
|
|
| 66 |
+ 'kol_id': self.kol_id, |
|
| 67 |
+ 'nickname': self.final_nickname, |
|
| 68 |
+ 'avatar_url': self.avatar_url, |
|
| 69 |
+ 'banner_url': self.banner_url, |
|
| 70 |
+ 'intro': self.intro, |
|
| 71 |
+ 'image_url': self.image_url, |
|
| 72 |
+ 'fans': self.fans, |
|
| 73 |
+ } |
@@ -0,0 +1,4 @@ |
||
| 1 |
+from django.test import TestCase |
|
| 2 |
+ |
|
| 3 |
+ |
|
| 4 |
+# Create your tests here. |
@@ -0,0 +1,4 @@ |
||
| 1 |
+from django.shortcuts import render |
|
| 2 |
+ |
|
| 3 |
+ |
|
| 4 |
+# Create your views here. |
@@ -0,0 +1,23 @@ |
||
| 1 |
+#!/usr/bin/env python |
|
| 2 |
+import os |
|
| 3 |
+import sys |
|
| 4 |
+ |
|
| 5 |
+ |
|
| 6 |
+if __name__ == "__main__": |
|
| 7 |
+ os.environ.setdefault("DJANGO_SETTINGS_MODULE", "kodosale.settings")
|
|
| 8 |
+ try: |
|
| 9 |
+ from django.core.management import execute_from_command_line |
|
| 10 |
+ except ImportError: |
|
| 11 |
+ # The above import may fail for some other reason. Ensure that the |
|
| 12 |
+ # issue is really that Django is missing to avoid masking other |
|
| 13 |
+ # exceptions on Python 2. |
|
| 14 |
+ try: |
|
| 15 |
+ import django |
|
| 16 |
+ except ImportError: |
|
| 17 |
+ raise ImportError( |
|
| 18 |
+ "Couldn't import Django. Are you sure it's installed and " |
|
| 19 |
+ "available on your PYTHONPATH environment variable? Did you " |
|
| 20 |
+ "forget to activate a virtual environment?" |
|
| 21 |
+ ) |
|
| 22 |
+ raise |
|
| 23 |
+ execute_from_command_line(sys.argv) |
@@ -0,0 +1,10 @@ |
||
| 1 |
+#!/bin/bash |
|
| 2 |
+ |
|
| 3 |
+# Ignoring autogenerated files |
|
| 4 |
+# -- Migration directories |
|
| 5 |
+# Ignoring error codes |
|
| 6 |
+# -- E128 continuation line under-indented for visual indent |
|
| 7 |
+# -- E402 module level import not at top of file |
|
| 8 |
+# -- E501 line too long |
|
| 9 |
+ |
|
| 10 |
+pycodestyle --exclude=build,migrations,.tox --ignore=E128,E402,E501 . |
@@ -0,0 +1,8 @@ |
||
| 1 |
+StatusCode==1.0.0 |
|
| 2 |
+furl==2.1.0 |
|
| 3 |
+jsonfield==2.0.2 |
|
| 4 |
+mysqlclient==1.4.6 |
|
| 5 |
+rlog==0.3 |
|
| 6 |
+-r requirements_dj.txt |
|
| 7 |
+-r requirements_pywe.txt |
|
| 8 |
+-r requirements_redis.txt |
@@ -0,0 +1,3 @@ |
||
| 1 |
+ipdb==0.12.3 |
|
| 2 |
+ipython==7.11.1 |
|
| 3 |
+uwsgi==2.0.18 |
@@ -0,0 +1,2 @@ |
||
| 1 |
+isort==4.3.21 |
|
| 2 |
+pycodestyle==2.5.0 |
@@ -0,0 +1,15 @@ |
||
| 1 |
+Django==2.2.12 |
|
| 2 |
+django-admin==2.0.1 |
|
| 3 |
+django-detect==1.0.18 |
|
| 4 |
+django-file==1.0.4 |
|
| 5 |
+django-json-render==1.0.3 |
|
| 6 |
+django-json-response==1.1.5 |
|
| 7 |
+django-logit==1.1.3 |
|
| 8 |
+django-models-ext==1.1.9 |
|
| 9 |
+django-redis-connector==1.0.3 |
|
| 10 |
+django-response==1.1.1 |
|
| 11 |
+django-rlog==1.0.7 |
|
| 12 |
+django-short-url==1.1.4 |
|
| 13 |
+django-six==1.0.4 |
|
| 14 |
+django-uniapi==1.0.7 |
|
| 15 |
+django-we==1.5.5 |
@@ -0,0 +1,2 @@ |
||
| 1 |
+pywe-oauth==1.1.1 |
|
| 2 |
+pywe-pay==1.0.13 |
@@ -0,0 +1,3 @@ |
||
| 1 |
+hiredis==1.0.1 |
|
| 2 |
+redis==3.4.1 |
|
| 3 |
+redis-extensions==2.0.0 |
@@ -0,0 +1,4 @@ |
||
| 1 |
+#!/bin/bash |
|
| 2 |
+ |
|
| 3 |
+sudo sysctl -w net.core.somaxconn=65535 |
|
| 4 |
+sudo sysctl -w net.core.netdev_max_backlog=65535 |
@@ -0,0 +1,77 @@ |
||
| 1 |
+# -*- coding: utf-8 -*- |
|
| 2 |
+ |
|
| 3 |
+from StatusCode import BaseStatusCode, StatusCodeField |
|
| 4 |
+ |
|
| 5 |
+ |
|
| 6 |
+class ParamStatusCode(BaseStatusCode): |
|
| 7 |
+ """ 4000xx 参数相关错误码 """ |
|
| 8 |
+ PARAM_NOT_FOUND = StatusCodeField(400000, 'Param Not Found', description=u'参数不存在') |
|
| 9 |
+ |
|
| 10 |
+ |
|
| 11 |
+class ProfileStatusCode(BaseStatusCode): |
|
| 12 |
+ """ 4001xx 用户相关错误码 """ |
|
| 13 |
+ PROFILE_NOT_FOUND = StatusCodeField(400101, 'Profile Not Found', description=u'用户不存在') |
|
| 14 |
+ |
|
| 15 |
+ |
|
| 16 |
+class PhoneStatusCode(BaseStatusCode): |
|
| 17 |
+ """ 4002xx 手机相关错误码 """ |
|
| 18 |
+ INVALID_PHONE = StatusCodeField(400200, 'Invalid Phone', description=u'非法手机号') |
|
| 19 |
+ PHONE_NOT_FOUND = StatusCodeField(400201, 'Phone Not Found', description=u'手机号不存在') |
|
| 20 |
+ PHONE_ALREADY_EXISTS = StatusCodeField(400202, 'Phone Already Exists', description=u'手机号已存在') |
|
| 21 |
+ |
|
| 22 |
+ |
|
| 23 |
+class OrderStatusCode(BaseStatusCode): |
|
| 24 |
+ """ 4040xx 订单/支付相关错误码 """ |
|
| 25 |
+ UNIFIED_ORDER_FAIL = StatusCodeField(404000, 'Unified Order Fail', description=u'统一下单失败') |
|
| 26 |
+ ORDER_NOT_FOUND = StatusCodeField(404001, 'Order Not Found', description=u'订单不存在') |
|
| 27 |
+ # 订单支付状态 |
|
| 28 |
+ ORDER_NOT_PAY = StatusCodeField(404011, 'Order Not Pay', description=u'订单未支付') |
|
| 29 |
+ ORDER_PAYING = StatusCodeField(404012, 'Order Paying', description=u'订单支付中') |
|
| 30 |
+ ORDER_PAY_FAIL = StatusCodeField(404013, 'Order Pay Fail', description=u'微信支付失败') |
|
| 31 |
+ # 通知校验状态 |
|
| 32 |
+ SIGN_CHECK_FAIL = StatusCodeField(404090, 'Sign Check Fail', description=u'签名校验失败') |
|
| 33 |
+ FEE_CHECK_FAIL = StatusCodeField(404091, 'FEE Check Fail', description=u'金额校验失败') |
|
| 34 |
+ |
|
| 35 |
+ |
|
| 36 |
+class PayStatusCode(BaseStatusCode): |
|
| 37 |
+ """ 4041xx 支付相关错误码 """ |
|
| 38 |
+ |
|
| 39 |
+ |
|
| 40 |
+class WithdrawStatusCode(BaseStatusCode): |
|
| 41 |
+ """ 4042xx 提现相关错误码 """ |
|
| 42 |
+ BALANCE_INSUFFICIENT = StatusCodeField(404200, 'Balance Insufficient', description=u'提现金额不足') |
|
| 43 |
+ |
|
| 44 |
+ |
|
| 45 |
+class TokenStatusCode(BaseStatusCode): |
|
| 46 |
+ """ 4090xx 票据相关错误码 """ |
|
| 47 |
+ TOKEN_NOT_FOUND = StatusCodeField(409001, 'Token Not Found', description=u'票据不存在') |
|
| 48 |
+ |
|
| 49 |
+ |
|
| 50 |
+class SignatureStatusCode(BaseStatusCode): |
|
| 51 |
+ """ 4091xx 签名校验错误 """ |
|
| 52 |
+ SIGNATURE_ERROR = StatusCodeField(409101, 'Signature Error', description=u'签名错误') |
|
| 53 |
+ |
|
| 54 |
+ |
|
| 55 |
+class GVCodeStatusCode(BaseStatusCode): |
|
| 56 |
+ """ 4092xx 图形验证码相关错误码 """ |
|
| 57 |
+ GRAPHIC_VCODE_ERROR = StatusCodeField(409201, 'Graphic VCode Error', description=u'图形验证码错误') |
|
| 58 |
+ |
|
| 59 |
+ |
|
| 60 |
+class SVCodeStatusCode(BaseStatusCode): |
|
| 61 |
+ """ 4093xx 短信验证码相关错误码 """ |
|
| 62 |
+ SMS_QUOTA_LIMIT = StatusCodeField(409300, 'SMS Quota Limit', description=u'短信次数超限') |
|
| 63 |
+ SMS_VCODE_ERROR = StatusCodeField(409301, 'SMS VCode Error', description=u'验证码错误,请稍后重试') |
|
| 64 |
+ SMS_VCODE_HAS_SEND = StatusCodeField(409302, 'SMS VCode Has Send', description=u'验证码已发送,请勿重复获取') |
|
| 65 |
+ |
|
| 66 |
+ |
|
| 67 |
+class InsufficientStatusCode(BaseStatusCode): |
|
| 68 |
+ """ 4095xx 不足相关错误码 """ |
|
| 69 |
+ BALANCE_INSUFFICIENT = StatusCodeField(409501, 'Balance Insufficient', description=u'余额不足') |
|
| 70 |
+ INTEGRAL_INSUFFICIENT = StatusCodeField(409502, 'Integral Insufficient', description=u'积分不足') |
|
| 71 |
+ |
|
| 72 |
+ |
|
| 73 |
+class PermissionStatusCode(BaseStatusCode): |
|
| 74 |
+ """ 4099xx 权限相关错误码 """ |
|
| 75 |
+ PERMISSION_DENIED = StatusCodeField(409900, 'Permission Denied', description=u'权限不足') |
|
| 76 |
+ UPLOAD_PERMISSION_DENIED = StatusCodeField(409910, 'Upload Permission Denied', description=u'上传权限不足') |
|
| 77 |
+ UPDATE_PERMISSION_DENIED = StatusCodeField(409930, 'Update Permission Denied', description=u'更新权限不足') |
@@ -0,0 +1,24 @@ |
||
| 1 |
+# -*- coding: utf-8 -*- |
|
| 2 |
+ |
|
| 3 |
+from json_response import JsonpResponse, JsonResponse |
|
| 4 |
+from StatusCode import StatusCodeField |
|
| 5 |
+ |
|
| 6 |
+ |
|
| 7 |
+def response_data(status_code=200, message=None, description=None, data={}, **kwargs):
|
|
| 8 |
+ return dict({
|
|
| 9 |
+ 'status': status_code, |
|
| 10 |
+ 'message': message, |
|
| 11 |
+ 'description': description, |
|
| 12 |
+ 'data': data, |
|
| 13 |
+ }, **kwargs) |
|
| 14 |
+ |
|
| 15 |
+ |
|
| 16 |
+def response(status_code=200, message=None, description=None, data={}, msg_args=[], msg_kwargs={}, desc_args=[], desc_kwargs={}, request=None, callback=None, **kwargs):
|
|
| 17 |
+ # Final Message and Description |
|
| 18 |
+ message, description = (message or status_code.message, description or status_code.description) if isinstance(status_code, StatusCodeField) else (message, description) |
|
| 19 |
+ # Final Response Data |
|
| 20 |
+ resp_data = response_data(status_code, (message or '').format(*msg_args, **msg_kwargs), (description or '').format(*desc_args, **desc_kwargs), data, **kwargs) |
|
| 21 |
+ # Assign Callback |
|
| 22 |
+ callback = callback or (request and request.GET.get('callback'))
|
|
| 23 |
+ # Call JsonResponse or JsonpResponse |
|
| 24 |
+ return JsonpResponse(callback, resp_data, safe=False) if callback else JsonResponse(resp_data, safe=False) |
@@ -0,0 +1,6 @@ |
||
| 1 |
+# -*- coding: utf-8 -*- |
|
| 2 |
+ |
|
| 3 |
+from django.conf import settings |
|
| 4 |
+ |
|
| 5 |
+ |
|
| 6 |
+r = settings.REDIS_CACHE |
@@ -0,0 +1 @@ |
||
| 1 |
+# -*- coding: utf-8 -*- |
@@ -0,0 +1,18 @@ |
||
| 1 |
+# -*- coding: utf-8 -*- |
|
| 2 |
+ |
|
| 3 |
+ |
|
| 4 |
+def userinfo_save(userinfo): |
|
| 5 |
+ """ Save profile or something else """ |
|
| 6 |
+ # from account.models import UserInfo |
|
| 7 |
+ # from django.conf import settings |
|
| 8 |
+ # |
|
| 9 |
+ # unique_identifier = userinfo.get(settings.WECHAT_UNIQUE_IDENTIFICATION, '') |
|
| 10 |
+ # |
|
| 11 |
+ # user, created = UserInfo.objects.select_for_update().get_or_create(**{settings.WECHAT_UNIQUE_IDENTIFICATION: unique_identifier})
|
|
| 12 |
+ # user.unionid = userinfo.get('unionid', '')
|
|
| 13 |
+ # user.openid = userinfo.get('openid', '')
|
|
| 14 |
+ # user.nickname = userinfo.get('nickname', '')
|
|
| 15 |
+ # user.avatar = userinfo.get('headimgurl', '')
|
|
| 16 |
+ # user.save() |
|
| 17 |
+ # |
|
| 18 |
+ # return user |