123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767 |
- from __future__ import division
- from collections import defaultdict
- from datetime import datetime
- from django.conf import settings
- from django.db import transaction
- from django.db.models import Count, Q, Sum
- from django_logit import logit
- from django_response import response
- from paginator import pagination
- from TimeConvert import TimeConvert as tc
- from account.models import UserInfo
- from coupon.models import UserCouponInfo
- from integral.models import SaleclerkSubmitLogInfo
- from mch.models import AdministratorInfo, ConsumeInfoSubmitLogInfo, ModelInfo, DistributorInfo
- from member.models import GoodsOrderInfo
- from logs.models import MchInfoEncryptLogInfo
- from statistic.models import ConsumeModelSaleStatisticInfo, ConsumeSaleStatisticInfo, ConsumeUserStatisticInfo
- from utils.error.errno_utils import (AdministratorStatusCode, ProductBrandStatusCode, ProductCouponStatusCode,
- ProductMachineStatusCode, UserStatusCode)
- WECHAT = settings.WECHAT
- @logit
- def querysn(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- model_id = request.POST.get('model_id', '')
- sn = request.POST.get('sn', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- if not AdministratorInfo.objects.filter(admin_id=admin_id, admin_type=AdministratorInfo.MAINTENANCE, user_status=AdministratorInfo.ACTIVATED, status=True).exists():
- return response(AdministratorStatusCode.MAINTENANCE_NOT_FOUND)
- log = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=brand_id, model_id=model_id, serialNo=sn, submit_during_activity=True, status=True).order_by('has_used', '-pk').first()
- if not log:
- log = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=brand_id, model_id=model_id, serialNo=sn, status=True).order_by('-submit_during_activity', 'dupload').first()
- if not log:
- return response(ProductMachineStatusCode.SN_NOT_FOUND)
- return response(200, 'Query SN Success', u'查询序列号成功', data=log.data)
- @logit
- def queryusedsn(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- if not AdministratorInfo.objects.filter(admin_id=admin_id, admin_type=AdministratorInfo.MAINTENANCE, user_status=AdministratorInfo.ACTIVATED, status=True).exists():
- return response(AdministratorStatusCode.MAINTENANCE_NOT_FOUND)
- logs = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=brand_id, admin_id=admin_id, has_used=True, status=True).order_by('-used_at')
- logs = [log.data for log in logs]
- return response(200, 'Query Used SN Success', u'查询核销序列号成功', data={
- 'logs': logs,
- })
- @logit
- @transaction.atomic
- def usecoupon(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- model_id = request.POST.get('model_id', '')
- sn = request.POST.get('sn', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- if not AdministratorInfo.objects.filter(
- admin_id=admin_id,
- admin_type=AdministratorInfo.MAINTENANCE,
- user_status=AdministratorInfo.ACTIVATED,
- status=True
- ).exists():
- return response(AdministratorStatusCode.MAINTENANCE_NOT_FOUND)
- log = ConsumeInfoSubmitLogInfo.objects.filter(
- brand_id=brand_id,
- model_id=model_id,
- serialNo=sn,
- submit_during_activity=True,
- has_used=False,
- status=True
- ).first()
- if not log:
- return response(ProductMachineStatusCode.SN_NOT_FOUND)
- logdata = log.data
- if logdata.get('final_coupon_info', {}).get('coupon_has_expired', True):
- return response(ProductCouponStatusCode.COUPON_HAS_EXPIRED)
- log.has_used = True
- log.used_at = tc.utc_datetime()
- log.save()
- return response(200, 'Use Coupon Success', u'核销优惠券成功')
- @logit
- def userinfo(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- userinfos = UserInfo.objects.filter(status=True).order_by('-created_at')
- count = userinfos.count()
- userinfos, left = pagination(userinfos, page, num)
- userinfos = [userinfo.admindata for userinfo in userinfos]
- return response(200, 'Userinfo Success', u'用户列表获取成功', data={
- 'userinfos': userinfos,
- 'count': count,
- 'left': left,
- })
- @logit
- def query_usercoupons(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- user_id = request.POST.get('user_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- user = UserInfo.objects.get(user_id=user_id)
- except UserInfo.DoesNotExist:
- return response(UserStatusCode.USER_NOT_FOUND)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- coupons = UserCouponInfo.objects.filter(brand_id=administrator.brand_id, user_id=user_id, status=True).order_by('-created_at')
- coupons = [coupon.admindata for coupon in coupons]
- return response(200, 'User Coupon Success', u'用户劵列表获取成功', data={
- 'coupons': coupons,
- })
- @logit
- def query_usergoods(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- user_id = request.POST.get('user_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
-
- try:
- user = UserInfo.objects.get(user_id=user_id)
- except UserInfo.DoesNotExist:
- return response(UserStatusCode.USER_NOT_FOUND)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- logs = ConsumeInfoSubmitLogInfo.objects.filter(brand_id=administrator.brand_id, user_id=user_id, status=True).order_by('-created_at')
- logs = [log.adminuserdata for log in logs]
- return response(200, 'Userinfo Goods Success', u'用户商品列表获取成功', data={
- 'logs': logs,
- })
- @logit
- def query_userinfo(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- query = request.POST.get('query', '')
- level = request.POST.get('level', '')
- is_member = request.POST.get('is_member', '')
- code_version = request.POST.get('code_version', 0)
- sex = request.POST.get('sex', '')
- subscribe = request.POST.get('subscribe', '')
- has_membercard = request.POST.get('has_membercard', '')
- province = request.POST.get('province', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- userinfos = UserInfo.objects.filter(Q(status=True) & (Q(user_id__icontains=query) | Q(nickname__icontains=query) | Q(phone__icontains=query))).order_by('-created_at')
- if level:
- userinfos = userinfos.filter(level=level)
- if code_version:
- userinfos = userinfos.filter(code_version=code_version)
- if subscribe:
- userinfos = userinfos.filter(subscribe=subscribe)
- if has_membercard:
- userinfos = userinfos.filter(has_membercard=has_membercard)
- if is_member:
- userinfos = userinfos.filter(level__gte=1)
- if sex:
- userinfos = userinfos.filter(sex=sex)
-
- if province:
- userinfos = userinfos.filter(province_name=province)
- if start_time and end_time:
- ftime = datetime.strptime(start_time + ' 00:00:00', '%Y%m%d %H:%M:%S')
- ttime = datetime.strptime(end_time + ' 23:59:59', '%Y%m%d %H:%M:%S')
- userinfos = userinfos.filter(created_at__range=[ftime, ttime])
- count = userinfos.count()
- userinfos, left = pagination(userinfos, page, num)
- userinfos = [userinfo.admindata for userinfo in userinfos]
- return response(200, 'Userinfo Success', u'用户列表获取成功', data={
- 'userinfos': userinfos,
- 'count': count,
- 'left': left
- })
- @logit
- @transaction.atomic
- def userinfo_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- user_id = request.POST.get('user_id', '')
- integral = int(request.POST.get('integral', 0))
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
- try:
- user = UserInfo.objects.select_for_update().get(user_id=user_id, status=True)
- except UserInfo.DoesNotExist:
- return response(UserStatusCode.USER_NOT_FOUND)
- user.integral = integral
- user.save()
- return response(200, 'Userinfo Update Success', u'修改用户信息成功', data={})
- def statistic_userprofile(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- model_name = request.POST.get('model_name', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- if model_name:
- logs = ConsumeModelSaleStatisticInfo.objects.filter(model_name=model_name, ymd__gte=start_time, ymd__lte=end_time)
- else:
- logs = ConsumeModelSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
- sexs = {0: 0, 1: 0, 2: 0}
- subscribes = {0: 0, 1: 0}
- has_membercards = {0: 0, 1: 0}
- provinces = defaultdict(int)
- for log in logs:
- for user in log.users:
- try:
- user = UserInfo.objects.get(user_id=user, status=True)
- except UserInfo.DoesNotExist:
- continue
- provinces[user.province_name] += 1
- sexs[user.sex] += 1
- subscribes[user.subscribe] += 1
- has_membercards[user.has_membercard] += 1
- return response(200, 'Get User Profile Success', u'获取用户画像成功', data={
- 'provinces': provinces,
- 'sexs': sexs,
- 'subscribe': subscribes,
- 'has_membercards': has_membercards,
- })
- def statistic_daily(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- sale_logs = ConsumeSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
- user_logs = ConsumeUserStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time)
- sale_logs = [log.data for log in sale_logs]
- user_logs = [log.data for log in user_logs]
- return response(200, 'Get User Sales Statistic Success', u'获取销量统计成功', data={
- 'sale_logs': sale_logs,
- 'user_logs': user_logs,
- })
- def statistic_model(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- logs = ConsumeModelSaleStatisticInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time).values_list('model_name').annotate(Sum('num'))
- logs = [{'model_name': log[0], 'num': log[1]} for log in logs]
- return response(200, 'Get Model Statistic Success', u'获取型号统计成功', data={
- 'logs': logs
- })
- def statistic_distributor(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- model_name = request.POST.get('model_name', '')
- distributor_name = request.POST.get('distributor_name', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- daily_sql = 'select id, Count(*) AS num, Count(code_version=1 or NULL) AS code1 , Count(code_version=2 or NULL) AS code2, Count((code_version=1 AND has_scan=True) or NULL) AS has_code1_scan_num, Count((code_version=2 AND has_scan=True) or NULL) AS has_code2_scan_num FROM integral_saleclerksubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND test_sn=False AND status=True %s %s GROUP BY ymd;' % (start_time, end_time, ('AND model_uni_name="%s"' % (model_name)) if model_name else '', ('AND distributor_name="%s"' % (distributor_name)) if distributor_name else '')
- daily_logs = SaleclerkSubmitLogInfo.objects.raw(daily_sql)
- daily_logs = [{'ymd': log.ymd, 'num': log.num, 'code1': log.code1, 'code2': log.code2, 'has_code1_scan_num': log.has_code1_scan_num, 'has_code2_scan_num': log.has_code2_scan_num} for log in daily_logs]
- model_logs = []
- if model_name == '':
- model_sql = 'select id, model_uni_name, Count(*) AS num, Count(code_version=1 or NULL) AS code1 , Count(code_version=2 or NULL) AS code2, Count((code_version=1 AND has_scan=True) or NULL) AS has_code1_scan_num, Count((code_version=2 AND has_scan=True) or NULL) AS has_code2_scan_num FROM integral_saleclerksubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND test_sn=False AND status=True %s GROUP BY model_uni_name;' % (start_time, end_time, ('AND distributor_name="%s"' % (distributor_name)) if distributor_name else '')
- model_logs = SaleclerkSubmitLogInfo.objects.raw(model_sql)
- model_logs = [{'model_uni_name': log.model_uni_name, 'num': log.num, 'code1': log.code1, 'code2': log.code2, 'has_code1_scan_num': log.has_code1_scan_num, 'has_code2_scan_num': log.has_code2_scan_num} for log in model_logs]
-
- distributor_logs = []
- if distributor_name == '':
- distributor_sql = 'select id, distributor_name, Count(*) AS num, Count(code_version=1 or NULL) AS code1 , Count(code_version=2 or NULL) AS code2, Count((code_version=1 AND has_scan=True) or NULL) AS has_code1_scan_num, Count((code_version=2 AND has_scan=True) or NULL) AS has_code2_scan_num FROM integral_saleclerksubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND test_sn=False AND status=True %s GROUP BY distributor_name;' % (start_time, end_time, ('AND model_uni_name="%s"' % (model_name)) if model_name else '')
- distributor_logs = SaleclerkSubmitLogInfo.objects.raw(distributor_sql)
- distributor_logs = [{'distributor_name': log.distributor_name, 'num': log.num, 'code1': log.code1, 'code2': log.code2, 'has_code1_scan_num': log.has_code1_scan_num, 'has_code2_scan_num': log.has_code2_scan_num} for log in distributor_logs]
- return response(200, 'Get Distributor Statistic Success', u'获取经销商统计成功', data={
- 'daily_logs': daily_logs,
- 'model_logs': model_logs,
- 'distributor_logs': distributor_logs
- })
- def dashboard(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
- sale_logs = SaleclerkSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, test_user=False, dupload=False, test_sn=False, status=True)
- sale_count = sale_logs.count()
- sale_daily_logs = list(sale_logs.values('ymd').annotate(num=Count('pk')))
- sale_model_logs = list(sale_logs.values('model_uni_name').annotate(num=Count('pk')).order_by('-num'))[:10]
- sale_distributor_logs = list(sale_logs.values('distributor_name').annotate(num=Count('pk')).order_by('-num'))[:10]
-
- logs = ConsumeInfoSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, test_user=False, dupload=False, status=True)
- consumer_count = logs.count()
- consumer_daily_logs = list(logs.values('ymd').annotate(num=Count('pk')).order_by('ymd'))
- consumer_model_logs = list(logs.values('model_uni_name').annotate(num=Count('pk')).order_by('-num'))[:10]
- consumer_province_logs = list(logs.values('province').annotate(num=Count('pk')).order_by('-num'))[:10]
- return response(200, 'Get Distributor Statistic Success', u'获取经销商统计成功', data={
- 'sale_daily_logs': sale_daily_logs,
- 'sale_model_logs': sale_model_logs,
- 'sale_distributor_logs': sale_distributor_logs,
- 'consumer_daily_logs': consumer_daily_logs,
- 'consumer_model_logs': consumer_model_logs,
- 'consumer_province_logs': consumer_province_logs,
- 'sale_count': sale_count,
- 'consumer_count': consumer_count,
- })
- def statistic_consumer(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- model_name = request.POST.get('model_name', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
- daily_sql = 'select id, Count(id) AS num, Count(code_version=1 or NULL) AS code1 , Count(code_version=2 or NULL) AS code2 FROM mch_consumeinfosubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND status=True %s GROUP BY ymd;' % (start_time, end_time, ('AND model_uni_name="%s"' % (model_name)) if model_name else '')
- daily_logs = ConsumeInfoSubmitLogInfo.objects.raw(daily_sql)
- daily_logs = [{'ymd': log.ymd, 'num': log.num, 'code1': log.code1, 'code2': log.code2} for log in daily_logs]
- model_logs = []
- if model_name == '':
- model_sql = 'select id, model_uni_name, Count(id) AS num, Count(code_version=1 or NULL) AS code1 , Count(code_version=2 or NULL) AS code2 FROM mch_consumeinfosubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND status=True GROUP BY model_uni_name ORDER BY num desc;' % (start_time, end_time)
- model_logs = ConsumeInfoSubmitLogInfo.objects.raw(model_sql)
- model_logs = [{'model_uni_name': log.model_uni_name, 'num': log.num, 'code1': log.code1, 'code2': log.code2} for log in model_logs]
-
- province_sql = 'select id, province, Count(id) AS num, Count(code_version=1 or NULL) AS code1, Count(code_version=2 or NULL) AS code2 FROM mch_consumeinfosubmitloginfo where ymd >= %s AND ymd <= %s AND test_user=False AND dupload=False AND status=True %s GROUP BY province ORDER BY num desc;' % (start_time, end_time, ('AND model_uni_name="%s"' % (model_name)) if model_name else '')
- province_logs = ConsumeInfoSubmitLogInfo.objects.raw(province_sql)
- province_logs = [{'province': log.province, 'num': log.num, 'code1': log.code1, 'code2': log.code2} for log in province_logs]
- return response(200, 'Get Consumer Statistic Success', u'获取消费者统计成功', data={
- 'daily_logs': daily_logs,
- 'model_logs': model_logs,
- 'province_logs': province_logs,
- })
- def statistic_member(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
- users = ConsumeInfoSubmitLogInfo.objects.filter(ymd__gte=start_time, ymd__lte=end_time, test_user=False, dupload=False, status=True).values_list('user_id', flat=True).distinct()
- userinfos = UserInfo.objects.filter(user_id__in=users)
-
- level_logs = list(userinfos.values('level').annotate(num=Count('user_id')))
-
- integral_logs = list(userinfos.values('integral').annotate(num=Count('user_id')))
-
- shot_logs = list(userinfos.values('shots_num').annotate(num=Count('user_id')))
-
- sex_logs = list(userinfos.values('sex').annotate(num=Count('user_id')))
-
- province_logs = list(userinfos.values('province_name').annotate(num=Count('user_id')).order_by('-num'))
- return response(200, 'Get Consumer Statistic Success', u'获取消费者统计成功', data={
- 'level_logs': level_logs,
- 'integral_logs': integral_logs,
- 'shot_logs': shot_logs,
- 'sex_logs': sex_logs,
- 'province_logs': province_logs,
- })
- def record_consumer(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
- admin_id = request.POST.get('admin_id', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- query = request.POST.get('query', '')
- dupload = request.POST.get('dupload', '')
- code_version = request.POST.get('code_version', 0)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- logs = ConsumeInfoSubmitLogInfo.objects.filter(Q(status=True) & Q(test_user=False) & (Q(model_name__icontains=query) | Q(phone__icontains=query) | Q(serialNo__icontains=query))).order_by('-created_at')
- if dupload:
- logs = logs.filter(dupload=dupload)
- if code_version:
- logs = logs.filter(code_version=code_version)
- if start_time and end_time:
- logs = logs.filter(ymd__gte=start_time, ymd__lte=end_time)
- count = logs.count()
- logs, left = pagination(logs, page, num)
- logs = [log.admindata for log in logs]
- return response(200, 'Get Consumer Record Success', u'获取消费者销售记录成功', data={
- 'logs': logs,
- 'count': count,
- 'left': left
- })
- def record_sale(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- query = request.POST.get('query', '')
- dupload = request.POST.get('dupload', '')
- has_scan = request.POST.get('has_scan', '')
- code_version = request.POST.get('code_version', 0)
- is_online_sale = request.POST.get('is_online_sale', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- logs = SaleclerkSubmitLogInfo.objects.filter(Q(status=True) & Q(test_user=False) & Q(test_sn=False) & (Q(model_name__icontains=query) | Q(clerk_name__icontains=query) | Q(distributor_name__icontains=query) | Q(code__icontains=query))).order_by('-created_at')
- if dupload:
- logs = logs.filter(dupload=dupload)
- if code_version:
- logs = logs.filter(code_version=code_version)
- if has_scan:
- logs = logs.filter(has_scan=has_scan)
- if start_time and end_time:
- logs = logs.filter(ymd__gte=start_time, ymd__lte=end_time)
- if is_online_sale:
- logs = logs.filter(remark=('扫描条形码' if is_online_sale == '1' else ''))
- count = logs.count()
- logs, left = pagination(logs, page, num)
- logs = [log.admindata for log in logs]
- return response(200, 'Get Sale Record Success', u'获取销售员销售记录成功', data={
- 'logs': logs,
- 'count': count,
- 'left': left
- })
- def model_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- infos = list(ModelInfo.objects.filter(status=True).values_list('model_uni_name', flat=True).distinct().order_by('model_uni_name'))
- return response(200, 'Get Model List Success', u'获取型号列表成功', data={
- 'models': infos
- })
-
- def distributor_list(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- infos = list(DistributorInfo.objects.filter(status=True).values_list('distributor_name', flat=True).distinct().order_by('distributor_name'))
- return response(200, 'Get Model List Success', u'获取经销商列表成功', data={
- 'distributors': infos
- })
-
- def member_goods_order(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- phone = request.POST.get('phone', '')
- good_type = request.POST.get('good_type', '')
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- orders = GoodsOrderInfo.objects.filter(phone__icontains=phone, status=True).order_by('-created_at')
- if good_type:
- orders = orders.filter(good_type=good_type)
- count = orders.count()
- orders, left = pagination(orders, page, num)
- orders = [order.admindata for order in orders]
- return response(200, 'Get Member Goods Order List Success', u'获取会员商品订单列表成功', data={
- 'orders': orders,
- 'left': left,
- 'count': count
- })
- def member_goods_order_update(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- order_id = request.POST.get('order_id', '')
- tracking_number = request.POST.get('tracking_number', '')
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
- GoodsOrderInfo.objects.filter(pk=order_id, status=True).update(tracking_number=tracking_number)
- return response(200, 'Get Member Goods Order Update Success', u'获取会员商品订单修改成功')
- def record_warehouse(request):
- brand_id = request.POST.get('brand_id', settings.KODO_DEFAULT_BRAND_ID)
- admin_id = request.POST.get('admin_id', '')
- model_name = request.POST.get('model_name', '')
- sn = request.POST.get('sn', '')
- start_time = request.POST.get('start_time', '')
- end_time = request.POST.get('end_time', '')
- page = request.POST.get('page', 1)
- num = request.POST.get('num', 20)
- if brand_id != settings.KODO_DEFAULT_BRAND_ID:
- return response(ProductBrandStatusCode.BRAND_NOT_MATCH)
- try:
- administrator = AdministratorInfo.objects.get(admin_id=admin_id, user_status=AdministratorInfo.ACTIVATED, status=True)
- except AdministratorInfo.DoesNotExist:
- return response(AdministratorStatusCode.ADMINISTRATOR_NOT_FOUND)
-
- models = ModelInfo.objects.filter(model_name__icontains=model_name, status=True).values_list('pk', flat=True)
- logs = MchInfoEncryptLogInfo.objects.filter(model_pk__in=models, sn__icontains=sn, status=True)
- if start_time and end_time:
- start_time = datetime.strptime(start_time, '%Y%m%d')
- end_time = datetime.strptime(end_time+' 23:59:59', '%Y%m%d %H:%M:%S')
- logs = logs.filter(created_at__range=(start_time, end_time))
-
- logs = logs.order_by('-created_at')
-
- count = logs.count()
- logs, left = pagination(logs, page, num)
- logs = [log.admindata for log in logs]
- return response(200, 'Get Warehouse Record Success', u'获取入库记录成功', data={
- 'logs': logs,
- 'left': left,
- 'count': count
- })
|