api/mch_views.py

@@ -20,6 +20,7 @@ from utils.error.errno_utils import (AdministratorStatusCode, OperatorStatusCode

                                                      ProductDistributorStatusCode, ProductModelStatusCode, SaleclerkStatusCode,
              

                                                      UserStatusCode)
              

                 from utils.redis.connect import r
              

                +from utils.redis.rkeys import MINI_PROGRAM_GIS_LIST
              

                 
              

                 
              

                 WECHAT = settings.WECHAT
              
@@ -266,7 +267,7 @@ def consumer_info_api(request):

                     #     return response(ProductDistributorStatusCode.DISTRIBUTOR_NOT_FOUND)
              

                 
              

                     # 记录用户信息提交记录
              

                -    ConsumeInfoSubmitLogInfo.objects.create(
              

                +    log = ConsumeInfoSubmitLogInfo.objects.create(
              

                         user_id=user_id,
              

                         phone=purePhoneNumber,
              

                         iv=iv,
              
@@ -349,6 +350,13 @@ def consumer_info_api(request):

                             mssi.num += 1
              

                             mssi.save()
              

                 
              

                +            r.rpushjson(MINI_PROGRAM_GIS_LIST, {
              

                +                'brand_id': log.brand_id,
              

                +                'lat': log.lat,
              

                +                'lon': log.lon,
              

                +                'ymd': ymd,
              

                +            })
              

                +
              

                             # mssi2, _ = ConsumeModelSaleStatisticInfo.objects.select_for_update().get_or_create(
              

                             #     brand_id=brand.brand_id,
              

                             #     model_id=model.model_id,
              

statistic/views.py

@@ -219,24 +219,19 @@ def ymdtj(brand_id, ymd, lastymd):

                     # 与上个统计周期数据的用户人数比例
              

                     user_count_increase_pct = '%.2f' % (scan_user_count * 100.0 / last_scan_user_count) if last_scan_user_count != 0 else 0
              

                 
              

                -    # [经销商维度] 周期内镜头销售支数
              

                -    try:
              

                -        sell_volume_count = SaleStatisticInfo.objects.get(brand_id=brand_id, ymd=ymd).num
              

                -    except SaleStatisticInfo.DoesNotExist:
              

                -        sell_volume_count = 0
              

                +    # [消费者维度] 统计周期内型号扫描排行数据，请按顺序返回
              

                +    current_models = ConsumeModelSaleStatisticInfo.objects.filter(brand_id=brand_id, ymd=ymd, status=True).order_by('-num')
              

                +    models = [m.data for m in current_models[:20]]
              

                 
              

                -    try:
              

                -        last_sell_volume_count = SaleStatisticInfo.objects.get(brand_id=brand_id, ymd=lastymd).num
              

                -    except SaleStatisticInfo.DoesNotExist:
              

                -        last_sell_volume_count = 0
              

                +    # [消费者维度] 周期内镜头销售支数
              

                +    sell_volume_count = sum([m.get('num', 0) for m in current_models])
              

                +
              

                +    last_models = ConsumeModelSaleStatisticInfo.objects.filter(brand_id=brand_id, ymd=lastymd, status=True).order_by('-num')
              

                +    last_sell_volume_count = sum([m.num for m in last_models])
              

                 
              

                     # 与上个统计周期数据的销售支数比例
              

                     volume_count_increase_pct = '%.2f' % (sell_volume_count * 100.0 / last_sell_volume_count) if last_sell_volume_count != 0 else 0
              

                 
              

                -    # [消费者维度] 统计周期内型号扫描排行数据，请按顺序返回
              

                -    models = ConsumeModelSaleStatisticInfo.objects.filter(brand_id=brand_id, ymd=ymd, status=True).order_by('-num')[:20]
              

                -    models = [m.data for m in models]
              

                -
              

                     # [经销商维度] 统计周期内销售员排行数据，请按顺序返回
              

                     salesmen = SaleclerkSaleStatisticInfo.objects.filter(brand_id=brand_id, ymd=ymd, status=True).order_by('-num')[:20]
              

                     salesmen = [s.data for s in salesmen]