nl-22 ol-22"> 18
+def delete_guest_entrance_control(src=0):
22 19
     """ 删除游客入口控制 """
23
-    return r.delete(GUEST_ENTRANCE_CONTROL_INFO)
20
+    return r.delete(GUEST_ENTRANCE_CONTROL_INFO % src)

+ 2 - 2
utils/redis/rkeys.py

@@ -1,7 +1,7 @@
1 1
 # -*- coding: utf-8 -*-
2 2
 
3 3
 # 唯一标识相关
4
-UUID_LIST = 'uuid:list'  # List, 唯一标识列表
4
+UUID_LIST = 'uuid:list'  # List,唯一标识列表
5 5
 
6 6
 # 用户相关
7 7
 PROFILE_INFO = 'profile:info:%s'  # STRING,用户信息,user_id
@@ -59,7 +59,7 @@ SYSTEM_MESSAGE_READ_INFO = 'system:message:read:info:%s'  # STRING,系统消
59 59
 SYSTEM_MESSAGE_DELETED_INFO = 'system:message:deleted:info:%s'  # STRING,系统消息删除信息,user_id
60 60
 
61 61
 # 游客入口相关
62
-GUEST_ENTRANCE_CONTROL_INFO = 'guest:entrance:control:info'  # STRING,游客入口控制信息
62
+GUEST_ENTRANCE_CONTROL_INFO = 'guest:entrance:control:info:%s'  # STRING,游客入口控制信息,src
63 63
 
64 64
 # APP 相关
65 65
 LATEST_APP_INFO = 'latest:app:info:%s'  # STRING,最新 APP 信息,src

+ 2 - 4
utils/redis/rmessage.py

@@ -1,15 +1,12 @@
1 1
 # -*- coding: utf-8 -*-
2 2
 
3
-from message.models import SystemMessageDeleteInfo, SystemMessageReadInfo
4 3
 from utils.redis.connect import r
5 4
 from utils.redis.rkeys import SYSTEM_MESSAGE_DELETED_INFO, SYSTEM_MESSAGE_READ_INFO
6 5
 
7 6
 
8
-# 系统消息相关
9
-
10
-
11 7
 def set_system_message_read_info(user_id):
12 8
     """ 设置系统消息读取信息 """
9
+    from message.models import SystemMessageReadInfo
13 10
     read_messages = SystemMessageReadInfo.objects.filter(user_id=user_id, status=True)
14 11
     read_message_ids = [msg.msg_id for msg in read_messages]
15 12
     r.setexjson(SYSTEM_MESSAGE_READ_INFO % user_id, r.REDIS_EXPIRED_ONE_MONTH, read_message_ids)
@@ -23,6 +20,7 @@ def get_system_message_read_info(user_id):
23 20
 
24 21
 def set_system_message_delete_info(user_id):
25 22
     """ 设置系统消息删除信息 """
23
+    from message.models import SystemMessageDeleteInfo
26 24
     deleted_messages = SystemMessageDeleteInfo.objects.filter(user_id=user_id, status=True)
27 25
     deleted_message_ids = [msg.msg_id for msg in deleted_messages]
28 26
     r.setexjson(SYSTEM_MESSAGE_DELETED_INFO % user_id, r.REDIS_EXPIRED_ONE_MONTH, deleted_message_ids)

+ 2 - 6
utils/redis/rorder.py

@@ -6,14 +6,10 @@ from utils.redis.connect import r
6 6
 from utils.redis.rkeys import LENSMAN_PHOTO_ORDER_RECORD
7 7
 
8 8
 
9
-# 摄影师照片购买记录相关
10
-
11
-
12 9
 def set_lensman_order_record(porder):
13 10
     """ 设置摄影师照片购买记录 """
14
-    porder_info = porder.porder_info
15
-    r.setexjson(LENSMAN_PHOTO_ORDER_RECORD % (porder.photo_id, porder.user_id), r.REDIS_EXPIRED_ONE_MONTH, porder_info, cls=DjangoJSONEncoder)
16
-    return porder_info
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
17 13
 
18 14
 
19 15
 def set_lensman_order_record_by_id(photo_id, user_id):

+ 1 - 4
utils/redis/rprice.py

@@ -1,15 +1,12 @@
1 1
 # -*- coding: utf-8 -*-
2 2
 
3
-from account.models import LensmanInfo
4 3
 from utils.redis.connect import r
5 4
 from utils.redis.rkeys import LENSMAN_PHOTO_PRICE_FIXED
6 5
 
7 6
 
8
-# 最新 APP 相关
9
-
10
-
11 7
 def set_lensman_price_fixed(user_id):
12 8
     """ 设置摄影师价格设定 """
9
+    from account.models import LensmanInfo
13 10
     try:
14 11
         lensman = LensmanInfo.objects.get(lensman_id=user_id)
15 12
     except LensmanInfo.DoesNotExist:

+ 0 - 3
utils/redis/rprofile.py

@@ -4,9 +4,6 @@ from utils.redis.connect import r
4 4
 from utils.redis.rkeys import PROFILE_INFO
5 5
 
6 6
 
7
-# 用户相关
8
-
9
-
10 7
 def set_profile_info(user):
11 8
     """ 设置用户信息 """
12 9
     r.setjson(PROFILE_INFO % user.user_id, user.data)

+ 0 - 3
utils/redis/rtourguide.py

@@ -4,9 +4,6 @@ from utils.redis.connect import r
4 4
 from utils.redis.rkeys import TOUR_GUIDE_GROUP_USER_OWN
5 5
 
6 6
 
7
-# 导游相关
8
-
9
-
10 7
 def set_tour_guide_own_group(user_id, group_id):
11 8
     """ 设置导游拥有的旅行团 """
12 9
     r.set(TOUR_GUIDE_GROUP_USER_OWN % user_id, group_id)

+ 0 - 3
utils/redis/rtouruser.py

@@ -4,9 +4,6 @@ from utils.redis.connect import r
4 4
 from utils.redis.rkeys import TOUR_GUIDE_GROUP_USER_BELONG
5 5
 
6 6
 
7
-# 旅行团成员相关
8
-
9
-
10 7
 def set_tour_user_belong_group(user_id, group_id):
11 8
     """ 设置旅行团成员所属的旅行团 """
12 9
     r.set(TOUR_GUIDE_GROUP_USER_BELONG % user_id, group_id)

kodo - Gogs: Go Git Service

Nessuna descrizione

views.py 18KB

    # -*- coding: utf-8 -*- from __future__ import division import xlrd from django.conf import settings from django.db import transaction from pysnippets.strsnippets import strip from TimeConvert import TimeConvert as tc from integral.models import SaleclerkSubmitLogInfo from mch.models import (BrandInfo, ConsumeInfoSubmitLogInfo, DistributorInfo, ModelCameraBodyInfo, ModelInfo, SaleclerkInfo) from statistic.models import (ConsumeDistributorSaleStatisticInfo, ConsumeModelSaleStatisticInfo, ConsumeProvinceSaleStatisticInfo, ConsumeSaleStatisticInfo, ConsumeUserStatisticInfo, DistributorSaleStatisticInfo, ModelSaleStatisticInfo, ProvinceSaleStatisticInfo, SaleclerkSaleStatisticInfo, SaleStatisticInfo) from utils.redis.connect import r from utils.redis.rkeys import MINI_PROGRAM_GIS_LIST PROVINCE_LIST = { "110000": "北京市", "120000": "天津市", "130000": "河北省", "140000": "山西省", "150000": "内蒙古自治区", "210000": "辽宁省", "220000": "吉林省", "230000": "黑龙江省", "310000": "上海市", "320000": "江苏省", "330000": "浙江省", "340000": "安徽省", "350000": "福建省", "360000": "江西省", "370000": "山东省", "410000": "河南省", "420000": "湖北省", "430000": "湖南省", "440000": "广东省", "450000": "广西壮族自治区", "460000": "海南省", "500000": "重庆市", "510000": "四川省", "520000": "贵州省", "530000": "云南省", "540000": "西藏自治区", "610000": "陕西省", "620000": "甘肃省", "630000": "青海省", "640000": "宁夏回族自治区", "650000": "新疆维吾尔自治区", "710000": "台湾省", "810000": "香港特别行政区", "820000": "澳门特别行政区" } def pre_provinces(): brands = BrandInfo.objects.filter(status=True) for brand in brands: for pcode, pname in PROVINCE_LIST.items(): pssi, created = ProvinceSaleStatisticInfo.objects.get_or_create(brand_id=brand.brand_id, province_code=pcode, ymd=0) pssi.province_name = pname pssi.save() cpssi, created = ConsumeProvinceSaleStatisticInfo.objects.get_or_create(brand_id=brand.brand_id, province_code=pcode, ymd=0) cpssi.province_name = pname cpssi.save() def pre_models(): brands = BrandInfo.objects.filter(status=True) for brand in brands: models = ModelInfo.objects.filter(brand_id=brand.brand_id, status=True) for mdl in models: mssi, created = ModelSaleStatisticInfo.objects.get_or_create(brand_id=brand.brand_id, model_id=mdl.model_id, ymd=0) mssi.model_name = mdl.model_name mssi.save() cmssi, created = ConsumeModelSaleStatisticInfo.objects.get_or_create(brand_id=brand.brand_id, model_id=mdl.model_id, ymd=0) cmssi.model_name = mdl.model_name cmssi.save() def pre_distributors(): brands = BrandInfo.objects.filter(status=True) for brand in brands: distributors = DistributorInfo.objects.filter(brand_id=brand.brand_id, status=True) for dtbt in distributors: dssi, created = DistributorSaleStatisticInfo.objects.get_or_create(brand_id=brand.brand_id, distributor_id=dtbt.distributor_id, ymd=0) dssi.distributor_name = dtbt.distributor_name dssi.save() cdssi, created = ConsumeDistributorSaleStatisticInfo.objects.get_or_create(brand_id=brand.brand_id, distributor_id=dtbt.distributor_id, ymd=0) cdssi.distributor_name = dtbt.distributor_name cdssi.save() def pre_all(): pre_provinces() pre_models() pre_distributors() # In [55]: cv # Out[55]: 991000295147.0 # # In [56]: str(cv) # Out[56]: '9.91000295147e+11' # # In [57]: repr(cv) # Out[57]: '991000295147.0' def convert_to_str(cv): if isinstance(cv, (int, float)): cv = repr(cv)[:-2] if repr(cv).endswith('.0') else repr(cv) if isinstance(cv, str): cv = cv.strip() return cv def pre_new_models(fpath='./pre/static/models_20180816.xls'): workbook = xlrd.open_workbook(fpath) # sheet = workbook.sheet_by_name('SMR') sheets = workbook.sheets() sheet = sheets[0] nrows = sheet.nrows for idx in range(1, nrows): rvals = sheet.row_values(idx) print(rvals) jancode = strip(rvals[0]) if not jancode: continue mdl, _ = ModelInfo.objects.get_or_create(jancode=jancode) mdl.brand_id = settings.KODO_DEFAULT_BRAND_ID mdl.brand_name = settings.KODO_DEFAULT_BRAND_NAME mdl.model_name = strip(rvals[1]) mdl.model_uni_name = strip(rvals[2]) mdl.category = strip(rvals[3]) mdl.model_full_name = strip(rvals[4]) mdl.warehouse = strip(rvals[5]) mdl.save() def pre_adaptive_cameras(fpath=u'./pre/static/腾龙镜头适用机型V1.xlsx'): ModelCameraBodyInfo.objects.all().delete() workbook = xlrd.open_workbook(fpath) # sheet = workbook.sheet_by_name('SMR') # import ipdb;ipdb.set_trace() sheets = workbook.sheets() # Deal sheet0 sheet0 = sheets[0] # Deal sheet1-n sheets = sheets[1:] for sheet in sheets: model_name = sheet.name model_full_name = sheet.row_values(2)[0] print(model_name, model_full_name) nrows = sheet.nrows for idx in range(4, nrows): rvals = sheet.row_values(idx) print(rvals) for val in rvals: val = strip(val) if not val: continue if u'卡口' in val: continue print(val) ModelCameraBodyInfo.objects.get_or_create( brand_id=settings.KODO_DEFAULT_BRAND_ID, brand_name=settings.KODO_DEFAULT_BRAND_NAME, model_name=model_name, model_full_name=model_full_name, camera_name=val, ) def fill_ym(): for o in ConsumeSaleStatisticInfo.objects.all(): ymd = str(o.ymd) if len(ymd) == 8: # 月销量统计 ssi, _ = ConsumeSaleStatisticInfo.objects.get_or_create( brand_id=o.brand_id, ymd=ymd[:6], ) ssi.num += o.num ssi.save() # 年销量统计 ssi, _ = ConsumeSaleStatisticInfo.objects.get_or_create( brand_id=o.brand_id, ymd=ymd[:4], ) ssi.num += o.num ssi.save() for o in ConsumeModelSaleStatisticInfo.objects.all(): ymd = str(o.ymd) if len(ymd) == 8: # 月型号销量统计 mssi, _ = ConsumeModelSaleStatisticInfo.objects.get_or_create( brand_id=o.brand_id, model_id=o.model_id, ymd=ymd[:6], ) mssi.model_name = o.model_name mssi.num += o.num mssi.save() # 年型号销量统计 mssi, _ = ConsumeModelSaleStatisticInfo.objects.get_or_create( brand_id=o.brand_id, model_id=o.model_id, ymd=ymd[:4], ) mssi.model_name = o.model_name mssi.num += o.num mssi.save() for o in SaleStatisticInfo.objects.all(): ymd = str(o.ymd) if len(ymd) == 8: # 月销量统计 ssi, _ = SaleStatisticInfo.objects.get_or_create( brand_id=o.brand_id, ymd=ymd[:6], ) ssi.num += o.num ssi.save() # 年销量统计 ssi, _ = SaleStatisticInfo.objects.get_or_create( brand_id=o.brand_id, ymd=ymd[:4], ) ssi.num += o.num ssi.save() def refreshs(): ConsumeUserStatisticInfo.objects.all().delete() ConsumeSaleStatisticInfo.objects.all().delete() ConsumeProvinceSaleStatisticInfo.objects.all().delete() ConsumeModelSaleStatisticInfo.objects.all().delete() logs = ConsumeInfoSubmitLogInfo.objects.filter(verifyResult=1, dupload=False, test_user=False, status=True) for log in logs: ymd = tc.local_string(utc_dt=log.created_at, format='%Y%m%d') try: mdl = ModelInfo.objects.get(model_id=log.model_id) except ModelInfo.DoesNotExist: continue with transaction.atomic(): cusi, _ = ConsumeUserStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, ymd=ymd, ) cusi.users = list(set(cusi.users + [log.user_id])) cusi.num = len(cusi.users) cusi.save() cusi, _ = ConsumeUserStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, ymd=ymd[:6], ) cusi.users = list(set(cusi.users + [log.user_id])) cusi.num = len(cusi.users) cusi.save() cusi, _ = ConsumeUserStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, ymd=ymd[:4], ) cusi.users = list(set(cusi.users + [log.user_id])) cusi.num = len(cusi.users) cusi.save() cssi, _ = ConsumeSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, ymd=ymd, ) cssi.num += 1 cssi.save() cssi, _ = ConsumeSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, ymd=ymd[:6], ) cssi.num += 1 cssi.save() cssi, _ = ConsumeSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, ymd=ymd[:4], ) cssi.num += 1 cssi.save() # 日型号销量统计 cmssi, _ = ConsumeModelSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, model_name=mdl.model_uni_name, ymd=ymd, ) cmssi.num += 1 cmssi.save() # 月型号销量统计 cmssi, _ = ConsumeModelSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, model_name=mdl.model_uni_name, ymd=ymd[:6], ) cmssi.num += 1 cmssi.save() # 年型号销量统计 cmssi, _ = ConsumeModelSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=mdl.brand_id, model_name=mdl.model_uni_name, ymd=ymd[:4], ) cmssi.num += 1 cmssi.save() r.rpushjson(MINI_PROGRAM_GIS_LIST, { 'brand_id': log.brand_id, 'user_id': log.user_id, 'lat': log.lat, 'lon': log.lon, 'phone': log.phone, 'ymd': tc.local_string(utc_dt=log.created_at, format='%Y%m%d'), 'model_id': log.model_id, 'serialNo': log.serialNo, 'pk': log.pk, }) def refreshs2(): SaleStatisticInfo.objects.all().delete() ModelSaleStatisticInfo.objects.all().delete() DistributorSaleStatisticInfo.objects.all().delete() ProvinceSaleStatisticInfo.objects.all().delete() SaleclerkSaleStatisticInfo.objects.all().delete() logs = SaleclerkSubmitLogInfo.objects.filter(dupload=False, test_user=False, test_sn=False, status=True) for log in logs: ymd = tc.local_string(utc_dt=log.created_at, format='%Y%m%d') try: brand = BrandInfo.objects.get(pk=log.brand_pk) except BrandInfo.DoesNotExist: continue try: model = ModelInfo.objects.get(pk=log.model_pk) except ModelInfo.DoesNotExist: continue try: clerk = SaleclerkInfo.objects.get(clerk_id=log.clerk_id, status=True) except SaleclerkInfo.DoesNotExist: continue try: distributor = DistributorInfo.objects.get(distributor_id=clerk.distributor_id) except DistributorInfo.DoesNotExist: continue with transaction.atomic(): # 日销量统计 ssi, _ = SaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, ymd=ymd, ) ssi.num += 1 ssi.save() # 月销量统计 ssi, _ = SaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, ymd=ymd[:6], ) ssi.num += 1 ssi.save() # 年销量统计 ssi, _ = SaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, ymd=ymd[:4], ) ssi.num += 1 ssi.save() # 型号销量统计 mssi, _ = ModelSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, model_name=model.model_uni_name, ymd=ymd, ) mssi.saleclerks += [clerk.clerk_id] mssi.num = len(mssi.saleclerks) mssi.save() mssi, _ = ModelSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, model_name=model.model_uni_name, ymd=ymd[:6], ) mssi.saleclerks += [clerk.clerk_id] mssi.num = len(mssi.saleclerks) mssi.save() mssi, _ = ModelSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, model_name=model.model_uni_name, ymd=ymd[:4], ) mssi.saleclerks += [clerk.clerk_id] mssi.num = len(mssi.saleclerks) mssi.save() # 经销商销量统计 dssi, _ = DistributorSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, distributor_id=distributor.distributor_id, ymd=ymd, ) dssi.distributor_name = distributor.distributor_name dssi.num += 1 dssi.save() dssi2, _ = DistributorSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, distributor_id=distributor.distributor_id, ymd=0, ) dssi2.distributor_name = distributor.distributor_name dssi2.num += 1 dssi2.save() # 日省份销量统计 pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, province_code=distributor.distributor_province_code, ymd=ymd, ) pssi.province_name = distributor.distributor_province_name pssi.num += 1 pssi.save() # 月省份销量统计 pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, province_code=distributor.distributor_province_code, ymd=ymd[:6], ) pssi.province_name = distributor.distributor_province_name pssi.num += 1 pssi.save() # 年省份销量统计 pssi, _ = ProvinceSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, province_code=distributor.distributor_province_code, ymd=ymd[:4], ) pssi.province_name = distributor.distributor_province_name pssi.num += 1 pssi.save() # 日销售员销量统计 sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, clerk_id=clerk.clerk_id, ymd=ymd, ) sssi.distributor_id = distributor.distributor_id sssi.distributor_name = distributor.distributor_name sssi.distributor_short_name = distributor.distributor_short_name sssi.clerk_name = clerk.clerk_name sssi.num += 1 sssi.save() # 月销售员销量统计 sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, clerk_id=clerk.clerk_id, ymd=ymd[:6], ) sssi.distributor_id = distributor.distributor_id sssi.distributor_name = distributor.distributor_name sssi.distributor_short_name = distributor.distributor_short_name sssi.clerk_name = clerk.clerk_name sssi.num += 1 sssi.save() # 年销售员销量统计 sssi, _ = SaleclerkSaleStatisticInfo.objects.select_for_update().get_or_create( brand_id=brand.brand_id, clerk_id=clerk.clerk_id, ymd=ymd[:4], ) sssi.distributor_id = distributor.distributor_id sssi.distributor_name = distributor.distributor_name sssi.distributor_short_name = distributor.distributor_short_name sssi.clerk_name = clerk.clerk_name sssi.num += 1 sssi.save()