ASJServer/Controller/UserBrandController.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
@AUTHOR: ASJRD019
@NAME: AnsjerFormal
@software: PyCharm
@DATE: 2019/5/9 11:50
@Version: python3.6
@MODIFY DECORD:ansjer dev
@file: AliPayObject.py
@Contact: pzb3076@163.com
"""

from django.views.generic.base import View
from django.utils.decorators import method_decorator
from django.views.decorators.csrf import csrf_exempt
from Service.ModelService import ModelService
from Model.models import User_Brand,Device_User
from django.utils import timezone
import traceback,time
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Service.CommonService import CommonService
from collections import Counter
'''

http://192.168.136.45:8077/userbrandinfo?operation=query&token=test&page=1&line=10

http://192.168.136.39:8000/userbrandinfo?operation=query&token=test&page=1&line=5
http://192.168.136.39:8000/userbrandinfo?operation=queryAll&token=eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJ1c2VySUQiOiIxNTQzOTA5MDUwNDEzMTM4MDAxMzgwMDAiLCJsYW5nIjoiY24iLCJ1c2VyIjoiMTM4MDAxMzgwMDEiLCJtX2NvZGUiOiIxMjM0MTMyNDMyMTQiLCJleHAiOjE1NTk4OTY4NTd9.nhK3VSghSGjyXKjel4woz7R_3bhjgqQDlX-ypYsklNU&page=1&line=5
'''


class UserBrandInfo(View):
    @method_decorator(csrf_exempt)
    def dispatch(self, *args, **kwargs):
        return super(UserBrandInfo, self).dispatch(*args, **kwargs)

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

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        self.clientIP = CommonService.get_ip_address(request)
        return self.validation(request_dict=request.POST)

    def validation(self, request_dict, *args, **kwargs):
        response = ResponseObject()
        token = request_dict.get('token', None)
        if token is not None:
            tko = TokenObject(token)
            response.lang = tko.lang
            if tko.code == 0:
                userID = tko.userID
                operation = request_dict.get('operation', None)
                if userID is not None:
                    if operation == 'query':
                        return self.query_info(request_dict, userID,response)
                    elif operation == 'add':
                        return self.add_info(request_dict, userID,response)
                    elif operation == 'queryAll':
                        return self.query_all_info(request_dict, userID,response)
                    elif operation == 'queryDeviceSupplier':
                        return self.query_deviceSupplier_info(request_dict, userID,response)
                    else:
                        return response.json(444,'444')
                else:
                    return response.json(309)
            else:
                return response.json(tko.code)
        else:
            return response.json(309)
            # 获取外网IP




    # http://192.168.136.39:8000/userbrandinfo?operation=add&token=test&deviceSupplier=12341234&deviceModel=deviceModel&osType=osType&osVersion=osVersion
    def add_info(self, request_dict, userID,response):
        deviceSupplier = request_dict.get('deviceSupplier', None)
        deviceModel = request_dict.get('deviceModel', None)
        osType = request_dict.get('osType', None)
        osVersion = request_dict.get('osVersion', None)

        print(self.clientIP)
        try:
            user_brand = User_Brand(
                userID=Device_User.objects.get(userID=userID),
                deviceSupplier=deviceSupplier,
                deviceModel=deviceModel,
                osType=osType,
                osVersion=osVersion,
                ip=self.clientIP,
                addTime = int(time.time())
            )
            user_brand.save()
        except Exception:
            errorInfo = traceback.format_exc()
            print(errorInfo)
            return response.json(424, {'details': errorInfo})
        else:
            print(type(user_brand.addTime))
            return response.json(0,{'id':user_brand.id})


    def query_info(self, request_dict, userID,response):
        page = int(request_dict.get('page', None))
        line = int(request_dict.get('line', None))
        param_flag = CommonService.get_param_flag(data=[page, line])
        if param_flag is True:
            user_brand_queryset = User_Brand.objects.filter(userID=userID).order_by('-id')
            if user_brand_queryset.exists():
                count = user_brand_queryset.count()
                res = user_brand_queryset[(page - 1) * line:page * line]
                send_json = CommonService.qs_to_dict(res)
                send_json['count'] = count
                return response.json(0, send_json)
            return response.json(0, {'datas': [], 'count': 0})
        else:
            return response.json(444)


    def query_all_info(self, request_dict, userID,response):
        page = int(request_dict.get('page', None))
        line = int(request_dict.get('line', None))
        param_flag = CommonService.get_param_flag(data=[page, line])
        if param_flag is True:
            check_perm = ModelService.check_perm(userID=userID,permID=30)
            if check_perm is True:
                # 按照用户去重复查询
                user_brand_queryset = User_Brand.objects.all().order_by('userID').values_list('userID', flat=True).distinct()
                print (user_brand_queryset)
                send_jsons=[]
                counts=0
                for i in user_brand_queryset:
                    counts=counts+1
                    user_brand_querysetlast = User_Brand.objects.filter(userID=i).order_by('-addTime')[:1]
                    user_brand_querysetlast = CommonService.qs_to_dict(user_brand_querysetlast)
                    username = ModelService.get_user_name(userID=user_brand_querysetlast["datas"][0]['fields']['userID'])
                    user_brand_querysetlast["datas"][0]['fields']['username']=username
                    send_jsons.append(user_brand_querysetlast["datas"][0])
                # 按照加入的日期排序
                send_jsons = sorted(send_jsons, key=lambda x:x['fields']['addTime'], reverse=True)
                # 分页
                send_jsons = send_jsons[(page - 1) * line:page * line]
                return response.json(0, {'datas': send_jsons, 'count': counts})

            else:
                return response.json(404)
        else:
            return response.json(444)


    def query_deviceSupplier_info(self, request_dict, userID,response):
        check_perm = ModelService.check_perm(userID=userID,permID=30)
        if check_perm is True:
            # 按照用户去重复查询
            user_brand_queryset = User_Brand.objects.all().order_by('userID').values_list('userID', flat=True).distinct()
            print (user_brand_queryset)
            send_jsons=[]
            counts=0
            for i in user_brand_queryset:
                counts=counts+1
                user_brand_querysetlast = User_Brand.objects.filter(userID=i).order_by('-addTime')[:1]
                user_brand_querysetlast = CommonService.qs_to_dict(user_brand_querysetlast)
                username = ModelService.get_user_name(userID=user_brand_querysetlast["datas"][0]['fields']['userID'])
                user_brand_querysetlast["datas"][0]['fields']['username']=username
                send_jsons.append(user_brand_querysetlast["datas"][0])
            deviceSupplier=[]
            for k, v in enumerate(send_jsons):
                deviceSupplier.append(v['fields']['deviceSupplier'])
            deviceSupplier = Counter(deviceSupplier)
            return response.json(0, {'datas': deviceSupplier})

        else:
            return response.json(404)