ASJServer/Controller/Cloudsum.py

# -*- coding: utf-8 -*-
"""
@Time ： 2021/1/8 12:00
@Auth ： liehaoquan
@File ：Cloudsum.py
@IDE ：PyCharm
"""
import json

from Ansjer.config import SERVER_TYPE
from Model.models import Order_Model, UID_Bucket, UserExModel
from Object.RedisObject import RedisObject
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from django.views import View

from Service.CommonService import CommonService
from Service.ModelService import Device_User, ModelService
from django.db.models import Count, Sum


class Cloudsum(View):
    def dispatch(self, requset, *args, **kwargs):
        return super(Cloudsum, self).dispatch(requset, *args, **kwargs)

    def get(self, request, *args, **kwargs):
        operation = kwargs.get('operation')
        request.encoding = 'utf-8'
        return self.validation(request.GET, request, operation)

    def post(self, request, *args, **kwargs):
        operation = kwargs.get('operation')
        request.encoding = 'utf-8'
        return self.validation(request.POST, request, operation)

    def validation(self, request_dict, request, operation):
        response = ResponseObject()
        token = request_dict.get('token', None)
        tko = TokenObject(token)
        response.lang = tko.lang
        userID = tko.userID
        print('userID:', userID)
        if tko.code != 0:
            return response.json(tko.code)
        if userID is None or operation is None:
            return response.json(444, 'operation')
        if operation == 'cloudservicesum':
            return self.cloudservicesum(userID, response)
        if operation == 'userappversion':
            return self.userappversion(userID, response)
        if operation == 'usercount':
            return self.usercount(userID, request_dict, response)
        if operation == 'usercloud':
            return self.usercloud(userID, response)

    # 类型：用户手机
    # 统计用户手机型号  已有
    # 统计某段时间内新用户的增长数√
    # 统计一天用户打开zosi app的频率   已有
    # 统计用户下载zosi app数，卸载人数
    # 统计用户使用zosi app的版本√

    # 统计用户使用zosi app的版本以及使用zosi app不同版本的用户数量
    def userappversion(self, userID, response):
        own_permission = ModelService.check_perm(userID=userID, permID=30)
        if own_permission is not True:
            return response.json(404)
        res = UserExModel.objects.extra(tables=['app_info'],
                                        select={'appname': 'app_info.appName',
                                                'appversion': 'app_info.newAppversion'},
                                        where=["user_ex.appBundleId=app_info.appBundleId"]). \
            values('appBundleId', 'appname', 'appversion').annotate(dates=Count('appBundleId')).order_by()
        print(res.query)
        print(res)
        return response.json(0, list(res))

    # 统计某段时间内新用户的增长数
    def usercount(self, userID, request_dict, response):
        own_permission = ModelService.check_perm(userID=userID, permID=30)
        if own_permission is not True:
            return response.json(404)

        # 优化代码
        # usercountyear = request_dict.get('usercountyear', None)
        # if usercountyear == None:
        #     return response.json(444)
        # usercountyear = int(usercountyear)
        # count = Device_User.objects.extra(select={'dates': "DATE_FORMAT(data_joined,'%%Y-%%m')"},
        #                                   where=["data_joined between '%s-01-01' and '%s-01-01' "],
        #                                   params=[usercountyear, usercountyear+1]).values(
        #     'dates').annotate(用户合计=Count('data_joined')).order_by('dates')
        count = Device_User.objects.extra(select={'dates': "DATE_FORMAT(data_joined,'%%Y-%%m')"}, ).values(
            'dates').annotate(用户合计=Count('data_joined')).order_by('dates')
        print(count.query)
        return response.json(0, list(count))

    # 类型：云存服务统计
    # 统计开通云存的设备有多少台√
    # 统计未支付，支付成功的订单√
    # 统计开通云存的增长率    (每个月开通云存套餐的总数)√
    # 统计已开通云存的各套餐总数√
    # 统计已支付的订单总金额√
    def cloudservicesum(self, userID, response):
        own_permission = ModelService.check_perm(userID=userID, permID=30)
        if own_permission is not True:
            return response.json(404)
        uid_cloud = UID_Bucket.objects.values('uid').distinct().count()
        cloud_sum = UID_Bucket.objects.all().count()
        pay_0 = Order_Model.objects.filter(status='0').count()
        pay_1 = Order_Model.objects.filter(status='1').count()
        money = Order_Model.objects.filter(status='1').aggregate(Sum('price'))
        data_dict = {
            "开通云存的设备数": uid_cloud,
            "已开通云存的各套餐总数": cloud_sum,
            "未支付的订单数": pay_0,
            "已支付的订单数": pay_1,
            "已支付的订单总金额": money['price__sum'],
        }
        return response.json(0, data_dict)

    # 每个月开通云存套餐的总数
    def usercloud(self, userID, response):
        own_permission = ModelService.check_perm(userID=userID, permID=30)
        if own_permission is not True:
            return response.json(404)
        a = Order_Model.objects.extra(select={'dates': "FROM_UNIXTIME(addTime,'%%Y-%%m')"}).values(
            'dates').filter(status=1).annotate(开通云存合计=Count('addTime')).order_by('dates')
        return response.json(0, list(a))